
标签: TCP Gateway
TCP Gateway是一款物联网设备网关技术架构设计(Session 管理、心跳管理、数据上行、数据下行),通过在云端进行智能边缘核心设备的建立、身份制定、策略规则制定、函数编写,然后生成配置文件下发。

说明
NioEventLoop 是 Netty 的 Reactor 线程,其角色:
1、Boss Group:作为服务端 Acceptor 线程,用于 accept 客户端链接,并转发给 WorkerGroup 中的线程。
2、Worker Group:作为 IO 线程,负责 IO 的读写,从 SocketChannel 中读取报文或向 SocketChannel 写入报文。
3、Task Queue/Delay Task Queue:作为定时任务线程,执行定时任务,例如链路空闲检测和发送心跳消息等。
概要说明
TcpServer :提供TCP连接服务
TcpSessionManager: 你可以添加监听事件,用于监听TCP会话创建、销毁等
LogSessionListener:一个日志监听器,它和tcpSessionManager关联,监听器必须事先 SessionListener
TcpSender:TCP发送者,用户向客户端发送消息通知、实现下行逻辑
ServerConfig: TCP 的配置管理类
TcpConnector: TCP 容器,用于管理服务和客户端的连接
NotifyProxy: 发送通知到代理类
以上都是默认配置,你可以不修改,但是你可能需要换个TCP端口
.TCP网关的网络结构
基于Netty构建TCP网关的长连接容器,作为网关接入层提供服务API请求调用。
客户端通过域名+端口访问TCP网关,域名不同的运营商对应不同的VIP,VIP发布在LVS上,LVS将请求转发给后端的HAProxy,再由HAProxy把请求转发给后端的Netty的IP+Port。
LVS转发给后端的HAProxy,请求经过LVS,但是响应是HAProxy直接反馈给客户端的,这也就是LVS的DR模式。
TCP网关执行时序图

其中步骤一至步骤九是 Netty 服务端的创建时序,步骤十至步骤十三是 TCP 网关容器创建的时序。
步骤一:创建 ServerBootstrap 实例,ServerBootstrap 是 Netty 服务端的启动辅助类。
步骤二:设置并绑定 Reactor 线程池,EventLoopGroup 是 Netty 的 Reactor 线程池,EventLoop 负责所有注册到本线程的 Channel。
步骤三:设置并绑定服务器 Channel,Netty Server 需要创建 NioServerSocketChannel 对象。
步骤四:TCP 链接建立时创建 ChannelPipeline,ChannelPipeline 本质上是一个负责和执行 ChannelHandler 的职责链。
步骤五:添加并设置 ChannelHandler,ChannelHandler 串行的加入 ChannelPipeline 中。
步骤六:绑定监听端口并启动服务端,将 NioServerSocketChannel 注册到 Selector 上。
步骤七:Selector 轮训,由 EventLoop 负责调度和执行 Selector 轮询操作。
步骤八:执行网络请求事件通知,轮询准备就绪的 Channel,由 EventLoop 执行 ChannelPipeline。
步骤九:执行 Netty 系统和业务 ChannelHandler,依次调度并执行 ChannelPipeline 的 ChannelHandler。
步骤十:通过 Proxy 代理调用后端服务,ChannelRead 事件后,通过发射调度后端 Service。
步骤十一:创建 Session,Session 与 Connection 是相互依赖关系。
步骤十二:创建 Connection,Connection 保存 ChannelHandlerContext。
步骤十三:添加 SessionListener,SessionListener 监听 SessionCreate 和 SessionDestory 等事件。
程序运行案例步骤

