使用rocketmq-spring-boot-starter发送，消费消息的简单示例

发布日期: 2021-04-02

文章字数: 261

阅读时长: 1 分

阅读次数:

使用rocketmq-spring-boot-starter发送，消费消息的简单示例

1. 引入依赖

<!-- rokcetmq starter  -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.0</version>
</dependency>

2. 修改配置文件

# application.properties
rocketmq.name-server=139.224.103.236:9876
rocketmq.producer.group=spring-application-name

3. 生产者发送消息

// 引入rocketMQTemplate
@Autowired
private RocketMQTemplate rocketMQTemplate;

// 通过rocketMQTemplate发送消息。
// destination: formats: `topicName:tags`
// payload: 消息内容
rocketMQTemplate.syncSend("CSS:ORDER_CANCEL", "orderId-111");

4. 消费者接受消息

消费的的依赖和配置文件同生产者一样。组名修改即可。

@Slf4j
@Component
@RocketMQMessageListener(topic = "CSS", selectorExpression = "ORDER_CANCEL", consumerGroup = "spring-application-name")
public class TestConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("Receive message：" + message);
        // 业务逻辑处理。。。
    }
}