一、背景
在前段時(shí)間寫項(xiàng)目時(shí),需要用到SOCKET編程,于是看看幫助文檔,簡單的寫了一個(gè)小例子,他娘的,盡然發(fā)現(xiàn)一個(gè)無法解釋的問題,于是不斷的調(diào)試,
還好終于知道出錯(cuò)的原因在哪里,覺得在項(xiàng)目中可能遇見,特別是初學(xué)者故此將心得寫下。
二、實(shí)現(xiàn)功能
超級(jí)簡單的例子,就是客戶端連接到服務(wù)器端后,發(fā)送hello server給服務(wù)器端,而服務(wù)器端首先拿到客戶端傳過來的信息,打印到控制臺(tái)上,接著再向客戶端發(fā)送hello client的信息。***補(bǔ)充說明--該例子只是本人在入門學(xué)習(xí)socket編程亂寫的,所以功能簡單。***
三、項(xiàng)目代碼
3.1 服務(wù)器端代碼
package com.congine.socket.test;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class TcpServerStu2 {
public static void main(String[] args) {
try {
ServerSocket ss = new ServerSocket(8888);
Socket s = null;
while(true) {
s = ss.accept();
System.out.println("a client connection!");
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println("client say:"+br.readLine());
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
bw.write("hello client!");
bw.flush();
bw.close();
br.close();
s.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
3.2 客戶端代碼
package com.congine.socket.client.test;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class TcpClient2 {
public static void main(String[] args) {
try {
Socket s = new Socket("127.0.0.1",8888);
BufferedWriter dos = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
dos.write("hello server!");
dos.flush();
System.out.println("hello world!");
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println("server say:"+br.readLine());
dos.close();
br.close();
s.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
四、產(chǎn)生問題
????? 服務(wù)器只提示一個(gè)a client connection,而客戶端就是打印hello world,接著服務(wù)器和客戶端就阻塞到哪里,傻傻的等待。
五、問題的假想
??? 1、 產(chǎn)生以上問題以后,第一時(shí)間我就利用IDE的調(diào)試來查看執(zhí)行的過程,于是我在server端設(shè)置一個(gè)斷點(diǎn),接著在client端設(shè)置一個(gè)斷點(diǎn)。然后,我開始用debug方式啟動(dòng)服務(wù)器端,跟預(yù)想的一樣,服務(wù)器端在ss.accept()阻塞住,接著我再啟動(dòng)client端,發(fā)現(xiàn)client可以執(zhí)行到末尾br.readLine()處阻塞,程序就沒法執(zhí)行了,跟預(yù)想的不一樣,預(yù)想中根據(jù)程序運(yùn)行的結(jié)果,在調(diào)試Client端應(yīng)該有一個(gè)時(shí)間點(diǎn)切換到server端打印 a client connection,可是結(jié)果卻沒有。那么這里肯定存在一個(gè)問題,IDE的debug運(yùn)行機(jī)制跟RUN運(yùn)行機(jī)制不一樣,哈哈,各位有興趣可以去研究。
?? 2、接著我就在考慮,既然兩端都沒有接收到雙方的信息,并且發(fā)生阻塞(相當(dāng)于死循環(huán)),那是不是client端發(fā)送的數(shù)據(jù)和server端發(fā)送的數(shù)據(jù)在同一個(gè)IO通道中阻塞住了,因此接收不到,(哈哈,現(xiàn)在想想發(fā)現(xiàn)當(dāng)時(shí)的想法很幼稚),于是我就按著這種思路走,在服務(wù)器的打印了a client connection后,讓服務(wù)器線程休眠1000毫秒,結(jié)果
?? 3、接著我又在想,既然不是這個(gè)原因,那么會(huì)不會(huì)是因?yàn)榉庋b的字符流問題,于是我將BufferedReader 換成DataInputStreamStream,BufferedWriter 換成DataOutputStream,結(jié)果意外的發(fā)現(xiàn)竟然能夠得到正確結(jié)果,但是我始終沒法真正的發(fā)現(xiàn)發(fā)生錯(cuò)誤的本質(zhì)原因,難道以后都不用BufferedReader和BufferedWriter,心里總有一點(diǎn)不快的感覺,但是很無奈,只好放了放。
?? 4、功能解決了,但是問題的根本原因沒有找到,項(xiàng)目時(shí)間又緊迫,所以只好放了放,接著學(xué)習(xí)別的,就在昨天,我漫不經(jīng)心的看看JDK幫助文檔中的BufferedReader這個(gè)類以及比較我的代碼看了,就看到readLine()方法,上面的提示是
該方法功能,讀取一個(gè)文本行。通過下列字符之一即可認(rèn)為某行已終止:換行 ('\n')、回車 ('\r') 或回車后直接跟著換行。 于是我在想如果沒有輸入換行 ('\n')、回車 ('\r') ,那這個(gè)方法就一直阻塞在哪里嗎?正好想到我寫入輸出流的文字沒有換行,難道是這個(gè)原因,于是改了改調(diào)試了一下,果然
五、總結(jié)
?? 在BufferedReader中的readLine方法讀入時(shí)是讀入一行,一定要包括換行符\n在用bufferedwriter的write方法寫入的str不包括換行符導(dǎo)致停在了reanline。因此即時(shí)flush也是沒有用,readLine方法認(rèn)為你沒有讀完。一直阻塞在那。
??
在前段時(shí)間寫項(xiàng)目時(shí),需要用到SOCKET編程,于是看看幫助文檔,簡單的寫了一個(gè)小例子,他娘的,盡然發(fā)現(xiàn)一個(gè)無法解釋的問題,于是不斷的調(diào)試,

二、實(shí)現(xiàn)功能
超級(jí)簡單的例子,就是客戶端連接到服務(wù)器端后,發(fā)送hello server給服務(wù)器端,而服務(wù)器端首先拿到客戶端傳過來的信息,打印到控制臺(tái)上,接著再向客戶端發(fā)送hello client的信息。***補(bǔ)充說明--該例子只是本人在入門學(xué)習(xí)socket編程亂寫的,所以功能簡單。***
三、項(xiàng)目代碼
3.1 服務(wù)器端代碼
package com.congine.socket.test;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class TcpServerStu2 {
public static void main(String[] args) {
try {
ServerSocket ss = new ServerSocket(8888);
Socket s = null;
while(true) {
s = ss.accept();
System.out.println("a client connection!");
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println("client say:"+br.readLine());
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
bw.write("hello client!");
bw.flush();
bw.close();
br.close();
s.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
3.2 客戶端代碼
package com.congine.socket.client.test;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class TcpClient2 {
public static void main(String[] args) {
try {
Socket s = new Socket("127.0.0.1",8888);
BufferedWriter dos = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
dos.write("hello server!");
dos.flush();
System.out.println("hello world!");
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println("server say:"+br.readLine());
dos.close();
br.close();
s.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
四、產(chǎn)生問題
????? 服務(wù)器只提示一個(gè)a client connection,而客戶端就是打印hello world,接著服務(wù)器和客戶端就阻塞到哪里,傻傻的等待。
五、問題的假想
??? 1、 產(chǎn)生以上問題以后,第一時(shí)間我就利用IDE的調(diào)試來查看執(zhí)行的過程,于是我在server端設(shè)置一個(gè)斷點(diǎn),接著在client端設(shè)置一個(gè)斷點(diǎn)。然后,我開始用debug方式啟動(dòng)服務(wù)器端,跟預(yù)想的一樣,服務(wù)器端在ss.accept()阻塞住,接著我再啟動(dòng)client端,發(fā)現(xiàn)client可以執(zhí)行到末尾br.readLine()處阻塞,程序就沒法執(zhí)行了,跟預(yù)想的不一樣,預(yù)想中根據(jù)程序運(yùn)行的結(jié)果,在調(diào)試Client端應(yīng)該有一個(gè)時(shí)間點(diǎn)切換到server端打印 a client connection,可是結(jié)果卻沒有。那么這里肯定存在一個(gè)問題,IDE的debug運(yùn)行機(jī)制跟RUN運(yùn)行機(jī)制不一樣,哈哈,各位有興趣可以去研究。
?? 2、接著我就在考慮,既然兩端都沒有接收到雙方的信息,并且發(fā)生阻塞(相當(dāng)于死循環(huán)),那是不是client端發(fā)送的數(shù)據(jù)和server端發(fā)送的數(shù)據(jù)在同一個(gè)IO通道中阻塞住了,因此接收不到,(哈哈,現(xiàn)在想想發(fā)現(xiàn)當(dāng)時(shí)的想法很幼稚),于是我就按著這種思路走,在服務(wù)器的打印了a client connection后,讓服務(wù)器線程休眠1000毫秒,結(jié)果

?? 3、接著我又在想,既然不是這個(gè)原因,那么會(huì)不會(huì)是因?yàn)榉庋b的字符流問題,于是我將BufferedReader 換成DataInputStreamStream,BufferedWriter 換成DataOutputStream,結(jié)果意外的發(fā)現(xiàn)竟然能夠得到正確結(jié)果,但是我始終沒法真正的發(fā)現(xiàn)發(fā)生錯(cuò)誤的本質(zhì)原因,難道以后都不用BufferedReader和BufferedWriter,心里總有一點(diǎn)不快的感覺,但是很無奈,只好放了放。
?? 4、功能解決了,但是問題的根本原因沒有找到,項(xiàng)目時(shí)間又緊迫,所以只好放了放,接著學(xué)習(xí)別的,就在昨天,我漫不經(jīng)心的看看JDK幫助文檔中的BufferedReader這個(gè)類以及比較我的代碼看了,就看到readLine()方法,上面的提示是
該方法功能,讀取一個(gè)文本行。通過下列字符之一即可認(rèn)為某行已終止:換行 ('\n')、回車 ('\r') 或回車后直接跟著換行。 于是我在想如果沒有輸入換行 ('\n')、回車 ('\r') ,那這個(gè)方法就一直阻塞在哪里嗎?正好想到我寫入輸出流的文字沒有換行,難道是這個(gè)原因,于是改了改調(diào)試了一下,果然

五、總結(jié)
?? 在BufferedReader中的readLine方法讀入時(shí)是讀入一行,一定要包括換行符\n在用bufferedwriter的write方法寫入的str不包括換行符導(dǎo)致停在了reanline。因此即時(shí)flush也是沒有用,readLine方法認(rèn)為你沒有讀完。一直阻塞在那。
??
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號(hào)聯(lián)系: 360901061
您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長非常感激您!手機(jī)微信長按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
