netty解码器LengthFieldBasedFrameDecoder用法详解

Netty

Netty是一个高性能、异步事件驱动的网络应用程序框架,它提供了对并发和异步编程的抽象,使得开发网络应用程序变得更加简单和高效。
在Netty中,EventLoopGroup是处理I/O操作的多线程事件循环器。在上面的示例中,我们创建了两个EventLoopGroup实例:bossGroup和workerGroup。bossGroup负责接收客户端的连接请求,并将这些连接分配给workerGroup中的工作线程进行处理。每个工作线程都是一个独立的EventLoop,它负责处理分配给它的连接上的所有I/O事件。
由于Netty的EventLoop是非阻塞的,并且每个EventLoop都可以同时处理多个连接,因此Netty服务器能够高效地处理大量的并发连接。此外,Netty还提供了多种优化技术,如零拷贝、内存池等,以进一步提高性能。
基于Netty的TCP服务器是支持并发的,并且能够处理大量的并发连接。可以根据需要调整EventLoopGroup的线程数、优化处理器逻辑等,以满足应用程序的特定需求。

LengthFieldBasedFrameDecoder用法详解

以LengthFieldBasedFrameDecoder(1024, 0, 2, 0, 2)为例。

LengthFieldBasedFrameDecoder语法
LengthFieldBasedFrameDecoder(int maxFrameLength, int lengthFieldOffset, int lengthFieldLength, int lengthAdjustment, int initialBytesToStrip)
maxFrameLength

该参数表示允许的最大帧长度,在这里设置为 1024 字节。如果接收到的帧长度超过这个值,Netty 会抛出 TooLongFrameException 异常,以防止内存溢出或恶意攻击。

lengthFieldOffset

表示长度字段的偏移量,这里是 0。它指定了长度字段开始的位置,从帧的起始位置开始计算。例如,如果你的帧结构是 [长度字段][数据],长度字段就在帧的开头,那么偏移量就是 0。

lengthFieldLength

表示长度字段的长度,这里是 2 字节。这意味着长度字段占用 2 个字节。例如,如果长度字段的值是 0x000A(十六进制),则表示后续的数据长度是 10 字节。

lengthAdjustment

表示长度调整值,这里是 0。它用于在计算帧长度时对长度字段进行调整。例如,如果长度字段表示的是长度字段之后的数据长度,那么长度调整值为 0。但如果长度字段包含了长度字段本身,那么长度调整值可能为负数,以排除长度字段的长度。

initialBytesToStrip

表示从解码帧中要跳过的初始字节数,这里是 2。它指定了在解码后从帧的起始位置跳过的字节数。如果该值为 2,那么长度字段将被跳过,解码后的帧将不包含长度字段。

举例说明
协议数据格式
字段长度说明
cmdLen2json长度(高位优先)
cmdPayloadnjson内容
dataLen2数据长度(高位优先)
dataPayloadn文件二进制数据内容

假设有以下两种不同的帧结构:

示例一

帧结构:[长度字段 (2 字节)][数据]
例如,一个完整的帧可能是 0x000A 48656C6C6F(十六进制)。
解释:
0x000A 是长度字段,表示后续的数据长度为 10 字节(十六进制的 0x000A 等于十进制的 10)。
48656C6C6F 是数据部分,它是 Hello 的 ASCII 码表示。
在这种情况下,LengthFieldBasedFrameDecoder(1024, 0, 2, 0, 2) 的工作流程如下:
当接收到 0x000A 48656C6C6F 时:
首先,根据 lengthFieldOffset = 0 和 lengthFieldLength = 2,读取前 2 个字节 0x000A 作为长度字段。
然后,根据 lengthAdjustment = 0,不进行长度调整。
最后,根据 initialBytesToStrip = 2,将长度字段 0x000A 从解码结果中去掉,将 48656C6C6F 作为最终解码的数据。

示例二

