spring 集成 tcp 服务器向 tcp 客户端发送消息

Question

我要写一个完美的client-server应用是Spring集成。我有一个服务器接收消息并向客户端发送响应的部分。

我也想不时向客户发送一些信息。我在 TcpConnectionEvent 中设置了一个带有 connectionId 的 header，但没有任何反应。下面是我的代码。我从几天开始就遇到了这个问题。感谢您的帮助！

<!-- CLIENT SIDE -->

<int:gateway id="gw"
    service-interface="com.app.hos.service.client.Gateway"
    default-request-channel="input"/>

<int-ip:tcp-connection-factory id="client"
    type="client"
    host="localhost"
    port="14020"
    single-use="false"
    so-timeout="10000"
    />

<int:channel id="input" />

<int-ip:tcp-outbound-gateway id="outGateway"
    request-channel="transformChannel"
    reply-channel="reply"
    connection-factory="client"
    request-timeout="10000"
    reply-timeout="10000"
    />
<int:channel id="transformChannel" />

<int:channel id="reply" datatype="java.lang.String" />

<!-- TRANSFORMERS -->
<int:transformer id="testTransformer" ref="testTransformerBean" input-channel="input"
         method="transform" output-channel="transformChannel"/>

<bean id="testTransformerBean" class="com.app.hos.service.integration.Transformer" />

<!-- SERVER SIDE -->

<bean id="connectionSerializeDeserialize" class="com.app.hos.service.integration.ByteArrayToStringConverter"/>

<int-ip:tcp-connection-factory id="hosServer"
    type="server"
    port="14020"
    serializer="connectionSerializeDeserialize"
    deserializer="connectionSerializeDeserialize"
    using-nio="true"/>

<int-ip:tcp-inbound-gateway id="inputHosGateway"
    connection-factory="hosServer"
    request-channel="toServerChannel"
    error-channel="errorChannel"/>


<int:channel id="toServerChannel"/>

<int:channel id="errorChannel"/>

<int:channel id="inputChannel" />

<int:service-activator input-channel="toServerChannel"
    ref="server"
    method="serverTest"/>

<bean id="server"
    class="com.app.hos.service.server.Server" />


<!-- TCP EVENTS -->

<int:service-activator input-channel="eventChannel"
    ref="event"
    method="eventTest"/>

<bean id="event"
    class="com.app.hos.service.integration.Event" />

<int:channel id="eventChannel"/>

<int-event:inbound-channel-adapter channel="eventChannel"
                event-types="org.springframework.integration.ip.tcp.connection.TcpConnectionEvent"/>

我设置 connectionId 的 Transforemr：

@Autowired
public Event event;

public Message<String> transform(Message<String> msg) {

    Message<String> newMessage = MessageBuilder.withPayload(msg.getPayload())
            .setHeader(IpHeaders.CONNECTION_ID, event.getConncetionId())
            .copyHeadersIfAbsent(msg.getHeaders())
            .build();
    return newMessage;
}

我尝试通过网关发送消息的 MVC 控制器：

@Autowired
public TestController(Gateway gateway) {
    this.gateway = gateway;
}

@RequestMapping(value = "/showTest", method=RequestMethod.GET)
public String showTestPage() {
    return "test/sendMessageTest";
}

@RequestMapping(value = "/sendMessage", method=RequestMethod.GET)
public void sendMessage() {
    gateway.send("Working!");
}

Answer 1

您不能在发送任意数据时使用网关，它们严格用于 request/reply 消息传递。

无论如何，您发送到一个完全不同的连接。

您需要一个入站通道适配器和出站通道适配器（共享服务器连接工厂），而不是入站网关。

当您想发送任意数据（不是 request/reply 的一部分）时，将消息发送到 oubound 通道适配器，并适当设置连接 ID header。

Answer 2

感谢帮助！这就是解决方案：

<int:channel id="input" />

<int-ip:tcp-outbound-channel-adapter id="outboundChannel"
    channel="transformChannel"
    connection-factory="hosServer" />

<int-ip:tcp-inbound-channel-adapter id="inboundChannel"
    channel="toServerChannel"
    connection-factory="hosServer"
    />


<int:channel id="transformChannel" />

<int:channel id="reply" datatype="java.lang.String" />

<!-- TRANSFORMERS -->
<int:transformer id="testTransformer" ref="testTransformerBean" input-channel="input"
         method="transform" output-channel="transformChannel"/>

<bean id="testTransformerBean" class="com.app.hos.service.integration.Transformer" />

<!-- SERVER SIDE -->

<bean id="connectionSerializeDeserialize" class="com.app.hos.service.integration.ByteArrayToStringConverter"/>

<int-ip:tcp-connection-factory id="hosServer"
    type="server"
    port="14020"
    serializer="connectionSerializeDeserialize"
    deserializer="connectionSerializeDeserialize"
    using-nio="true"/>


<int:channel id="toServerChannel"/>

<int:channel id="errorChannel"/>

<int:channel id="inputChannel" />

<int:service-activator input-channel="toServerChannel"
    ref="server"
    method="serverTest"/>

<bean id="server"
    class="com.app.hos.service.server.Server" />


<!-- TCP EVENTS -->

<int:service-activator input-channel="eventChannel"
    ref="event"
    method="eventTest"/>

<bean id="event"
    class="com.app.hos.service.integration.Event" />

<int:channel id="eventChannel"/>

<int-event:inbound-channel-adapter channel="eventChannel"
                event-types="org.springframework.integration.ip.tcp.connection.TcpConnectionEvent"/>

spring 集成 tcp 服务器向 tcp 客户端发送消息

spring integration tcp server send message to tcp client

spring

client

tcp

spring-integration

server