草庐IT

tcp - Spring 集成 TCP。获取已连接客户端的连接 ID

coder 2023-09-18 原文

我在这里遇到动态 TCP 连接方法 ( Spring-IP Dynamic FTP Sample) 的问题。收到消息后，我想获取收到消息的 TCP 连接详细信息。这样我就可以在我的应用程序中跟踪发送该消息的发件人。但是在服务激活器中我无法获得这个细节。

当我的 TCP 客户端连接到服务器时，还需要连接详细信息。这样，如果服务器想要启动通信，它将具有连接详细信息。

有关信息，我的应用程序有多个 TCP 客户端和服务器。

最佳答案

在 Mr. Gary Russell 的另一个帖子中得到了答案回复。

回答

对于正常的请求/回复处理，使用入站网关，框架将负责将服务激活器回复路由到正确的套接字。它通过使用连接 ID header 来执行此操作。

如果您需要提供任意回复(例如，一条消息有多个回复，您必须使用入站和出站 channel 适配器，并且您的应用程序负责设置连接 ID header 。

有两种方法可以访问服务激活器调用的 POJO 中所需的 header :

public void foo(byte[] payload, @Header(IpHeaders.CONNECTION_ID) String connectionId) {
    ...
}

public void foo(Message<byte[]> message) {
    String connectionId = message.getHeaders().get(...);
}

然后，当您发送回复时，您需要以某种方式设置该 header 。

编辑

下面是我的实现

要获取所有已连接的客户端，只需从上下文中获取 ServerConnectionFactory 并访问方法 .getConnectedClients()。它为每个连接的客户端返回列表 connectionIds。

AbstractServerConnectionFactory connFactory = (AbstractServerConnectionFactory) appContext.getBean("server");
List<String> openConns = connFactory.getOpenConnectionIds();

如上面 Gary 的回复中所述，在向客户端发送消息时使用此 connectionId 并将其设置在连接 header 中。示例代码如下。

MessageChannel serverOutAdapter = null;
try{
    serverOutAdapter = (MessageChannel) appContext.getBean("toObAdapter");
}catch(Exception ex){
    LOGGER.error(ex.getMessage());
    throw ex;
}

    if(null == serverOutAdapter){
        throw new Exception("output channel not available");
    }

    AbstractServerConnectionFactory connFactory = (AbstractServerConnectionFactory) appContext.getBean("serverConnFactoryBeanId");
    List<String> openConns = connFactory.getOpenConnectionIds();
    if(null == openConns || openConns.size() == 0){

        throw new Exception("No Client connection registered");
    }

    for (String connId: openConns) {
        MessageBuilder<String> mb = MessageBuilder.withPayload(message).setHeader(IpHeaders.CONNECTION_ID, connId);
        serverOutAdapter.send(mb.build());
    }

注意 1:如果您想从服务器发送消息，请谨慎配置服务器和客户端连接工厂，使其不会超时。即在客户端连接工厂中放置 so-keep-alive = true。

注意 2:如果服务器必须与客户端通信，请确保客户端在加载上下文后立即连接到服务器。因为 Spring-IP 客户端连接工厂只有在第一条消息发出时才会连接。为了在上下文加载后连接客户端，将 client-mode="true" 放入“tcp-outbound-channel-adapter”的 tcp 客户端上下文中。

关于tcp - Spring 集成 TCP。获取已连接客户端的连接 ID，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39062895/

端的SpringstrongsectionAbstractServerConnectionFactorytcpspring-integration

有关tcp - Spring 集成 TCP。获取已连接客户端的连接 ID的更多相关文章

  1. ruby - 续集在添加关联时访问many_to_many连接表 - 2

    我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以

  2. ruby-on-rails - 带 Spring 锁的 Rails 4 控制台 - 2

    我正在使用Ruby2.1.1和Rails4.1.0.rc1。当执行railsc时，它被锁定了。使用Ctrl-C停止，我得到以下错误日志:~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.2/lib/spring/client/run.rb:47:in`gets':Interruptfrom~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.2/lib/spring/client/run.rb:47:in`verify_server_version'from~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.

  3. ruby - 无法在 60 秒内获得稳定的 Firefox 连接 (127.0.0.1 :7055) - 2

    我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例，但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗？ 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)，我们在StackOverflow上找到一个类

  4. ruby-on-rails - 如何使辅助方法在 Rails 集成测试中可用？ - 2

    我在app/helpers/sessions_helper.rb中有一个帮助程序文件，其中包含一个方法my_preference，它返回当前登录用户的首选项。我想在集成测试中访问该方法。例如，这样我就可以在测试中使用getuser_path(my_preference)。在其他帖子中，我读到这可以通过在测试文件中包含requiresessions_helper来实现，但我仍然收到错误NameError:undefinedlocalvariableormethod'my_preference'.我做错了什么？require'test_helper'require'sessions_hel

  5. ruby-on-rails - 我如何将 Hoptoad 与 DelayedJob 和 DaemonSpawn 集成？ - 2

    我一直很高兴地使用DelayedJob习惯用法:foo.send_later(:bar)这会调用DelayedJob进程中对象foo的方法bar。我一直在使用DaemonSpawn在我的服务器上启动DelayedJob进程。但是...如果foo抛出异常，Hoptoad不会捕获它。这是任何这些包中的错误...还是我需要更改某些配置...或者我是否需要在DS或DJ中插入一些异常处理来调用Hoptoad通知程序？回应下面的第一条评论。classDelayedJobWorker 最佳答案 尝试monkeypatchingDelayed::W

  6. jenkins部署1--jenkins+gitee持续集成 - 2

    前置步骤我们都操作完了，这篇开始介绍jenkins的集成。话不多说，看操作1、登录进入jenkins后会让你选择安装插件，选择第一个默认的就行。安装完成后设置账号密码，重新登录。2、配置JDK和Git都需要执行路径，所以需要先把执行路径找到，先进入服务器的docker容器，2.1JDK的路径root@69eef9ee86cf:/usr/bin#echo$JAVA_HOME/usr/local/openjdk-82.2Git的路径root@69eef9ee86cf:/#whichgit/usr/bin/git3、先配置JDK和Git。点击：ManageJenkins>>GlobalToolCon

  7. spring.profiles.active和spring.profiles.include的使用及区别说明 - 2

    转自:spring.profiles.active和spring.profiles.include的使用及区别说明下文笔者讲述spring.profiles.active和spring.profiles.include的区别简介说明,如下所示我们都知道，在日常开发中,开发|测试|生产环境都拥有不同的配置信息如：jdbc地址、ip、端口等此时为了避免每次都修改全部信息，我们则可以采用以上的属性处理此类异常spring.profiles.active属性例：配置文件,可使用以下方式定义application-${profile}.properties开发环境配置文件:application-dev

  8. ruby - 我的 Ruby IRC 机器人没有连接到 IRC 服务器。我究竟做错了什么？ - 2

    require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame

  9. ruby - Rails -- :id attribute? 所需的数据库索引 - 2

    因此，当我遵循MichaelHartl的RubyonRails教程时，我注意到在用户表中，我们为:email属性添加了一个唯一索引，以提高find的效率方法，因此它不会逐行搜索。到目前为止，我们一直在根据情况使用find_by_email和find_by_id进行搜索。然而，我们从未为:id属性设置索引。:id是否自动索引，因为它在默认情况下是唯一的并且本质上是顺序的？或者情况并非如此，我应该为:id搜索添加索引吗？ 最佳答案 大多数数据库(包括sqlite，这是RoR中的默认数据库)会自动索引主键，对于RailsMigration

  10. ruby-on-rails - 连接字符串时如何在 <%=%> block 内输出 html_safe？ - 2

    考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证＆符号不会被转义？由于我无法控制的原因，我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清，我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://

随机推荐