Spring Cloud Stream 3.x 集成 RocketMQ

配置

spring:
  cloud:
    stream:
      rocketmq:
        binder:
          name-server: localhost:9876
      function:
				# 这里配置消费者函数名，多个函数以;隔开
        definition: myTopic
      bindings:
				# 生产者，前缀必须以对应的 definition , out 代表生产者，0 代表索引
        myTopic-out-0:
					destination: my-topic
					group: test
				# 消费者，前缀必须以对应的 definition , in 代表消费者，0 代表索引
        myTopic-in-0:
          destination: my-topic

手动发送消息

@Component
public class MQProducer {

    @Resource
    private StreamBridge streamBridge;

    public void sendMsg() {
        streamBridge.send("myTopic-out-0", "test");
    }
}

接收消息

@Component
public class MQConsumer {

    public Consumer<String> myTopic() {
				return message -> {
					System.out.print(message )
				}
    }
}

Reference

SpringCloud之Stream消息驱动RocketMQ讲解 - 上善若泪 - 博客园

[toc] # 1 Stream消息驱动 本文是以 `RocketMQ` 为例讲解，[点击此处了解SpringBoot整合RocketMQ](https://jingzh.blog.csdn.net/article/details/130554340) ## 1.1 简介 ### 1.1.1 定义

https://www.cnblogs.com/jingzh/p/17513839.html