客户端：

1. package com.kxg_08;
   
2. 
   
3. import java.io.BufferedWriter;
   
4. import java.io.IOException;
   
5. import java.io.InputStream;
   
6. import java.io.OutputStreamWriter;
   
7. import java.net.Socket;
   
8. import java.util.Scanner;
   
9. 
   
10. public class ClientDemo {
    
11.         public static void main(String[] args) throws IOException {
    
12.                 Socket s = new Socket("10.164.22.254", 48264);
    
13. 
    
14.                 Scanner sc = new Scanner(System.in);
    
15.                 String data = null;
    
16.                 while ((data = sc.nextLine()) != null) {
    
17. 
    
18.                         BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
    
19.                                         s.getOutputStream()));
    
20.                         bw.write(data);
    
21.                         bw.newLine();
    
22.                         bw.flush();
    
23. 
    
24.                         InputStream is = s.getInputStream();
    
25.                         byte[] bys = new byte[1024];
    
26.                         int len = is.read(bys);
    
27.                         String str = new String(bys, 0, len);
    
28. 
    
29.                         System.out.println("Server" + str);
    
30.                         if (data.equals("我下了")) {
    
31.                                 break;
    
32.                         }
    
33.                 }
    
34.                 s.close();
    
35.         }
    
36. }

复制代码

服务器端：

1. package com.kxg_08;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.IOException;
   
5. import java.io.InputStreamReader;
   
6. import java.io.OutputStream;
   
7. import java.net.ServerSocket;
   
8. import java.net.Socket;
   
9. 
   
10. public class ServerDemo {
    
11.         public static void main(String[] args) throws IOException {
    
12.                 ServerSocket ss = new ServerSocket(48264);
    
13. 
    
14. 
    
15.                 Socket s = ss.accept();
    
16.                 String ip = s.getInetAddress().getHostAddress();
    
17. 
    
18.                 BufferedReader br = new BufferedReader(new InputStreamReader(
    
19.                                 s.getInputStream()));
    
20.                 String len = null;
    
21.                 while ((len = br.readLine()) != null) {
    
22.                         System.out.println(ip + ":" + len);
    
23. 
    
24.                         OutputStream os = s.getOutputStream();
    
25.                         os.write("数据已收到".getBytes());
    
26.                 }
    
27.                 s.close();
    
28.         }
    
29. }

复制代码