netty自定義解碼器

在socket傳輸通信中容易丟包問題，什么半包問題，這些都是很正常的問題，處理方法就是定義自己的編解碼規則了，讓每次接收按定義好的規則為一個完整包作為數據源即可。

 

下面個例子就是netty自定義的一個解碼器:

import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import java.util.List;
 
public class XmlDecoder extends ByteToMessageDecoder {
 
    String lastStr = "";
 
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        System.out.println("解碼器:");
        int len = in.readableBytes();
        if (len < 1) return;
        byte[] bytes = new byte[len];
        in.getBytes(0, bytes);
        String temp = new String(bytes);
      //這里為XML結束標簽，自行替換
        int index = temp.indexOf("</body>");
        if (index == -1) {
            lastStr += temp;
        } else {
            lastStr += temp.substring(0, index+14 );
            ByteBuf buffer = ByteBufAllocator.DEFAULT.buffer();
            buffer.writeBytes(lastStr.getBytes());
            out.add(buffer);
            lastStr = "";
        }
        in.skipBytes(len);
    }
    
}