Tcp协议传输文件时，传输完成一定要记得关闭输出流     new Socket().shutdownOutput();
以便将文件结尾标志传至服务器端，让程序正常终止。

1. import java.io.File;
   
2. import java.io.FileInputStream;
   
3. import java.io.FileOutputStream;
   
4. import java.io.IOException;
   
5. import java.io.InputStream;
   
6. import java.io.OutputStream;
   
7. import java.net.ServerSocket;
   
8. import java.net.Socket;
   
9. 
   
10. 
    
11. public class TcpDemo4 {
    
12. 
    
13.         /**
    
14.          * TCP协议服务端多线程技术
    
15.          * @throws Exception
    
16.          */
    
17.         public static void main(String[] args) throws Exception {
    
18.                 ServerSocket ss = new ServerSocket(10888);
    
19.                 while(true){
    
20.                         Socket s = new Socket();
    
21.                         s = ss.accept();
    
22.                         new Thread(new Upload(s)).start();
    
23.                 }
    
24.         }
    
25. 
    
26. }
    
27. class Client{
    
28.         public static void main(String[] args) throws Exception, IOException {
    
29.                 Socket s = new Socket("192.168.220.1",10888);
    
30.                 File src = new File("F:\\深色壁纸\\1 (2).jpg");
    
31.                 FileInputStream fin = new FileInputStream(src);
    
32.                 byte[] buf = new byte[1024];
    
33.                 int len = 0;
    
34.                 OutputStream os = s.getOutputStream();
    
35.                 System.out.println("客户端开始传输...");
    
36.                 while ((len = fin.read(buf)) != -1) {
    
37.                         os.write(buf, 0, len);
    
38.                 }
    
39.                 s.shutdownOutput();
    
40.                 InputStream in = s.getInputStream();
    
41.                 len = in.read(buf);
    
42.                 System.out.println(new String(buf, 0, len));
    
43.                 fin.close();
    
44.                 s.close();
    
45.         }
    
46. }
    
47. class Upload implements Runnable{
    
48.         private Socket s;
    
49.         private int count = 0;
    
50.         public Upload(Socket s) {
    
51.                 super();
    
52.                 this.s = s;
    
53.         }
    
54. 
    
55.         @Override
    
56.         public void run() {
    
57.                 System.out.println("服务器启动");
    
58.                 String ip = s.getInetAddress().getHostAddress();
    
59.                 File dir = new File("f:\\tcp多线程");
    
60.                 dir.mkdirs();
    
61.                 File des = new File(dir,ip+".jpg");
    
62.                 while (des.exists())
    
63.                         des = new File(dir, ip + "(" + ++count + ")" + ".jpg");
    
64.                 FileOutputStream fos = null;
    
65.                 try {
    
66.                          fos = new FileOutputStream(des);
    
67.                         InputStream in = s.getInputStream();
    
68.                         byte[] buf = new byte[1024];
    
69.                         int len = 0;
    
70.                         System.out.println("开始上传...");
    
71.                         while ((len = in.read(buf)) != -1) {
    
72.                                 fos.write(buf, 0, len);
    
73.                         }
    
74.                         System.out.println("done");
    
75.                         OutputStream os = s.getOutputStream();
    
76.                         os.write("上传成功".getBytes());
    
77.                 } catch (Exception e) {
    
78.                         // TODO Auto-generated catch block
    
79.                         e.printStackTrace();
    
80.                 }finally{
    
81.                         if(null!=fos)
    
82.                                 try {
    
83.                                         fos.close();
    
84.                                 } catch (IOException e) {
    
85.                                         e.printStackTrace();
    
86.                                 }
    
87.                         try {
    
88.                                 s.close();
    
89.                         } catch (IOException e) {
    
90.                                 e.printStackTrace();
    
91.                         }
    
92.                 }
    
93.         }
    
94. }
    

复制代码

Tcp协议传输文件时，传输完成一定要记得关闭输出流     new Socket().shutdownOutput();
以便将文件结尾标志传至服务器端，让程序正常终止。

1. import java.io.File;
   
2. import java.io.FileInputStream;
   
3. import java.io.FileOutputStream;
   
4. import java.io.IOException;
   
5. import java.io.InputStream;
   
6. import java.io.OutputStream;
   
7. import java.net.ServerSocket;
   
8. import java.net.Socket;
   
9. 
   
10. 
    
11. public class TcpDemo4 {
    
12. 
    
13.         /**
    
14.          * TCP协议服务端多线程技术
    
15.          * @throws Exception
    
16.          */
    
17.         public static void main(String[] args) throws Exception {
    
18.                 ServerSocket ss = new ServerSocket(10888);
    
19.                 while(true){
    
20.                         Socket s = new Socket();
    
21.                         s = ss.accept();
    
22.                         new Thread(new Upload(s)).start();
    
23.                 }
    
24.         }
    
25. 
    
26. }
    
27. class Client{
    
28.         public static void main(String[] args) throws Exception, IOException {
    
29.                 Socket s = new Socket("192.168.220.1",10888);
    
30.                 File src = new File("F:\\深色壁纸\\1 (2).jpg");
    
31.                 FileInputStream fin = new FileInputStream(src);
    
32.                 byte[] buf = new byte[1024];
    
33.                 int len = 0;
    
34.                 OutputStream os = s.getOutputStream();
    
35.                 System.out.println("客户端开始传输...");
    
36.                 while ((len = fin.read(buf)) != -1) {
    
37.                         os.write(buf, 0, len);
    
38.                 }
    
39.                 s.shutdownOutput();
    
40.                 InputStream in = s.getInputStream();
    
41.                 len = in.read(buf);
    
42.                 System.out.println(new String(buf, 0, len));
    
43.                 fin.close();
    
44.                 s.close();
    
45.         }
    
46. }
    
47. class Upload implements Runnable{
    
48.         private Socket s;
    
49.         private int count = 0;
    
50.         public Upload(Socket s) {
    
51.                 super();
    
52.                 this.s = s;
    
53.         }
    
54. 
    
55.         @Override
    
56.         public void run() {
    
57.                 System.out.println("服务器启动");
    
58.                 String ip = s.getInetAddress().getHostAddress();
    
59.                 File dir = new File("f:\\tcp多线程");
    
60.                 dir.mkdirs();
    
61.                 File des = new File(dir,ip+".jpg");
    
62.                 while (des.exists())
    
63.                         des = new File(dir, ip + "(" + ++count + ")" + ".jpg");
    
64.                 FileOutputStream fos = null;
    
65.                 try {
    
66.                          fos = new FileOutputStream(des);
    
67.                         InputStream in = s.getInputStream();
    
68.                         byte[] buf = new byte[1024];
    
69.                         int len = 0;
    
70.                         System.out.println("开始上传...");
    
71.                         while ((len = in.read(buf)) != -1) {
    
72.                                 fos.write(buf, 0, len);
    
73.                         }
    
74.                         System.out.println("done");
    
75.                         OutputStream os = s.getOutputStream();
    
76.                         os.write("上传成功".getBytes());
    
77.                 } catch (Exception e) {
    
78.                         // TODO Auto-generated catch block
    
79.                         e.printStackTrace();
    
80.                 }finally{
    
81.                         if(null!=fos)
    
82.                                 try {
    
83.                                         fos.close();
    
84.                                 } catch (IOException e) {
    
85.                                         e.printStackTrace();
    
86.                                 }
    
87.                         try {
    
88.                                 s.close();
    
89.                         } catch (IOException e) {
    
90.                                 e.printStackTrace();
    
91.                         }
    
92.                 }
    
93.         }
    
94. }
    

复制代码