帧结构:[数据][长度字段 (2 字节)]
例如,一个完整的帧可能是 48656C6C6F 0x000A(十六进制)。
解释:
48656C6C6F 是数据部分,它是 Hello 的 ASCII 码表示。
0x000A 是长度字段,表示数据部分的长度为 10 字节。
在这种情况下,LengthFieldBasedFrameDecoder(1024, 4, 2, -2, 0) 可能更合适:
当接收到 48656C6C6F 0x000A 时:
lengthFieldOffset = 4 表示长度字段从第 4 个字节开始。
lengthFieldLength = 2 表示长度字段长度为 2 字节。
lengthAdjustment = -2 表示长度字段包含自身,需要从长度中减去长度字段的长度,因为长度字段在数据之后。
initialBytesToStrip = 0 表示不跳过任何字节,最终解码结果将包含长度字段。

代码示例

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/66438.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

继承(5)

大家好,今天我们继续来学习继承的相关知识,来看看子类构造方法(也叫做构造器)是如何做的。 1.6 子类构造方法 父子父子,先有父再有子,即:子类对象构选时,需要先调用基类构造方法,然后执行子类的构造方法 ★此时虽然执行了父类的…

VulnHub-Acid(1/100)

参考链接: ​​​​​​​【VulnHub】Acid靶场复盘-CSDN博客 靶场渗透(二)——Acid渗透_ambassador 靶场渗透-CSDN博客 网络安全从0到0.5之Acid靶机实战渗透测试 | CN-SEC 中文网 Vulnhub靶场渗透练习(四) Acid - 紅人 - 博客园 红日团队…

51c自动驾驶~合集45

我自己的原文哦~ https://blog.51cto.com/whaosoft/13020031 #运动控制和规划控制需要掌握的技术栈~ 各大垃圾家电造车厂又要开始了~~~​ 1、ROS的通信方式 李是Lyapunov的李:谈谈ROS的通信机制 话题通信和服务通信,其中话题通信是通过发布和订阅…

【Unity3D】AB包加密(AssetBundle加密)

