黑马程序员技术交流社区

标题: 【已解决】关于Socket编程中文件上传问题 [打印本页]

---

作者: 何拴绪    时间: 2012-5-26 18:13
标题: 【已解决】关于Socket编程中文件上传问题


这段代码中文件上传成功了可是阻塞方法还是没有停止，判断标记貌似没有被执行 这么回事？

1. import java.io.*;
   
2. import java.net.*;
   
3. class TextClient
   
4. {
   
5. public static void main(String[] args) throws Exception
   
6. {
   
7. Socket s = new Socket("127.0.0.1",10005);
   
8. BufferedReader br = new BufferedReader(new FileReader("TCPDemo.java"));
   
9. String line = null;
   
10. BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));//老师是这里用的打印流我用的字符流
    
11. while((line=br.readLine())!=null) {
    
12. bw.write(line);
    
13. bw.newLine();
    
14. bw.flush();
    
15. }
    
16. bw.write("over");//结束标记
    
17. bw.flush();
    
18. BufferedReader brIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
19. System.out.println( brIn.readLine());
    
20. br.close();
    
21. s.close();
    
22. }
    
23. }
    
24. class TextServer
    
25. {
    
26. public static void main(String[] args) throws Exception
    
27. {
    
28. ServerSocket ss = new ServerSocket(10005);
    
29. Socket s = ss.accept();
    
30. String ip = s.getInetAddress().getHostAddress();
    
31. System.out.println(ip);
    
32. BufferedWriter bw = new BufferedWriter(new FileWriter("Server.txt"));
    
33. BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
34. BufferedWriter bwIn = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
    
35. 
    
36. String line = null;
    
37. while((line=br.readLine())!=null) {
    
38. if("over".equals(line))
    
39. break;
    
40. bw.write(line);
    
41. bw.newLine();
    
42. bw.flush();
    
43. }
    
44. bwIn.write("上传成功");//返回客户端字样
    
45. bw.close();
    
46. ss.close();
    
47. }
    
48. }
    

复制代码

---

作者: 王硕'    时间: 2012-5-26 18:38
bw.write("over");//结束标记
bw.neLine();
bw.flush();

你之前都写对了，就知道时候什么原因了，估计是漏写的吧。
对了，既然使用字符流，为什么不用PrintWriter?

---

作者: 何拴绪    时间: 2012-5-26 19:01

王硕' 发表于 2012-5-26 18:38
bw.write("over");//结束标记
bw.neLine();
bw.flush();

不是这里的问题，貌似还是不可以，麻烦再帮我分析下

---

作者: 张亭    时间: 2012-5-26 19:02


import java.io.*;
import java.net.*;
class TextClient {
public static void main(String[] args) throws Exception {
Socket s = new Socket("127.0.0.1", 10005);
BufferedReader br = new BufferedReader(new FileReader("TCPDemo.java"));
String line = null;
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
s.getOutputStream()));// 老师是这里用的打印流我用的字符流
while ((line = br.readLine()) != null) {
bw.write(line);
bw.newLine();
bw.flush();
}
bw.write("over");// 结束标记
bw.newLine();//要加上这句
bw.flush();
BufferedReader brIn = new BufferedReader(new InputStreamReader(
s.getInputStream()));
System.out.println(brIn.readLine());
br.close();
s.close();
}
}
class TextServer {
public static void main(String[] args) throws Exception {
ServerSocket ss = new ServerSocket(10005);
Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip);
BufferedWriter bw = new BufferedWriter(new FileWriter("Server.txt"));
BufferedReader br = new BufferedReader(new InputStreamReader(
s.getInputStream()));
BufferedWriter bwIn = new BufferedWriter(new OutputStreamWriter(
s.getOutputStream()));
String line = null;
while ((line = br.readLine()) != null) {
if ("over".equals(line))
break;
bw.write(line);
bw.newLine();
bw.flush();
}
bwIn.write("上传成功");// 返回客户端字样
bwIn.newLine();//加上这两句
bwIn.close();
bw.close();
ss.close();
}
}
因为你用的都是readLine()方法,这个方法要读到换行标记才结束
所以要添上对应的newLine()

