RocketMQspring boot有集成吗?

RocketMQspring boot有集成吗?

展开
收起
嘟嘟嘟嘟嘟嘟 2023-10-30 12:47:32 196 分享 版权
2 条回答
写回答
取消 提交回答
  • 确实,RocketMQ与Spring Boot可以集成。在Spring Boot中集成RocketMQ只需要简单的四步:首先引入相关依赖,然后添加RocketMQ的相关配置。

    以下是一个简单的示例来说明如何在Spring Boot项目中集成RocketMQ:

    1. 引入maven库。在pom.xml文件中添加以下代码:
      <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>
      
    2. 在application.properties或application.yml文件中添加RocketMQ的相关配置,如下所示:
      rocketmq.name-server=127.0.0.1:9876 
      rocketmq.producer.group=my-producer-group
      
    3. 在需要发送消息的地方,使用@Autowired注解注入RocketMQTemplate,然后通过它来发送消息,如下所示:
      ```java
      @Autowired
      private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(String topic, String message) {
    rocketMQTemplate.convertAndSend(topic, message);
    }
    ```

    2023-10-30 14:44:33
    赞同 展开评论
  • 就是springboot
    d3b86623eaf8ae2044cd55edd840e73d.png
    直接消费,很方便。服务端用的5.1.3,客户端是5.0。
    此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”

    2023-10-30 12:54:05
    赞同 展开评论
问答分类:
问答标签:

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理