最简单的TCP程序

populace

网络编程里面最简单的一个tcp程序，把一个文件从客户端上传到服务器端，上传成功后服务器端提示上传完成。代码不多，一个服务端和一个客户端。
　　服务端代码：

1. import java.io.FileOutputStream;
   
2. import java.io.IOException;
   
3. import java.io.InputStream;
   
4. import java.io.OutputStream;
   
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.         // 创建服务端Socket对象
    
11.         ServerSocket ss = new ServerSocket(1299);
    
12.         // 监听客户端tcp连接
    
13.         Socket s = ss.accept();
    
14.         //定义输入流以读取客户端上传文件
    
15.         InputStream is = s.getInputStream();
    
16.         //创建文件字节流输出对象，将读入的字节流写入文件
    
17.         FileOutputStream fos = new FileOutputStream("F:\\UUcall.exe");
    
18.         byte[] bys = new byte[1024];
    
19.         int length = 0;
    
20.         while ((length = is.read(bys)) != -1) {
    
21.             fos.write(bys, 0, length);
    
22.         }
    
23.         //禁用套接字输入流
    
24.         s.shutdownInput();
    
25.         //创建套接字输出流，向客户端发送消息
    
26.         OutputStream os = s.getOutputStream();
    
27.         //提示客户端文件上传成功
    
28.         os.write("Upload successfully.".getBytes());
    
29.         fos.close();
    
30.         s.close();
    
31.     }
    
32. }

复制代码

客户端代码：

1. import java.io.File;
   
2. import java.io.FileInputStream;
   
3. import java.io.IOException;
   
4. import java.io.InputStream;
   
5. import java.io.OutputStream;
   
6. import java.net.Socket;
   
7. 
   
8. public class ClientDemo {
   
9.     public static void main(String[] args) throws IOException{
   
10.         //创建客户端Socket对象，并指定服务器地址及端口号
    
11.         Socket s = new Socket("127.0.0.1",1299);
    
12.         //调用getOutputStream()方法产生输出流对象
    
13.         OutputStream os = s.getOutputStream();
    
14.         //创建本地文件字节流对象，模拟文件上传操作
    
15.         FileInputStream fis = new FileInputStream(new File("D:\\UUcall.exe"));
    
16.         //定义字节数组，每读取2048字节写一次
    
17.         byte[] bys = new byte[2048];
    
18.         //记录每次实际读取长度
    
19.         int length = 0;
    
20.         while ((length = fis.read(bys))!=-1) {
    
21.             os.write(bys,0,length);
    
22.         }
    
23.         //禁用Socket对象的输出流
    
24.         s.shutdownOutput();
    
25.         //获取Socket对象的输入流以读取服务器回送消息
    
26.         InputStream is = s.getInputStream();
    
27.         byte[] msg = new byte[1024];
    
28.         int len = is.read(msg);
    
29.         String string = new String(msg,0,len);
    
30.         System.out.println(string);
    
31.         //关闭文件字节流对象
    
32.         fis.close();
    
33.         //关闭此套接字对象
    
34.         s.close();
    
35.     }
    
36. }

复制代码