---

作者: 王硕'    时间: 2012-5-26 19:12

何拴绪 发表于 2012-5-26 19:01
不是这里的问题，貌似还是不可以，麻烦再帮我分析下

。。。 是这个问题。不过没楼上哥们说的完整。
一个是客户端写给服务端的结束符号没加换行符，服务端的读就无法结束，
另外一个是服务端写给客户端的没加换行附，导致客户端的读无法结束。
哥们，还是那句话， 用println()一句话就解决问题胃

---

作者: 何拴绪    时间: 2012-5-26 19:21

张亭 发表于 2012-5-26 19:02
import java.io.*;
import java.net.*;
class TextClient {

谢谢啊 解决了 可是为什么不关流就不行呢？

---

作者: 张晨    时间: 2012-5-26 19:36
建议使用发送，接收，发送，接收的方式处理，比较明确
然后你的主要错误就是没有刷新字符流，所以client的字符都没有发送出去
我帮你修改了一下，自己对比着看吧

1. import java.io.*;
   
2. import java.net.*;
   
3. public class TextClient {
   
4. 
   
5.         public static void main(String[] args) throws Exception {
   
6.                 Socket s = new Socket("127.0.0.1", 10005);
   
7.                 BufferedReader br = new BufferedReader(new FileReader("TCPDemo.java"));
   
8.                 String line = null;
   
9.                 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
   
10.                                 s.getOutputStream()));// 老师是这里用的打印流我用的字符流
    
11.                 BufferedReader brIn = new BufferedReader(new InputStreamReader(
    
12.                                 s.getInputStream()));
    
13.                
    
14.                 while ((line = br.readLine()) != null) {
    
15.                         System.out.println( line); //for test
    
16.                         bw.write(line);
    
17.                         bw.newLine();
    
18.                         bw.flush();
    
19.                         brIn.readLine();
    
20.                 }
    
21.                 bw.write("over");// 结束标记
    
22.                 bw.newLine();
    
23.                 bw.flush();
    
24. 
    
25.                 System.out.println(brIn.readLine());
    
26.                 br.close();
    
27.                 s.close();
    
28.         }
    
29. }
    
30. 
    

复制代码

1. import java.io.*;
   
2. 
   
3. import java.net.*;
   
4. 
   
5. public class TextServer {
   
6. 
   
7.         public static void main(String[] args) throws IOException {
   
8. 
   
9.                 ServerSocket ss = new ServerSocket(10005);
   
10.                 Socket s = ss.accept();
    
11.                 String ip = s.getInetAddress().getHostAddress();
    
12.                 System.out.println(ip);
    
13.                 BufferedWriter bw = new BufferedWriter(new FileWriter("Server.txt"));
    
14.                 BufferedReader br = new BufferedReader(new InputStreamReader(
    
15.                                 s.getInputStream()));
    
16.                 BufferedWriter bwIn = new BufferedWriter(new OutputStreamWriter(
    
17.                                 s.getOutputStream()));
    
18.                 String line = null;
    
19.                 char[] buff= new char[1024];
    
20.                 int len;
    
21.                 while ((line = br.readLine()) != null) {
    
22.                         if ("over".equals(line))
    
23.                                 break;
    
24.                         bw.write(line);
    
25.                         bw.newLine();
    
26.                         //bw.flush();
    
27.                         bwIn.write("ok");  //add by zc
    
28.                         bwIn.newLine();  //add by zc
    
29.                         bwIn.flush();
    
30.                        
    
31.                 }
    
32.                 bwIn.write("上传成功");// 返回客户端字样
    
33.                 bwIn.newLine();
    
34.                 bwIn.flush();
    
35.                 System.out.println("successful");
    
36.                 bw.close();
    
37.                 ss.close();
    
38.         }
    
39. }

复制代码

---

作者: 张亭    时间: 2012-5-26 21:12

何拴绪 发表于 2012-5-26 19:21
谢谢啊 解决了 可是为什么不关流就不行呢？

关流的时候会自动flush一下,所以,省略了close()前面的flush()方法;
因为程序结束了,直接写close() 就OK了

---

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

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