目录 一、死信交换机【不推荐】 二、延迟消息插件【推荐】 2.1 安装插件【Linux】 2.2 安装插件【Windows】 2.3 如何使用 延时消息：生产者发送消息...
一、RabbitMQ基础概念 RabbitMQ是一个开源的、实现AMQP（高级消息队列协议）的消息代理中间件，负责应用间异步消息传递、解耦、削峰、异步处理任务等。 核心...
Kafka 数据实时同步到 Elasticsearch数据同步 核心配置文件 (需要创建新文件) name=elasticsearch-sinkconnector.class=io.confluent.connect.elasticsear...
Springboot配置 @Configurationpublic class ApiRetryQueueConfig { // 普通交换机的名称 public static final String API_RETRY_EXCHANGE = \"API_RETRY_EX...
目录 一.TTL 1.设置消息的TTL 2.设置队列的TTL 3.俩者区别 二.死信队列 定义： 消息成为死信的原因： 1.消息被拒绝（basic.reject 或 basic.nack）...
一、RabbitMQ基础概念 RabbitMQ是一个开源的、实现AMQP（高级消息队列协议）的消息代理中间件，负责应用间异步消息传递、解耦、削峰、异步处理任务等。 核心...
Kafka 数据实时同步到 Elasticsearch数据同步 核心配置文件 (需要创建新文件) name=elasticsearch-sinkconnector.class=io.confluent.connect.elasticsear...
Springboot配置 @Configurationpublic class ApiRetryQueueConfig { // 普通交换机的名称 public static final String API_RETRY_EXCHANGE = \"API_RETRY_EX...
目录 一.TTL 1.设置消息的TTL 2.设置队列的TTL 3.俩者区别 二.死信队列 定义： 消息成为死信的原因： 1.消息被拒绝（basic.reject 或 basic.nack）...
Kafka并没有使⽤JDK⾃带的Timer或者DelayQueue来实现延迟的功能，⽽是基于时间轮⾃定义了⼀个⽤于实现延迟功能的定时器（SystemTimer）。 JDK的Timer和Delay...
