【spring cloud streamMQ】采用新版 spring 官方推荐 streamBridge 生产消费 streamMQ 示例
在Spring Cloud Stream中，你可以使用StreamBridge来向消息中间件发送消息，而不管消息最终流向哪个目的地。这是一个简单的例子：
- 首先，在你的Spring Boot应用中引入Spring Cloud Stream依赖和对应的消息中间件（如RabbitMQ或Kafka）依赖。
- 配置你的消息通道。
@EnableBinding(Processor.class)
public class StreamBridgeExample {
@Autowired
private StreamBridge streamBridge;
public void sendMessage(String message) {
streamBridge.send("output-channel-name", MessageBuilder.withPayload(message).build());
}
}在上面的代码中，output-channel-name是你定义的输出消息通道的名称。StreamBridge用于将消息发送到这个通道，而这个通道连接到了消息中间件。
要注意的是，StreamBridge应该仅用于发送消息，不应该用于接收消息。接收消息应该通过定义对应的@StreamListener方法来处理。
评论已关闭