3

我正在使用 Spring Boot 创建一个 Spring Integration 原型。

我有一个接受控制台输入并将其发送到单独的套接字/tcp 应用程序的“集线器”。

tcp 应用程序回显它在对集线器的回复中发送的内容。

然后集线器获取 tcp 响应并将其发送到单独的 restful/http 应用程序。http 应用程序回显发送回集线器的内容。

我被困在集线器的 int-http:outbound-gateway 上，它向 http 发送请求。当我省略“回复通道”时，我可以输入不止一位文本并发送到 tcp 应用程序。该回复被转发到 http 应用程序并打印在控制台中。但是，当我包含回复通道时，我可以向 tcp 应用程序发送一条消息（http 应用程序接收它），然后集线器应用程序“停止”；我在控制台中输入消息，点击“输入”，但没有任何反应。

这是我的配置：

    <!-- TO tcp application/server -->
    <int:channel id="input" />

    <int:gateway id="simple.gateway"
        service-interface="com.foo.SimpleGateway"
        default-request-channel="input"/>

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

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

    <int:object-to-string-transformer id="clientBytes2String"
        input-channel="clientBytes2StringChannel"
        output-channel="broadcast.channel" />

    <int:channel id="broadcast.channel" />

    <int:recipient-list-router id="tcp.broadcast.list"
        input-channel="broadcast.channel">
        <int:recipient channel="to.http" />
        <!-- other channels to broadcast to -->
    </int:recipient-list-router>

    <!-- TO HTTP restful endpoint -->
    <!-- this sends the requests -->
    <int:channel id="to.http" />

<!--    <int-http:outbound-gateway id="http-outbound-gateway"  -->
<!--        request-channel="to.http" -->
<!--        url="http://localhost:8080/howdy?message={msg}" -->
<!--        http-method="GET" -->
<!--        expected-response-type="java.lang.String" -->
<!--        charset="UTF-8"> -->
<!--        <int-http:uri-variable name="msg" expression="payload"/> -->
<!--    </int-http:outbound-gateway> -->

    <int-http:outbound-gateway id="http-outbound-gateway" 
        request-channel="to.http"
        url="http://localhost:8080/howdy?message={msg}"
        http-method="GET"
        expected-response-type="java.lang.String"
        charset="UTF-8"
        reply-channel="from.http.pubsub.channel">
        <int-http:uri-variable name="msg" expression="payload"/>
    </int-http:outbound-gateway>

<!-- http://docs.spring.io/spring-integration/reference/html/messaging-endpoints-chapter.html -->
<int:publish-subscribe-channel id="from.http.pubsub.channel" />

<bean id="inboundHTTPPrinterService"
        class="com.foo.service.InboundHTTPPrinterService"/> 

<int:service-activator id="inboutdHttpPrintServiceActivator"
    ref="inboundHTTPPrinterService"
    input-channel="from.http.pubsub.channel"
    method="printFromHttp"/>

</beans>

在其最终形式中，我希望在某处打印 HTTP 响应并转发到单独的 AMQP 应用程序。

4

1 回答 1

0

您的描述不清楚，但是，我想，您的意思是这里的一些问题：

<int:service-activator id="inboutdHttpPrintServiceActivator"
    ref="inboundHTTPPrinterService"
    input-channel="from.http.pubsub.channel"
    method="printFromHttp"/>

很高兴看到printFromHttp()源代码，但根据您的担心，该方法似乎是void.

要将消息发送回replyChannel标头中，您应该从服务方法中返回一些内容。看起来在你的情况下它就足够了，payload或者message如果那样的话。

于 2016-01-21T19:57:06.503 回答