rabbitmq概述【原创】

rabbitmq概述【原创】

MQ全称 Message Queue（消息队列），rabbitmq是实现mq的一种产品，基于erlang语言，安装时要注意erlang版本与rabbitmq的兼容问题。兼容问题解决参考文章：RabbitMQ的bug解决https://blog.csdn.net/w_rcss/article/details/122304690。

**

rabbitmq有着如下优势：

**

应用解耦
在微服务框架中，一个微服务调用另一个微服务，如果被调用的微服务错误，那么起调用作用的微服务也会报错，这是因为应用之间的耦合度过高。如果加入rabbitmq产品，微服务应用之间无之间调用关系，就能提升容错性和可维护性。异步处理
如一个订单系统，任务无法异步处理时，耗时较长。
一个下单 *** 作耗时：20 + 300 + 300 + 300 = 920ms
使用rabbitmq后
用户点击完下单按钮后，只需等待25ms就能得到下单响应 (20 + 5 = 25ms)。削峰填谷
在客户访问需求量大的时候把消息保存起来，在任务访问量小的时候一起处理。减小高并发压力 rabbitmq可以有四种用法：

在网页端访问rabbitmq端口。在rabbitmq管控台添加消息队列，发送消息。直接写rabbitmq代码。用spring+配置文件写rabbitmq代码。这种方式容易设置死信队列，延迟队列。用SpringBoot写rabbitmq代码。

rabbitmq由生产者和消费者两大模块构成，生产者生产消息，并通过交换机发送消息至消息队列，消费者消费消息，消息然后从消息队列消失。

rabbitmq有如下几种工作模式：

简单模式：一个生产者一个消费者。工作队列模式：一个生产者多个消费者。订阅模式：相较于工作队列模式，在生产者和消费者中加入了交换机。交换机决定了将消息推送到哪些消费者。交换机又有广播、定向和通配符模式。广播模式会把消息交给所有绑定到交换机的队列。定向模式会把消息交给符合指定routing key 的队列。通配符模式会把消息交给符合routing pattern（路由模式） 的队列，是定向模式的扩展。通配符模式下#匹配一个或多个词，*匹配一个词。

Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑
定，或者没有符合路由规则的队列，那么消息会丢失！

列举一些rabbitmq的高级特性

消息的可靠投递
在使用 RabbitMQ 的时候，作为消息发送方希望杜绝任何消息丢失或者投递失败场景。RabbitMQ 为我
们提供了两种方式用来控制消息的投递可靠性模式。

confirm 确认模式return 退回模式

rabbitmq 整个消息投递的路径为：
producer—>rabbitmq broker—>exchange—>queue—>consumer
消息从 producer 到 exchange 投递失败则会返回一个 confirmCallback 。
消息从 exchange–>queue 投递失败则会返回一个 returnCallback 。
我们将利用这两个 callback 控制消息的可靠性投递。

Consumer Ack
ack指Acknowledge，确认。 表示消费端收到消息后的确认方式。
有三种确认方式：

自动确认：acknowledge=“none”手动确认：acknowledge=“manual”根据异常情况确认：acknowledge=“auto”，（这种方式使用麻烦，不作讲解）

其中自动确认是指，当消息一旦被Consumer接收到，则自动确认收到，并将相应 message 从
RabbitMQ 的消息缓存中移除。但是在实际业务处理中，很可能消息接收到，业务处理出现异常，那么
该消息就会丢失。如果设置了手动确认方式，则需要在业务处理成功后，调用channel.basicAck()，手
动签收，如果出现异常，则调用channel.basicNack()方法，让其自动重新发送消息。

消费端限流
在rabbitmq管控台设置或spring xml配置文件设置。

Time To Live
消息过期时间设置

死信队列
死信队列，英文缩写：DLX 。Dead Letter Exchange（死信交换机），当消息成为Dead
message后，可以被重新发送到另一个交换机，这个交换机就是DLX。
消息成为死信的三种情况：

队列消息长度到达限制；消费者拒接消费消息，basicNack/basicReject,并且不把消息重新放入原目标队
列,requeue=false；原队列存在消息过期设置，消息到达超时时间未被消费；

队列绑定死信交换机：
给队列设置参数： x-dead-letter-exchange 和 x-dead-letter-routing-key

延迟队列
延迟队列，即消息进入队列后不会立即被消费，只有到达指定时间后，才会被消费。
实现方式：用首先通过ttl让消息在指定时间后过期。然后进入死信队列，在死信队列中被消费。