(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111559646.X (22)申请日 2021.12.20 (71)申请人 徐工汉云技 术股份有限公司 地址 221122 江苏省徐州市徐州经济技 术 开发区科技路6号 (72)发明人 胡旭辉　王飞　郭佳宇　邢斌　 (74)专利代理 机构 南京纵横知识产权代理有限 公司 32224 代理人 俞翠华 (51)Int.Cl. H04L 12/66(2006.01) H04L 9/40(2022.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) (54)发明名称 一种实现终端在分布式网关session唯一的 方法及装置 (57)摘要 本发明公开了一种实现终端在分布式网关 session唯一的方法及装置， 所述方法包括终端 登入网关； 利用网关进行数据库认证， 认证成功 后更新其自身的数据库信息； 当网关完成设备认 证后， 则将终端的登录信息发布 到kafka组件； 利 用其余各网关订阅kafka组件的kafka消息， 当接 收到终端的登录信息后， 各网关根据预设的规则 更新终端在其内部的本地 缓存数据。 本发明使用 kafka作为分布式网关间的消息传递组件， 具有 低时延、 高并发的特点， 能够充分利用kafka的发 布订阅机制， 将网关切换消息发布到所有网关， 从而实现 分布式网关 session唯一的目的。 权利要求书1页 说明书4页 附图2页 CN 114285699 A 2022.04.05 CN 114285699 A 1.一种实现终端在分布式网关 session唯一的方法， 其特 征在于， 包括： 终端登入网关； 利用网关进行 数据库认证， 认证成功后更新 其自身的数据库信息； 当网关完成设备认证后， 则将终端的登录信息发布到kafka组件； 利用其余各网关订阅kafka组件的kafka消息， 当接收到终端的登录信息后， 各网关根 据预设的规则更新终端在其内部的本地缓存数据。 2.根据权利要求1所述的一种实现终端在分布式网关session唯一的方法， 其特征在 于， 所述各网关根据预设的规则更新终端在其内部的本地缓存数据， 具体包括： 如果是本网关则不做处 理； 如果是其 他网关， 则需要清除该终端在其内部的本地缓存数据。 3.根据权利要求1所述的一种实现终端在分布式网关session唯一的方法， 其特征在 于， 在利用网关进 行数据库认证， 认证成功后更新其自身的数据库信息步骤之后还包括： 更 新设备管理库中与该终端对应的数据。 4.一种实现终端在分布式网关session唯一的装置， 其特征在于， 包括： kafka组件和若 干个独立设置的网关， 各网关均 与所述kafka组件分别相连； 当终端登入某网关后， 利用该网关进行数据库认证， 认证成功后更新其自身的数据库 信息； 当该网关完成设备认证后， 则将终端的登录信息发布到kafka组件； 利用其余各网关订阅kafka组件的kafka消息， 当接收到终端的登录信息后， 各网关根 据预设的规则更新终端在其内部的本地缓存数据。 5.根据权利要求4所述的一种实现终端在分布式网关session唯一的装置， 其特征在 于： 所述各网关根据预设的规则更新终端在其内部的本地缓存数据， 具体包括： 如果是本网关则不做处 理； 如果是其 他网关， 则需要清除该终端在其内部的本地缓存数据。 6.根据权利要求4所述的一种实现终端在分布式网关session唯一的装置， 其特征在 于： 所述装置还 包括设备 管理库； 所述设备 管理库用于存 储与终端对应的数据。权　利　要　求　书 1/1 页 2 CN 114285699 A 2一种实现终端在分布式网关ses sion唯一的方 法及装置 技术领域 [0001]本发明具体涉及一种实现终端在分布式网关 session唯一的方法及装置 。 背景技术 [0002]网关是设备连网极为重要的一环， 它承担着接受设备连接、 设备认证、 协议转换、 指令下发等功 能。 网关的健康与否决定了设备能否正常连接平台， 一旦设备无法健康地连 接平台， 可能会产生巨大的损失。 例如需要持续运转的混凝土搅拌车， 当无法健康连接平台 可能出现停 转的情况， 导致混弄土凝固从而造成损失。 所以网关模块必须具备高并发、 高稳 定性的特点。 如图1所示为现有技术中设备接入网关的结构示意图。 如图2所示， 现有技术中 的指令下发流程包括： 设备初次登录到网关以后， 网关会对设备进 行认证， 这时网关会查询 数据库数据确认登入的设备是否正确， 认证完成后网关会将设备信息一份缓存在本地缓存 中， 一份更新到数据库中。 当需要 执行设备指 令下发时， 下发模块从数据库中找到网关的连 接信息， 从而找到对应的网关传递相关指令， 网关再从自己的本地缓存中找到连接信息进 行指令下发。 缓存的目的就是减少设备认证与数据库的交互， 当本地缓存存在时， 直接与缓 存完成认证， 从而保证网关的高并发性。 而网关本地缓存的数据有一定的时间期限。 在某些 场景下， 例如网关程序更新导致的网关重启过程中， 由于负载均衡的机制， 在网关重启过程 中会发生大量的设备切换网关， 有时切换不止一次， 而在切换过程中， 会发生新旧网关的本 地缓存同时存在设备 的登录信息， 当网关本地缓存存在相应设备信息时， 此时设备再连接 网关则不会更新数据库， 多份缓存的存在叠加重启过程中的频繁切换导致数据库中的设备 连接信息与实际不符， 最 终导致在指 令下发过程中， 设备明明在线， 下发指 令却无法下发到 设备的问题。 发明内容 [0003]针对上述问题， 本发明提出一种实现终端在分布式网关session唯一 的方法及装 置， 使用kafka作为分布式网关 间的消息传递组件， 具有低时延、 高并发的特点， 能够 充分利 用kafka的发布订阅机制， 将网关切换消息发布到所有网关， 从而实现分布 式网关session 唯一的目的。 [0004]为了实现上述 技术目的， 达 到上述技术效果， 本发明通过以下技 术方案实现： [0005]第一方面， 本发明提供了一种实现终端在分布式网关session唯一的方法， 包括： 终端登入网关； [0006]利用网关进行 数据库认证， 认证成功后更新 其自身的数据库信息； [0007]当网关完成设备认证后， 则将终端的登录信息发布到kafka组件； [0008]利用其余各网关订阅kafka组件的kafka消息， 当接收到终端的登录信息后， 各网 关根据预设的规则更新终端在其内部的本地缓存数据。 [0009]可选地， 所述各网关根据预设的规则更新终端在其内部 的本地缓存数据， 具体包 括：说　明　书 1/4 页 3 CN 114285699 A 3