明月松間照 清泉石上流


                                                  ——— 兵臨城下   貓科動物
          posts - 70, comments - 137, trackbacks - 0, articles - 23
            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

          一個關于Java Socket的問題,大家看一下

          Posted on 2006-04-29 17:05 兵臨城下 閱讀(5343) 評論(9)  編輯  收藏 所屬分類: J2SE

          一個關于Java Socket的問題,大家看一下:
          我的目的是從client端發出一段字符串,server端接收后原樣返回給客戶端。
          客戶端:ConnClient? 服務器端ConnSerer(完整源代碼附在最后)

          ===client端===
          建了一個out流和in流:
          BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
          ??
          PrintWriter Clientout = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);

          向server端輸出:clientOut.println("hello");? clientout.close();
          等待服務器端返回代碼片段:
          StringBuffer sbuf = new StringBuffer();
          char[] buff = new char[10];
          ??
          int iLen = in.read(buff);
          ??
          while (iLen>0) {?
          ?? sbuf.append(buff,0,iLen);
          ?? if (sbuf.toString().trim().equals("hello")){
          ?????? System.out.println(sbuf.toString());
          ??????? break;
          ?? }
          ??? iLen = in.read(buff);
          }

          ?


          ===server端===
          同樣建了一個in流和out流
          BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
          ??
          PrintWriter Serverout = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);

          接收client端信息和原樣返回信息:
          StringBuffer sbuf = new StringBuffer();
          ????
          char[] buff = new char[10];
          int iLen = in.read(buff);
          ?????????
          while(iLen>0){?
          ?sbuf.append(buff,0,iLen);
          ?if (sbuf.toString().trim().equals("hello")){
          ?
          ?System.out.println("Echoing: " + sbuf.toString());
          ?serverout.println(sbuf.toString());?????? //此處為server端輸出流,返回給client端
          ?break;
          ??????? }

          ?iLen = in.read(buff);
          }


          問題來了:
          1、如果按以上代碼運行,server端可以收到client的信息,但client端卻收不到返回的信息。為什么?
          2、后來我把client端的clientout.close()注釋掉后,一切正常,client端能收到server端返回的信息。這又為什么?
          難道server端和client端用的是一個out流?為什么client端把out流關掉后(clientout.close()),server端就不能返回信息呢?

          以我以前的理解,server端和client端建的兩個輸出流應該是獨立的。不會因為我把client端的out流關掉后,server端out流就不能返回了?不會吧!呵呵!


          還有一個問題:server端怎么判斷client端數據已經發送完畢?
          一開始,我用clientout.print("hello"),運行后,server端顯示已經連接成功但一直偵聽,沒有收到信息,認為client端還沒有發送完成。
          后來,我改用clientout.println("hello"),運行后,一切正常,服務器端也收到信息(hello)。
          從上看出server的地判定就是一個回車符,不知道這樣認識對不對?大家指點!
          經過我試驗,如果client端print后,用clientout.close()也可以使server端接收到信息。但卻不能返回信息。也就是我發現上面說述的問題來由。

          以上幾個問題,請大家和banq大哥多加指點!

          源代碼如下:
          client端:
          package com.socket;

          import java.net.*;
          import java.io.*;

          public class ConnClient {
          ? public static void main(String[] args) throws IOException {

          ?InetAddress addr = InetAddress.getByName(null);
          ?
          ?System.out.println("addr = " + addr);
          ?
          ?Socket socket = new Socket(addr, 8080);
          ?//socket.setSoTimeout(5000);
          ?
          ?try {
          ?? System.out.println("socket = " + socket);
          ?? BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
          ??
          ?? PrintWriter clientout = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
          ??
          ?? String strSend = "hello";
          ??
          ? ?
          ?? clientout.println(strSend);
          ?? //clientout.println("\r\n");
          ?? //clientout.println();
          ?? //clientout.close();
          ?? StringBuffer sbuf = new StringBuffer();
          ??
          ?char[] buff = new char[10];
          ??
          ?int iLen = in.read(buff);
          ??
          ?while (iLen>0) {?
          ??sbuf.append(buff,0,iLen);
          ??if (sbuf.toString().trim().equals(strSend)){
          ???System.out.println(sbuf.toString());
          ????? break;
          ???? }
          ?? iLen = in.read(buff);
          ?}
          ?
          ?}catch(Exception e){
          ??e.printStackTrace();
          ?} finally {
          ?? System.out.println("closing...");
          ?? socket.close();
          ?}
          ?
          }
          }


          server端代碼:
          package com.socket;
          import java.io.*;
          import java.net.*;

          public class ConnServer {?
          ?
          ? public static final int PORT = 8080;
          ? public static void main(String[] args) throws IOException {

          ?ServerSocket s = new ServerSocket(PORT);
          ?System.out.println("Started: " + s);
          ?try {
          ?? Socket socket = s.accept();
          ?? try {
          ?System.out.println("Connection accepted: "+ socket);
          ?BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

          ?PrintWriter serverout = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
          ??
          ????? StringBuffer sbuf = new StringBuffer();
          ???????
          ?char[] buff = new char[10];
          ?iLen = in.read(buff);
          ?????????
          ?while(iLen>0){?
          ?sbuf.append(buff,0,iLen);
          ?if(sbuf.toString().trim().equals("hello")){
          ?
          ?System.out.println("Echoing: " + sbuf.toString());
          ?serverout.println(sbuf.toString());
          ??????? }
          ?????????? iLen = in.read(buff);
          }??
          ?? }catch(Exception e) { e.printStackTrace();}
          ??? finally {
          ???System.out.println("closing...");
          ???
          ???socket.close();
          ?? }
          ?
          ?} finally {
          ?? s.close();
          ?}
          ? }
          }


          評論

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2006-05-02 17:45 by 兵臨城下
          經過幾天的調試,初步有點心得,在我的blog上記錄一下:
          1、client端,clientout.close()語句表面上只是關閉了socket輸出流,但從我的調試中發現,在關閉這個out流后,client就不能在取得socket,說明在關閉out流的同時,也隱式的關閉了socket。所以server端就無法返回數據了。解釋我的第一和第二個問題。
          2、關于server端判定client端是否信息發送完畢的信號問題。
          從我幾天的調試中,我總結出幾點(可能還有其他的,請補充):
          a、就是經常使用的out.println(out.print不行)
          b、那就是關閉client端out流,out.close()。但這種方法卻關閉了socket,顯然不是大家所愿的。

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2006-05-08 13:49 by 兵臨城下
          問題進行中……(實時紀錄)
          考慮到字節流的需要,在client端和server端都改用字節流DataInputStream和DataOutputStream,相應的輸出方法使用out.write(byte[]) 。
          問題一:此種輸入輸出流沒有了out.println()方法,該怎么判定client端輸出流的結束??
          問題二:在client端,發送的信息的源分為兩種,字符串和文件流。兩種不同的輸入流在server端接收判斷結束時是否存在區別??

          對于問題二,筆者有一些心得:
          server端的接收代碼段是:
          byte[] sbyte = new byte[1024];
          int len;
          while((len = in.read(sbyte)) != -1) {
          out.write(sbyte,0,len);
          out.flush();
          }

          如果client端輸入流為字符串,server端在接收完畢后,在while語句中不能正常跳出。而使用文件流時就可以跳出循環。

          以上問題歡迎大家發表意見!

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2006-05-08 21:12 by 兵臨城下
          更正一下,上面所說的文件流能順利跳出循環不正確,其實不然。
          實際上在client端傳輸完成后,server端while循環還是不能跳出,最后能夠完整輸出實際是在客戶端強制關閉socket后,server端while才跳出循環的。
          從以上我總結出,不管是字符流,還是文件流,都得附加一個標示符來標識client端傳輸的結束。

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2006-05-12 12:19 by 兵臨城下
          又獲益頗多啊!
          再來說說這幾天的心得:
          關于這個socket,折騰了好幾天了啊!
          出現這個問題的初衷是:公司內想要實現java和C++的socket通訊。

          關于這個java端(也就是client端)發送信息結束的判定問題總結如下:
          如果server端也是java程序(C++我不是很了解),而且server端使用一個while循環讀取數據時(類似于while((len = in.read(sbyte)) != -1) {}),即使client端發送完成,即while((len = inFile.read(bb)) != -1) {}循環語句跳出后,server端仍然在while語句中,不能正常跳出。因為server端認為你沒有發送結束。
          究其原因,我認為,因為在java socket中對于socket的input和output流結束,有一個socket方法來給出結束的標志:socket.shutdownOutput();socket.shutdownInput();

          這兩個方法為java socket判定client端發送結束的標志。

          當然如果和我上述留言中所說的,使用特定設置的標志符當然是可以的。

          # re: 一個關于Java Socket的問題,大家看一下[未登錄]  回復  更多評論   

          2009-02-28 22:11 by sunshine
          如果通信協議用的是java默認的編碼格式,客戶端還是用BufferedReader.readline()方法,這個是以\r\n為界定符的。在你從socket產生bufferedReader的時候,PrintWriter clientout = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true)最后一個boolean標志是否在println()方法中自動調用outputstream.flush()把緩存的東西是否發送出去。否則還要自己再調用PrintWriter.flush()發送。而且這個println()后在你的數據后加上\r\n,用客戶端的readline()正好可以讀到你的數據,當然是去掉了\r\n.

          如果你要使用自己的界定符,就不能使用BufferedReader,應該使用它的基類,在while(in.ready())循環中inputstream.read(),然后自己斷開你的數據。這和串口的通信是一樣。既然是輸入流,當然收到是連續的字節數據,除非你制定一個界定符,否則系統怎么知道你發送完了?同時,還要注意發送字節的時候,兩端的編碼格式要一致。

          # 回答得太好了  回復  更多評論   

          2009-06-27 21:20 by 周小兵
          哥們,你回答的太好了,這正是我遇到的問題,問題都和你一樣的,我在看你的回答前,我已經測試過,找到了問題的原因,上網驗證發現你回答的和我測試的一樣。有緣多多交流啊,QQ:379172684。
          頂!

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2011-08-10 16:25 by careinlost
          我遇到了相同的問題,
          當我在客戶端使用shutdownoutput時,服務端并未能完全獲取全部數據就拋出異常了,嘗試了client線程等待也不行。

          有什么辦法能夠使客戶端shutdownoutput前讓服務端接收完數據,而不是在while(read)中等待?

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2011-12-28 10:10 by Jawe
          樓主V5,解決了困擾我一天的問題

          # re: 一個關于Java Socket的問題,大家看一下  回復  更多評論   

          2012-09-26 09:25 by 飛飛俠
          看了半天,樓主還是沒有解決問題啊
          主站蜘蛛池模板: 南开区| 阿巴嘎旗| 威信县| 乌拉特前旗| 德化县| 灯塔市| 兰溪市| 嘉禾县| 玉田县| 长春市| 林甸县| 滕州市| 鄂州市| 临湘市| 凌云县| 威海市| 信丰县| 准格尔旗| 常山县| 祥云县| 黄陵县| 株洲市| 红安县| 乌海市| 织金县| 凉城县| 上饶县| 辰溪县| 历史| 湄潭县| 平罗县| 凉城县| 鄂尔多斯市| 大关县| 尼木县| 安岳县| 玛曲县| 屯门区| 子长县| 湖口县| 宁波市|