当前位置： 首页 > news >正文

好的做网站公司wordpress福利整站源码

news 2025/10/28 15:19:48
好的做网站公司,wordpress福利整站源码,南京创网网络技术有限公司,基础型网站什么是粘包和拆包？在网络编程中，粘包和拆包是两个常见的问题：粘包（TCP粘包）：多个小数据包被合并成一个大数据包发送拆包（TCP拆包）：一个大数据包被分割成多个小数据包发送…

什么是粘包和拆包？

在网络编程中，粘包和拆包是两个常见的问题：

  • 粘包（TCP粘包）：多个小数据包被合并成一个大数据包发送
  • 拆包（TCP拆包）：一个大数据包被分割成多个小数据包发送

为什么会出现粘包和拆包？

1. TCP协议特性

TCP是面向流的协议，数据以字节流的形式传输，没有明确的消息边界。TCP会根据网络状况自动调整发送策略：

// 示例：发送方连续发送多个消息
socket.getOutputStream().write("Hello".getBytes());
socket.getOutputStream().write("World".getBytes());
socket.getOutputStream().write("Netty".getBytes());

接收方可能收到：

  • "HelloWorldNetty" (粘包)
  • "Hello" + "WorldNetty" (部分粘包)
  • "He" + "lloWorld" + "Netty" (拆包)
2. 缓冲区机制

TCP有发送缓冲区和接收缓冲区，数据在缓冲区中可能被合并或分割：

// 发送缓冲区示例
ByteBuffer sendBuffer = ByteBuffer.allocate(1024);
sendBuffer.put("Hello".getBytes());
sendBuffer.put("World".getBytes());
// 缓冲区满了才发送，导致粘包
3. Nagle算法

TCP的Nagle算法会将多个小包合并成一个大包发送，减少网络开销

Netty解决方案

1. 固定长度方案
public class FixedLengthFrameDecoder extends ByteToMessageDecoder {private final int frameLength;public FixedLengthFrameDecoder(int frameLength) {this.frameLength = frameLength;}@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {// 检查是否有足够的数据while (in.readableBytes() >= frameLength) {// 读取固定长度的数据ByteBuf frame = in.readBytes(frameLength);out.add(frame);}}
}// 使用示例
pipeline.addLast(new FixedLengthFrameDecoder(10));

优点：实现简单，性能好

缺点：不够灵活，可能造成数据浪费

2. 分隔符方案
public class DelimiterBasedFrameDecoder extends ByteToMessageDecoder {private final ByteBuf delimiter;public DelimiterBasedFrameDecoder(ByteBuf delimiter) {this.delimiter = delimiter;}@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {// 查找分隔符位置int delimiterIndex = indexOf(in, delimiter);if (delimiterIndex >= 0) {// 读取到分隔符的数据ByteBuf frame = in.readBytes(delimiterIndex);// 跳过分隔符in.skipBytes(delimiter.capacity());out.add(frame);}}private int indexOf(ByteBuf haystack, ByteBuf needle) {// 实现查找分隔符的逻辑for (int i = haystack.readerIndex(); i < haystack.writerIndex() - needle.capacity() + 1; i++) {boolean found = true;for (int j = 0; j < needle.capacity(); j++) {if (haystack.getByte(i + j) != needle.getByte(j)) {found = false;break;}}if (found) {return i - haystack.readerIndex();}}return -1;}
}// 使用示例
ByteBuf delimiter = Unpooled.copiedBuffer("\n".getBytes());
pipeline.addLast(new DelimiterBasedFrameDecoder(delimiter));
3. 长度字段方案（推荐）
public class LengthFieldBasedFrameDecoder extends ByteToMessageDecoder {private final int maxFrameLength;private final int lengthFieldOffset;private final int lengthFieldLength;private final int lengthAdjustment;private final int initialBytesToStrip;public LengthFieldBasedFrameDecoder(int maxFrameLength,int lengthFieldOffset,int lengthFieldLength,int lengthAdjustment,int initialBytesToStrip) {this.maxFrameLength = maxFrameLength;this.lengthFieldOffset = lengthFieldOffset;this.lengthFieldLength = lengthFieldLength;this.lengthAdjustment = lengthAdjustment;this.initialBytesToStrip = initialBytesToStrip;}@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {// 检查是否有足够的数据读取长度字段if (in.readableBytes() < lengthFieldOffset + lengthFieldLength) {return;}// 标记当前读取位置int actualLengthFieldOffset = in.readerIndex() + lengthFieldOffset;// 读取长度字段long frameLength = getUnadjustedFrameLength(in, actualLengthFieldOffset, lengthFieldLength);// 计算实际帧长度frameLength += lengthAdjustment + lengthFieldOffset + lengthFieldLength;// 检查帧长度是否合理if (frameLength < 0) {in.skipBytes(lengthFieldLength);throw new CorruptedFrameException("negative pre-adjustment length field: " + frameLength);}if (frameLength > maxFrameLength) {in.skipBytes(lengthFieldLength);throw new TooLongFrameException("Adjusted frame length (" + frameLength + ") is greater than maxFrameLength (" + maxFrameLength + ")");}// 检查是否有完整的帧if (in.readableBytes() < frameLength) {return;}// 跳过指定的字节数in.skipBytes(initialBytesToStrip);// 读取帧数据int readerIndex = in.readerIndex();int actualFrameLength = (int) frameLength - initialBytesToStrip;ByteBuf frame = in.retainedSlice(readerIndex, actualFrameLength);in.skipBytes(actualFrameLength);out.add(frame);}protected long getUnadjustedFrameLength(ByteBuf buf, int offset, int length) {long frameLength;switch (length) {case 1:frameLength = buf.getUnsignedByte(offset);break;case 2:frameLength = buf.getUnsignedShort(offset);break;case 3:frameLength = buf.getUnsignedMedium(offset);break;case 4:frameLength = buf.getUnsignedInt(offset);break;case 8:frameLength = buf.getLong(offset);break;default:throw new DecoderException("unsupported lengthFieldLength: " + length + " (expected: 1, 2, 3, 4, or 8)");}return frameLength;}
}

Netty内置的解决方案

1. FixedLengthFrameDecoder
// 固定长度解码器
public class FixedLengthServer {public static void main(String[] args) throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();// 固定长度解码器，每个消息10字节pipeline.addLast(new FixedLengthFrameDecoder(10));pipeline.addLast(new StringDecoder());pipeline.addLast(new FixedLengthHandler());}});ChannelFuture future = bootstrap.bind(8080).sync();System.out.println("固定长度服务器启动成功");future.channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}class FixedLengthHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {String message = (String) msg;System.out.println("收到消息: [" + message + "]");ctx.writeAndFlush("收到: " + message + "\n");}
}
2. DelimiterBasedFrameDecoder
// 分隔符解码器
public class DelimiterServer {public static void main(String[] args) throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();// 使用换行符作为分隔符ByteBuf delimiter = Unpooled.copiedBuffer("\n".getBytes());pipeline.addLast(new DelimiterBasedFrameDecoder(1024, delimiter));pipeline.addLast(new StringDecoder());pipeline.addLast(new DelimiterHandler());}});ChannelFuture future = bootstrap.bind(8081).sync();System.out.println("分隔符服务器启动成功");future.channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}class DelimiterHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {String message = (String) msg;System.out.println("收到消息: [" + message + "]");ctx.writeAndFlush("收到: " + message + "\n");}
}
3. LengthFieldBasedFrameDecoder（最常用）
// 长度字段解码器
public class LengthFieldServer {public static void main(String[] args) throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();// 长度字段解码器配置// maxFrameLength: 最大帧长度// lengthFieldOffset: 长度字段偏移量// lengthFieldLength: 长度字段长度// lengthAdjustment: 长度调整值// initialBytesToStrip: 跳过的字节数pipeline.addLast(new LengthFieldBasedFrameDecoder(65535, 0, 4, 0, 4));pipeline.addLast(new StringDecoder());pipeline.addLast(new LengthFieldHandler());}});ChannelFuture future = bootstrap.bind(8082).sync();System.out.println("长度字段服务器启动成功");future.channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}class LengthFieldHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {String message = (String) msg;System.out.println("收到消息: [" + message + "]");ctx.writeAndFlush("收到: " + message + "\n");}
}

最后

Netty提供了多种TCP粘包、拆包问题的解决方案：

