在Spring Integration中跨不同的流维护多个TCP连接

问题描述

背景:我有一个系统,通常每个用户都通过长时间运行的TCP连接连接到服务器。每个用户都有自己的私钥,用于通过此TCP连接连接到服务器。当用户向服务器发送消息时,服务器会通过其活动的TCP连接将该消息广播回一些或所有其他用户

问题:对于这些用户中的某些用户,我们希望他们能够通过多播与服务器进行通信,因此我为此构建了一个多播 TCP代理服务器(我们不控制用于原始服务器,因此无法对其进行处理以处理多播流量)。该代理将通过多播与用户通信,并通过TCP连接与服务器通信。对于每个向代理发送消息的用户,代理应与服务器建立单独的TCP连接,并使用该最终用户的私钥连接到服务器。我正在尝试在Spring Integration中设置这些通信流,但是我一直在努力弄清楚这种设置在该框架中是否可行,或者是否最好为此编写自定义内容

现在,我正在努力的最大部分是在TCP方面。从概念上讲,在用户->服务器部分,我有一个多播接收器适配器,该适配器分为两个流,一个用于使用多播消息中接收的信息创建新连接,另一个用于沿着已创建的连接发送数据。是否有一种方法可以在一个流中创建这些TCP连接,然后以某种方式保留该连接信息以供另一流使用?这些已建立的连接也将需要用于在事物的服务器->用户端接收消息。我正在努力找出在框架内完成此操作的正确方法

请让我知道是否有其他信息可以帮助您回答这个问题,我知道这是一种非常奇怪的情况,我想在此处解决

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...