客户端：

1. package com.kxg_09;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.FileInputStream;
   
6. import java.io.IOException;
   
7. import java.net.Socket;
   
8. 
   
9. /*
   
10. * 客户端文本文件，服务器输出在控制台
    
11. */
    
12. public class ClientDemo {
    
13.         public static void main(String[] args) throws IOException {
    
14. 
    
15.                 // 创建客户端Socket对象
    
16.                 Socket s = new Socket("10.164.22.254", 48264);
    
17. 
    
18.                 // 封装数据源
    
19.                 BufferedInputStream bis = new BufferedInputStream(new FileInputStream(
    
20.                                 "a.txt"));
    
21. 
    
22.                 // 封装通道中的流
    
23.                 BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());
    
24. 
    
25.                 // 读取数据源
    
26.                 byte[] bys = new byte[1024];
    
27.                 int len = 0;
    
28.                 while ((len = bis.read(bys)) != -1) {
    
29.                         // 读取内容写入到通道流中
    
30.                         bos.write(bys, 0, len);
    
31.                 }
    
32. 
    
33.                 // 释放资源
    
34.                 bis.close();
    
35.                 bos.close();
    
36.         }
    
37. }
    

复制代码

服务器端：

1. package com.kxg_09;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.IOException;
   
5. import java.net.ServerSocket;
   
6. import java.net.Socket;
   
7. 
   
8. public class ServerDemo {
   
9.         public static void main(String[] args) throws IOException {
   
10. 
    
11.                 // 创建服务器Socket对象
    
12.                 ServerSocket ss = new ServerSocket(48264);
    
13. 
    
14.                 // 监听客户端连接
    
15.                 Socket s = ss.accept();
    
16. 
    
17.                 // 封装通道中的流
    
18.                 BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
    
19. 
    
20.                 // 读取通道中的流
    
21.                 byte[] bys = new byte[1024];
    
22.                 int len = 0;
    
23.                 while ((len = bis.read(bys)) != -1) {
    
24.                         // 字节数组转为字符串
    
25.                         String str = new String(bys, 0, len);
    
26.                         System.out.println(str);
    
27.                 }
    
28. 
    
29.                 s.close();
    
30.         }
    
31. }

复制代码