确实,RocketMQ与Spring Boot可以集成。在Spring Boot中集成RocketMQ只需要简单的四步:首先引入相关依赖,然后添加RocketMQ的相关配置。
以下是一个简单的示例来说明如何在Spring Boot项目中集成RocketMQ:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.4.1</version>
<relativePath/>
</parent>
<dependencies>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
</dependencies>
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-producer-group
@Autowired
注解注入RocketMQTemplate
,然后通过它来发送消息,如下所示:public void sendMessage(String topic, String message) {
rocketMQTemplate.convertAndSend(topic, message);
}
```
就是springboot
直接消费,很方便。服务端用的5.1.3,客户端是5.0。
此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/