欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 教育 > 幼教 > RabbitMQ知识总结

RabbitMQ知识总结

2024/10/24 22:25:31 来源:https://blog.csdn.net/qq_53199639/article/details/141059152  浏览:    关键词:RabbitMQ知识总结

基本结构

不同的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里进行消息同步。

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com