RabbitMQ 入门到精通(这一篇就够了)

一、什么是 RabbitMQ

RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

二、安装 RabbitMQ

1 安装 Erlang
1.1什么是 Erlang
Erlang(['ə:læŋ])是一种通用的面向并发的编程语言，它由瑞典电信设备制造商爱立信所辖的 CS-Lab 开发，目的是创造一种可以应对大规模并发活动的编程语言和运行环境
系统版本：CentOS6.5 ; RabbitMQ－Server：3.5.1
2 安装 erlang
2.1安装准备，下载安装文件
wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.r pm
rpm-Uvherlang-solutions-1.0-1.noarch.rpm
修改 primary.xml.gz 的 sha 的加密值
cd/var/cache/yum/x86_64/6/erlang-solutionssha1sumprimary.xml.gz
修改vimrepomd.xml

<datatype="primary">
<checksumtype="sha">结果为 sha1sum 命令结果</checksum>

3 安装 erlang
yum install erlang
4 安装完成后可以用 erl 命令查看是否安装成功
erl-version
5 安装 RabbitMQServer
5.1安装准备，下载 RabbitMQServer
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.1/rabbitmqserver-3.5.1-1.noarch.rpm
5.2安装 RabbitMQServer
rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc
yum install rabbitmq-server-3.5.1-1.noarch.rpm
6 启动 RabbitMQ
6.1配置为守护进程随系统自动启动，root 权限下执行:
chkconfig rabbitmq-serveron
6.2启动 rabbitMQ 服务
/sbin/service rabbitmq-serverstart
7 安装 Web 管理界面插件
7.1安装命令
rabbitmq-plugins enable rabbitmq_management
7.2安装成功后会显示如下内容

The following plugins have been enabled:
mochiweb
webmachine
rabbitmq_web_dispatch
amqp_client
rabbitmq_management_agent
rabbitmq_management
Plugin configuration haschanged. Restart RabbitMQ forchanges totakeeffect.

8 设置 RabbitMQ 远程 ip 登录
因为默认的账号和密码都是guest ;所以我们以创建个admin帐号，密码 123456 为例，创建一个账号并支持远程 ip 访问.
8.1创建账号
rabbitmqctl add_user admin 123456
8.2设置用户角色
rabbitmqctl set_user_tags admin administrator
8.3设置用户权限
rabbitmqctl set_permissions-p"/"oldlu".""."".*"
8.4设置完成后可以查看当前用户和角色(需要开启服务)
rabbitmqctl list_users
浏览器输入：serverip:15672。其中 serverip 是 RabbitMQ-Server 所在主机的 ip。

三、为什么要使用 RabbitMQ？他解决了什么问题？

在这里插入图片描述

四、消息队列基础知识。

1 Provider
消息生产者，就是投递消息的程序。
2 Consumer
消息消费者，就是接受消息的程序。
3 没有使用消息队列时消息传递方式

在这里插入图片描述

4 使用消息队列后消息传递方式

消息消息

5 什么是队列？
队列就像存放了商品的仓库或者商店，是生产商品的工厂和购买商品的用户之间的中转站
6 队列里存储了什么？
在 rabbitMQ 中，信息流从你的应用程序出发，来到 Rabbitmq 的队列，所有信息可以只存储在一个队列中。队列可以存储很多信息，因为它基本上是一个无限制的缓冲区，前提是你的机器有足够的存储空间。
7 队列和应用程序的关系？
多个生产者可以将消息发送到同一个队列中，多个消息者也可以只从同一个队列接收数据。

五、编写 RabbitMQ 的入门案例

1 搭建项目环境
1.1创建项目

在这里插入图片描述

1.2修改 pom 文件添加 RabbitMQ 坐标

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

1.3修改全局配置文件，添加 RabbitMQ 相关的配置

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

2 编写代码
创建队列

 /** 
 * 创建消息队列 
 * @author Administrator 
 * */
@Configuration 
public class QueueConfig {
/** * 创建队列 * @return */ 
    @Bean 
    public Queue createQueue(){  
        return new Queue("hello-queue");    
    }
}

创建消息提供者

/**
 * 消息发送者
 *
 * @author Administrator
 */
@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：队列的名称。
        //参数二：消息
        this.rabbitAmqpTemplate.convertAndSend("hello-queue", msg);
    }
}

消息接收者

@Component
public class Receiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     * @param msg
     */
    @RabbitListener(queues="hello-queue")
    public void process(String msg){
        System.out.println("receiver: "+msg);
    }
}

