Spring Integration - IP -接收多个响应
Spring Integration是一个基于Spring框架的集成解决方案，用于构建企业级应用程序中的消息驱动和事件驱动的系统。它提供了一种简单而强大的方式来实现不同系统之间的通信和数据交换。
IP（Internet Protocol）是互联网协议的缩写，是一种网络通信协议，用于在网络中传输数据包。它定义了数据包的格式和传输规则，使得不同设备和网络能够相互通信。
在Spring Integration中，IP是一个重要的组件，用于接收多个响应。当一个请求发送给多个服务提供者时，IP可以接收并处理这些服务提供者返回的多个响应。它提供了一种灵活的机制来处理多个响应，并将它们整合到一个统一的结果中。
使用Spring Integration的IP，可以实现以下优势：
- 异步处理：IP可以异步接收和处理多个响应，提高系统的并发性和响应速度。
- 容错处理：IP可以处理服务提供者返回的多个响应，并根据需要进行容错处理，确保系统的稳定性和可靠性。
- 灵活配置：IP提供了灵活的配置选项，可以根据具体需求进行定制和扩展。
应用场景：
- 并行处理：当需要同时向多个服务提供者发送请求，并处理它们的响应时，可以使用IP来接收和整合多个响应。
- 聚合数据：当需要从多个服务提供者获取数据，并将它们聚合到一个结果中时，可以使用IP来接收和整合多个响应。
- 分布式系统：在分布式系统中，不同的服务之间需要进行通信和数据交换，可以使用IP来实现消息驱动和事件驱动的集成。
推荐的腾讯云相关产品： 腾讯云提供了一系列与云计算和集成相关的产品，可以与Spring Integration结合使用，实现更强大的功能和性能。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CDB）：https://cloud.tencent.com/product/cdb_mysql
- 云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 人工智能平台（AI）：https://cloud.tencent.com/product/ai
- 物联网平台（IoT）：https://cloud.tencent.com/product/iotexplorer
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估和决策。
相关·内容
1回答
我似乎在将Spring后端配置为接收和发送TCP消息时遇到了一些困难。看看用户在这个问题中建议的配置-- --我尝试将这个配置放到我的root-context.xml中。但是，对于所有标记，它都会显示一条消息，如：
Unable to locate Spring NamespaceHandler for element 'int-ip:tcp-outbound-gateway' of schema namespace 'http://www.springframework.org/schema/integration/ip'
int-ip:tcp-outbou
浏览 7提问于2014-11-14得票数 1
回答已采纳
我有一个使用spring集成的简单tcp客户端，它接收消息并将其写入文件。 我希望客户端默认连接到thing.input.primary.host，但在连接失败的情况下，我希望它重新连接到thing.input.secondary.host，然后像正常一样发送消息；spring集成中是否支持此行为？ 编辑:为了清晰起见。我想做的是，如果thingClient失败，让它从thingClient切换到thingClientSecondary。 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:
浏览 52提问于2020-06-24得票数 0
我不能清楚地理解如何在Spring Integration中读取TCP流。我有一个外部服务，它将一些数据广播到连接到它的客户端(TCP、Java套接字)。我已经在Spring Integration中尝试了很多配置。我的应用程序成功地连接到我的外部服务(我可以从服务的日志中确认)，但我仍然无法捕获流。但是，当我手动向服务发送一些消息(通过MessageChannel)时，我的bean可以正常工作。这确实意味着我的配置被配置为捕获写入事件。我找不到明确的指南或手册来配置它以接收TCP流。我的项目中有以下xml配置：
<?xml version="1.0" encoding=
浏览 4提问于2016-12-22得票数 1
1回答
除了TCP之外，我还需要类似于的东西。因此，客户端发送消息和TCP服务器可以发送回响应，如OK。对于TCP套接字-表达式=“@inbound.socket”和destination-expression="headers'ip_packetAddress'“，不能使用。
我的配置现在是这样的：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns
浏览 3提问于2017-05-10得票数 3
回答已采纳
我正在开发Spring Integration来调用SOAP服务。无论如何，我能够通过出站网关调用SOAP服务，并且我正在接收响应。但是现在我需要调用一个安全的SOAP服务。如何使用Spring Integration调用它。在这个问题上，有人能帮我吗？提前谢谢你。
浏览 0提问于2014-12-24得票数 0
我正在使用spring集成tcp进行高容量集成，并且我只在一个连接上发送请求和接收数百万以上的数据，并且两个接收消息之间的时间不到100毫秒。 下面是我的context xml，我使用的是TCPOutboundGateway。 <?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-ip="http://www.springframe
浏览 84提问于2020-09-07得票数 0
回答已采纳
2回答
我正在尝试使用来发送和接收数据到使用HEX数据进行通信的大型机。因此，我的配置如下：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.
浏览 2提问于2017-08-21得票数 0
回答已采纳
我是和Spring支持的新手。我正在尝试启动一个TCP客户端
连接到serverSocket。ServerSocket在5678端口的本地主机上
客户端向服务器发送消息并接收响应。
但是在运行spring基本示例时，我得到了以下错误。
我已经修改了%spring-samples%/basic/tcp-client-server.xml代码。更改是我在tcpClientServerDemo-context.xml中注释掉了服务器端。
以下是变化。
<?xml version="1.0" encoding="UTF-8"?>
&l
浏览 3提问于2016-02-15得票数 0
回答已采纳
在使用通道适配器通过TCP发送/接收消息时，我得到了一个异常。我正在尝试使用TcpSendingMessageHandler发送消息到套接字，并使用TcpReceivingChannelAdapter接收消息。在这里，我可以发送消息，但在接收消息时出现异常。请让我知道我在配置中遗漏了什么。
我的配置类：
public class SampleTCPConnection {
//Client Side
@Bean
public MessageChannel requestChannel() {
return new DirectChannel()
浏览 8提问于2017-04-06得票数 0
我试图把FailoverCCF和CachingCCF结合起来，但至今没有成功。以下是我尝试过的：
FailoverClientConnectionFactory failoverClientConnectionFactory = new FailoverClientConnectoinFactory(underlyingCF());
failoverClientConnectionFactory.setSingleUse(true); // this is because CachingClient connection factory will force the singleUse = t
浏览 4提问于2015-07-17得票数 1
回答已采纳
我已经使用在线提供的文档和示例设置了Spring集成网关。我发送的XML消息是ISO-8859-1编码的，但是接收方告诉我消息是以与ISO-8859-1不同的编码发送给他们的。
我的配置如下所示：
<!-- Spring integration begins -->
<beans:bean id="javaDeserializer"
class="org.springframework.integration.ip.tcp.serializer.ByteArrayRawSerializer" />
<int:gat
浏览 0提问于2016-01-22得票数 1
我需要(我的应用程序)通过TCP连接在通道中接收命令(字符串值)。当我收到命令时，应用程序将其发送到路由器，将请求路由到不同的通道，以便使用服务激活器激活服务。
路由器首先验证命令。如果命令无效，则路由器不应允许进一步处理，需要将自定义错误消息发送回发送方(TCP客户端)。我想要一个解决方案，可以在路由之前或期间分析我的命令并发送错误响应，而无需任何进一步的处理。
以下是配置和代码。
弹簧集成Config
<ip:tcp-connection-factory id="server"
type="server"
port="$
浏览 5提问于2017-02-06得票数 0
回答已采纳
我的应用程序使用spring集成与第三方系统通信。我发送一个有效负载，并得到一个我解析和使用的响应。一切都很好。请在下面找到我使用的SI xml。 现在，我希望应用程序在我尝试连接的服务器不可用、超时或拒绝连接等异常情况下重新尝试建立连接。我如何使用SI xml配置来实现这一点？请指点一下。 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http:/
浏览 15提问于2019-02-18得票数 0
回答已采纳
我正在通过Spring Integration设置一个TCP客户端，发送带有字符串的消息作为有效负载，不期望返回。也许序列化程序/反序列化程序工作不正常？对不起，我正在学习Spring集成。 我可以通过oepnssl连接到外部TCP服务器： ---
# DC API Test System: microstrategy
sessions.list.
.
response
,status_code,1
,status_message,Unrecognised operation
,time,2019-02-15 07:08:08 (+1000)
. 我需要发送的命令是"sessions
浏览 53提问于2019-02-15得票数 0
我使用来处理数据，然后返回一个响应。我已经安装了入站适配器和出站适配器，并设置了几个通道来处理初始ACK并处理数据并向客户端返回响应。
当客户端断开连接时，我们触发一个额外的进程，该进程运行在数据库中的所有数据之上。
问题是当客户端发送数据，我们开始处理数据，然后客户端断开连接，出站适配器(？)尝试将该进程的响应发送回客户端。这会导致异常，并中断我们在断开连接后启动的附加进程的流。
在我的本地机器上运行它运行良好。当将其部署到运行Corretto 11的Amazon 2实例上的AWSElasticBean秸秆时，它会失败，出现以下错误。
在尝试发送之前，我不确定是否有一种方法可以检查客户端是否
浏览 2提问于2020-11-17得票数 1
摘要
我正在使用Spring的代理通过我的应用程序传输到上游服务器的TCP流，然后通过我的应用程序将该服务器的响应代理回客户机。虽然这是双向通信，但我需要高容量、异步吞吐量，所以不能使用网关.相反，我尝试使用第34.8.2节中描述的协作出站和入站通道适配器。
集成组件设置
请求
TcpReceivingChannelAdapter通过端口6060上的TcpNetServerConnectionFactory接收请求。它将这些请求放在请求QueueChannel上。请求由TcpSendingMessageHandler接收，它通过TcpNetClientConnectionFactory生成的客
浏览 0提问于2019-02-01得票数 0
我正在尝试创建一个TCP/IP模拟器，它模拟我无法在其上进行测试的生产服务器。服务器接收和发送字节数组，而不是字符串。
在使用Spring Integration时，我可以在不使用ByteArrayRawSerializer的情况下很好地进行对话，但是当我实现ByteArrayRawSerializer时，即使消息正在服务器上处理，我也无法将消息接收回客户端。
Transformers.objectToString()方法似乎是可疑的，但在这一点上，我相信我已经尝试了几乎所有的方法。敬请指教...
重要的客户端代码如下：
@Bean
FailoverClientConnecti
浏览 45提问于2019-12-04得票数 1
回答已采纳
我浏览了这篇文章并实现了eventListner。 I实现了Spring通道，如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integrati
浏览 0提问于2016-07-25得票数 0
回答已采纳
我构建在TCP网关上的应用程序运行良好。它接收传入TCP网关的请求消息，并将该消息转发给serviceActivator以准备响应，并将响应发送给客户端。
发送到客户端后，我想将消息保存到数据库中。我只是想知道，在向客户端发送响应后，是否可以将消息转发到另一个serviceActivator。
如果是，应该如何设置spring配置？我希望在这方面提供任何帮助。
以下是spring上下文文件：
<beans>
<int-ip:tcp-connection-factory id="crLfServer"
type="serv
浏览 3提问于2017-02-13得票数 1
回答已采纳
1回答
我正在编写一个小应用程序来检查openshift上几个spring特性的功能和配置。您可以在这里找到代码：
目前，我尝试测试spring集成tcp/ip支持，因为openshift对绑定到端口的能力有一些严格的限制。服务器套接字部分很简单:选择一个允许的端口并使用内部服务器ip (而不是localhost)。
我在客户端失败了。我想使用我的公共dns条目打开一个tcp连接来连接到我的服务器。据我所知(下面的堆栈跟踪)，我的应用程序无法打开到服务器的传出连接的本地套接字。
17:41:36.309 [pool-3-thread-1] DEBUG o.s.i.i.t.c.TcpNetClientC
浏览 4提问于2013-06-04得票数 1
回答已采纳
1回答
我试图使用4的DSL编写一个简单的消息流，如下所示：
-> in.ch -> Processing -> JmsGatewayOut -> JMS_OUT_QUEUE
Gateway
<- out.ch <- Processing <- JmsGatewayIn <- JMS_IN_QUEUE
由于请求/响应是异步的，当我通过初始网关注入消息时，消息会一直传递到JMS_OUT_QUEUE。除了这个消息流之外，还会将一个回复消息放回JMS_IN_QUEUE中，然后由JmsGatewayIn接收它。此时，消息将被处理并放置
浏览 1提问于2014-07-16得票数 1
回答已采纳
嗨，你能帮我一下吗？我在中使用Spring4.3.8。我得到了这个异常: org.springframework.beans.factory.parsing.BeanDefinitionParsingException:配置问题:无法为XML模式命名空间定位：类路径资源-config.xml
Maven配置：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-integration</artifac
浏览 3提问于2017-05-07得票数 1
回答已采纳
这是How to implement HTTP request/reply when the response comes from a rabbitMQ reply queue using Spring Integration DSL?的后续问题。 我们能够在本地成功构建Spring Integration应用程序和SCDF流。我们可以向rabbitMQ请求队列发送一个http请求，该请求队列被绑定到SCDF stream rabbit源。我们还可以从绑定到stream兔接收器的rabbitMQ响应队列接收返回的响应。 我们已经将SCDF流部署到绑定了内部rabbitMQ代理的PCF环境中
浏览 6提问于2021-04-08得票数 0
回答已采纳
我有一个客户端通过套接字向主机发送数据。偶尔我会得到java.io.EOFException。
问题是:我怎么知道是谁导致插座关闭的？这个异常总是因为远程主机关闭套接字而引发的吗？
或者也可能是一个内部网络连接问题？还是我的ISP？
org.springframework.messaging.MessagingException: Dispatcher failed to deliver Message; nested exception is org.springframework.messaging.MessagingException: Exception while awaiting
浏览 2提问于2017-09-08得票数 0
回答已采纳
1回答
我使用这个非常简单的配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-ip=&#
浏览 2提问于2017-05-09得票数 0
回答已采纳
如何实现服务激活器来读取特定字节数？
我的context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
浏览 3提问于2015-09-28得票数 2
回答已采纳
我正在尝试自动更新我的tcp-inbound-channel-adapter bean，定义如下。稍后，我将在某些条件下开始这项工作。
<int-ip:tcp-inbound-channel-adapter
id="inboundClient" channel="replies" connection-factory="client"
client-mode="true" auto-startup="false" retry-interval="10000" />
自动
浏览 1提问于2016-07-20得票数 0
回答已采纳
我正在尝试创建一个使用spring集成启动TCP客户端的服务。该服务传递一个hostName和port来创建AbstractClientConnectionFactory。然后使用相同的TcpInboundGateway创建一个AbstractClientConnectionFactory。最后，启动网关。我得到的错误发生在endOfLineSerializer完成后
@Service
public class TcpService {
@Autowired
private TaskScheduler taskScheduler;
private TcpInboun
浏览 0提问于2018-11-24得票数 1
回答已采纳
1回答
我有一个JMS出站网关，它通过请求队列发送消息，并通过响应队列接收消息。我想知道什么是将节流应用于响应队列中的消息接收部分的最简单方法。我尝试过将Poller设置为出站网关，但是当我设置它时，响应消息根本不会被消耗。在出站网关中可以使用Poller进行邮件消费节流吗？如果是这样的话，是怎么做的？如果没有，我如何才能最好地抑制消息响应消费呢？
我的堆栈是：
o.s.i:spring-integration-java-dsl:1.0.0.RC1
o.s.i:spring-integration-jms:4.0.4.RELEASE
我的IntegrationgConfig.class：
@Confi
浏览 2提问于2014-11-19得票数 1
回答已采纳
从我的应用程序中，我需要配置需要连接到单个服务器的多个客户端连接。为此，我根据配置了多少客户端，使用ApplicationContext Beanfactory创建了一个可变数量的bean。以下是两个客户端的代码：
//setup beans;
AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext();
ctx.scan("pkg");
ConnectionFactory factory = new ConnectionFactory();
int clients = 2;
浏览 5提问于2016-05-24得票数 2
回答已采纳
我有一个Spring集成服务器运行在一个tcp入站网关上，一个客户端使用常规的java套接字连接到服务器。
客户端连接到服务器，服务器处理请求，然后发送响应。客户端读取响应，然后使用socket.close()关闭连接。
在服务器端，配置了tcp连接-事件-入站通道适配器，我看到：
TcpConnectionExceptionEvent [source=org.springframework.integration.ip.tcp.connection.TcpNetConnection@2294e71d, cause=org.springframework.integration.ip.tcp.
浏览 0提问于2015-11-04得票数 1
回答已采纳
1回答
我有一个非常奇怪的情况，一个TCP服务器基本上维护两个协议。第一个消息对发送STX|PAYLOAD|ETX消息，并返回相同的STX|PAYLOAD|ETX消息类型。 另一个消息对发送STX|有效负载|ETX消息，但仅返回|有效负载|(无STX/ETX字节)。 我已经创建了一个自定义的序列化程序/反序列化程序来处理异常，但我收到的错误是在接收连接时发生的(如下面的堆栈跟踪所示)。 在服务器上使用CTRL进行测试使我能够接收消息。因此，我认为AbstractConnectionFactory在默认情况下使用ByteArrayCrLfSerializer。但是，当我尝试使用定制序列化程序时，连接工
浏览 31提问于2019-12-11得票数 0
回答已采纳
我试图在spring集成应用程序中启动一个简单的websocket服务器。
由于下列依赖关系，我构建了我的应用程序：
dependencies {
compile("org.springframework.boot:spring-boot-starter-integration")
compile("org.springframework:spring-websocket")
compile("org.springframework.integration:spring-integration-ip")
compi
浏览 2提问于2016-02-14得票数 0
回答已采纳
我使用int-ip:tcp-connection-factory和int-ip:tcp-outbound-gateway与外部服务器进行通信。服务器提供的大多数服务的协议遵循标准的请求-响应风格.效果很好。然而，在一些情况下，我只需要发送一个请求，而不需要响应。
我的问题是，如何配置我的通道和连接，以便我可以指定是否等待响应？目前，我无法找到一种方法，而且Spring总是在发送请求后阻塞，即使我没有期望得到响应。
编辑:正如建议的那样，我使用了一个tcp-outbound-channel-adapter。我的配置文件只有以下内容：
<int:channel id="request
浏览 2提问于2013-09-24得票数 1
回答已采纳
我有以下简单的代理集成流程。其主要任务是接收来自代理的请求，将其发送到实际端点，获取响应并将其发送回客户端。
@SpringBootApplication
@EnableIntegration
public class IntegrationApp {
@Value("${narko.pin}")
private String pinUrl;
public static void main(String[] args) {
SpringApplication.run(MinzdravApplication.class, args);
}
@Bean
publ
浏览 13提问于2022-08-10得票数 2
回答已采纳
1回答
客户端
、、、
我正在寻找一个示例，通过不使用xml(spring-integration)的快速引导连接TCP。
我从 URL中得到了以下片段。
在本例中，仅使用主方法就足以连接tcp。为什么其他豆类和变压器在这里声明？
这样做不对吗？我不使用简单的Java客户端来接受响应，而是与Spring集成。但是没有使用Java的适当示例。
你能帮忙吗？
package com.example;
import java.net.Socket;
import javax.net.SocketFactory;
import org.springframework.boot.SpringApplication;
im
浏览 0提问于2019-01-05得票数 3
回答已采纳
1回答
我有以下要求
连接到套接字(TCP)
发送初始化消息没有来自服务器的响应
检查连接是否处于活动状态，如果是，则发送轮询消息。
如果有一个响应过程的话。
我试图为TCP连接使用Spring集成，但当我尝试执行第二步时，框架将等待响应。是否有一种方法可以将其配置为不等待步骤2中的响应？
以下是Spring配置：
<int:gateway default-request-channel="msOutbound"
service-interface="com.home.tcp.UserService" id="g
浏览 2提问于2016-04-04得票数 0
基本上，我不知道港口在手。我将向主机发出REST请求，以发送端口号。我正在获取端口号，但无法继续前进，因为我无法将连接工厂设置为带有接收端口号的inBoundClient。请看下面的代码，了解问题所在。
我的tcp连接定义如下：
<?xml version="1.0" encoding="UTF-8"?>
<context:component-scan base-package="com.tcpclient" />
<beans xmlns="http://www.springframework.org/sc
浏览 5提问于2016-07-25得票数 0
回答已采纳
我正在尝试使用控制总线命令(即@AdapterID.stop() )停止带有客户端连接工厂的TCP适配器，用于创建流的代码如下：
IntegrationFlow flow = IntegrationFlows.from(Tcp.inboundAdapter(Tcp.nioClient("127.0.0.1",3226))
.serializer(customSerializer)
.deserializer(customSerializer)
.id("abc")).clientMo
浏览 1提问于2018-06-04得票数 2
1回答
无法发送UDP消息的响应
、、、、
我正试图通过以下方式发送信息：
netcat -u localhost 11111abcd
我只需要客户端得到答案:好的，它得到消息，然后尝试用OK回答。但是它会无限地将其写入应用程序日志：
消息: GenericMessage [payload=byte2，payload=byte2 ip_address=127.0.0.1，id=8db6aa3b-b56b-6dce-9554-c7b0ce050142，ip_port=49489，ip_hostname=127.0.0.1，timestamp=1494442285767}]
消息有效负载:确定
配置：
<?xml versio
浏览 2提问于2017-05-10得票数 0
回答已采纳
我们目前有Spring Boot应用程序，它们使用Spring Integration SFTP来发送和接收基于Cron时间表的文件。我们正在尝试使用Spring Cloud Function将应用程序转换为Azure函数。我只是想知道，当应用程序从Azure函数接收http调用时，有什么方法可以调用Spring Integration SFTP适配器运行一次吗？从Spring Integration的文档中可以看出，轮询器的唯一选择要么是Cron，要么是固定速率/固定延迟。提前感谢您的帮助或建议！
浏览 14提问于2020-09-22得票数 0
我是春季集成的新手，目前还在测试我的集成流程。我的流量看起来就像这样。
format.Convert 从TCP通道适配器收到一些数据，在XML 中将其发送到JSON。将JSON消息发送到amazon .。
XML文件是：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instanc
浏览 3提问于2021-09-13得票数 0
回答已采纳
我一直在使用spring Framework4开发一个项目，我正在尝试通过spring-integration-ip库创建一个简单的TCP客户端。我已经调整了所有的配置：
applicationContext.xml
...
<int:channel id="tcpChannel" />
<int-ip:tcp-outbound-channel-adapter id="outboundClient"
channel="tcpChannel"
connection-factory="tcpConnectionFactor
浏览 2提问于2018-07-28得票数 1
1回答
我使用spring集成来创建一个客户端套接字(java代码)，它必须将消息发送到服务器套接字(闪存客户端)。基本上，我希望通过套接字通信将消息推送到闪存，而不考虑来自它的任何响应。应该发送的消息从GW到send方法被调用。
我能够推送一条消息，但问题是我的客户端套接字正在等待一个响应，如果它没有得到响应，它会在某个时候超时。这是我的配置：
<int:gateway id="gw"
service-interface="integration.MessageGateway"
default-request-channel="input
浏览 5提问于2014-07-17得票数 0
回答已采纳
我在下面的screnario中使用SI 3.0.2：
客户端向我发送TCP套接字消息。
使用TCPInboundGateway接收消息
使用HttpOutboundGateway转换消息并将其发送到REST服务
接收HTTP响应并再次转换它
通过TCPInboundGateway replyChannel将转换后的消息发送回客户端
客户收到了我的答复。
不幸的是，我依赖的是一个质量很差的网络，有时客户端和我的SI服务器之间会断开连接。另一个方向(HTTP )是稳定的。因此，当SI服务器与REST服务通信时，我想检测客户机何时断开连接。
我找到了一个解决方案，tcp连接-
浏览 12提问于2014-07-01得票数 0
回答已采纳
1回答
服务器:获取Ip地址&有效负载
、、、、
我刚刚开始使用，我实现了TCP服务器，它只向客户机发送一个"OK“消息。我想记录客户端IP地址和从客户端收到的文本。
我能够成功地获得以下配置文件由客户端发送的文本，但我不知道如何获得客户端的IP地址。
下面是TCP服务器的配置文件。
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframewor
浏览 0提问于2014-08-27得票数 0
回答已采纳
1回答
在计票器从DB获取数据后，我将调用外部服务。在从该服务获得响应后，我想在一个单独的线程中调用另一个系统。这意味着，在得到响应后，我的计票程序应该再进行一次记录，并且send.In加法调用其他系统应该并行地工作。
为此，我使用了一个直接通道来接收来自DB的数据。使用服务激活器向外部服务发送请求。响应被传递给一个执行者channel.can，请告诉我下面的配置对于这个场景是否正确？
为了清晰起见，我共享poller.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http
浏览 1提问于2015-11-26得票数 0
回答已采纳
我将我的Spring Boot版本从2.1.8.RELEASE升级到2.2.2.RELEASE (因此Spring Integration从5.1升级到5.2.2.RELEASE)，如果我们在符合条件的spring转换器中有一个杰克逊转换器，那么使用@IntegrationConverter的自动转换似乎不再有效。 转换器是自动声明的，因为我在项目依赖项中声明了对jackson-databind的依赖项。我需要jackson，因为我必须将从HTTP请求接收到的有效负载转换为java bean。但是因为这个转换器是声明的，所以它被用来代替Spring integration bean，并且它无
浏览 55提问于2020-01-07得票数 1
回答已采纳
1回答
嗨，我正在尝试构建一个Spring引导应用程序，并使用spring集成。
应用程序1: Publisher
Jms Message -> Broker ->queue1
应用程序2:订阅者和发行者
Broker->queue1->Transform->HTTP CALL->HTTP Response->JMS Message->Broker->queue2
Publisher Flow
@Configuration
public class EchoFlowOutBound {
@Autowired
private Con
浏览 0提问于2018-07-27得票数 1
回答已采纳
我有一个用例，在这种情况下，我们通过web服务接收有效负载，web服务可能包含单个业务消息或其中的许多业务消息。
在我们的SI流中，我们使用Splitter将接收到的有效载荷分解为不同的业务消息(可能在其中最多有5000条业务消息)，如果有效负载包含多个业务消息，则在拆分列表开始时使用Splitter还包括响应业务消息。拆分后，我们有一个Router将列表中的第一个消息(响应业务消息)路由到一个通道(response.ch)，该通道作为响应返回到web服务Endpoint，所有其他业务消息都路由到另一个通道(request.jms.ch)，该通道将消息传递到MQ队列中，以便在其他地方进行处理。
浏览 4提问于2014-11-25得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