加密前: 加密后,直接无法加载ab,所以无法正常看到ab内容。 using UnityEngine; using UnityEditor; using System.IO; public static class AssetBundleDemoTest {[MenuItem("Tools/打包!")]public static void Build(){//注意:St…

平面坐标转大地坐标(arcgisPro中进行)

1、将需要转换的红线导入arcgisPro中,如下: 2、在地图菜单栏中,选择坐标转换工具,如下: 3、打开坐标转换工具 4、开启捕捉 5、 设置大地坐标显示格式 6、如下: 7、显示如图: 8、再依次添加几个待…

Python 在PDF中添加数字签名

在数字化时代,文件的安全性和可信度变得尤为重要。无论是商业文件、法律文件还是个人文件,都可能需要证明其来源的真实性和完整性。PDF数字签名就是解决这些问题的关键工具。PDF数字签名不仅能够确保文件的安全性,还能提高工作效率&#xff0…

Mysql--基础篇--函数(字符串函数,日期函数,数值函数,聚合函数,自定义函数及与存储过程的区别等)

MySQL提供了丰富的内置函数,涵盖了字符串处理、数值计算、日期和时间操作、聚合统计、控制流等多种功能。这些函数可以帮助你简化SQL查询,提升开发效率。 除了内置函数,MySQL还支持自定义函数(User-Defined Functions)…

STM32学习(十)

I2C模块内部结构 I2C(Inter-Integrated Circuit)模块是一种由Philips公司开发的二线式串行总线协议,用于短距离通信,允许多个设备共享相同的总线‌。 ‌硬件连接简单‌:I2C通信仅需要两条总线,即SCL&…

尚硅谷· vue3+ts 知识点学习整理 |14h的课程(持续更ing)

vue3 主要内容 核心:ref、reactive、computed、watch、生命周期 常用:hooks、自定义ref、路由、pinia、miit 面试:组件通信、响应式相关api ----> 笔记:ts快速梳理;vue3快速上手.pdf 笔记及大纲 如下&#xff…

【Ubuntu20.04】Apollo10.0 Docker容器部署+常见错误解决

官方参考文档【点击我】 Apollo 10.0 版本开始,支持本机和Docker容器两种部署方式。 如果您使用本机部署方式,建议使用x86_64架构的Ubuntu 22.04操作系统或者aarch64架构的Ubuntu 20.04操作系统。 如果您使用Docker容器部署方式,可以使用x…

安卓14无法安装应用解决历程

客户手机基本情况: 安卓14,对应的 targetSdkVersion 34 前天遇到了安卓14适配问题,客户发来的截图是这样的 描述:无法安装我们公司的B应用。 型号:三星google美版 解决步骤: 1、寻找其他安卓14手机测试…

利用 NineData 实现 PostgreSQL 到 Kafka 的高效数据同步

记录一次 PostgreSQL 到 Kafka 的数据迁移实践。前段时间,NineData 的某个客户在一个项目中需要将 PostgreSQL 的数据实时同步到 Kafka。需求明确且普遍: PostgreSQL 中的交易数据,需要实时推送到 Kafka,供下游多个系统消费&#…

Zookeeper是如何保证事务的顺序一致性的?

大家好,我是锋哥。今天分享关于【Zookeeper是如何保证事务的顺序一致性的?】面试题。希望对大家有帮助; Zookeeper是如何保证事务的顺序一致性的? 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 Zookeeper 通过多个机制来保证事务的顺序一…

电脑如何无线控制手机?

想在电脑上无线控制手机,需要用到Total Control控制软件,具体步骤如下: 1、首先我们在电脑上安装上控制软件Total Control并打开。 2、开启手机USB调试和ADB仅充电模式。 3、手机电脑均连接上相同局域网。 4、连接(首次使用需要用手机U…

内网穿透的应用-自托管文件分享系统PicoShare搭建流程与远程共享实战教程

文章目录 前言1. 本地安装Docker2. 本地部署PicoShare3. 如何使用PicoShare4. 公网远程访问本地 PicoShare4.1 内网穿透工具安装4.2 创建远程连接公网地址 5. 固定PicoShare公网地址 前言 大家好!在数字化时代,文件共享变得越来越重要,尤其是…

STM32 拓展 电源控制

目录 电源控制 电源框图 VDDA供电区域 VDD供电区域 1.8V低电压区域 后备供电区域 电压调节器 上电复位和掉电复位 可编程电压检测器(PVD) 低功耗 睡眠模式(只有CUP(老板)睡眠) 进入睡眠模式 退出睡眠模式 停机(停止)模式(只留核心区域(上班)) 进入停…

内蒙古水系详细很全shp格式arcgis软件无偏移坐标下载后内容测评

标题中的“内蒙古水系详细很全shp格式arcgis软件无偏移坐标”指的是一个地理信息系统(GIS)数据集,该数据集详细记录了内蒙古地区的水系信息,并以ESRI公司的标准矢量数据格式——Shapefile(.shp)进行存储。S…

【Rust自学】10.6. 生命周期 Pt.2:生命周期的语法与例子

喜欢的话别忘了点赞、收藏加关注哦,对接下来的教程有兴趣的可以关注专栏。谢谢喵!(・ω・) 10.6.1. 生命周期标注语法 生命周期的标注并不会改变引用的生命周期长度。如果某个函数它制定了泛型生命周期参数,那么它就可…

HTML 显示器纯色亮点检测工具

HTML 显示器纯色亮点检测工具 相关资源文件已经打包成html等文件,可双击直接运行程序,且文章末尾已附上相关源码,以供大家学习交流,博主主页还有更多Html相关程序案例,秉着开源精神的想法,望大家喜欢&#…

晨辉面试抽签和评分管理系统之一:考生信息管理和编排

晨辉面试抽签和评分管理系统(下载地址:www.chenhuisoft.cn)是公务员招录面试、教师资格考试面试、企业招录面试等各类面试通用的考生编排、考生入场抽签、候考室倒计时管理、面试考官抽签、面试评分记录和成绩核算的面试全流程信息化管理软件。提供了考生…