java中处理socket通信过程中粘包的情况

这两天学习了java中处理socket通信过程中粘包的情况，而且很重要，所以，今天添加一点小笔记。

处理粘包程序是客户端的接受消息线程：

客户端：

import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.io.OutputStreamWriter; 
import java.io.PrintWriter; 
import java.io.Reader; 
import java.net.Socket; 
import java.nio.CharBuffer; 
 
public class TestSocketClient { 
 
   
  public static void main(String[] args) { 
    // TODO Auto-generated method stub 
     
    new TestSocketClient().start(); 
  } 
  class SendThread extends Thread{ 
    private Socket socket; 
    public SendThread(Socket socket){ 
      this.socket=socket; 
    } 
    @Override 
    public void run(){ 
      while(true){ 
 try{ 
   Thread.sleep(1000);  
   String send=""+System.currentTimeMillis()+""; 
   PrintWriter pw=new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); 
   pw.write(send); 
   pw.flush(); 
 }catch(Exception e){ 
   e.printStackTrace(); 
 } 
      } 
    } 
  } 
  class ReceiveThread extends Thread{ 
    private Socket socket; 
    private volatile byte[] bytes=new byte[0]; 
    public ReceiveThread(Socket socket){ 
      this.socket=socket; 
    } 
    public byte[] mergebyte(byte[] a,byte[] b,int begin,int end){ 
      byte[] add=new byte[a.length+end-begin]; 
      int i=0; 
      for(i=0;i

服务端：

package com.meituan.service.bankgate.gateway; 
 
 
import java.io.*; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.nio.CharBuffer; 
import java.util.Date; 
 
public class TESTAHAHHA { 
 
  private final static String SOAP_BEGIN = "1024*16){ 
     break; 
   } 
 } 
      }catch(Exception e){ 
 e.printStackTrace(); 
      }finally{ 
 if(socket!=null){ 
   try{ 
     if(!socket.isClosed()){ 
socket.close(); 
     } 
   }catch(Exception e){ 
     e.printStackTrace(); 
   } 
 } 
      } 
    } 
  } 
 
} 



以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。