package org.springblade.jfpt.nettyTcpServer;
|
|
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.handler.codec.ByteToMessageDecoder;
|
import java.util.List;
|
|
/**
|
* 自定义解码器
|
*
|
*/
|
public class MyNettyDecode extends ByteToMessageDecoder {
|
public final int BASE_LENGTH = 4 + 4 ;
|
|
// @Override
|
// protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
|
// System.out.println("byteBuf = " + byteBuf.readableBytes());
|
// // 可读长度必须大于基本长度
|
// if (byteBuf.readableBytes() >= BASE_LENGTH) {
|
// // 防止socket字节流攻击
|
// // 防止，客户端传来的数据过大
|
// // 因为，太大的数据，是不合理的
|
// if (byteBuf.readableBytes() > 202048) {
|
// byteBuf.skipBytes(byteBuf.readableBytes());
|
// }
|
//
|
// // 记录包头开始的index
|
// int beginReader;
|
//
|
// while (true) {
|
// // 获取包头开始的index
|
// beginReader = byteBuf.readerIndex();
|
// // 标记包头开始的index
|
// byteBuf.markReaderIndex();
|
// // 读到了协议的开始标志，结束while循环
|
// if (byteBuf.readInt() == NettyConstant.HEAD_DATA) {
|
// break;
|
// }
|
//
|
// // 未读到包头，略过一个字节
|
// // 每次略过，一个字节，去读取，包头信息的开始标记
|
// byteBuf.resetReaderIndex();
|
// byteBuf.readByte();
|
//
|
// // 当略过，一个字节之后，
|
// // 数据包的长度，又变得不满足
|
// // 此时，应该结束。等待后面的数据到达
|
// if (byteBuf.readableBytes() < BASE_LENGTH) {
|
// return;
|
// }
|
// }
|
//
|
// // 消息的长度
|
//
|
// int length = byteBuf.readInt();
|
// // 判断请求数据包数据是否到齐
|
// if (byteBuf.readableBytes() < length) {
|
// // 还原读指针
|
// byteBuf.readerIndex(beginReader);
|
// return;
|
// }
|
//
|
// // 读取data数据
|
// byte[] data = new byte[length];
|
// byteBuf.readBytes(data);
|
// System.out.println("byteBuf末尾 = " + byteBuf);
|
//
|
// NettyProPool protocol = new NettyProPool(data.length, data);
|
// list.add(protocol);
|
// System.out.println("list = " + list);
|
// }
|
// }
|
|
static final int PACKET_SIZE = 110088;
|
|
// 用来临时保留没有处理过的请求报文
|
ByteBuf tempMsg = Unpooled.buffer();
|
|
/**
|
* @param ctx
|
* @param in 请求的数据
|
* @param out 将粘在一起的报文拆分后的结果保留起来
|
* @throws Exception
|
*/
|
@Override
|
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
|
System.out.println(Thread.currentThread() + "收到了一次数据包，长度是：" + in.readableBytes());
|
|
// 合并报文
|
ByteBuf message = null;
|
int tmpMsgSize = tempMsg.readableBytes();
|
System.out.println("tmpMsgSize = " + tmpMsgSize);
|
// 如果暂存有上一次余下的请求报文，则合并
|
if (tmpMsgSize > 0) {
|
message = Unpooled.buffer();
|
message.writeBytes(tempMsg);
|
message.writeBytes(in);
|
System.out.println("合并：上一数据包余下的长度为：" + tmpMsgSize + ",合并后长度为:" + message.readableBytes());
|
} else {
|
message = in;
|
}
|
|
int size = message.readableBytes();
|
int counter = size / PACKET_SIZE;
|
for (int i = 0; i < counter; i++) {
|
byte[] request = new byte[PACKET_SIZE];
|
// 每次从总的消息中读取220个字节的数据
|
message.readBytes(request);
|
|
// 将拆分后的结果放入out列表中，交由后面的业务逻辑去处理
|
out.add(Unpooled.copiedBuffer(request));
|
}
|
|
// 多余的报文存起来
|
// 第一个报文： i+ 暂存
|
// 第二个报文： 1 与第一次
|
size = message.readableBytes();
|
if (size != 0) {
|
System.out.println("多余的数据长度：" + size);
|
// 剩下来的数据放到tempMsg暂存
|
tempMsg.clear();
|
tempMsg.writeBytes(message.readBytes(size));
|
}
|
}
|
}
|
