先說(shuō)明一下粘包的概念: 發(fā)送時(shí)是兩個(gè)單獨(dú)的包、兩次發(fā)送，但接收時(shí)兩個(gè)包連在一起被一次接收到。

在以前 WinCE 下 Socket 編程，確實(shí)也要處理粘包的問(wèn)題，沒(méi)想到在 Android 下也遇到了。
首先想從發(fā)送端能否避免這樣的問(wèn)題，例如: (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ù)和變量的說(shuō)明：

/**
?*?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ù)器/客戶端的通訊，剛開(kāi)始我也是這樣做的。所以，遇到了上面的問(wèn)題。

//?發(fā)送數(shù)據(jù)包，默認(rèn)為?false，即客戶端發(fā)送數(shù)據(jù)采用?Nagle?算法；
//?但是對(duì)于實(shí)時(shí)交互性高的程序，建議其改為?true，即關(guān)閉?Nagle?算法，客戶端每發(fā)送一次數(shù)據(jù)，無(wú)論數(shù)據(jù)包大小都會(huì)將這些數(shù)據(jù)發(fā)送出去
clientSocket.setTcpNoDelay(true);

看以下較完整的 Socket 初始化與設(shè)置過(guò)程:

/*?*?*?*?*?*?*?*?*?*?客戶端?Socket?通過(guò)構(gòu)造方法連接服務(wù)器?*?*?*?*?*?*?*?*?*?*/
try?{
??//?客戶端?Socket?可以通過(guò)指定?IP?地址或域名兩種方式來(lái)連接服務(wù)器端,實(shí)際最終都是通過(guò)?IP?地址來(lái)連接服務(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ù)，無(wú)論數(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í)間沒(méi)響應(yīng)，自動(dòng)關(guān)閉客戶端socket
??//?防止服務(wù)器端無(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)過(guò)輸出緩沖區(qū)，立即發(fā)送
??clientSocket.sendUrgentData(0x44);//"D"
??//?向服務(wù)器端寫(xiě)數(shù)據(jù)，寫(xiě)入一個(gè)緩沖區(qū)
??//?注：此處字符串最后必須包含“rnrn”，告訴服務(wù)器HTTP頭已經(jīng)結(jié)束，可以處理數(shù)據(jù)，否則會(huì)造成下面的讀取數(shù)據(jù)出現(xiàn)阻塞
??//?在write()?方法中可以定義規(guī)則，與后臺(tái)匹配來(lái)識(shí)別相應(yīng)的功能，例如登錄Login()?方法，可以寫(xiě)為write("Login|LeoZheng,0603?rnrn"),供后臺(tái)識(shí)別;
??bufWrite.write("Login|LeoZheng,0603?rnrn");
??//?發(fā)送緩沖區(qū)中數(shù)據(jù)?-?前面說(shuō)調(diào)用?flush()?無(wú)效，可能是調(diào)用的方法不對(duì)吧！
??bufWrite.flush();
}
catch?(UnknownHostException?e)?{
	e.printStackTrace();
}?catch?(IOException?e)?{
	e.printStackTrace();
}

/*?*?*?*?*?*?*?*?*?*?Socket?客戶端讀取服務(wù)器端響應(yīng)數(shù)據(jù)?*?*?*?*?*?*?*?*?*?*/
try?{
??//?serverSocket.isConnected?代表是否連接成功過(guò)
??//?判斷?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?客戶端通過(guò)?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();
}

最后說(shuō)明一點(diǎn): 無(wú)論 Socket 如何設(shè)置，接收方是一定要處理粘包的問(wèn)題的。即在接收時(shí)，對(duì)接收到的數(shù)據(jù)進(jìn)行分析，看是否存在數(shù)據(jù)不全或粘包的現(xiàn)象。