物联网开发tcp协议之——netty拆包问题

2024-06-07 10:04

本文主要是介绍物联网开发tcp协议之——netty拆包问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.前言

tcp协议是物联网开发中比较常见的一种通信协议,而netty则是一tcp通信协议中一个比较优秀的框架。tcp协议是一种长连接的协议,是流式传输的,开发过程中最长遇见的问题就是拆包粘包问题。我目前对接过的物联网系列有智能家居设备,433酒店智控设备,充电桩设备,安防设备,传感器(温度,噪声等等类的),对接设备的过程中有的是和厂家对接,这种需要完全根据厂家的协议走,有的是公司自研的这和设备端嵌入式工程师商议协议即可。对接过程中遇到的一个最大问题就是拆包粘包的过程。下面就目前我遇到的协议中做一个总结:

1.常规协议,netty常规编解码器

使用Netty实现的tcp服务端,由于tcp是流式传输的,故需要选用一个解码器对流式消息进行解码和包分隔,以防收到不正确的包。例如LineBasedFrameDecoder,LengthFieldBasedFrameDecoder,DelimiterBasedFrameDecoder等常用解码器。

比如对接的智能家居设备是公司自研的设备,嵌入式工程师也是我们自己公司的,定义协议的时候,以固定报文结尾,假如固定报文为:0D0ABBBB,那么可使用netty编解码器ByteArrayDecoder,ByteArrayEncoder,附上代码:

public class HwServerInitializer extends ChannelInitializer<SocketChannel> {
//@Overrideprotected void initChannel(SocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();ByteBuf delimiter = Unpooled.copiedBuffer(new byte[]{0x0D, 0x0A, (byte)0xBB, (byte)0xBB});// 以("\n")为结尾分割的 解码器pipeline.addLast("framer", new DelimiterBasedFrameDecoder(10000, delimiter));// 字符串解码 和 编码pipeline.addLast("decoder", new ByteArrayDecoder());pipeline.addLast("encoder", new ByteArrayEncoder());// 自己的逻辑Handlerpipeline.addLast("handler", new HwServerHandler());}
}

2.不规则协议

有些协议是用常规的编解码器解决不了的,比如下面这一个安防类的协议,

包很长,常规的编解码器解决不了,一直拆包粘包,那么就需要自定义编解码器了,附上自定义解码器的代码

public class MyMessageDecode extends ByteToMessageDecoder {private static final Logger log = LoggerFactory.getLogger(MyMessageDecode.class);@Overrideprotected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {// 标记一下当前的readIndex的位置byteBuf.markReaderIndex();byte[] magic = new byte[5];byteBuf.readBytes(magic);byte[] len = new byte[4];byteBuf.readBytes(len);int lens=Integer.parseInt(MyStringUtil.byteArrayToASCII(len));if (byteBuf.readableBytes()<lens-10){byteBuf.resetReaderIndex();return;}byte[] data = new byte[lens-9];byteBuf.readBytes(data);byte[] mesages=new byte[lens];System.arraycopy(magic, 0, mesages, 0, 5);System.arraycopy(len, 0, mesages, 5, 4);System.arraycopy(data, 0, mesages, 9, lens-9);// byteBuf.resetReaderIndex();list.add(mesages);}
}

拆包粘包问题解决

这篇关于物联网开发tcp协议之——netty拆包问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1038865

相关文章

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Vue3绑定props默认值问题

《Vue3绑定props默认值问题》使用Vue3的defineProps配合TypeScript的interface定义props类型,并通过withDefaults设置默认值,使组件能安全访问传入的... 目录前言步骤步骤1:使用 defineProps 定义 Props步骤2:设置默认值总结前言使用T

SpringBoot 多环境开发实战(从配置、管理与控制)

《SpringBoot多环境开发实战(从配置、管理与控制)》本文详解SpringBoot多环境配置,涵盖单文件YAML、多文件模式、MavenProfile分组及激活策略,通过优先级控制灵活切换环境... 目录一、多环境开发基础(单文件 YAML 版)(一)配置原理与优势(二)实操示例二、多环境开发多文件版

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同

HTTP 与 SpringBoot 参数提交与接收协议方式

《HTTP与SpringBoot参数提交与接收协议方式》HTTP参数提交方式包括URL查询、表单、JSON/XML、路径变量、头部、Cookie、GraphQL、WebSocket和SSE,依据... 目录HTTP 协议支持多种参数提交方式,主要取决于请求方法(Method)和内容类型(Content-Ty

Web服务器-Nginx-高并发问题

《Web服务器-Nginx-高并发问题》Nginx通过事件驱动、I/O多路复用和异步非阻塞技术高效处理高并发,结合动静分离和限流策略,提升性能与稳定性... 目录前言一、架构1. 原生多进程架构2. 事件驱动模型3. IO多路复用4. 异步非阻塞 I/O5. Nginx高并发配置实战二、动静分离1. 职责2

解决升级JDK报错:module java.base does not“opens java.lang.reflect“to unnamed module问题

《解决升级JDK报错:modulejava.basedoesnot“opensjava.lang.reflect“tounnamedmodule问题》SpringBoot启动错误源于Jav... 目录问题描述原因分析解决方案总结问题描述启动sprintboot时报以下错误原因分析编程异js常是由Ja

Python实战之SEO优化自动化工具开发指南

《Python实战之SEO优化自动化工具开发指南》在数字化营销时代,搜索引擎优化(SEO)已成为网站获取流量的重要手段,本文将带您使用Python开发一套完整的SEO自动化工具,需要的可以了解下... 目录前言项目概述技术栈选择核心模块实现1. 关键词研究模块2. 网站技术seo检测模块3. 内容优化分析模

MySQL 表空却 ibd 文件过大的问题及解决方法

《MySQL表空却ibd文件过大的问题及解决方法》本文给大家介绍MySQL表空却ibd文件过大的问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考... 目录一、问题背景:表空却 “吃满” 磁盘的怪事二、问题复现:一步步编程还原异常场景1. 准备测试源表与数据