RabbitMQ知识总结

发布于:2024-08-14 ⋅ 阅读:(122) ⋅ 点赞:(0)

基本结构

不同的virtual-host实现隔离效果(属于自己的环境)

简单的Spring AMQP测试

依赖和配置文件

发送消息

接受消息

Work Queue

结论:1.一个消息只被消费了一次

2.消息被平均分配给两个消费者了,没有重复消费

这个命令可以让消费者处理完才能继续获得消息,让其能者多劳

work模型可以解决消息堆积问题

交换机

Fanout交换机

将消息发送到交换机

Direct交换机

可以设置指定的blindingKey,消息按序投放,投到设置了对应key的队列中去

Topic交换机

总的来说,Direct的RoutingKey只能写完整的Key,Topic可以写通配符,更灵活;

Java中声明交换机(Exchange)和队列(Queue)

声明

注解

消息转换器

默认转换成字节,文件变大,还可能会有恶意代码执行

消息可靠性(MQ高级)

1.发送到MQ丢失问题(发送者可靠性)

2.消息队列消息丢失问题(MQ可靠性)

3.消费者的可靠性(消费者可靠性)

延迟消息

生产者的可靠性保证

重连

重连:链接失败的重试,不是发送消息的重试

确认

生产者确认机制的实现

MQ的可靠性

发生消息积压(满)时,会刷盘一些消息到硬盘上,腾出空间,再接收消息,这个过程是阻塞的

数据持久化

spring中创建队列和交换机和消息默认都是持久化选择的

消息持久化更改delivery_mode=2(重启消息不丢失),持久化消息在队列满时不会阻塞

Lazy Queuu

消费者可靠性

消费者确认机制

消费失败处理

本地重试

本地重试失败后处理策略(默认是直接丢弃的)

具体投递指定交换机的实施

enabled

业务幂等

1.可以更改个消息转换器属性,转换的时候加上个唯一id

2.基于业务本身做判断

延迟消息

死信交换机

延迟消息插件

这种方式简单,装上插件,声明交换机的时候将delayed=“true”,然后发送消息设置setDelay()

取消超时订单

高可用性保证

RabbitMQ 有三种模式:单机模式,普通集群模式,镜像集群模式。

单机模式:就是demo级别的,一般就是你本地启动了玩玩儿的,没人生产用单机模式

普通集群模式:意思就是在多台机器上启动多个RabbitMQ实例,每个机器启动一个。

镜像集群模式:这种模式,才是所谓的RabbitMQ的高可用模式,跟普通集群模式不一样的是,你创建的queue,无论元数据(元数据指RabbitMQ的配置数据)还是queue里的消息都会存在于多个实例上,然后每次你写消息到queue的时候,都会自动把消息到多个实例的queue里进行消息同步。