TTL 过期时间 2. 死信交换器和死信队列何为死信? 被拒绝的消息过期的消息消息队列达到最大长度 交换机的持久化是我们在使用rabbitmq经常需要做的事情,声明交换器时将 durable 参数设置为 true 来实现的。如果不设置持久化属性的话,当 RabbitMQ 服务重启后交换器的数据就会丢 ...
分类:
其他好文 时间:
2021-07-05 19:07:34
阅读次数:
0
备份交换器 备份交换器,英文名称为Alternate Exchange,简称AE。通过在声明交换器(调用channel.ExchangeDeclare方法)时添加alternate-exchange参数来实现。 备份交换器工作流程如下: using (var channel = connection ...
分类:
Web程序 时间:
2021-06-10 17:56:20
阅读次数:
0
接着前面的Topic交换器,我们来研究一下Fanout交换器。 Fanout交换器: 扇形模式,不处理路由键,只是简单将队列绑定到交换器,发送到交换器的每条消息都回被转发到该交换器绑定的所有队列中,类型子网传播,通过Fanout交换器转发消息是最快的 现在进入实例工程来了解一下FanoutExcha ...
分类:
编程语言 时间:
2021-04-16 11:44:48
阅读次数:
0
消息追踪 消息跟踪,排查问题。追踪消息的生产和消费 Firehose Firehose 的原理是将生产者投递给RabbitMQ 的消息,或者RabbitMQ 投递给消费者的消息按照指 定的格式发送到默认的交换器上。这个默认的交换器的名称为 amq.rabbitmq.trace ,它是一个 topic ...
分类:
其他好文 时间:
2021-01-19 12:22:49
阅读次数:
0
RabbitMQ : 1.优先级队列 交换机exchange揭秘 direct交换机 (直接交换器) fanout交换机 (广播是式交换器) topic交换机 (主题交换器) headers交换机 (消息体的header匹配) 消息持久化,消息扩容 1. Direct(直接交换器) Exchange ...
分类:
其他好文 时间:
2020-11-19 12:02:00
阅读次数:
4
将队列和交换器绑定的方法如下,可以与前两节中的方法定义(exchangeDeclare和queueDeclare)进行类比。 1.Queue.BindOk queueBind(String queue, String exchange, String routingKey) throws IOExc ...
分类:
其他好文 时间:
2020-10-12 20:34:35
阅读次数:
28
介绍 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件。主要用来做异步处理、应用解耦、流量削峰、日志处理等等方面的处理。 特点 可靠性: RabbitMQ使用一些机制来保证可靠性, 如持久化、传输确认及发布确认等。 灵活的路由 : 在消息进入队列之前,通过交换器来路由消息。对于... ...
分类:
其他好文 时间:
2020-10-07 20:24:27
阅读次数:
25
使用注解方式实现RabbitMq整合 在进行该部分实验前把之前的交换器和队列删除,在RabbitMq管理后台完成。 1、RabbitMq配置类 @Configuration public class RabbitMQConfig { /** * 定制JSON格式的消息转换器 * @return */ ...
分类:
编程语言 时间:
2020-09-17 22:24:43
阅读次数:
45
vhost是什么,能给项目配置带来什么好处?1、vhost是一个微型的消息队列服务器,它拥有自己的队里、绑定、交换器、权限控制,一个项目在不同的环境可以使用不同的vhost,比如开发环境用的是order.dev,测试环境用的是order.test,通过配置文件读取不同的配置。2、vhost通过在各个实列间提供逻辑上的分离,比如订单服务和营销服务,可以使用不同的虚拟主机,进行各自的队列配置,保证了不
分类:
其他好文 时间:
2020-09-17 20:33:07
阅读次数:
34
1.AMQP Messaging中的基本概念 Broker:接收和分发消息的应用,RabbitMQ Server就是Message Broker。Virtual Host:出于多租户和安全因素设计的,把AMQP的基本组件划分到一个虚拟的分组中,类似于网络中的Namespace概念。当多个不同的用户使 ...
分类:
其他好文 时间:
2020-07-01 15:57:34
阅读次数:
73