​
安装 RocketMQ

下载脚本文件

git clone https://github.com/pig-mesh/rocketmq-docker-compose

修改 IP 为宿主机 IP

vim ./broker.conf

执行启动 rocketmq

docker-compose up -d

​
代码整合

目标服务增加 rocketmq 依赖 jar

<dependency>
    <groupId>com.pig4cloud.plugin</groupId>
    <artifactId>rocketmq-spring-boot3-starter</artifactId>
    <version>2.2.3</version>
</dependency>

nacos 对应的服务配置文件增加链接相关信息

rocketmq:
  name-server: 192.168.0.12:9876
  producer:
    group: test-group

配置队列监听消费者

@Slf4j
@Service
@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "test-group")
public class MyConsumer1 implements RocketMQListener<String> {
    public void onMessage(String message) {
        log.info("received message: {}", message);
    }
}

测试消息发送

@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    void contextLoads() {
        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
    }
}

​
♥️ 获取支持

遇到问题？

如果您在使用过程中遇到任何问题、有功能建议或需求，请点击此卡片前往 Gitee 仓库提交 Issue。