1. import java.io.*;
   
2. import java.net.*;
   
3. /*
   
4. 需求：实现多个客户端的并发上传图片
   
5. */
   
6. class ClientThread implements Runnable
   
7. {
   
8.         private Socket s;
   
9.         ClientThread(Socket s)
   
10.         {
    
11.                 this.s = s;
    
12.         }
    
13.         public void run()
    
14.         {
    
15.                 int count = 1;
    
16.                 try
    
17.                 {
    
18.                         InputStream in = s.getInputStream();
    
19. 
    
20.                         File file = new File(count+".jpg");
    
21. 
    
22.                          while(file.exists())
    
23.                         {
    
24.                                 file = new File((++count)+".jpg");
    
25.                         }
    
26.                         
    
27.                         FileOutputStream fos = new FileOutputStream(file);
    
28. 
    
29.                         byte[] buf = new byte[1024];
    
30. 
    
31.                         int len = 0;
    
32. 
    
33.                         while((len=in.read(buf))!=-1)
    
34.                         {
    
35.                                 fos.write(buf,0,len);
    
36.                         }
    
37.                         //s.shutdownInput();
    
38. 
    
39.                         OutputStream out = s.getOutputStream();
    
40. 
    
41.                         out.write("恭喜您，图片上传成功".getBytes());
    
42. 
    
43.                         s.close();        
    
44.                 }
    
45.                 catch(Exception e)
    
46.                 {
    
47.                         throw new RuntimeException("图片上传失败");
    
48.                 }
    
49.         }
    
50. }
    
51. //服务端
    
52. class TcpServer6
    
53. {
    
54.         public static void main(String[] args)throws Exception
    
55.         {
    
56.                 ServerSocket ss = new ServerSocket(9999);
    
57. 
    
58.                 while(true)
    
59.                 {
    
60.                         Socket s = ss.accept();
    
61.                         new Thread(new ClientThread(s)).start();
    
62.                 }
    
63.         }
    
64. }
    
65. //客户端
    
66. class TcpClient6
    
67. {
    
68.         public static void main(String[] args) throws Exception
    
69.         {
    
70.                 Socket s = new Socket("127.0.0.1",9999);
    
71. 
    
72.                 FileInputStream fis = new FileInputStream("d:\\1.jpg");
    
73. 
    
74.                 OutputStream out = s.getOutputStream();
    
75. 
    
76.                 byte[] bufin = new byte[1024];
    
77. 
    
78.                 int lenin = 0;
    
79. 
    
80.                 while((lenin=fis.read(bufin))!=-1)
    
81.                 {
    
82.                         out.write(bufin,0,lenin);
    
83.                 }
    
84.                 s.shutdownOutput();
    
85. 
    
86.                 InputStream in = s.getInputStream();
    
87. 
    
88.                 byte[] bufout = new byte[1024];
    
89. 
    
90.                 int lenout = in.read(bufout);
    
91. 
    
92.                 String info = new String(bufout,0,lenout);
    
93. 
    
94.                 System.out.println(info);
    
95.                
    
96.                 s.close();
    
97.         }
    
98. }

复制代码

问题是这样的，我把服务端开启后，用客户端给服务端发了几个图片，但是我发现我发到服务端的图片怎么都不能显示？我感觉我代码没写错，而且用的都是字节流，应该不存在刷新的问题吧，怎么发生这种问题，连续几个图片都是如此。

如果问题未解决，请继续追问，如果没有问题了，请将帖子分类 改为“已解决”，谢谢

程序运行完，客户端就停止了，只有服务端还开着，我试过了只有把服务端ctrl+c图片才能刷新变成可浏览状态。

你的程序没有阻塞吧？阻塞的话没有释放资源，图片是打不开的，你ctrl+c停止运行，然后看看图片能打开吗

梁航斌 发表于 2013-4-13 17:56
看成这个了

看了下API，有flush()但是是从OutputStream继承的，
flush()方法加进去还是没用。

吴林飞 发表于 2013-4-13 17:41
FileOutputStream是字节流OK?字节流有刷新操作么？

看成这个了

梁航斌 发表于 2013-4-13 14:54
你注意打“*”号的地方。可能是没刷新，文件不全所以打不开

FileOutputStream是字节流OK?字节流有刷新操作么？

1. import java.io.*;
   
2. import java.net.*;
   
3. /*
   
4. 需求：实现多个客户端的并发上传图片
   
5. */
   
6. class ClientThread implements Runnable
   
7. {
   
8.         private Socket s;
   
9.         ClientThread(Socket s)
   
10.         {
    
11.                 this.s = s;
    
12.         }
    
13.         public void run()
    
14.         {
    
15.                 int count = 1;
    
16.                 try
    
17.                 {
    
18.                         InputStream in = s.getInputStream();
    
19. 
    
20.                         File file = new File(count+".jpg");
    
21. 
    
22.                          while(file.exists())
    
23.                         {
    
24.                                 file = new File((++count)+".jpg");
    
25.                         }
    
26.                         
    
27.                         FileOutputStream fos = new FileOutputStream(file);
    
28. 
    
29.                         byte[] buf = new byte[1024];
    
30. 
    
31.                         int len = 0;
    
32. 
    
33.                         while((len=in.read(buf))!=-1)
    
34.                         {
    
35.                                 fos.write(buf,0,len);
    
36.                                 //********************************
    
37.                                fos.flush();//兄弟，请记得刷新
    
38.                                //********************************
    
39.                         }
    
40.                         //s.shutdownInput();
    
41. 
    
42.                         OutputStream out = s.getOutputStream();
    
43. 
    
44.                         out.write("恭喜您，图片上传成功".getBytes());
    
45. 
    
46.                         s.close();        
    
47.                 }
    
48.                 catch(Exception e)
    
49.                 {
    
50.                         throw new RuntimeException("图片上传失败");
    
51.                 }
    
52.         }
    
53. }

复制代码

你注意打“*”号的地方。可能是没刷新，文件不全所以打不开