RabbitMQ – 消息确认中提到了当消费者收到消息后，需要对消息进行确认，队列才会把这个消息删除。如果消息处理中发生了异常需要拒绝消息怎么办呢？在这个章节中，我们看到了没确认消息时，如果断开了和rabbitmq的连接，消息会回到待发送那边，等待其他消费者，虽然我们可以通过关闭连接来拒绝消息，但是频繁的频繁的建立…

安装最新版本的rabbitmq(3.3.1)，并启用management plugin后，使用默认的账号guest登陆管理控制台，却提示登陆失败。

RabbitMQ – 消息确认这篇文章中，提到了消息预取，避免了rabbitmq一直往消费端发送数据，导致消费端出现无限制的缓冲区问题。消息预取定义了信道上或者消费者允许的最大未确认的消息数量。一旦未确认数达到了设置的值，RabbitMQ将停止传递更多消息，除非至少有一条未完成的消息得到确认。使用消息预取的时候，会调用chan…

RabbitMQ – 队列中提到，接收消息的时候，有两个方式，一个是consume，一个是get，这两个方法都有一个autoAck的参数。当我们设置为true的时候，说明消费者会通过AMQP显示的向rabbitmq发送一个确认，rabbitmq自动视其确认了消息，然后把消息从队列中删除。下面用consume的方式做些例子来理解autoAck的参数设置。

/usr/bin/curl 127.0.0.1:15672 查看本地能否访问1、开启web控制，在web端设置 执行rabbitmq-plugins enable rabbitmq_management 开启web访问 重启服务 service  rabbitmq-server restart 登录 ‘[链接]:15672’,默认用户名密码为guest:guest,该用户只能本机登录； 添加用户，赋予admin权限，保存用户；再点击用户，赋予…

Worker starting control []([链接] Supervisor 是Linux的进程监视器。 它会自动启动您的控制台进程。 安装在Ubuntu上，你需要运行命令: sudo apt-get install supervisor Supervisor 配置文件通常可用 /etc/supervisor/conf.d。 你可以创建任意数量的配置文件。 配置示例: {代码…} 在这种情况下，Supervisor 会启动4…

AMQP消息路由必须包含三部分，交换器、队列、绑定。如下图所示，生产者把消息发送给交换器，交换器再路由到符合条件的队列上，最终被消费者接收。绑定决定了消息如何从路由器路由到相应的队列。这一篇，主要是了解一下队列。

什么是生产端的可靠性投递 保证消息成功发出 保证MQ节点的成功接收 发送端收到MQ节点(borker)的确认应答 完善的消息补偿机制 互联网大厂生产端可靠性投递方案 消息落库对消息状态进行打标 生产者将业务数据和消息入库，并设置信息状态为0，即初始待投递 生产者将消息发送至broker broker向生产者发送确认 生产者收到brok…

先说一个实际的业务场景：Client端有一个请求需要进行耗时处理或者查询，这个处理在Server端做。Server 端处理完后通知给请求的Client端。这种场景可以称之为RPC(Remote Procedure Call)

之前几篇说了类似广播的fanout类型的Exchange，支持分类的direct类型的Exchange。在使用direct类型的Exchange中使用了log的例子，我们可以区分info, debug, warn, error类型的log。但是实际中可能还会有更进一步的需求类似，我希望看到系统内核的error日志信息，希望看到请求耗时最长的接口的debug日志。对于这样的需求…