测试代码

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootServerApplication.class)
public class QueueTest {

    @Autowired
    private Sender sender;

    /*
     * 测试消息队列
     */
    @Test
    public void test1() throws Exception {
        while (true) {
            Thread.sleep(1000);
            this.sender.send("Hello RabbitMQ");
        }
    }
}

六、 RabbitMQ 原理图

在这里插入图片描述

1.Message
消息。消息是不具名的，它由消息头消息体组成。消息体是不透明的，而消息头则由一系列可选属性组成，这些属性包括：routing-key(路由键)、priority(相对于其他消息的优先权)、delivery-mode(指出消息可能持久性存储)等。
2.Publisher
消息的生产者。也是一个向交换器发布消息的客户端应用程序。
3.Consumer
消息的消费者。表示一个从消息队列中取得消息的客户端应用程序。
4.Exchange
交换器。用来接收生产者发送的消息并将这些消息路由给服务器中的队列。
三种常用的交换器类型

direct(发布与订阅完全匹配)
fanout(广播)
topic(主题，规则匹配)

5.Binding
绑定。用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将交换器理解成一个由绑定构成的路由表。
6.Queue
消息队列。用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者链接到这个队列将其取走。
7.Routing-key
路由键。RabbitMQ 决定消息该投递到哪个队列的规则。队列通过路由键绑定到交换器。消息发送到 MQ 服务器时，消息将拥有一个路由键，即便是空的，RabbitMQ 也会将其和绑定使用的路由键进行匹配。如果相匹配，消息将会投递到该队列。如果不匹配，消息将会进入黑洞。
8.Connection
链接。指 rabbit 服务器和服务建立的 TCP 链接。
9.Channel 信道。
1，Channel 中文叫做信道，是 TCP 里面的虚拟链接。例如：电缆相当于 TCP，信道是一个独立光纤束，一条 TCP 连接上创建多条信道是没有问题的。
2，TCP 一旦打开，就会创建 AMQP 信道。
3，无论是发布消息、接收消息、订阅队列，这些动作都是通过信道完成的。 10.VirtualHost
虚拟主机。表示一批交换器，消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在链接时指定， RabbitMQ 默认的是 vhost
11.Borker
表示消息队列服务器实体。
12.交换器和队列的关系
交换器是通过路由键和队列绑定在一起的，如果消息拥有的路由键跟队列和交换器的路由键匹配，那么消息就会被路由到该绑定的队列中。
也就是说，消息到队列的过程中，消息首先会经过交换器，接下来交换器在通过路由键匹配分发消息到具体的队列中。路由键可以理解为匹配的规则。
13.RabbitMQ 为什么需要信道？为什么不是 TCP 直接通信？
1.TCP 的创建和销毁开销特别大。创建需要 3 次握手，销毁需要 4 次分手。

如果不用信道，那应用程序就会以 TCP 链接 Rabbit，高峰时每秒成千上万条链接会造成资源巨大的浪费，而且操作系统每秒处理 TCP 链接数也是有限制的，必定造成性能瓶颈。
信道的原理是 vhost同用一条 TCP 链接。一条 TCP 链接可以容纳无限的信道,即使每秒成千上万的请求也不会成为性能的瓶颈。

七、 Rabbit 交换器讲解

1 Direct 交换器(发布与订阅完全匹配)
1.1需求

在这里插入图片描述

1.2搭建环境
1.2.1创建项目
1.2.2修改全局配置文件
修改 Consumer 的配置文件

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131 spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456
设置交换器的名称 mq.config.exchange=log.direct
info 队列名称 mq.config.queue.info=log.info
info 路由键 mq.config.queue.info.routing.key=log.info.routing.key
error 队列名称 mq.config.queue.error=log.error
error 路由键 mq.config.queue.error.routing.key=log.error.routing.key

修改 Provider 的配置文件

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131 spring.rabbitmq.port=5672
spring.rabbitmq.username=oldlu spring.rabbitmq.password=123456
设置交换器的名称 mq.config.exchange=log.direct
info 路由键 mq.config.queue.info.routing.key=log.info.routing.key
error 路由键 mq.config.queue.error.routing.key=log.error.routing.key
error 队列名称 mq.config.queue.error=log.error

1.3编写 Consumer
InfoReceiver

