[SpringBoot系列004] SpringBoot整合RabbitMQ

水深无声 2024-02-18 21:04 6阅读 0赞

**RabbitMQ是以AMQP协议实现的一种消息中间件产品，**  
AMQP是Advanced Message Queuing Protocol的简称，它是一个面向消息中间件的开放式标准应用层协议。AMQP中定义了以下标准特性：

消息方向
    消息队列
    消息路由（包括：点到点模式和发布-订阅模式）
    可靠性
    安全性

安装RabbitMQ[windows]
    Erlang/OTP 20.3下载地址：
    http://erlang.org/download/otp_win64_20.3.exe
    Erlang/OTP其它版本下载地址：http://www.erlang.org/downloads
    
    RabbitMQ Server 3.7.4下载地址：
    https://dl.bintray.com/rabbitmq/all/rabbitmq-server/
    3.7.4/rabbitmq-server-3.7.4.exe 
    RabbitMQ其它版本下载地址：https://www.rabbitmq.com/download.html

进入rabbitmq安装目录的sbin目录，在此打开dos命令窗口，执行以下命令  
**rabbitmq-plugins enable rabbitmq\_management**  
出现如下提示，说明web管理插件安装成功  
![这里写图片描述][70]  
打开浏览器并访问：http://localhost:15672/，并使用默认用户guest登录，密码也为guest，即可进入管理界面

**添加依赖**

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

![这里写图片描述][70 1]

![这里写图片描述][70 2]

![这里写图片描述][70 3]

rabbit mq连接配置
    ## rabbitmq config
    spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=springboot
    spring.rabbitmq.password=123456

**创建Rabbit配置类**  
配置类主要用来配置队列、交换器、路由等高级信息

import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    @Configuration
    public class RabbitConfig {
        @Bean
        public Queue firstQueue() {
          // 创建一个队列，名称为：first
            return new Queue("first");
        }
    }

**创建消息产生者类**

@Component
    public class Sender {
        @Autowired
        private AmqpTemplate rabbitTemplate;
        public void send() {
            rabbitTemplate.convertAndSend("first", "test rabbitmq message !!!");
        }
    }
    
    说明：通过注入AmqpTemplate接口的实例来实现消息的发送，
    AmqpTemplate接口定义了一套针对AMQP协议的基础操作

**创建消息消费者**

@Component
    @RabbitListener(queues = "first")
    public class Receiver {
        @RabbitHandler
        public void process(String msg) {
            System.out.println("receive msg : " + msg);
        }
    }
    
    说明：
    @RabbitListener注解：定义该类需要监听的队列
    @RabbitHandler注解：指定对消息的处理

**创建测试类**

@RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes = SpringBootMain.class)
    public class RabbitmqTest {
        @Autowired
        private Sender sender;
        @Test
        public void testRabbitmq() throws Exception {
            sender.send();
        }
    }

**启动主程序：SpringBootStart**

控制台如果出现以下信息，则说明rabbitmq连接成功
    Created new connection: rabbitConnectionFactory#29102d45:0/SimpleConnection
    @1dcfb5ba[delegate=amqp://springboot@127.0.0.1:5672/, localPort= 55088]

**运行Junit测试类**

控制台输出：
    receive msg : test rabbitmq message !!!
    集成Rabbit MQ完毕!

[70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/63b2431e4544424082f29799726794b4.png
[70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/e737a4d338dd4d8682f0f64b7a2044db.png
[70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/115a0c8b4e924631ad94a6b2d4aad30e.png
[70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/7b9220fcbf9649b7ba81fd73860af658.png