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

自己的网站怎么和百度做友链网站开发哪里

wzjs 2025/9/18 21:22:39
自己的网站怎么和百度做友链,网站开发哪里,企业官网开发排行榜,网站前端设计是什么什么是粘包和拆包？在网络编程中，粘包和拆包是两个常见的问题：粘包（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/wzjs/784025.html

相关文章：

  • 做网站红色和什么搭配好网站开发行业
  • 网站入口你明白我的意思吧wordpress生活类主题
  • 设计软件免费下载网站编辑wordpress模板下载
  • 东莞海天网站建设深圳外贸建站及推广
  • 做徽标哪个网站素材多网站页面确认书
  • 网站建设任务书企业开源建站系统
  • 电子商务网站策划书3000字网站开发图片编辑
  • 菏泽市住房和城乡建设局网站wordpress页面归档
  • 中煤矿山建设集团网站谁会建设网站
  • 无锡网站制作计划wordpress加密修改密码
  • 南阳seo网站排名关键词那种网站
  • 大理建设招标有限公司网站网站图片优化器
  • 网页设计与网站建设考试题目wordpress定时发布
  • 无需下载直接进入的网站的代码wordpress怎么进主页
  • 网站建设方案详解如何做品牌网站
  • 用frontpage做网站重庆市企业网站建设
  • 建设部安全员证书查询网站创建网站的详细步骤
  • 网站建设的整体设计流程在家自己做网站
  • 学做投资网站好重庆好的seo平台
  • 网站建设与管理就业方向提交网站给百度
  • 中铁建设集团集采网站wordpress本地配置文件
  • asp.net mvc 5网站开发之美 pdf网络营销的公司有哪些
  • 安徽响应式网站推荐wordpress页脚版权
  • 网站做动态和静态哪个贵群晖wordpress 站点
  • 凤阳网站建设哪家好简单官网模板
  • 湖北省城乡与住房建设厅网站营销型网站建设运营
  • 企业网站建设报价北京微信网站开发
  • 企业如何做网站建站网络营销的方式和方法
  • flash网站收录网站建设便捷
  • 企业网站建设报价模板专做美容师招聘网站