读取AMQP消息头spring cloud stream

Question

我开发了spring批处理应用程序，该应用程序生成由json对象列表组成的amqp（rabbitmq）消息。消息具有包含一些元数据的标头。Spring cloud stream应用程序正在消费消息，我使用了功能性方法。如何访问标题<将消息头用于除路由之外的任何内容，这是一种糟糕的方法吗？

Answer 1

如果Spring Cloud Stream应用程序中的函数签名接受消息（例如）：

@Bean
public Consumer<Message<?>> consume() {
    return message -> {
        message.getHeaders()....
    };
}

...然后您可以简单地访问消息头。我们也在努力简化它。

不，将消息头用于除路由之外的任何事情都不是一种坏方法。将消息头视为元信息，仅与当前消息相关。对当前消息重要但不在之后的任何内容。