/**
 * 消息接收者
 *
 * @author Administrator
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.info}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.DIRECT),
                key = "${mq.config.queue.info.routing.key}"
        )
)
public class InfoReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Info........receiver: " + msg);
    }
}

ErrorReceiver

/**
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.error}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.DIRECT),
                key = "${mq.config.queue.error.routing.key}"
        )
)
public class ErrorReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Error..........receiver: " + msg);
    }
}

1.4编写 Provider

@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    //exchange 交换器名称
    @Value("${mq.config.exchange}")
    private String exchange;
    
    //routingkey 路由键
    @Value("${mq.config.queue.error.routing.key}")
    private String routingkey;
    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：交换器名称。
        //参数二：路由键
        //参数三：消息
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, this.routingkey, msg);
        this.rabbitAmqpTemplate.convertAndSend("hello-queue", msg);
    }
}

2 Topic 交换器(主题，规则匹配)
2.1需求

在这里插入图片描述

2.2搭建环境
2.2.1创建项目
2.2.2修改配置文件
Provider

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131 spring.rabbitmq.port=5672
spring.rabbitmq.username=admib spring.rabbitmq.password=123456

设置交换器的名称

mq.config.exchange=log.topic Consumer spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131
spring.rabbitmq.port=5672 spring.rabbitmq.username=oldlu spring.rabbitmq.password=123456

设置交换器的名称 mq.config.exchange=log.topic

info 队列名称 mq.config.queue.info=log.info

error 队列名称 mq.config.queue.error=log.error

log 队列名称 mq.config.queue.logs=log.all

2.3编写 Provider
UserSender

@Component
public class UserSender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    //exchange 交换器名称
    @Value("${mq.config.exchange}")
    private String exchange;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：交换器名称。
        //参数二：路由键
        //参数三：消息
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "user.log.debug", "user.log.debug....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "user.log.info", "user.log.info....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "user.log.warn", "user.log.warn....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "user.log.error", "user.log.error....." + msg);
    }
}

ProductSender

@Component
public class ProductSender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    //exchange 交换器名称
    @Value("${mq.config.exchange}")
    private String exchange;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：交换器名称。
        //参数二：路由键
        //参数三：消息
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "product.log.debug", "product.log.debug....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "product.log.info", "product.log.info....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "product.log.warn", "product.log.warn....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "product.log.error", "product.log.error....." + msg);
    }
}

OrderSender

@Component
public class OrderSender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    //exchange 交换器名称
    @Value("${mq.config.exchange}")
    private String exchange;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：交换器名称。
        //参数二：路由键
        //参数三：消息
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "order.log.debug", "order.log.debug....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "order.log.info", "order.log.info....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "order.log.warn", "order.log.warn....." + msg);
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "order.log.error", "order.log.error....." + msg);
    }
}

2.4编写 Consumer
InfoReceiver

/**
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.info}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.DIRECT),
                key = "${mq.config.queue.info.routing.key}"
        )
)
public class InfoReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Info........receiver: " + msg);
    }
}

ErrorReceiver

/**
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.error}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.DIRECT),
                key = "${mq.config.queue.error.routing.key}"
        )
)
public class ErrorReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Error..........receiver: " + msg);
    }
}

LogsReceiver

/**
 * 消息接收者
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器 
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列 *
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = "${mq.config.queue.logs}", autoDelete = "tr ue"),
        exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.TOPIC), key = "*.log.*"))
public class LogsReceiver {
    /**
     * 接收消息的方法。采用消息队列监听机制 * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("......All........receiver: " + msg);
    }
}

3 Fanout 交换器(广播)

3.1需求

在这里插入图片描述

3.2搭建环境
3.2.1创建项目
3.2.2修改配置文件

Consumer spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131 spring.rabbitmq.port=5672
spring.rabbitmq.username=admin spring.rabbitmq.password=123456

设置交换器的名称

mq.config.exchange=order.fanout

短信服务队列名称 mq.config.queue.sms=order.sms

push 服务队列名称 mq.config.queue.push=order.push

Provider

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131 spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

设置交换器的名称 mq.config.exchange=order.fanout

3.3编写 Consumer
SmsReceiver

/**
 * 消息接收者
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * key:路由键
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.sms}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.FANOUT)
        )
)
public class SmsReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Sms........receiver: " + msg);
    }
}

PushReceiver

/**
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.push}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.FANOUT)
        )
)
public class PushReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("Push..........receiver: " + msg);
    }
}

3.4编写 Provider

/**
 * 消息发送者
 */
@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    //exchange 交换器名称
    @Value("${mq.config.exchange}")
    private String exchange;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
        //向消息队列发送消息
        //参数一：交换器名称。
        //参数二：路由键
        //参数三：消息
        this.rabbitAmqpTemplate.convertAndSend(this.exchange, "", msg);
    }
}

