客户端设置connection_name 在建立连接时，设置connection_name属性，可以在RabbitMQ Managerment 中查看到连接来自那个实例。 amqp.connect(rabbitMqAdd…

使用docker-compose可以方便快速的安装rabbitmq用于测试，同时有管理界面可以查看当前消息状态。 首先新建目录 mkdir -p /data/rabbitmq docker-compose.yml内容如下…

郑重声明：危险动作，切勿在正式运行环境中模仿。你们搞挂了服务器 ，我概不负责。 我写这篇文档的目的不是让大家去弄崩溃别人的rabbitmq服务器，而是想告诉大家要避免这种情况弄崩溃了自己的rabbitmq服务器。或者对其…

虽然 rabbitmq 没有延时队列的功能,但是稍微变动一下也是可以实现的 实现延时队列的基本要素 存在一个倒计时机制:Time To Live(TTL) 当到达时间点的时候会触发一个发送消息的事件:Dead Lette…

导语 RabbitMQ 想必大家都有了解，不做多介绍来。这里实现的是用 RabbitMQ 作为 Larvel 队列的驱动，替代 Redis。下面以 Laradock 中安装示例。 安装 切换到 laradock 目录，将…

生产者端confirm模式的实现原理 生产者将信道设置成confirm模式，一旦信道进入confirm模式，所有在该信道上面发布 的消息都会被指派一个唯一的ID(从1开始)，一旦消息被投递到所有匹配的队列之后， brok…

写在前面 在我们的生产环境中搭了两台rabbitmq， 前面架设了一台HAProxy做负载均衡，当我们的客户端连接到HAProxy，然后由HAProxy负责将链接分配给其中一台rabbitmq，客户端需要需要负责断线重连…

包含RabbitMQ的消息队列服务的一个主要特征是保留消息发布顺序.这已在 RabbitMQ documentation中得到确认： [QUOTE 1] Section 4.7 of the AMQP 0-9-1 cor…

SpringCloud（第 037 篇）通过bus/refresh半自动刷新ConfigClient配置 – 一、大致介绍 1、上章节我们讲到了手动刷新配置，但是我们假设如果微服务一多的话，那么我们是不是需要…

我用的是rabbitmq-server-3.6.1. 似乎有两种选择如何设置同步批量大小.第一个是政策选项“ha-sync-batch-size”.它在RabbitMQ文档here中进行了描述.第二个是配置文件选项“mi…

HelloWorld 简介 RabbitMQ：接受消息再传递消息，可以视为一个“邮局”。发送者和接受者通过队列来进行交互，队列的大小可以视为无限的，多个发送者可以发生给一个队列，多个接收者也可以从一个队列中接受消息。 c…

在尝试理解直接,扇出和主题交换之间的区别时,我想确认主题交换的优点是生产者推送到交换并指定完全特定的路由密钥,并且队列可以通过绑定到多个路由密钥通配符.例如主题推动…… $channel->basic_publis…