Spring Boot(六)：RabbitMQ 详解

àì夳堔傛蜴生んèń 2022-01-23 09:45 257阅读 0赞

###         RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。消息中间件最主要的作用是解耦，中间件最标准的用法是生产者生产消息传送到队列，消费者从队列中拿取消息并处理，生产者不用关心是谁来消费，消费者不用关心谁在生产消息，从而达到解耦的目的。在分布式的系统中，消息队列也会被用在很多其它的方面，比如：分布式事务的支持，RPC 的调用等等。RabbitMQ 的高可用性、高性能、灵活性等一些特点确实很好用。RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。 RabbitMQ 主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据。AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP 的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。RabbitMQ 是一个开源的 AMQP 实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP 等，支持 AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。 ###

### 相关概念： ###

### 通常我们谈到队列服务, 会有三个概念： 发消息者、队列、收消息者，RabbitMQ 在这个基本概念之上, 多做了一层抽象, 在发消息者和 队列之间, 加入了交换器 (Exchange). 这样发消息者和队列就没有直接联系, 转而变成发消息者把消息给交换器, 交换器根据调度策略再把消息再给队列。 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5MTY3NjI5_size_16_color_FFFFFF_t_70][]

## Spring Boot 集成 RabbitMQ： ##

### Spring Boot 提供了`spring-boot-starter-amqp` 项目对消息各种支持。 ###

### 1、配置 Pom 包，主要是添加 `spring-boot-starter-amqp` 的支持 ###

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

### 2、配置文件 ###

### 配置 RabbitMQ 的安装地址、端口以及账户信息 ###

spring.application.name=Spring-boot-rabbitmq
    
    spring.rabbitmq.host=192.168.168.186
    spring.rabbitmq.port=9876
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=admin123

### 3、队列配置 ###

package cn.tycoding.MQ;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * @Data: Created on 2019/6/3
     * @Desc: 队列配置
     */
    @Configuration
    public class RabbitConfig{
        @Bean
        public Queue Queue(){
            return new Queue("test");
        }
    }

### 4、发送者 ###

rabbitTemplate 是 Spring Boot 提供的默认实现

package cn.tycoding.MQ;
    
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.util.Date;
    
    /**
     * @Data: Created on 2019/6/3
     * @Desc: 发送消息者
     */
    @Component
    public class SenderMessage {
        @Autowired
        private AmqpTemplate rabbitTemplate;
    
        public void send(){
            String context = "test" + new Date();
            System.out.println("Sender : "+ context);
            this.rabbitTemplate.convertAndSend("test",context);
        }
    }

### 5、接收者 ###

package cn.tycoding.MQ;
    
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /**
     * @Data: Created on 2019/6/3
     * @Desc: 接受者
     */
    @Component
    @RabbitListener(queues = "test")
    public class ReceiverMessage {
        @RabbitHandler
        public void process(String test){
            System.out.println("Receiver : "+test);
        }
    }

### 6、测试 ###

package cn.tycoding.MQ;
    
    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;
    
    /**
     * @Data: Created on 2019/6/3
     * @Desc:
     */
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class RabbitMqTest {
        @Autowired
        private SenderMessage senderMessage;
    
        @Test
        public void test() throws Exception{
            senderMessage.send();
        }
    }

## 这里要注意一点，发送者和接收者的 queue name 必须一致，不然不能接收。 ##

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE5MTY3NjI5_size_16_color_FFFFFF_t_70]: /images/20220123/45c9c480234b4a12a409c68209217e82.png