Spring Cloud Stream Apps - 在步骤之间传递信息

Question

谁能建议我在 SCDF 管道的步骤之间传递元数据的方法？ 以下是我试图解决的一些用例：

1. 使用“文件”源时，名称、目录、大小等文件详细信息将传递到下一步。
2. 我希望将在流程步骤中创建的一些元数据传递到下一个步骤。 （此元数据与有效负载分开）

我希望有一种方法可以在 rabbit 或 kafka 消息头中发送此类详细信息。

Answer 1

您当然可以/应该使用消息标头。 请记住，您控制他处理程序方法的返回值。如果您的处理程序方法返回 POJO，那么框架将从它创建一个 Message 复制某些标头等。但是，在您的情况下，如果您想控制进入 Message 的所有内容（包括标头），您只需要定义处理程序方法返回消息（见下文）：

@StreamListener(..)
@SendTo(..)
public Message<?> handle(String str) {
  . . .
  return MessageBuilder.withPayload(..).setHeader(..).setHeader(..).build();
}