Spring Integration 使用 randomUUID 丰富标头

我是 Spring Integration 的新手，使用 Java 7，在转向 Spring 集成 DSL 之前我有这个 xml 配置，并且我的应用程序正在努力使用从随机 UUID 生成的监视 ID 来丰富标头（这是为了将请求与稍后在日志中搜索的响应，也许这可以以不同的方式完成，不知道）：

<int:chain input-channel="requestChannel" output-channel="responseChannel">     
    <int:header-enricher>
        <int:header name="translator-monitoringId" expression="T(java.util.UUID).randomUUID()"/>
    </int:header-enricher>
    <int:transformer ref="customHeaderTransformerBean" method="convertToJson"/>     
    <int-amqp:outbound-gateway      
        exchange-name="translatorExchange"      
        amqp-template="amqpTemplate"        
        routing-key-expression ="headers['translatorRoutingKey']"       
        mapped-request-headers="translator-*"       
        mapped-reply-headers="translator-*"/>       
</int:chain>

因此，在转向 DSL 后，我得到了以下结果：

return IntegrationFlows
    .from("requestChannel")
    .enrichHeaders(new Consumer<HeaderEnricherSpec>() {
        @Override
        public void accept(HeaderEnricherSpec t) {
            t.header(Constants.MONITORING_ID, UUID.randomUUID());
        }
    }) 
    .transform(customToJsonTransformer())
    .handle(Amqp
        .outboundGateway(rabbitTemplate())
        .exchangeName(TRANSLATOR_EXCHANGE_NAME)
        .routingKeyExpression(
            "headers['" + Constants.TRANSLATOR_ROUTING_KEY + "']")
            .mappedReplyHeaders(Constants.AMQP_CUSTOM_HEADER_FIELD_NAME_MATCH_PATTERN)
            .mappedRequestHeaders(Constants.AMQP_CUSTOM_HEADER_FIELD_NAME_MATCH_PATTERN))
        .route(new ResponseFromTranslatorRouterSI(jsonResponseMessageChannel(), exceptionResponseMessageChannel())).get();

好吧，问题是随机 UUID 作为监听 ID 包含在标头中，但在第一次执行后它保持不变，它不会像以前那样随着每个请求而改变。

你知道我是否遗漏了什么吗？

感谢您的帮助。

对，那是正确的。

让我们再看一下您的代码：

public void accept(HeaderEnricherSpec t) {
      t.header(Constants.MONITORING_ID, UUID.randomUUID());
}

所以，当你的UUID.randomUUID()会被评价吗？对了，就在期间accept()方法调用。因此只有一次。

使用您处理的 XML 变体expression它真正评估每条消息。

要使其以 Java DSL 风格工作，您应该执行类似的操作：

 t.headerExpression(Constants.MONITORING_ID, "T(java.util.UUID).randomUUID()");

或者更好的是：

t.headerFunction(Constants.MONITORING_ID, 
     new Function<Message<Object>, Object>() {
           Object apply(Message<Object> message) {
               return UUID.randomUUID();
           }
     }
);