MQ全称 Message Queue(消息队列),rabbitmq是实现mq的一种产品,基于erlang语言,安装时要注意erlang版本与rabbitmq的兼容问题。兼容问题解决参考文章:RabbitMQ的bug解决。
**
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让消息在指定时间后过期。然后进入死信队列,在死信队列中被消费。