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

在以前 WinCE 下 Socket 編程，確實也要處理粘包的問題，沒想到在 Android 下也遇到了。
首先想從發(fā)送端能否避免這樣的問題，例如: (1) 調用強制刷數(shù)據(jù)完成發(fā)送的函數(shù)；(2) 設置發(fā)送超時。
1 先試了調用 flush() 函數(shù)，但運行后現(xiàn)象依舊
2 設置發(fā)送超時是 Windows 平臺的做法，但在 Android 平臺下是否有類似的設置呢？
查看 Socket 類的實現(xiàn)代碼：java.net.socket socket.class 文件后發(fā)現(xiàn)，還是有函數(shù)可以完成這樣的設置的。請看如下函數(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;

一般情況下，只需要調用如下的代碼即可：

public?Socket?clientSocket?=?null;
//?實例化對象并連接到服務器
clientSocket?=?new?Socket("172.25.103.1",12589);

不用做任何設置就可以完成與服務器/客戶端的通訊，剛開始我也是這樣做的。所以，遇到了上面的問題。

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

看以下較完整的 Socket 初始化與設置過程:

/*?*?*?*?*?*?*?*?*?*?客戶端?Socket?通過構造方法連接服務器?*?*?*?*?*?*?*?*?*?*/
try?{
??//?客戶端?Socket?可以通過指定?IP?地址或域名兩種方式來連接服務器端,實際最終都是通過?IP?地址來連接服務器
??//?新建一個Socket，指定其IP地址及端口號
??Socket?clientSocket?=?new?Socket("172.25.103.1",12589);
??//?客戶端socket在接收數(shù)據(jù)時，有兩種超時：1.?連接服務器超時，即連接超時；2.?連接服務器成功后，接收服務器數(shù)據(jù)超時，即接收超時
??//?設置?socket?讀取數(shù)據(jù)流的超時時間
??clientSocket.setSoTimeout(5000);
??//?發(fā)送數(shù)據(jù)包，默認為?false，即客戶端發(fā)送數(shù)據(jù)采用?Nagle?算法；
??//?但是對于實時交互性高的程序，建議其改為?true，即關閉?Nagle?算法，客戶端每發(fā)送一次數(shù)據(jù)，無論數(shù)據(jù)包大小都會將這些數(shù)據(jù)發(fā)送出去
??clientSocket.setTcpNoDelay(true);
??//?設置客戶端?socket?關閉時，close()?方法起作用時延遲?30?秒關閉，如果?30?秒內盡量將未發(fā)送的數(shù)據(jù)包發(fā)送出去
??clientSocket.setSoLinger(true,?30);
??//?設置輸出流的發(fā)送緩沖區(qū)大小，默認是4KB，即4096字節(jié)
??clientSocket.setSendBufferSize(4096);
??//?設置輸入流的接收緩沖區(qū)大小，默認是4KB，即4096字節(jié)
??clientSocket.setReceiveBufferSize(4096);
??//?作用：每隔一段時間檢查服務器是否處于活動狀態(tài)，如果服務器端長時間沒響應，自動關閉客戶端socket
??//?防止服務器端無效時，客戶端長時間處于連接狀態(tài)
??clientSocket.setKeepAlive(true);
??//?客戶端向服務器端發(fā)送數(shù)據(jù)，獲取客戶端向服務器端輸出流
??OutputStream?osSend?=?clientSocket.getOutputStream();
??OutputStreamWriter?osWrite?=?new?OutputStreamWriter(osSend);
??BufferedWriter?bufWrite?=?new?BufferedWriter(osWrite);
??//?代表可以立即向服務器端發(fā)送單字節(jié)數(shù)據(jù)
??clientSocket.setOOBInline(true);
??//?數(shù)據(jù)不經(jīng)過輸出緩沖區(qū)，立即發(fā)送
??clientSocket.sendUrgentData(0x44);//"D"
??//?向服務器端寫數(shù)據(jù)，寫入一個緩沖區(qū)
??//?注：此處字符串最后必須包含“rnrn”，告訴服務器HTTP頭已經(jīng)結束，可以處理數(shù)據(jù)，否則會造成下面的讀取數(shù)據(jù)出現(xiàn)阻塞
??//?在write()?方法中可以定義規(guī)則，與后臺匹配來識別相應的功能，例如登錄Login()?方法，可以寫為write("Login|LeoZheng,0603?rnrn"),供后臺識別;
??bufWrite.write("Login|LeoZheng,0603?rnrn");
??//?發(fā)送緩沖區(qū)中數(shù)據(jù)?-?前面說調用?flush()?無效，可能是調用的方法不對吧！
??bufWrite.flush();
}
catch?(UnknownHostException?e)?{
	e.printStackTrace();
}?catch?(IOException?e)?{
	e.printStackTrace();
}

/*?*?*?*?*?*?*?*?*?*?Socket?客戶端讀取服務器端響應數(shù)據(jù)?*?*?*?*?*?*?*?*?*?*/
try?{
??//?serverSocket.isConnected?代表是否連接成功過
??//?判斷?Socket?是否處于連接狀態(tài)
??if(true?==?serverSocket.isConnected()?&&?false?==?serverSocket.isClosed())?{
??	//?客戶端接收服務器端的響應，讀取服務器端向客戶端的輸入流
??	InputStream?isRead?=?serverSocket.getInputStream();
??	//?緩沖區(qū)
??	byte[]?buffer?=?new?byte[isRead.available()];
??	//?讀取緩沖區(qū)
??	isRead.read(buffer);
??	//?轉換為字符串
??	String?responseInfo?=?new?String(buffer);
??	//?日志中輸出
??	Log.i("Socket?Server",?responseInfo);
??}
??//?關閉網(wǎng)絡
??serverSocket.close();
}
catch?(UnknownHostException?e)?{
	e.printStackTrace();
}?catch?(IOException?e)?{
	e.printStackTrace();
}

/*?*?*?*?*?*?*?*?*?*?Socket?客戶端通過?connect?方法連接服務器?*?*?*?*?*?*?*?*?*?*/
try?{
??Socket?serverSocket?=?new?Socket();
??//?使用默認的連接超時
??serverSocket.connect(new?InetSocketAddress("172.25.103.1",12589));		//?連接超時?3?秒:?serverSocket.connect(new?InetSocketAddress("172.25.103.1",12589),3000);
??
??//?關閉?socket
??serverSocket.close();
}
catch?(UnknownHostException?e)?{
	e.printStackTrace();
}?catch?(IOException?e)?{
	e.printStackTrace();
}

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