消息分发 消费者客户端可以通过推模式和拉模式来进行消息消费。 当rabbitmq队列有多个消费者时,...[作者空间]
前面说了RabbitMQ的事务,可是采用事务机制实现会严重降低 RabbitMQ 的消息吞吐量,这里就引入...[作者空间]
在使用 RabbitMQ 的时候,可以通过消息持久化操作来解决因为服务器的异常崩溃而导致的消息丢失,除此之...[作者空间]
rabbitmq的持久化分成三个部分:交换器的持久化、队列的持久化和消息的持久化 交换器的持久化是...[作者空间]
概念 延迟队列存储的对象是对应的延迟消息,所谓"延迟消息"是指当消息被发送以后,并不想让消费者立刻拿到消息...[作者空间]
概念 DLX,全称为Dead-Letter-Exchange,可以称之为死信交换器,也有人称之为死信邮箱。...[作者空间]
消息TTL 方式1:通过队列属性设置,队列中所有消息,都有相同的过期时间。 方式2:第二种方法是对消息本身进行单独...[作者空间]
上一节mandatory和immediate[https://www.jianshu.com/p/f922...[作者空间]
mandatory和immediate是 channel.basicPublish方法中的两个参数,它们都...[作者空间]
确认消息 为了保证消息从队列可靠的到达消费者, RabbitMQ 提供了消息确认机制,消费者在订阅队列时,...[作者空间]
fanout 它会把所有发送到该交换器的消息路由到所有与该交换器绑定的队列中。 direct di...[作者空间]
rabbitmq架构图 架构拆解 Publisher 生产者,就是投递消息的一方。 生产者创建消息,然后发...[作者空间]
可靠性∶RabbitMQ使用一些机制来保证可靠性,如持久化、传输确认及发布确认等。 灵活的路由∶在消息进入队列之前...[作者空间]
解耦∶在项目启动之初来预测将来会碰到什么需求是极其困难的。消息中间件在处理过程中间插入了一个隐含的、基于数据的接口...[作者空间]
正文 1.使用交换器和队列 1.定义交换器Exchange.DeclareOk Channel.exchangeD...[作者空间]