  1. FixedLengthFrameDecoder：适合固定长度消息
  2. DelimiterBasedFrameDecoder：适合文本协议
  3. LengthFieldBasedFrameDecoder：最灵活，适合二进制协议
  4. 自定义编解码器：完全控制协议格式

在实际项目中，建议优先使用Netty内置的解码器，只有在特殊需求时才考虑自定义实现。

http://www.dtcms.com/a/538071.html

相关文章：

  • 四川广汉市规划和建设局网站国家查企业的网站
  • 外贸云网站建设优秀高端网站建设报价
  • 模板网站的域名是什么意思全屋定制十大名牌价格
  • 企业网站建设问题研究网站 子域名
  • 建设通网站是免费的吗深圳外网站建设
  • ai绘画sd零基础第二弹——提示词基础
  • 公司做网站需要准备什么材料生物技术网站开发
  • 门户网站与官网的区别天津网络推广seo
  • wordpress添加会员标识seo诊断报告
  • 怎么退出建设银行网站广州企业网站建设电话
  • 设计有哪些网站互联网营销专业
  • 云南集优科技网站巴州住房和城乡建设局网站
  • 成都建设网站那个好seo关键词挖掘工具
  • 沈阳网站建设工作室自己做网站用什么app
  • 合作网站seo网页设计图片简单
  • 品牌高端网站制作具有设计感的网站
  • 【Linux】grep命令
  • 深入浅出Faster R-CNN：目标检测的里程碑算法
  • 浪琴手表网站建设图安徽平台网站建设制作
  • C++小协程栈和临时变量及作用域的栈溢出问题分析
  • Nacos配置中心动态刷新全解析：配置中心核心概念与架构
  • RL-100：基于现实世界强化学习的高性能机器人操作
  • ubuntu22.04配置MID360激光雷达
  • 免费制作软件app的网站胶州网站建设 网络推广
  • vs2017网站开发建设一个门户网站价格
  • 泰和县网站免费建站家具定制东莞网站建设
  • 构建时变量注入：Vite 环境下 SCSS 与 JavaScript 的变量同步机制
  • 前端性能优化全流程指南：策略、工具与实践案例
  • 玉林市建设工程交易中心网站金泉网做网站推广
  • 青海省住房城乡建设厅网站首页企业建站免费模板