黑马程序员技术交流社区

标题: 并发上传文件 [打印本页]

---

作者: 沈文杰    时间: 2013-3-26 17:19
标题: 并发上传文件

1. package com.itheima;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileInputStream;
   
5. import java.io.FileOutputStream;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.ServerSocket;
   
9. import java.net.Socket;
   
10. 
    
11. class UpLoadThread implements Runnable{
    
12.         private Socket s ;
    
13.        
    
14.         UpLoadThread(Socket s){
    
15.                 this.s = s;
    
16.         }
    
17.        
    
18.         public void run(){
    
19.                 int count=1;
    
20.                 String ip = s.getInetAddress().getHostAddress();
    
21.                 try{
    
22.                         System.out.println(ip+"::::connect");
    
23.                        
    
24.                         InputStream ips = s.getInputStream();
    
25.                        
    
26.                        
    
27.                         File file = new File(ip+"("+(count)+")"+".txt");
    
28.                         if(file.exists())
    
29.                                 file = new File(ip+"("+(count++)+")"+".txt");
    
30.                        
    
31.                         FileOutputStream fos = new FileOutputStream(file);                       
    
32.                         byte[] arr = new byte[1024];
    
33.                         int len = 0;
    
34.                         while((len = ips.read(arr))!=-1){
    
35.                                 fos.write(arr,0,len);
    
36.                                
    
37.                         }
    
38.                        
    
39.                         OutputStream ops = s.getOutputStream();
    
40.                        
    
41.                         ops.write("文件上传成功".getBytes());
    
42.                         ops.flush();
    
43.                        
    
44.                         fos.close();
    
45.                         s.close();
    
46.                 }
    
47.                 catch(Exception e){
    
48.                         throw new RuntimeException("文件上传失败！");
    
49.                 }       
    
50.         }
    
51. }
    
52. 
    
53. class UpLoadClient{
    
54.        
    
55.         public static void main(String[] args)throws Exception{
    
56.                
    
57.                 Socket s = new Socket("127.0.0.1",10009);
    
58.                 OutputStream ops = s.getOutputStream();
    
59.                
    
60.                 FileInputStream fis = new FileInputStream("d:\\demo.txt");
    
61.                 byte[] arr = new byte[1024];
    
62.                 int len =0;
    
63.                 while((len = fis.read(arr))!=-1){
    
64.                         ops.write(arr,0,len);
    
65.                        
    
66.                 }
    
67.                 s.shutdownOutput();
    
68.                
    
69.                 InputStream ips = s.getInputStream();
    
70.                 byte[] bt = new byte[1024];
    
71.                 int num = ips.read(bt);
    
72.                 System.out.println(new String(bt,0,num));
    
73.                
    
74.         }
    
75. }
    
76. 
    
77. class UpLoadServer{
    
78.         public static void main(String[] args)throws Exception{
    
79.                 ServerSocket ss = new ServerSocket(10009);
    
80.                
    
81.                 while(true){
    
82.                         Socket s = ss.accept();
    
83.                         new Thread(new UpLoadThread(s)).start();
    
84.                 }
    
85.        
    
86.         }
    
87. }

复制代码

运行时抛出上传失败异常了；实际已经上传成功了，但是服务端返回的信息没接收到。。不知道怎么回事啊求解

---

作者: 沈文杰    时间: 2013-3-26 17:20

---

作者: 沈文杰    时间: 2013-3-26 18:40
帮帮忙啊

---

作者: 黄玉昆    时间: 2013-3-26 18:57
是不是你的第42行代码可以去掉啊，这里可以不用刷新了。你试试吧

---

作者: 沈文杰    时间: 2013-3-26 20:00

黄玉昆 发表于 2013-3-26 18:57
是不是你的第42行代码可以去掉啊，这里可以不用刷新了。你试试吧

我试过还是不行啊...

---

作者: 贾振凯    时间: 2013-3-28 20:42

public class UpLoadThread implements Runnable{
    private Socket s;
    private int count=1;//此处把count改成成员变量用于线程共享记录重名文件数
    /*UpLoadThread(Socket s){
            this.s = s;
    } */
    public void setSocket(Socket s){//在服务器端辅助UpLoadThread对象共享的工具方法
     this.s = s;
    }
    public void run(){
        String ip = s.getInetAddress().getHostAddress();
        try{
            System.out.println(ip+"::::connect");
            InputStream ips = s.getInputStream();
            File file = new File(ip+"("+(count)+")"+".txt");
            while(file.exists()){//此处改为while,可保证即使你服务器重启,依然可以确保文件名称编排连续
                    file = new File(ip+"("+(++count)+")"+".txt");//count++改为++count
            }
            FileOutputStream fos = new FileOutputStream(file);                        
            byte[] arr = new byte[1024];
            int len = 0;
            while((len = ips.read(arr))!=-1){
                    fos.write( arr,0,len);
            }
            
            OutputStream ops = s.getOutputStream();
            ops.write("文件上传成功".getBytes());
            
            fos.close();
            s.close();
        }
        catch(Exception e){
                throw new RuntimeException("文件上传失败！");
        }        
    }
}


class UpLoadClient{

    public static void main(String[] args)throws Exception{
     
        Socket s = new Socket("127.0.0.1",10009);
        
        OutputStream ops = s.getOutputStream();
        FileInputStream fis = new FileInputStream("D:\\demo.txt");
        byte[] arr = new byte[1024];
        int len =0;
        while((len = fis.read(arr))!=-1){
                ops.write(arr,0,len);
        }
        s.shutdownOutput();//调用此方法以后上传线程就可以收到一个-1的读取结束标志位
        InputStream ips = s.getInputStream();
        byte[] bt = new byte[1024];
        int num = ips.read(bt);
        System.out.println(new String(bt,0,num));
        fis.close();
        s.close();
    }
}

public class UpLoadServer{

    public static void main(String[] args)throws Exception{
        ServerSocket ss = new ServerSocket(10009);
      //此处共享,就不用每个线程都在创建一个UpLoadThread对象啦,且可以共享count成员变量
        UpLoadThread ult = new UpLoadThread();
        while(true){
            Socket s = ss.accept();
            ult.setSocket(s);
            new Thread(ult).start();
        }
    }
}



搞了挺长时间也就修了修边边角角的东西,感觉这些细节跟你抛出的那个异常也没啥关系,现在在我这是运行正常啦,另外请教下

s.shutdownOutput();//调用此方法以后上传线程就可以收到一个-1的读取结束标志位


我关于这句话的了解对不对,感觉是这个样子

---

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

黑马程序员IT技术论坛 X3.2