向 http-inbound-gateway 的回复通道发送消息

Question

我有一个带有弹簧集成的以下设置。

<int-http:inbound-gateway id="restListener"
                          request-channel="restChannel"
                          reply-channel="restResponseChannel"
                          path="/service"
                          supported-methods="POST"
                          reply-timeout="5000"
</int-http:inbound-gateway>



<int:channel id="restChannel"/>
<int:channel id="restResponseChannel"/>

<int:service-activator input-channel="restChannel"
                       ref="restRequestHandler"
                       method="handleRestRequest"/>

我在网关上收到 2 种不同类型的 POST 请求，它们都被传递给service-activator 进行处理。在一种类型的 POST 请求中，我的 service-activator 可以立即处理它并以标准响应回复。但是，其他类型的请求将通过不同的通道路由并由不同的处理器处理（取决于内容）。我希望处理这两种类型的请求的输出作为 REST 调用的response 发送。

对于第一种类型的请求，我可以简单地这样做

public void handleRestRequest(Message<JsonNode> postMessage) {
     if (type1) {
        // Do processing
        restResponseChannel.send(MessageBuilder
                .withPayload("{\"result\":\"success!\"}")
                .copyHeaders(postMessage.getHeaders())
                .build());
     } else {
        // send to another channel for further processing
     }

}

但是对于第二种类型的请求，如果我尝试将send 输出到restResponseChannel（没有标题），那么我会遇到异常

org.springframework.messaging.core.DestinationResolutionException: 否 output-channel 或 replyChannel 标头可用

我无权访问第二种请求的原始标头。如何将输出发送到reply-channel？ （我在某处读到网关创建了一个匿名通道来连接到reply-channel，并且没有这些标头会导致异常，但是我不完全了解底层机制来自己调试）

Answer 1

你完全正确理解。

如果您不携带请求标头，则没有TemporaryReplyChannel 标头可以将回复与响应相关联。实现见GenericMessagingTemplate.doSendAndReceive()：

TemporaryReplyChannel tempReplyChannel = new TemporaryReplyChannel(this.throwExceptionOnLateReply);
    requestMessage = MessageBuilder.fromMessage(requestMessage).setReplyChannel(tempReplyChannel)
            .setHeader(this.sendTimeoutHeader, null)
            .setHeader(this.receiveTimeoutHeader, null)
            .setErrorChannel(tempReplyChannel).build();

    try {
        doSend(channel, requestMessage, sendTimeout);
    }
    catch (RuntimeException ex) {
        tempReplyChannel.setSendFailed(true);
        throw ex;
    }

    Message<?> replyMessage = this.doReceive(tempReplyChannel, receiveTimeout);

所以，如果没有那个标题，就不可能接受回复。这种行为与许多其他消息replyAddress 模式中的行为相同。

reply-channel="restResponseChannel" 只是为了方便您不想查询下一个频道的标头，或者当您不仅想向响应发送回复，而且想向其他地方发送回复时 - 发布-订阅模式。

除非携带标题，否则您别无选择。一种是直接使用Message，另一种是使用@Headers Map<String, Object>服务方法。