方案一由于RocketMQ只有固定的延时等级，如下：public enum DelayTimeLevel { NO_NEED_TO_DELAY

概述TopicExchange与DirectExchange类似，区别在于routingKey必须是多个单词的列表，并且以 · 分割。Queue与Exchange指定BindingKey时可以使用通配符：#：代指0个或多个单词*：代指一个单词利用SpringAMQP演示TopicExchange

概述Direct Exchange 会将接收到的消息根据规则路由到指定的Queue，因此称为路由模式（routes）。每一个Queue都与Exchange设置一个BindingKey发布者发送消息时，指定消息的RoutingKeyExchange将消息路由到BindingKey与消息RoutingK

概述Fanout Exchange 会将接收到的消息广播到每一个跟其绑定的queue生产者将消息发送到交换机，由交换机再去发给绑定该交换机的所有队列，每个队列接受到的消息都是一样的，再有消费者去消费，注意，此处的交换机exchange并不存储消息，存储消息的是队列queue。SpringAMQP提供

概述Work queue，工作队列，可以提高消息处理速度，避免队列消息堆积模拟WorkQueue，实现一个队列绑定多个消费者基本思路如下：在publisher服务中定义测试方法，每秒产生50条消息，发送到simple.queue在consumer服务中定义两个消息监听者，都监听simple.queu

什么是AMQPSpringAMQP实现消息的发送#####依赖 <!--AMQP依赖，包含RabbitMQ--> <dependency> <groupId>org.springframework.boot<

环境安装好docker拉取镜像docker pull rabbitmq创建容器并运行docker run -di --name=myrabbit -p 15672:15672 rabbitmq#推荐方式docker run -di --name myrabbit -e RABBITMQ_DEFAUL

简述RabbitMQ是一个开源的遵循AMQP协议实现的基于Erlang语言编写，支持多种客户端（语言）,用于在分布式系统中存储消息，转发消息，具有高可用，高可扩性，易用性等特征的消息中间件。安装环境准备centos8.x安装Erlang查看系统版本号[root@iZm5e3zk8pqk27ssml4