SpringBoot整合RocketMQ使用详解

伏加特遇上西柚

已于 2024-06-22 10:59:11 修改

阅读量2.6k

点赞数 23

分类专栏： # 消息中间件文章标签： java-rabbitmq spring boot rabbitmq

于 2024-05-06 20:41:50 首次发布

本文链接：https://blog.csdn.net/weixin_43811057/article/details/138092888

版权

一 SpringBoot整合RocketMQ实现消息发送和接收

消息生产者

1）添加依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
        </dependency>

2）配置文件

server:
  port: 8081
  servlet:
    context-path: /

rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: producer-demo1

3）启动类



@SpringBootApplication
public class RocketmqProducerApplication {
   

    public static void main(String[] args) {
   
        ConfigurableApplicationContext run = SpringApplication.run(RocketmqProducerApplication.class, args);
    }
}

4）测试类

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {
   RocketmqProducerApplication.class})
public class ProducerTest {
   
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    public void ConvertAndSendTest() {
   
        rocketMQTemplate.convertAndSend("springboot-mq", "hello springboot rocketmq");
    }
    
}

消息消费者

1）添加依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>