Android Socket 發送與接收數據問題: 發送后的數據接收到總是粘包

先說明一下粘包的概念: 發送時是兩個單獨的包、兩次發送，但接收時兩個包連在一起被一次接收到。
在以前 WinCE 下 Socket 編程，確實也要處理粘包的問題，沒想到在 Android 下也遇到了。
首先想從發送端能否避免這樣的問題，例如: (1) 調用強制刷數據完成發送的函數；(2) 設置發送超時。
1 先試了調用 flush() 函數，但運行后現象依舊
2 設置發送超時是 Windows 平台的做法，但在 Android 平台下是否有類似的設置呢？
查看 Socket 類的實現代碼：java.net.socket socket.class 文件后發現，還是有函數可以完成這樣的設置的。請看如下函數和變量的說明：

/** 
 * 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);  

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

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

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

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

/* * * * * * * * * * Socket 客戶端讀取服務器端響應數據 * * * * * * * * * */  
try {  
  // serverSocket.isConnected 代表是否連接成功過  
  // 判斷 Socket 是否處於連接狀態  
  if(true == serverSocket.isConnected() && false == serverSocket.isClosed()) {  
    // 客戶端接收服務器端的響應，讀取服務器端向客戶端的輸入流  
    InputStream isRead = serverSocket.getInputStream();  
    // 緩沖區  
    byte[] buffer = new byte[isRead.available()];  
    // 讀取緩沖區  
    isRead.read(buffer);  
    // 轉換為字符串  
    String responseInfo = new String(buffer);  
    // 日志中輸出  
    Log.i("Socket Server", responseInfo);  
  }  
  // 關閉網絡  
  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 如何設置，接收方是一定要處理粘包的問題的。即在接收時，對接收到的數據進行分析，看是否存在數據不全或粘包的現象。