1. /*
   
2. 需求:
   
3.         通过TCP的Socket和ServerSocket,向服务端上传图片;
   
4. */
   
5. import java.io.*;
   
6. import java.net.*;
   
7. 
   
8. class SocketClient
   
9. {
   
10.         public static void main(String[] args)
    
11.         {
    
12.                 File file=new File("yuanye.jpg");
    
13.                 if (!file.exists())
    
14.                 {
    
15.                         throw new RuntimeException("你所关联的图片不存在");
    
16.                 }
    
17.                 BufferedInputStream bufi=null;
    
18.                 try
    
19.                 {
    
20.                         bufi=new BufferedInputStream(new FileInputStream(file));       
    
21.                 }
    
22.                 catch (FileNotFoundException fe)
    
23.                 {
    
24.                         throw new RuntimeException("您所关联的文件不存在");
    
25.                 }
    
26.                 Socket s=null;
    
27.                 try
    
28.                 {
    
29.                         s=new Socket("192.168.0.4",10000);
    
30.                 }
    
31.                 catch (UnknownHostException ue)
    
32.                 {
    
33.                         throw new RuntimeException("你说要连接的服务器地址有误");
    
34.                 }
    
35.                 catch (IOException ie)
    
36.                 {
    
37.                         throw new RuntimeException("套接字建立失败");
    
38.                 }
    
39.                 BufferedOutputStream bufo=null;
    
40.                 try
    
41.                 {
    
42.                         bufo=new BufferedOutputStream(s.getOutputStream());
    
43. 
    
44.                         byte[] buf=new byte[1024];
    
45. 
    
46.                         int len=0;
    
47. 
    
48.                         while ((len=bufi.read(buf))!=-1)
    
49.                         {
    
50.                                 bufo.write(buf,0,len);
    
51.                                 bufo.flush();
    
52. 
    
53.                         }                //为什么这会变成死循环啊???
    
54.                         System.out.println("到这里..............");
    
55.                         s.shutdownOutput();
    
56. 
    
57.                         byte[] b=new byte[1024];
    
58. 
    
59.                         int num=s.getInputStream().read(b);
    
60. 
    
61.                         System.out.println(new String(b,0,num));
    
62.                 }
    
63.                 catch (IOException ie)
    
64.                 {
    
65.                         throw new RuntimeException("文件上传失败");
    
66.                 }               
    
67.         }               
    
68. }
    
69. 
    
70. 
    
71. class ClientThread implements Runnable
    
72. {
    
73.         private Socket s;
    
74.         public ClientThread(Socket s)
    
75.         {
    
76.                 this.s=s;
    
77.         }
    
78.         public void run()
    
79.         {
    
80.                 File file=new File("yuanye复件.jpg");
    
81. 
    
82.                 InputStream is=null;               
    
83.                 try
    
84.                 {
    
85.                         is=s.getInputStream();                       
    
86.                 }
    
87.                 catch (IOException ie)
    
88.                 {
    
89.                         throw new RuntimeException("获取用户端读取流失败");
    
90.                 }
    
91.                 BufferedOutputStream bufo=null;
    
92.                 try
    
93.                 {
    
94.                         bufo=new BufferedOutputStream(new FileOutputStream(file));
    
95. 
    
96.                         byte[] buf=new byte[1024];
    
97. 
    
98.                         int len=0;
    
99. 
    
100.                         while ((len=is.read(buf))!=-1)
     
101.                         {
     
102.                                 bufo.write(buf,0,len);
     
103.                                 bufo.flush();
     
104.                         }
     
105.                         OutputStream os=s.getOutputStream();
     
106. 
     
107.                         os.write("上传成功".getBytes());
     
108.                 }
     
109.                 catch (IOException ie)
     
110.                 {
     
111.                         throw new RuntimeException("文件上传失败");
     
112.                 }
     
113.                 finally
     
114.                 {
     
115.                         try
     
116.                         {
     
117.                                 if (bufo!=null)
     
118.                                 {
     
119.                                         bufo.close();
     
120.                                 }
     
121.                         }
     
122.                         catch (IOException i)
     
123.                         {
     
124.                                 throw new RuntimeException("输出流关闭失败");
     
125.                         }
     
126.                         try
     
127.                         {
     
128.                                 s.close();
     
129.                         }
     
130.                         catch (IOException i)
     
131.                         {
     
132.                                 throw new RuntimeException("关闭客户端失败");
     
133.                         }
     
134.                 }
     
135.         }
     
136. }
     
137. 
     
138. class  SocketServer
     
139. {
     
140.         public static void main(String[] args) throws Exception
     
141.         {
     
142.                 ServerSocket ss=new ServerSocket(10000);
     
143.                
     
144.                 while (true)
     
145.                 {
     
146.                         Socket s=ss.accept();
     
147. 
     
148.                         new Thread(new ClientThread(s));
     
149.                 }
     
150.         }
     
151. }
     

复制代码

问题在48行处,while(){}发生了死循环;

怎么一直没有人回答啊???

孙国军 发表于 2012-4-27 08:57
怎么一直没有人回答啊???

人  了   ,那些大师都跑哪去聊啊

  new Thread(new ClientThread(s)).start()，现成是要运行才可以的。。。。

============================================================

运行你的代码，果然卡起，怀疑是客户端关闭网络输出流的时候出错了，更改代码：
                System.out.println("到这里..............");
                s.shutdownOutput();
                System.out.println("到这里2..............");//更改1
发现可以输出 "到这里2.............." 可以得知是正确的输出文件了，打开文件夹发现服务端根本没有建立“yuanye复件.jpg”文件，怀疑服务端file流写错，查看一圈，没错。。。。
回到服务端主函数，想查看下是不是建立socket时错了，突然发现。。。你线程根本就没有start()啊。。

============================================================

这样竟然也可以编译通过。。java容忍度是在很高了。。。还是有什么专门的使用意义，求高手解释。
难道是
       Thread t = new Thread(new ClientThread(s))；
       t.start();


...................2分钟后，求人不如求己，放到服务端代码里试一下，还真是正确运行了，java牛B了。。。。
以上，回答完毕。