1.配置本地Host
Window 地址 // C:\Windows\System32\drivers\etc\hosts
添加 127.0.0.1 iot-open.icloud.com
2.启动Server
位置: com.ibyte.iot.test.server.TestTcpServer
3.启动Client
位置: com.ibyte.iot.test.client.TcpClient
加载全部内容
jdchain 区块链框架系统943KB110人下载京东区块链 JD Chain 是一个企业级的区块链框架系统,具有简洁、易用、可扩展和高性能的特点。 核心实现采用 Java 语言,学习门槛低,运维简便,无缝兼容企业应用IT架构。 这是主项目仓库,主要包括了文档和集成打包的结构,以及多个Git子模块仓库framework, core, explore 等。JD Chain 的目标是实现一个面向企业应用场景的通用区块链框架系统,能够作为企业级基础设施
下载ApacheMaven项目构建工具4.41MB109人下载Apache Maven项目构建工具是一个流行的Java项目构建系统。目前,绝大多数开发人员都把Ant当作Java编程项目的标准构建工具。遗憾的是,Ant的项目管理工具(作为make的替代工具)不能满足绝大多数开发人员的需要。通过检查Ant构建文件,很难发现项目的相关性信息和其它元信息(如开发人员/拥有者、版本或站点主页)。Maven除了以程序构建能力为特色之外,还提供Ant所缺少的高级项目管理工
下载
MaxKey单点登录认证系统 官方版20.59 MB109人下载MaxKey单点登录认证系统 官方版(马克思的钥匙)用户单点登录认证系统(Sigle Sign On System),寓意是最大钥匙,是业界领先的企业级IAM身份管理和身份认证产品,支持OAuth 2.0/OpenID Connect、SAML 2.0、JWT、CAS等标准化的开放协议,提供简单、标准、安全和开放的用户身份管理(IDM)、身份认证(AM)、单点登录(SSO)、RBAC权限管理和资源管理等。这里下载站为您提供MaxKey单点登录认证系统 官方版下载,欢迎您使用这里下载站安装体验!
下载SkyWalking应用性能监控系统4.16MB109人下载SkyWalking 是一款开源的应用性能监控系统,包括指标监控,分布式追踪,分布式系统性能诊断。功能:1、服务,服务实例,端点指标分析2、根本原因分析。在运行时分析代码。阅读Apache SkyWalking:使用性能分析来修复分布式跟踪的盲点。3、服务拓扑图分析4、服务,服务实例和端点依赖关系分析5、检测到慢速服务和端点6、性能优化7、分布式跟踪和上下文传播8、数据库访问指标。检测慢速数据库访
下载bishengjdk-8 毕昇JDK8131.38MB108人下载毕昇JDK 8是华为内部OpenJDK定制版Huawei JDK的开源版本,是一个高性能、可用于生产环境的OpenJDK发行版。Huawei JDK运行在华为内部500多个产品上,积累了大量使用场景和java开发者反馈的问题和诉求,解决了业务实际运行中遇到的多个问题,并在ARM架构上进行了性能优化,毕昇JDK运行在大数据等场景下可以获得更好的性能。毕昇JDK 8与Java SE标准兼容,目前仅支持
下载
kkFileView在线预览 官方版184.50MB107人下载 kkFileView在线预览是一款使用spring boot打造的文件文档在线预览项目解决方案,支持doc、docx、ppt、pptx、xls、xlsx、zip、rar、mp4、mp3以及众多类文本如txt、html、xml、java、properties、sql、js、md、json、conf、ini、vue、php、py、bat、gitignore等文件在线预览。
下载
Jenkins持续集成引擎 正式版17.87 MB107人下载Jenkins持续集成引擎 正式版的前身是Hudson是一个可扩展的持续集成引擎。Jenkins是一款开源CI&CD软件,用于自动化各种任务,包括构建、测试和部署软件。Jenkins支持各种运行方式,可通过系统包、Docker或者通过一个独立的Java程序。这里下载站为您提供Jenkins持续集成引擎 正式版下载,欢迎您使用这里下载站安装体验!
下载Jpom 监控管理系统 正式版1.55MB107人下载Jpom项目监控软件是一款简而轻的低侵入式在线构建、自动部署、日常运维、项目监控软件。Jpom项目监控软件主要功能及特点:1、创建、修改、删除项目、Jar包管理2、实时查看控制台日志、备份日志、删除日志、导出日志3、cpu、ram 监控、导出堆栈信息、查看项目进程端口、服务器状态监控4、多节点管理、多节点自动分发5、实时监控项目状态异常自动报警6、在线构建项目发布项目一键搞定7、多用户管理,用户项
下载LinkWeChat开源系统 免费版8.64MB105人下载LinkWeChat,是一款基于企业微信的开源 SCRM 系统,为企业构建私域流量系统的综合解决方案,能显著提升企业社交运营效率。
下载
ofdrw读写库98.15MB104人下载使用ofdrw读写库可以像写HTML和Word那样简单的编写OFD。根据《GB/T 33190-2016 电子文件存储与交换格式版式文档》标准实现版式文档OFD库(含有书签)。ofdrw读写库项目结构:ofdrw-core OFD核心API,参考《GB/T 33190-2016 电子文件存储与交换格式版式文档》实现的基础数据结构。ofdrw-font 生成OFD字体相关。ofdrw-layout
下载