整合 RocketMQ 消息队列

点击查看【bilibili】

安装 RocketMQ

• 下载脚本文件

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

• 修改 IP 为宿主机 IP

vim rocketmq-docker-compose/data/broker/broker.conf

• 执行启动 rocketmq

./run.sh

代码整合

• 目标服务增加 rocketmq 依赖 jar

<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-spring-boot-starter</artifactId>
  <version>2.2.1</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 static 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!");
    }
}

❤ 问题咨询