RocketMQ 中的机制 RocketMQ 中，消息消费结果的返回值有2个：ConsumeConcurrentlyStatus.CONSUME_SUCCESS 和 ConsumeConcurrentlyStatus.RECONSUME_LATER。 前者为消费成功，後者表示消费失败。消费失败后，RocketMQ会在特定时间间隔后进行重试，重试次数越多，时间间隔越长。 默认最多可以重试16次，每次重试的时间间隔为： messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h RabbitMQ 中的机制 RabbitMQ 中，消息消费确认模式有如下3种： AcknowledgeMode.NONE：不确认 AcknowledgeMode.AUTO：自动确认 AcknowledgeMode.MANUAL：手动确认 在Spring Boot中配置消费确认模式的配置： spring.rabbitmq.listener.simple.acknowledge-mode=manual 手动...

前言： 由于rabbitMQ使用erlang 语言开发，首先需要安装erlang，但最需要注意的就是这点，直接 yum  install -y erlang  安装的版本为 erlang.x86_64 0:R16B-03.18.el7  等此类为标准版本号的版本，与最新的RabbitMQ不兼容。所以建议去官网下载erlang，自行编译安装对应版本。官网下载地址：https://www.erlang.org/downloads 开始操练起来： #1 准备并安装依赖包 yum update yum install epel-release yum install gcc gcc-c++ glibc-devel make ncurses-devel openssl-devel autoconf java-1.8.0-openjdk-devel git wget wxBase.x86_64 #2 安装erlang (下载【国外站点】以及编译过程有点漫长) wget http://erlang.org/download/otp_src_22.1.tar.gz tar -xf otp...

在上一篇文章中，我们知道了RabbitMQ的消息流程如下： 但在具体的使用中，我们还需知道exchange的类型，因为不同的类型对应不同的队列和路由规则。 在rabbitmq中，exchange有4个类型：direct，topic，fanout，header。 direct exchange 此类型的exchange路由规则很简单： exchange在和queue进行binding时会设置routingkey channel.QueueBind(queue: "create_pdf_queue", exchange: "pdf_events", routingKey: "pdf_create", arguments: null);  然后我们在将消息发送到exchange时会设置对应的routingkey： channel.BasicPublish(exchange: "pdf_events", rout...

RabbitMQ是AMQP（高级消息队列协议）协议的一种实现，RabbitMQ的基本讲解也就是围绕着AMQP协议的讲解。 一、角色讲解 1.1 消息代理（message brokers）：大家可以理解为RabbitMQ 服务器，起到了消息接收，持久化和转发等作用。 1.2 发布者（publishers）或生产者（producers）：消息的产生来源，具有生产消息的角色。 1.3 消费者（consumers）：消息的接收者，消费消息的角色。 1.4 交换机（exchange）：用于接收生产者生产的消息，并按照一定的路由规则将消息转发到匹配的队列。 1.5 消息队列（queue）：根据指定的绑定规则来接受交换机内自身感兴趣的的消息。 1.6 绑定（binding）：将消息队列和交换机绑定在一起，绑定时指明队列匹配消息的匹配规则（可以理解为队列的兴趣爱好）。 1.7 路由键（routingKey）：生产者发送到交换机内的消息需要带上自己的路由键，交换机根据消息的路由键去和队列绑定时声明的binding匹配。 二、各个角色之间如何配合 2.1 生产者生产完消息后...

RabbitMQ 我们知道AMQP（高级消息队列协议） 是一个用于在分布式系统中存储转发消息进行通信网络协议。而RabbitMQ是实现AMQP协议的消息中间件的一种（主要用于应用程序的异步通信和解偶，消息的发送者无需关心消息使用者，反之亦然。），RabbitMQ的服务器端用Erlang语言编写，支持多种客户端，如：Python、.NET、Java、JMS、C、PHP等，支持AJAX。 既然RabbitMQ是对AMQP的具体实现。要想彻底的了解RabbitMQ的设计，我们必须要先来了解AMQP 模型。 这里大家如果有兴趣的可以去阅读官方文档AMQP_0-9-1_Model，这里我简单归纳总结一下 AMQP模型。 从上一篇章的应用解耦需求出发，我们来看看消息中间件（messaging middleware broker）及其上下游系统所扮演的角色。 很显然，在上面的使用场景分析中我们可以看出来，消息中间件（brokers） 主要承担一个消息（message）容器的角色，它接收从发布者（publishers） 亦称生产者（producers）那儿来的消息。并根据既定的路由规则把接收...