响应 通过 Rest Api 在多个出站网关调用之间传递的响应消息

Question

我有一个通过Rest接收消息的入站网关。收到的所有消息都进入内部网关。下面是入站网关xml文件。

 <bean name="testConfig" class="test.TestApiConfiguration"/>
    <context:annotation-config/>

    <int-http:inbound-gateway request-channel="requestChannel" supported-methods="POST" path="/data" reply-channel="replyChannel"
                              request-payload-type="com.test.model.CallFlow" header-mapper="cc20InBoundHeaders" error-channel="errorChannel" reply-timeout="9000">
        <int-http:request-mapping produces="application/json" consumes="application/json"/>
    </int-http:inbound-gateway>

    <bean id="cc20InBoundHeaders" class="org.springframework.integration.http.support.DefaultHttpHeaderMapper">
        <property name="inboundHeaderNames" value="*"/>
    </bean>

    <bean id="cc20OutBoundHeaders" class="org.springframework.integration.http.support.DefaultHttpHeaderMapper">
        <property name="outboundHeaderNames" value="Content-Type, HTTP_REQUEST_HEADERS"/>
        <property name="userDefinedHeaderPrefix" value="" />
    </bean>

因此，入站网关消息正确地以Json形式到达，然后内部网关接受它们，并根据配置将消息传递到通道中。

@MessagingGateway(name="callFlowGateway", requestChannel = "callFlowRequestChannel")
public interface ICallFlow {

    /**
     * Process CallFlow Request
     * @param message SI Message covering APiCall payload and relevant headers for service
     */
    @Gateway
    void processCallFlowRequest(Message<CallFlow> message);

}

直到这里，它的工作如预期的那样。消息先流向过滤器，然后流向路由器。在路由器中，如果一个json属性的类型是“饮料”服务，那么将调用饮料通道，并调用相关的出站网关来请求REST上的外部APIendpoint。

但是在调用该外部API的每个其余endpoint之前，您需要有一个有效的会话ID令牌来访问其他endpoint。它在其有效负载中返回一个会话ID来调用其他endpoint。此外，它将application/x-wan-form-urlencoded作为内容类型的标头。我创建了一个转换器来创建对身份验证服务的请求。

@MessageEndpoint               
public class AuthenticateTransformer {

    @Transformer(inputChannel = "splitterChannel", outputChannel = "authenticateRequestChannel")
    public Message<?> transform(CallFlow callFlow) {

        Map<String, Object> messagePayload = new HashMap<String, Object>();
        messagePayload.put("user", "test");
        messagePayload.put("password", "test");
        return MessageBuilder.withPayload(messagePayload).setHeader("Content-Type", "application/x-www-form-urlencoded").build();
        }
}

因此，理想情况下，一个对入站网关的调用-Json被转换为一个内部对象。基于JSON中的一个属性值，我使用http出站网关调用不同的外部restendpoint。

因为获取会话id的身份验证调用不在接收到的Json中，所以我必须在流中创建一个订单。

> < li>

我需要调用http出站网关进行身份验证，以获取该会话id。我如何从入站网关调用这个出站，因为它应该在每次调用其他endpoint之前执行。

在我获得该会话id后，我希望其他endpoint优先于rest，在此阶段，我希望调用ICallFlow gateway，以便基于json中的值和步骤1中的会话id，我可以调用其他Restendpoint并获得响应。

所以，我无法将会话ID令牌从第一次调用传递到第二次调用？另外，我希望只有在第一次身份验证请求完成后才能调用ICallFlow，并将该会话传递到其他后续请求中。我读到标头enrich可以做到这一点，我可以将有效负载放入标头中，但不知何故它不起作用。此外，我不知道如何以正确的顺序创建上述流。

任何帮助都将不胜感激。

Answer 1

你在一个单独的线程中包含了太多的信息，不知何故会造成混乱和误导。

我能给你的建议是ContentEnrich：https://docs.spring.io/spring-integration/docs/5.0.1.RELEASE/reference/html/messaging-transformation-chapter.html#payload-enricher

因此，您将通过< code>request-channel子流调用auth服务，获取一个会话id，并能够将其填充到标头或< code>ICallFlow有效负载中(如果可能)。

在@Transformer用例中使用消息生成器时应小心。之后不会合并请求标头，您将无法对

传送请求头的方式类似于在< code>transform()方法中接受< code>Message并在< code>MessageBuilder上调用< code>copyHeaders()。