云营销网站建设电话咨询,wordpress 增加中文字体,石家庄的电商网站建设,wordpress 主题king目录 一、死信交换机
1.1、什么是死信交换机
1.2、TTL
1.2.1、什么是 TTL
1.2.2、通过 TTL 模拟触发死信
二、延迟队列
2.1、什么是延迟队列
2.2、配置延迟队列插件
2.2.1、延迟队列配置
a#xff09;下载镜像
b#xff09;运行容器
c#xff09;刚刚设定的Rabb…目录 一、死信交换机
1.1、什么是死信交换机
1.2、TTL
1.2.1、什么是 TTL
1.2.2、通过 TTL 模拟触发死信
二、延迟队列
2.1、什么是延迟队列
2.2、配置延迟队列插件
2.2.1、延迟队列配置
a下载镜像
b运行容器
c刚刚设定的RabbitMQ的数据卷名称为mq-plugins所以我们使用下面命令查看数据卷
d在此目录下进入 MQ 容器内部.
e开启插件
2.3、SpringAMQP 使用延迟队列插件 一、死信交换机 1.1、什么是死信交换机
想要知道什么是死信交换机先来看看什么是死信dead letter~
当生产者发送了一个消息经过交换机到达队列时满足下列情况之一时就可以成为死信
消费者使用 basic.reject 或 basic.nack 声明消费失败并且消息的 requeue 参数设置为 false消息不重新加入到队列中.消息设置了过期时间到了时间没有被消费掉.要投递的队列消息堆积满了队列设置了最大消息数目最早的消息可能会成为死信LRU 算法淘汰的消息.
那么如果这个时候一个队列配置了 dead-letter-exchange 属性指定了一个交换机那么队列中的死信就会投递到这个交换机中而这个交换机就称为 死信交换机. 1.2、TTL
1.2.1、什么是 TTL
TTL 就是过期时间. 如果一个队列中的消息到了过期时间还没有被消费, 就会变成死信.
这里的消息到了过期时间实际上有两种情况
消息所在的队列设置了消息过期时间x_message_ttl.消息本身设置了存活时间. 1.2.2、通过 TTL 模拟触发死信
a声明一个直接交换机和一个配置了过期时间x-message-ttl 属性以及配 deadLetterExchange、deadLetterRoutingKey 属性的普通队列用来生成死信
Configuration
public class TTLMessageConfig {Beanpublic DirectExchange ttlDirectExchange() {return new DirectExchange(ttl.direct);}Beanpublic Queue ttlQueue() {return QueueBuilder.durable(ttl.queue).ttl(5000) //延时 5 s.deadLetterExchange(dl.direct) //消息如果超时没被消费就给这个死信交换机.deadLetterRoutingKey(dl).build();}Beanpublic Binding ttlBinding() {return BindingBuilder.bind(ttlQueue()).to(ttlDirectExchange()).with(ttl);}}b这里我们基于注解的方式声明一组死信交换机和队列 RabbitListener(bindings QueueBinding(value Queue(name dl.queue, durable true),exchange Exchange(name dl.exchange),key dl))public void listenDlQueue(String msg) {log.info(消费者收到死信消息msg msg);}c生产者发送一个过期时间为 5s 的消息 Testpublic void testTTLMessage() {//1.构造一个消息Message message MessageBuilder.withBody(hello ttl message.getBytes()).setDeliveryMode(MessageDeliveryMode.PERSISTENT).setExpiration(5000).build();//2.发送消息rabbitTemplate.convertAndSend(ttl.direct, ttl, message);//3.记录日志log.info(消息已经成功发送!);}d执行结果如下 Ps通过执行结果也可以看出如果消息和队列都设置了过期时间那么以时间短的为主. 二、延迟队列 2.1、什么是延迟队列
刚刚我们利用 TTL 结合死信交换机实现了当消息发出后消费者延迟收到消息的效果。这种消息模式就成为 延迟队列Delay Queue 模式。
延迟队列经常用于以下场景
延迟发送短信.用户下单如果再 5 分钟内没有支付就自动取消.预约工作会议10 分钟后自动通知所有参会人员. 2.2、配置延迟队列插件
由于 利用 TTL 结合死信交换机的方式实现起来比较麻烦并且延迟队列的需求又非常多因此 RabbitMQ 官方推出了一个插件可以通过更简单的方式达到延迟队列的效果. 2.2.1、延迟队列配置
我们在Centos7虚拟机中使用Docker来安装。 a下载镜像
docker pull rabbitmq:3.8-management b运行容器
docker run \-e RABBITMQ_DEFAULT_USERitcast \-e RABBITMQ_DEFAULT_PASS123321 \-v mq-plugins:/plugins \--name mq \--hostname mq1 \-p 15672:15672 \-p 5672:5672 \-d \rabbitmq:3.8-management Ps此命令还额外配置了插件目录对应的数据卷. c刚刚设定的RabbitMQ的数据卷名称为mq-plugins所以我们使用下面命令查看数据卷
docker volume inspect mq-plugins
结果如下 使用 cd 命令切换到 Mountpoint 指定的目录下. d在此目录下进入 MQ 容器内部.
我的容器名为mq所以执行下面命令
docker exec -it mq bash e开启插件
进入容器内部后执行以下命令开启插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange 2.3、SpringAMQP 使用延迟队列插件
a声明一个延迟队列. 这里实际上和声明普通交换机只多出了一个 delayed 属性设置为 true 就表示为延迟队列.
以下是基于 注解的方式声明交换机、队列、绑定. Ps如果是通过 java 代码的方式声明交换机只需要 ExchangeBuilder().directExhange.delay() 即可. Component
Slf4j
public class SpringRabbitListener {RabbitListener(bindings QueueBinding(value Queue(name delay.queue, durable true),exchange Exchange(name delay.direct, delayed true),key delay))public void listenDelayExchange(String msg) {log.info(消费者接收到到了延迟消息msg msg);}}b生产者只需要在生产消息的时候添加一个 headerx-delay对应的值就是延迟时间单位是毫秒 Testpublic void testDelayMessage() {//1.准备消息Message message MessageBuilder.withBody(hello ttl message.getBytes()).setDeliveryMode(MessageDeliveryMode.PERSISTENT).setHeader(x-delay, 5000) // 消息延迟时间.build();//2.消息 ID 需要封装到 CorrelationData 中CorrelationData correlationData new CorrelationData(UUID.randomUUID().toString());//3.发送消息rabbitTemplate.convertAndSend(delay.direct, delay, message, correlationData);log.info(消息已经成功发送!);}c结果如下
