物联网设备 TCP 代理转发系统求助

[unscientific404]

各位大佬好，求助一个问题：

我司有一套基于 TCP 协议开发的物联网系统，正常情况设备是和我们机房的后端服务器建立长连接，但是我们有很多属地化平台（后端服务部署在客户机房），这样就需要对设备修改远端服务 IP 。

同时由于配置的是定向物联网卡，IP 白名单经常搞错导致设备无法联网，因此领导希望开发一个TCP 代理中转系统，所有的设备都接入该服务，再由该服务解析报文里的设备号，决定转发到那个平台（上行和下行数据都需要对应转发）。

想请教大家有合适的开源方案吗，或者类似的检索关键词，不想重复造轮子（技术栈是 JAVA ）谢谢^_^。

---

当前情况：

设备 1 <-> 主平台

设备 2 <--> 主平台

设备 3 <--> 主平台

设备 4 <--> 属地化平台 A

设备 5 <--> 属地化平台 B

期望的效果：

设备 1 <--> TCP 代理 <--> 主平台

设备 2 <--> TCP 代理 <--> 主平台

设备 3 <--> TCP 代理 <--> 主平台

设备 4 <--> TCP 代理 <--> 属地化平台 A

设备 5 <--> TCP 代理 <--> 属地化平台 B

[Erroad]

@unscientific404 #13 拆包了，到七层了，用 java 或者 golang 写个转发程序吧

[hankai17]

@unscientific404 可以 直接上 openresty

[bugmakerxs]

7 层代理应该没有类似的。自己用 nio 整一个吧

[wangzy]

搞个 emq cloud 或者企业版，里面含部标协议转换（ cloud 最低版本得跟对方说开通 jt808 ），后端订阅 jt808 topic 直接获取解析后的 json ，然后根据设备号转发到其他 topic ，各地机房订阅自己 topic 就可以了。

emq 这个 jt808 的协议插件我应该是第一个客户，那时候数据都不对，现在用了 2 年多了

[liqinliqin]

swoole 十分钟完成

[u20237]

最好大部分协议都支持

[opengps]

似乎真的需要你介入开发一层，毕竟很多协议都是自定义的，行业里很多这种模式的

[opengps]

一般来说，推荐用增加一个独立消息队列单独转发位置数据即可

[chinawrj]

iptables 搞个 DNAT 转发就行了啊

[yplam]

可以考虑 设备<-->代理 agent<-->代理 server<-->平台 的方式，设备与平台的代码不变，agent 与 server 自己写，可以先按 tcp connection io copy 的方式实现，后面根据运行情况优化

[mineralsalt]

根本不需要自己搞一套 TCP 系统, 用 docker 一键安装一个开源的 EMQX, 好用的不得了, 各种客户端的 SDK 都有, 单机百万级连接, 支持 MQTT, WebSocket 等等各种协议, 比你们自己琢磨出来的玩意性能不知道好多少

[retanoj]

可以参考下 openresty stream 模块的使用案例
https://stackoverflow.com/questions/53168425/how-to-dispatch-tcp-request-to-backends-with-first-byte-of-content-in-openresty

https://wiki.shileizcc.com/confluence/pages/viewpage.action?pageId=47416507

[humbass]

思路有问题，正经的做法是：终端先查询服务器地址，然后再进行连接！

[Bijiabo]

比较好奇对于存量设备的兼容方式是什么，是按照当前情况继续将数据上传到属地华平台，还是会考虑将存量设备 OTA 变更为新的代理实现方案？

如果只是存量设备保持不变，只考虑新设备入网的时候接入对应的服务，也许可以考虑从配置 TCP 服务变更为配置 MQTT 服务，或者其他方案。物联网的不少业务场景中 TCP 不一定是合适的选择嘛

[cnbatch]

既然你就是运营商员工，那么其实最佳做法是出一套方案，把“IP 白名单搞错”这件事解决掉，因为这是根源所在。比如自动化管理 IP 白名单之类的。

说真的，按照你们领导的想法，做好了中转系统也许暂时躲避问题，但要是这种做法被客户无意中发现，不就等于收获新的吐槽，比如“运营商搞骚操作，原本直连的卡硬是被他们用中转服务器接管了”，甚至投诉：“你们拦截我们的数据再转发给我们，是不是改了内容？”

尤其是客户设备出故障的时候，要是你们真的搞了中转系统并且被客户发现，客户们还真有可能会认为是你们修改了数据导致设备损坏。

[Shiweizhi]

试试 Node-RED

[gemini]

这种定制类的场景应该没有开源的吧。
按照楼主描述应该是使用了行业标准协议，没有使用设备厂商 SDK 之类的。

画重点，需要自行开发一个中转模块（假设叫 RelayServer ），解决数据上行和下行的路由问题。

需要维护：
上行路由表：[设备号, 后端服务器信息] （这个是要提前配置好）
下行路由表：[设备号, 设备连接 Socket] （程序中自行维护）

1 ）上行：
RelayServer 收到上行数据包，按照协议解析（或部分解析）得到设备号，查询上行路由表得到要转发的后端服务器信息 BackendServerInfo ，转发上行数据。

检查该设备号是否存在于 [下行路由表] ，若不存在则添加下行路由信息（也就是后面回去的路）

2 ）下行：
RelayServer 收到上行数据包，根据设备号找到对应 Socket ，转发下行数据。

---
以上为单进程模式大概思路，设备或数据量不是非常大的情况应该能撑得住。
RelayServer 替换原有服务器，并把原有服务器后移。

另外，负载较高的是还有可能 RelayServer 会有多台，情况会更复杂一些，可以再多交流。

[tomqin]

开源的 K8s 原生物联网框架 Shifu 试一下？
https://github.com/Edgenesis/shifu
可以用 TCPdeviceShifu 实现你要的功能，YAML 直接部署
教程
https://github.com/Edgenesis/shifu/tree/main/examples%2FtcpDeviceShifu

[bronco]

水一个，阿里云的 NLB 就是干这个的，直接用~

[unscientific404]

@Bijiabo 协议是国家颁布的标准协议，走的 TCP ，这个没办法更改。相当于协议不是我们制定的，设备也不是我们生产的。