Android Socket 發(fā)送與接收數(shù)據(jù)問題處理: 發(fā)送后的數(shù)據(jù)接收到總是粘包
[導(dǎo)讀]先說明一下粘包的概念: 發(fā)送時(shí)是兩個(gè)單獨(dú)的包、兩次發(fā)送，但接收時(shí)兩個(gè)包連在一起被一次接收到。在以前 WinCE 下 Socket 編程，確實(shí)也要處理粘包的問題，沒想到在 Android 下也遇到了。首
先說明一下粘包的概念: 發(fā)送時(shí)是兩個(gè)單獨(dú)的包、兩次發(fā)送，但接收時(shí)兩個(gè)包連在一起被一次接收到。
在以前 WinCE 下 Socket 編程，確實(shí)也要處理粘包的問題，沒想到在 Android 下也遇到了。
首先想從發(fā)送端能否避免這樣的問題，例如: (1) 調(diào)用強(qiáng)制刷數(shù)據(jù)完成發(fā)送的函數(shù)；(2) 設(shè)置發(fā)送超時(shí)。
1 先試了調(diào)用 flush() 函數(shù)，但運(yùn)行后現(xiàn)象依舊
2 設(shè)置發(fā)送超時(shí)是 Windows 平臺(tái)的做法，但在 Android 平臺(tái)下是否有類似的設(shè)置呢？
查看 Socket 類的實(shí)現(xiàn)代碼：java.net.socket socket.class 文件后發(fā)現(xiàn)，還是有函數(shù)可以完成這樣的設(shè)置的。請(qǐng)看如下函數(shù)和變量的說明：
/**
?*?Sets?this?socket's?{@link?SocketOptions#TCP_NODELAY}?option.
?*/
public?void?setTcpNoDelay(boolean?on)?throws?SocketException?{
????checkOpenAndCreate(true);
????impl.setOption(SocketOptions.TCP_NODELAY,?Boolean.valueOf(on));
}和
/** ?*?This?boolean?option?specifies?whether?data?is?sent?immediately?on?this?socket. ?*?As?a?side-effect?this?could?lead?to?low?packet?efficiency.?The ?*?socket?implementation?uses?the?Nagle's?algorithm?to?try?to?reach?a?higher ?*?packet?efficiency?if?this?option?is?disabled. ?*/ public?static?final?int?TCP_NODELAY?=?1;
一般情況下，只需要調(diào)用如下的代碼即可：
public?Socket?clientSocket?=?null;
//?實(shí)例化對(duì)象并連接到服務(wù)器
clientSocket?=?new?Socket("172.25.103.1",12589);
不用做任何設(shè)置就可以完成與服務(wù)器/客戶端的通訊，剛開始我也是這樣做的。所以，遇到了上面的問題。
//?發(fā)送數(shù)據(jù)包，默認(rèn)為?false，即客戶端發(fā)送數(shù)據(jù)采用?Nagle?算法； //?但是對(duì)于實(shí)時(shí)交互性高的程序，建議其改為?true，即關(guān)閉?Nagle?算法，客戶端每發(fā)送一次數(shù)據(jù)，無論數(shù)據(jù)包大小都會(huì)將這些數(shù)據(jù)發(fā)送出去 clientSocket.setTcpNoDelay(true);
看以下較完整的 Socket 初始化與設(shè)置過程:
/*?*?*?*?*?*?*?*?*?*?客戶端?Socket?通過構(gòu)造方法連接服務(wù)器?*?*?*?*?*?*?*?*?*?*/
try?{
??//?客戶端?Socket?可以通過指定?IP?地址或域名兩種方式來連接服務(wù)器端,實(shí)際最終都是通過?IP?地址來連接服務(wù)器
??//?新建一個(gè)Socket，指定其IP地址及端口號(hào)
??Socket?clientSocket?=?new?Socket("172.25.103.1",12589);
??//?客戶端socket在接收數(shù)據(jù)時(shí)，有兩種超時(shí)：1.?連接服務(wù)器超時(shí)，即連接超時(shí)；2.?連接服務(wù)器成功后，接收服務(wù)器數(shù)據(jù)超時(shí)，即接收超時(shí)
??//?設(shè)置?socket?讀取數(shù)據(jù)流的超時(shí)時(shí)間
??clientSocket.setSoTimeout(5000);
??//?發(fā)送數(shù)據(jù)包，默認(rèn)為?false，即客戶端發(fā)送數(shù)據(jù)采用?Nagle?算法；
??//?但是對(duì)于實(shí)時(shí)交互性高的程序，建議其改為?true，即關(guān)閉?Nagle?算法，客戶端每發(fā)送一次數(shù)據(jù)，無論數(shù)據(jù)包大小都會(huì)將這些數(shù)據(jù)發(fā)送出去
??clientSocket.setTcpNoDelay(true);
??//?設(shè)置客戶端?socket?關(guān)閉時(shí)，close()?方法起作用時(shí)延遲?30?秒關(guān)閉，如果?30?秒內(nèi)盡量將未發(fā)送的數(shù)據(jù)包發(fā)送出去
??clientSocket.setSoLinger(true,?30);
??//?設(shè)置輸出流的發(fā)送緩沖區(qū)大小，默認(rèn)是4KB，即4096字節(jié)
??clientSocket.setSendBufferSize(4096);
??//?設(shè)置輸入流的接收緩沖區(qū)大小，默認(rèn)是4KB，即4096字節(jié)
??clientSocket.setReceiveBufferSize(4096);
??//?作用：每隔一段時(shí)間檢查服務(wù)器是否處于活動(dòng)狀態(tài)，如果服務(wù)器端長(zhǎng)時(shí)間沒響應(yīng)，自動(dòng)關(guān)閉客戶端socket
??//?防止服務(wù)器端無效時(shí)，客戶端長(zhǎng)時(shí)間處于連接狀態(tài)
??clientSocket.setKeepAlive(true);
??//?客戶端向服務(wù)器端發(fā)送數(shù)據(jù)，獲取客戶端向服務(wù)器端輸出流
??OutputStream?osSend?=?clientSocket.getOutputStream();
??OutputStreamWriter?osWrite?=?new?OutputStreamWriter(osSend);
??BufferedWriter?bufWrite?=?new?BufferedWriter(osWrite);
??//?代表可以立即向服務(wù)器端發(fā)送單字節(jié)數(shù)據(jù)
??clientSocket.setOOBInline(true);
??//?數(shù)據(jù)不經(jīng)過輸出緩沖區(qū)，立即發(fā)送
??clientSocket.sendUrgentData(0x44);//"D"
??//?向服務(wù)器端寫數(shù)據(jù)，寫入一個(gè)緩沖區(qū)
??//?注：此處字符串最后必須包含“rnrn”，告訴服務(wù)器HTTP頭已經(jīng)結(jié)束，可以處理數(shù)據(jù)，否則會(huì)造成下面的讀取數(shù)據(jù)出現(xiàn)阻塞
??//?在write()?方法中可以定義規(guī)則，與后臺(tái)匹配來識(shí)別相應(yīng)的功能，例如登錄Login()?方法，可以寫為write("Login|LeoZheng,0603?rnrn"),供后臺(tái)識(shí)別;
??bufWrite.write("Login|LeoZheng,0603?rnrn");
??//?發(fā)送緩沖區(qū)中數(shù)據(jù)?-?前面說調(diào)用?flush()?無效，可能是調(diào)用的方法不對(duì)吧！
??bufWrite.flush();
}
catch?(UnknownHostException?e)?{
e.printStackTrace();
}?catch?(IOException?e)?{
e.printStackTrace();
}/*?*?*?*?*?*?*?*?*?*?Socket?客戶端讀取服務(wù)器端響應(yīng)數(shù)據(jù)?*?*?*?*?*?*?*?*?*?*/
try?{
??//?serverSocket.isConnected?代表是否連接成功過
??//?判斷?Socket?是否處于連接狀態(tài)
??if(true?==?serverSocket.isConnected()?&&?false?==?serverSocket.isClosed())?{
?? //?客戶端接收服務(wù)器端的響應(yīng)，讀取服務(wù)器端向客戶端的輸入流
?? InputStream?isRead?=?serverSocket.getInputStream();
?? //?緩沖區(qū)
?? byte[]?buffer?=?new?byte[isRead.available()];
?? //?讀取緩沖區(qū)
?? isRead.read(buffer);
?? //?轉(zhuǎn)換為字符串
?? String?responseInfo?=?new?String(buffer);
?? //?日志中輸出
?? Log.i("Socket?Server",?responseInfo);
??}
??//?關(guān)閉網(wǎng)絡(luò)
??serverSocket.close();
}
catch?(UnknownHostException?e)?{
e.printStackTrace();
}?catch?(IOException?e)?{
e.printStackTrace();
}/*?*?*?*?*?*?*?*?*?*?Socket?客戶端通過?connect?方法連接服務(wù)器?*?*?*?*?*?*?*?*?*?*/
try?{
??Socket?serverSocket?=?new?Socket();
??//?使用默認(rèn)的連接超時(shí)
??serverSocket.connect(new?InetSocketAddress("172.25.103.1",12589)); //?連接超時(shí)?3?秒:?serverSocket.connect(new?InetSocketAddress("172.25.103.1",12589),3000);
??
??//?關(guān)閉?socket
??serverSocket.close();
}
catch?(UnknownHostException?e)?{
e.printStackTrace();
}?catch?(IOException?e)?{
e.printStackTrace();
}
最后說明一點(diǎn): 無論 Socket 如何設(shè)置，接收方是一定要處理粘包的問題的。即在接收時(shí)，對(duì)接收到的數(shù)據(jù)進(jìn)行分析，看是否存在數(shù)據(jù)不全或粘包的現(xiàn)象。
下載文檔
