SpringBoot+RabbitMQ 快速入门

开始使用

下载安装

• 首先要下载Erlang环境依赖，官网：https://www.erlang.org/downloads

• RabbitMQ版本需要与Erlang版本范围对应,官网查询版本对应关系：https://www.rabbitmq.com/which-erlang.html

• RabbitMQ下载，官网：https://www.rabbitmq.com/install-windows.html

官网下载很慢，win64-CSDN指路，Erlang22.2 RabbitMQ 3.8.2
后面就是一步步安装就好，注意，安装时以管理员权限运行安装程序。

安装rabbitmq_management可视化插件

• 启动RabbitMQ服务

• 打开开始菜单的RabbitMQ Command命令行工具，输入rabbitmq-plugins list查询可安装插件

• 输入rabbitmq-plugins enable rabbitmq_management安装插件

• 重启服务

• 访问 http://localhost:15672/ 默认用户名密码 guest guest

介绍

消息队列

• RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。

• 消息中间件最主要的作用是解耦，中间件最标准的用法是生产者生产消息传送到队列，消费者从队列中拿取消息并处理，生产者不用关心是谁来消费，消费者不用关心谁在生产消息，从而达到解耦的目的。

• 在分布式的系统中，消息队列也会被用在很多其它的方面，比如：分布式事务的支持，RPC 的调用等等。

RabbitMQ 介绍

• RabbitMQ 主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据；

• AMQP，即 Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。

• RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

• RabbitMQ 是一个开源的 AMQP 实现，服务器端用Erlang语言编写，用于在分布式系统中存储转发消息；

相关概念

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

其中比较重要的概念有 4 个，分别为：虚拟主机，交换机，队列，和绑定。

• 虚拟主机：一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢？很简单， RabbitMQ 当中，用户只能在虚拟主机的粒度进行权限控制。 因此，如果需要禁止A组访问B组的交换机/队列/绑定，必须为A和B分别创建一个虚拟主机。每一个 RabbitMQ 服务器都有一个默认的虚拟主机“/”。

• 交换机：Exchange 用于转发消息，但是它不会做存储 ，如果没有 Queue bind 到 Exchange 的话，它会直接丢弃掉 Producer 发送过来的消息。 这里有一个比较重要的概念：路由键 。消息到交换机的时候，交互机会转发到对应的队列中，那么究竟转发到哪个队列，就要根据该路由键。

• 绑定：也就是交换机需要和队列相绑定，这其中如上图所示，是多对多的关系。

RabbitMQ的交换机

交换机的功能主要是接收消息并且转发到绑定的队列，交换机不存储消息，在启用ack模式后，交换机找不到队列会返回错误。交换机有四种类型：Direct, topic, Headers and Fanout

• Direct：direct 类型的行为是”先匹配, 再投送”. 即在绑定时设定一个 routing_key, 消息的routing_key 匹配时, 才会被交换器投送到绑定的队列中去.
• Topic：按规则转发消息（最灵活）
• Headers：设置 header attribute 参数类型的交换机
• Fanout：转发消息到所有绑定队列

Direct 交换机

Direct Exchange 是 RabbitMQ 默认的交换机模式，也是最简单的模式，根据key全文匹配去寻找队列。

• X - Q1 就有一个 binding key，名字为 orange；
• X - Q2 就有 2 个 binding key，名字为 black 和 green。
• 当消息中的 路由键 和 这个 binding key 对应上的时候，那么就知道了该消息去到哪一个队列中。

Topic 交换机

Topic Exchange 转发消息主要是根据通配符。 在这种交换机下，队列和交换机的绑定会定义一种路由模式，那么，通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息。

这种交换机模式下：

• 路由键必须是一串字符，用句号（.） 隔开，比如说 agreements.us，或者 agreements.eu.stockholm 等。
• 路由模式中的星号（），主要用于匹配路由键指定位置的一个单词，比如说，一个路由模式是这样子：agreements..b.，那么就只能匹配这样的路由键：第一个单词是 agreements，第四个单词是 b。
• 路由模式中的井号（#）就表示相当于一个或者多个单词，例如一个匹配模式是 agreements.eu.berlin.#，那么，以agreements.eu.berlin 开头的路由键都是可以的。

具体代码发送的时候还是一样，第一个参数表示交换机，第二个参数表示路由键，第三个参数即消息。如下：

       rabbitTemplate.convertAndSend("testTopicExchange","key1.a.c.key2", "this is RabbitMQ!");

topic 和 direct 类似, 只是匹配上支持了”模式”, 在”点分”的 routing_key 形式中, 可以使用两个通配符:

• *表示一个词.
• #表示零个或多个词.

Headers交换机

headers 也是根据规则匹配, 相较于 direct 和 topic 固定地使用 routing_key , headers 则是一个自定义匹配规则的类型.

在队列与交换器绑定时, 会设定一组键值对规则, 消息中也包括一组键值对( headers 属性), 当这些键值对有一对, 或全部匹配时, 消息被投送到对应队列.

Fanout交换机

Fanout Exchange 消息广播的模式，不管路由键或者是路由模式，会把消息发给绑定给它的全部队列，如果配置了 routing_key 会被忽略。

Spring Boot 集成 RabbitMQ

开始使用

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

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

配置文件

    spring:
      rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: guest
        password: guest
        publisher-confirms: true
        virtual-host: /

队列配置

    @Configuration
    public class SimpleRabbitConfig {

        // 设置一个简单的队列
        @Bean
        public Queue queue() {
            return new Queue("helloMQ");
        }
    }

消息发送者（生产者）

rabbitTemplate 是 Spring Boot 提供的默认实现

    @Component
    public class SimpleSender {

        @Autowired
        private AmqpTemplate rabbitMQTemplate;

        public void send() {
            String context = "helloMQ " + new Date().getTime();
            rabbitMQTemplate.convertAndSend("helloMQ", context);
        }
    }

消息接收者

    @Component
    @RabbitListener(queues = {"helloMQ"})
    public class HelloReceiver {

        @RabbitHandler
        public void process(String hello) {
            System.out.println("Receiver  : " + hello);
        }
    }

测试

    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes = SenderApplication.class)
    public class RabbitMQTest {

        @Autowired
        private SimpleSender simpleSender;
    
        @Test
        public void hello() throws Exception {
            for (int i = 0; i < 10; i++) {
                simpleSender.send();
                Thread.sleep(1000);
            }
        }
    }

注意，发送者和接收者的queue name必须一致，不然不能接收

结尾

RabbitMQ与Springboot的其他配合使用方法：包括一对多、多对多、各种交换机实践、发送对象。

由于篇幅有限，需要的话可以移步本人的GitHub仓库，代码已上传自取哦。地址：https://github.com/caotinging