1. /*
   
2. 需求:
   
3. 通过TCP的Socket和ServerSocket,向服务段上传图片;
   
4. 思路:
   
5. Socket服务:
   
6. 1.想要上传图片,就需要使用IO字节流,把图片文件出入到Socket输出流,输出到服务端;
   
7. 2.
   
8. */
   
9. import java.io.*;
   
10. import java.net.*;
    
11. 
    
12. class SocketClient implements Runnable
    
13. {
    
14. private Socket s;
    
15. public SocketClient(Socket s)
    
16. {
    
17. this.s=s;
    
18. }
    
19. public void run()
    
20. {
    
21. File file=new File("yuanye.jpg");
    
22. 
    
23. if (file.exists())
    
24. {
    
25. throw new RuntimeException("您想要上传的图片文件不存在");
    
26. }
    
27. BufferedInputStream bufr=null;
    
28. try
    
29. {
    
30. bufr=new BufferedInputStream(new FileInputStream(file));
    
31. byte buf[]=new byte[1024];
    
32. 
    
33. int len=0;
    
34. 
    
35. while ((len=bufr.read(buf))!=-1)
    
36. {
    
37. s.getOutputStream().write(buf,0,len);
    
38. }
    
39. }
    
40. catch (FileNotFoundException fnfe)
    
41. {
    
42. throw new RuntimeException("关联文件到输入流失败");
    
43. }
    
44. catch (IOException ie)
    
45. {
    
46. throw new RuntimeException("上传文件失败");
    
47. }
    
48. finally
    
49. {
    
50. try
    
51. {
    
52. if (bufr!=null)
    
53. {
    
54. bufr.close();
    
55. }
    
56. }
    
57. catch (IOException ioe)
    
58. {
    
59. throw new RuntimeException("关闭输入流失败");
    
60. }
    
61. }
    
62. }
    
63. }
    
64. 
    
65. 
    
66. class SocketServer implements Runnable
    
67. {
    
68. private ServerSocket ss;
    
69. public SocketServer(ServerSocket ss)
    
70. {
    
71. this.ss=ss;
    
72. }
    
73. public void run()
    
74. {
    
75. File file=new File("yuanye复件.jpg");
    
76. PrintStream ps =null;
    
77. Socket s=null;
    
78. try
    
79. {
    
80. ps=new PrintStream(new BufferedOutputStream(new FileOutputStream(file)),true);
    
81. s=ss.accept();
    
82. 
    
83. byte[] buf=new byte[1024];
    
84. int len=0;
    
85. 
    
86. while ((len=s.getInputStream().read(buf))!=-1)
    
87. {
    
88. ps.println(buf);
    
89. }
    
90. }
    
91. catch (FileNotFoundException fnfe)
    
92. {
    
93. throw new RuntimeException("关联文件到输出流失败");
    
94. }
    
95. catch (IOException ie)
    
96. {
    
97. throw new RuntimeException("读取文件失败");
    
98. }
    
99. finally
    
100. {
     
101. ps.close();
     
102. 
     
103. try
     
104. {
     
105. if (s!=null)
     
106. {
     
107. s.close();
     
108. }
     
109. }
     
110. catch (IOException i)
     
111. {
     
112. throw new RuntimeException("客服端关闭失败");
     
113. }
     
114. }
     
115. 
     
116. }
     
117. }
     
118. 
     
119. class UploadingPictureByTCP
     
120. {
     
121. public static void main(String[] args) throws Exception
     
122. {
     
123. new Thread(new SocketClient(new Socket("192.168.0.4",10003))).start();
     
124. new Thread(new SocketServer(new ServerSocket(10003))).start();
     
125. }
     
126. }
     

复制代码

抱歉代码太多就没看了，你的异常是ConnectionException,也就是你在创建socket的时候就失败了，后面的代码根本就没有运行了
请问192.168.0.4是你本机的IP吗？  请你补充回答这个问题，然后再看其他问题

我感觉是这样的，你把客户端和服务端封装成了两个线程，主线程先开启了客户端，此时服务端尚未开启，所以产生了连接异常，你可以试试先开启服务端。
不知道行不行，或者你搞个类让服务端一直等待着。

高彰谦 发表于 2012-4-26 14:54
抱歉代码太多就没看了，你的异常是ConnectionException,也就是你在创建socket的时候就失败了，后面的代码根 ...

是本机的

Tcp是面向连接的，这个情况应该是楼主先开了客户端，导致的连接失败报错
public static void main(String[] args) throws Exception

{

new Thread(new SocketClient(new Socket("192.168.0.4",10003))).start();//这边先开了客户端导致链接失败报错，上下代码互换呢

new Thread(new SocketServer(new ServerSocket(10003))).start();

}

}

你好，服务器端需要先开，而且，可能是服务器开启监听需要时间。

1. new Thread(new SocketServer(new ServerSocket(10003))).start();
   
2.                 Thread.sleep(10*1000);
   
3.                 new Thread(new SocketClient(new Socket("127.0.0.1", 10003))).start();

复制代码

这样修改之后，起码可以建立连接了

稍作改动，已经可以从客户端上传文件到服务器端了，
有几个地方需要改动

1. if (!file.exists()) {
   
2.                         throw new RuntimeException("您想要上传的图片文件不存在");
   
3.                 }

复制代码

你没有加!，造成逻辑错误
我个人认为，写二进制文件没必要用PrintStream,我觉得PrintStream还是更加实用与字符操作，并且没有任何在操作二进制文件上的优势。

还有服务器端在接受文件数据时，while循环的退出条件不生效，因为socket.getInputStream.read(byte[] bytes)，当没有数据读入时，处于阻塞状态，而不会返回-1

这就是我全部的认识了。