八、使用 RabbitMQ 实现松耦合设计
1 需求

在这里插入图片描述

2 搭建环境
2.1修改配置文件

spring.rabbitmq.host=192.168.70.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

设置交换器的名称

mq.config.exchange=order.fanout

短信服务队列名称

mq.config.queue.sms=order.sms

push 服务队列名称

mq.config.queue.push=order.push

红包服务队列名称

mq.config.queue.red=red

2.2添加 RedReceiver

/**
 * @RabbitListener bindings:绑定队列
 * @QueueBinding value:绑定队列的名称
 * exchange:配置交换器
 * key:路由键
 * @Queue value:配置队列名称
 * autoDelete:是否是一个可删除的临时队列
 * @Exchange value:为交换器起个名称
 * type:指定具体的交换器类型
 */
@Component
@RabbitListener(
        bindings = @QueueBinding(
                value = @Queue(value = "${mq.config.queue.red}", autoDelete = "true"),
                exchange = @Exchange(value = "${mq.config.exchange}", type = ExchangeTypes.FANOUT)
        )
)
public class RedReceiver {

    /**
     * 接收消息的方法。采用消息队列监听机制
     *
     * @param msg
     */
    @RabbitHandler
    public void process(String msg) {
        System.out.println("给用户发送10元红包........receiver: " + msg);
    }
}

九、 RabbitMQ 消息处理
1 RabbitMQ 的消息持久化处理
消息的可靠性是 RabbitMQ 的一大特色，那么 RabbitMQ 是如何保证消息可靠性的呢——消息持久化。
1.1创建项目
1.2autoDelete属性
@Queue: 当所有消费客户端连接断开后，是否自动删除队列 ;true：删除 false：不删除
@Exchange：当所有绑定队列都不在使用时，是否自动删除交换器 true：删除 false：不删除
2 RabbitMQ 中的消息确认 ACK 机制

在这里插入图片描述

2.1创建项目
修改 Consusmer 配置文件解决 ACK 反馈问题

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

设置交换器的名称

mq.config.exchange=log.direct

info 队列名称

mq.config.queue.info=log.info

info 路由键

mq.config.queue.info.routing.key=log.info.routing.key

error 队列名称

mq.config.queue.error=log.error

error 路由键

mq.config.queue.error.routing.key=log.error.routing.key

开启重试

spring.rabbitmq.listener.retry.enabled=true

重试次数，默认为 3 次

spring.rabbitmq.listener.retry.max-attempts=5

参考书籍:RabbitMQ实战指南
总结:这本书籍写的是真的好,这也算是自己一个自我的总结吧,里面附有代码,精心整理,请大家要好好阅读,如有发现错误,还请大家斧正.文章原创,支持转载.侵权必究.

最后编辑于：2020.02.16 10:26:38

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 204,732评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 87,496评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 151,264评论 0赞 338
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,807评论 1赞 277
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,806评论 5赞 368
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,675评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 38,029评论 3赞 399
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,683评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 41,704评论 1赞 299
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,666评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,773评论 1赞 332
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,413评论 4赞 321
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 39,016评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,978评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,204评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 45,083评论 2赞 350
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,503评论 2赞 343

RabbitMQ 入门到精通(这一篇就够了)

一、 什么是 RabbitMQ

二、 安装 RabbitMQ

三、 为什么要使用 RabbitMQ？他解决了什么问题？

四、 消息队列基础知识。

五、 编写 RabbitMQ 的入门案例

六、 RabbitMQ 原理图

七、 Rabbit 交换器讲解

设置交换器的名称

设置交换器的名称 mq.config.exchange=log.topic

info 队列名称 mq.config.queue.info=log.info

error 队列名称 mq.config.queue.error=log.error

log 队列名称 mq.config.queue.logs=log.all

3 Fanout 交换器(广播)

设置交换器的名称

短信服务队列名称 mq.config.queue.sms=order.sms

push 服务队列名称 mq.config.queue.push=order.push

设置交换器的名称 mq.config.exchange=order.fanout

设置交换器的名称

短信服务队列名称

push 服务队列名称

红包服务队列名称

设置交换器的名称

info 队列名称

info 路由键

error 队列名称

error 路由键

开启重试

重试次数，默认为 3 次

推荐阅读更多精彩内容

一、什么是 RabbitMQ

二、安装 RabbitMQ

三、为什么要使用 RabbitMQ？他解决了什么问题？

四、消息队列基础知识。

五、编写 RabbitMQ 的入门案例