spring 集成 dsl 流变量以在流中存储和检索

Question

我正在寻找一些流变量，我需要在其中存储诸如 orderId、customerId 和流中收到的其他响应之类的值，以便我可以在流的后期使用它们来编写业务逻辑。

    .handle(outboundGateway("localhost:8080/order?orderId={orderId}")
                            .uriVariable("orderId", m -> m.getPayload())
                            .httpMethod(HttpMethod.GET)
                            .expectedResponseType(Order.class)

    .handle(outboundGateway("localhost:8080/orderDetails?orderId={orderId}")
                            .uriVariable("orderId", m -> m.getPayload())
                            .httpMethod(HttpMethod.GET)
                            .expectedResponseType(OrderDetails.class)

    .handle(outboundGateway("localhost:8080/customer?customerId={customerId}")
                            .uriVariable("customerId", m -> ((OrderDetails)m.getPayload()).getCustomerId())
                            .httpMethod(HttpMethod.GET)
                            .expectedResponseType(Customer.class)

    .handle(outboundGateway("localhost:8080/customerAddress?addressId={addressId}")
                            .uriVariable("addressId", m -> ((Customer)m.getPayload()).getAdderssId)
                            .httpMethod(HttpMethod.GET)
                            .expectedResponseType(CustomerAddress.class)
    .handle((p, h) -> somebusinesslogic)

Answer 1

流程中没有像state 这样的抽象。好吧，本质上，运行时根本没有流量。 IntegrationFlow 只是一个逻辑容器。将 Spring Integration 解决方案完全视为 stateless 会更好（除非我们谈论的是 aggregator）。

不过，有一种解决方案适合您，例如将任何额外所需的信息连同其标头中的消息一起传输。这样，您在.handle() 之前使用.enrichHeaders()，并且根据ServiceActivator 的传播性质，请求标头将复制到回复消息，因此它们可用于下一个流程步骤。