JAVA版基于netty的物联网高并发智能网关.zip

 ### GitHub项目地址（源码优先更新码云仓库） https://github.com/BrianApple/IOTGate ### 温馨提示 本项目的使用有一定的门槛，需要使用人员具备一定的物联网应用层协议知识，比如大小端、长度域等等 ### IOTGate开源版（基于GPL-2.0开源，请自行阅读GPL-2.0并准守相关条款，企业用户建议优先获取企业版使用权限！） 演示地址http://113.31.103.53:8686/ 用户名密码随意输入：  如果跳转报错则重新在地址栏输入http://113.31.103.xx:8686/ 即可正常访问！服务器资源有限，请不要对网关在线压测，谢谢！！ ** 👨‍💻👨‍💻👨‍💻服务器被被挖矿木马感染了,目前木马已经被干掉,万事为了珍惜我宝贵的服务器资源就暂时不提供演示版了 ** ### 名词解释 通信规约：应用层通信协议，与有些同学说的的“通信协议”是一个意思 ### IOTGate开源版压测聚合报告 win10笔记本，堆内存2g,线程数6k  ### 通过netty实现自定义协议物联网网关（单机和集群版） window笔记本电脑本地测试：**单网关**、**单前置节点**，每秒处理并发心跳8000+（根据jmeter本地最新压测统计数据），20W在线终端(长连接保持)内存占用量1G左右 ### 心跳检测 单机版可以通过配置文件个性化配置规约的心跳周期，集群版默认300秒 ### 入口类: Entrance.java ### IOTGate操作指南--系列博客 於之博客： https://www.xianglong.work/tag/IOTGate%E6%99%BA%E8%83%BD%E7%BD%91%E5%85%B3 於之CSDN: https://blog.csdn.net/sinat_28771747/category_8788959.html ### 端口占用 - kernel模式默认端口为：10915 （-k命令行参数开启） - rpc通信：10915 (集群模式下开启) ### 命令行参数说明 | 参数 | 是否必选 |是否含参| 含义 | |------------- |----------|----------|----------| | -n | 是 | 是 | 网关编号 | | -c | 否 | 否 | 启动集群模式 | | -z | 否 | 是 | zookeeper集群地址 | | -m | 否 | 是 | 前置ip地址(不含端口，前置默认8888) | | -k | 否 | 否 | 开启kernel模式，默认端口为10915 | | -f | 是 | 是 | 配置文件"iotGate.conf"的本地全路径 | ### 如何启动 自行将项目打成jar包，在linux下，执行java -jar iotGate.jar -n 1 [args...] 默认前置端口为8888，可自行源码中修改 - 单机方式启动 ：命令行参数使用“-m”指定前置服务地址 - 集群方式启动：命令行参数“-c”开启zookeeper集群模式，“-z”指定zookeeper集群的地址（逗号分隔） - **单机版网关不支持IOTGateConsole控制台动态维护，因为IOTGateConsole的节点发现依赖于zookeeper,集群版网关无论节点多少依然可以通过IOTGateConsole管理** ### 自定义网关头结构与注意事项 网关报头，是网关与前置通信时，作为网关登录和传输真实报文时携带网关自身和终端响应参数的报文，报文结构是自己定义，前置按照定义好的报文格式获取数据并做相应处理。 网关头结构如下： | 报文属性 | 字节数| 含义 | |------------- | ------------- | ----------| | AB | 1byte | 报文头 | | len | 4byte | 长度域：真实报文长度，包含“68”，“16”| | type | 1byte | 报头类型| | protocolType| 1byte | 协议类型（左侧起第一个bit为0 表示IPV4, 1表示IPV6 剩余7个bit表示规约类型编号）| | gateNum | 1byte | 网关编号| | 00*12 | 12byte |如果ip格式为IPV4，则当前为12字节0，反之，当前得12个byte+后续得4byte存放IPV6的值，存放顺序从左至右依次| | clientIP | 4byte | 终端的IP地址，ip地址的每个段位占一个字节（不含符号和端口号）| | port | 2byte | 终端对应的端口号| | count | 4byte | 终端与网关建立连接时对应的连接序号（1-10000循环）| 网关发送需要向前置发送登录报文，将自己注册到前置服务中，报文说明如下： - 1. 登录时长度为0；有真实报文时，长度域为整个真实报文长度值 - 2. 登录时type = 03；protocolType=15;count=1都为固定值；发送真实报文时，type=01,protocolType=00;count=终端与网关的连接序号 - 3. 前置发现报头长度为0 且type = 03; protocolType=15;就不会执行解析数据的方法，否则会继续解析真实报文 *************************************************************************************************************************** ### 网关配置文件种默认支持的两种真实报文 *“真实报文”即终端与网关通信时传输数据的报文，规约不同则报文结构差异明显 - 规约编号为“1”，报文结构如下 | 报文属性 | 字节数| 含义 | |------------- | ------------- | ----------| |68 | 1byte | 报头| | len | 2byte | 长度域 "传输帧中除起始字符68和结束字符16之外的帧字节总数，包含长度域本身字节数"| | data | n byte | 报文内容 | | 16 | 1byte | 报尾| - 规约编号为“2”，报文结构如下 | 报文属性 | 字节数| 含义 | |------------- | ------------- | ----------| | len | 4byte | 长度域值为data的字节数，不包含自身字节数| | data | n byte | 报文内容 | *** ### 版本 - IOTGate-v1.0 版本为集群版网关程序，通过命令行参数动态配置网关为单节点或集群（单节点不依赖zookeeper集群） 网关与前置通讯时默认轮询方式负载均衡 - IOTGate-v2.0.1.release IOTGate第一个正式稳定版本，可用于生产环境直接运行 ! - IOTGate-v2.0.2.release 解决了大家反应的一些bug，优化了内存泄漏异常，单机版本增加了配置单个规约心跳的配置选项，使得不同规约心跳的管理更加灵活！ - IOTGate-v2.0.3 IOTGate第一个正式发行版，可执行jar包下载地址 ：https://gitee.com/willbeahero/IOTGate/attach_files/454348/download 前置网关演示demo下载 ：https://gitee.com/willbeahero/IOTGate/attach_files/454354/download - master 基本功能开发完成，已经支持多规约本地配置以及IOTGateConsole远程开启/关闭/新增/删除网关多规约服务功能。后续master会继续扩展相关功能 - IOTGate-v3.x 规划中，增加集群版能力，简化部署方式 ### 关于多规约支持 物联网虽然火起来，但目前业内还没有比较统一的通讯规约，MQTT是目前业界使用比较广泛的物联网通讯协议了，我看了下阿里最近弄出来的物联网平台其主要也是支持MQTT物联网设备的接入，但他毕竟不是唯一的通讯规约，光我自己知道的通讯都有好几种了，而且每一种规约的报文格式都各不相同，因此，所谓多规约支持，也不可能做到所有物联网规约全支持，我目前的想法是，通过多规约得基础功能和高级功能可以将比较流行物联网规约都能够支持！ 那么IOTGate如何配置实现多规约支持呢？ IOTGate操作指南 ### IOTGate功能架构图  ### GATE CLUSTER 结构图  注：图中GATE CLIENT（项目名称“IOTGateConsole”，项目地址：https://gitee.com/willbeahero