黑马程序员技术交流社区

标题: 实现多个客户端的并发上传图片 [打印本页]
作者: 吴林飞    时间: 2013-4-13 14:41
标题: 实现多个客户端的并发上传图片
本帖最后由 吴林飞 于 2013-4-14 14:23 编辑
  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();

  20.                         File file = new File(count+".jpg");

  22.                          while(file.exists())
  23.                         {
  24.                                 file = new File((++count)+".jpg");
  25.                         }
  26.                         
  27.                         FileOutputStream fos = new FileOutputStream(file);

  29.                         byte[] buf = new byte[1024];

  31.                         int len = 0;

  33.                         while((len=in.read(buf))!=-1)
  34.                         {
  35.                                 fos.write(buf,0,len);
  36.                         }
  37.                         //s.shutdownInput();

  39.                         OutputStream out = s.getOutputStream();

  41.                         out.write("恭喜您，图片上传成功".getBytes());

  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);

  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);

  72.                 FileInputStream fis = new FileInputStream("d:\\1.jpg");

  74.                 OutputStream out = s.getOutputStream();

  76.                 byte[] bufin = new byte[1024];

  78.                 int lenin = 0;

  80.                 while((lenin=fis.read(bufin))!=-1)
  81.                 {
  82.                         out.write(bufin,0,lenin);
  83.                 }
  84.                 s.shutdownOutput();

  86.                 InputStream in = s.getInputStream();

  88.                 byte[] bufout = new byte[1024];

  90.                 int lenout = in.read(bufout);

  92.                 String info = new String(bufout,0,lenout);

  94.                 System.out.println(info);
  95.                
  96.                 s.close();
  97.         }
  98. }
复制代码
问题是这样的，我把服务端开启后，用客户端给服务端发了几个图片，但是我发现我发到服务端的图片怎么都不能显示？我感觉我代码没写错，而且用的都是字节流，应该不存在刷新的问题吧，怎么发生这种问题，连续几个图片都是如此。




未命名.JPG (1.56 KB, 下载次数: 39)

未命名.JPG
作者: 梁航斌    时间: 2013-4-13 14:54
本帖最后由 梁航斌 于 2013-4-13 14:55 编辑
  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();

  20.                         File file = new File(count+".jpg");

  22.                          while(file.exists())
  23.                         {
  24.                                 file = new File((++count)+".jpg");
  25.                         }
  26.                         
  27.                         FileOutputStream fos = new FileOutputStream(file);

  29.                         byte[] buf = new byte[1024];

  31.                         int len = 0;

  33.                         while((len=in.read(buf))!=-1)
  34.                         {
  35.                                 fos.write(buf,0,len);
  36.                                 //********************************
  37.                                fos.flush();//兄弟，请记得刷新
  38.                                //********************************
  39.                         }
  40.                         //s.shutdownInput();

  42.                         OutputStream out = s.getOutputStream();

  44.                         out.write("恭喜您，图片上传成功".getBytes());

  46.                         s.close();        
  47.                 }
  48.                 catch(Exception e)
  49.                 {
  50.                         throw new RuntimeException("图片上传失败");
  51.                 }
  52.         }
  53. }
复制代码
你注意打“*”号的地方。可能是没刷新，文件不全所以打不开
作者: 吴林飞    时间: 2013-4-13 17:41
梁航斌 发表于 2013-4-13 14:54
你注意打“*”号的地方。可能是没刷新，文件不全所以打不开

FileOutputStream是字节流OK?字节流有刷新操作么？
作者: 梁航斌    时间: 2013-4-13 17:56
本帖最后由 梁航斌 于 2013-4-13 18:00 编辑
吴林飞 发表于 2013-4-13 17:41
FileOutputStream是字节流OK?字节流有刷新操作么？

看成这个了
作者: 吴林飞    时间: 2013-4-13 18:49
梁航斌 发表于 2013-4-13 17:56
看成这个了

看了下API，有flush()但是是从OutputStream继承的，
flush()方法加进去还是没用。
作者: 梁航斌    时间: 2013-4-13 18:55
你的程序没有阻塞吧？阻塞的话没有释放资源，图片是打不开的，你ctrl+c停止运行，然后看看图片能打开吗
作者: 吴林飞    时间: 2013-4-13 22:05
程序运行完，客户端就停止了，只有服务端还开着，我试过了只有把服务端ctrl+c图片才能刷新变成可浏览状态。
作者: 黄玉昆    时间: 2013-4-14 14:16
如果问题未解决，请继续追问，如果没有问题了，请将帖子分类 改为“已解决”，谢谢



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2