三五互联做的网站怎么样,网页设计制作项目,免费制作简历,最新的网站开发框架6.1场景#xff1a; 1.定时发布文章
2.秒杀之后#xff0c;给30分钟时间进行支付#xff0c;如果30分钟后#xff0c;没有支付#xff0c;订单取消。
3.预约餐厅#xff0c;提前半个小时发短信通知用户。
A - 13:00 17:00 16:30 延迟时间#xff1a; 7*30 * 60 *…6.1场景 1.定时发布文章
2.秒杀之后给30分钟时间进行支付如果30分钟后没有支付订单取消。
3.预约餐厅提前半个小时发短信通知用户。
A - 13:00 17:00 16:30 延迟时间 7*30 * 60 * 1000
B - 11:00 18:00 17:30 延迟时间 13*30 * 60 * 1000
C - 8:00 14:00 13:30 延迟时间 11*30 * 60 * 1000
6.2第一种方式创建具有超时功能且绑定死信交换机的消息队列 Bean public Queue directQueueLong(){ return QueueBuilder.durable(“业务队列名称”) .deadLetterExchange(“死信交换机名称”) .deadLetterRoutingKey(“死信队列 RoutingKey”) .ttl(20000) // 消息停留时间 //.maxLength(500) .build(); } 监听死信队列即可处理超时的消息队列
缺点
上述实现方式中ttl延时队列中所有的消息超时时间都是一样的如果不同消息想设置不一样的超时时间就需要建立多个不同超时时间的消息队列比较麻烦且不利于维护。 6.3第二种方式创建通用延时消息 rabbitTemplate.convertAndSend(“交换机名称”, “RoutingKey”,“对象”, message { message.getMessageProperties().setExpiration(String.valueOf(5000))return message;});缺点
该种方式可以创建一个承载不同超时时间消息的消息队列但是这种方式有一个问题如果消息队列中排在前面的消息没有到超时时间即使后面的消息到了超时时间先到超时时间的消息也不会进入死信队列而是先检查排在最前面的消息队列是否到了超时时间如果到了超时时间才会继续检查后面的消息。 6.4 第三种方式使用rabbitmq的延时队列插件实现同一个队列中有多个不同超时时间的消息并按时间超时顺序出队 6.4.1下载延迟插件 在 RabbitMQ 的 3.5.7 版本之后提供了一个插件rabbitmq-delayed-message-exchange来实现延迟队列 同时需保证 Erlang/OPT 版本为 18.0 之后。
我这里 MQ 的版本是 3.10.0 现在去 GitHub 上根据版本号下载插件 6.4.2安装插件并启用 我用的是 Docker 客户端下载完成后直接把插件放在 /root 目录然后拷贝到容器内plugins目录下rabbitmq是容器的name也可以使用容器id
docker cp /home/208/rabbitmq_delayed_message_exchange-3.10.0.ez rabbitmq:/plugins 进入 Docker 容器
docker exec -it rabbitmq /bin/bash 在plugins内启用插件
#先执行解除防火墙限制增加文件权限 umask 0022 rabbitmq-plugins enable rabbitmq_delayed_message_exchange 退出容器
exit 重启 RabbitMQ
docker restart rabbitmq 通过UI查看 6.4.3原理
6.4.4如何使用 1、消费者
2、生产者 6.延迟队列 6.1场景 1.定时发布文章
2.秒杀之后给30分钟时间进行支付如果30分钟后没有支付订单取消。
3.预约餐厅提前半个小时发短信通知用户。
A - 13:00 17:00 16:30 延迟时间 7*30 * 60 * 1000
B - 11:00 18:00 17:30 延迟时间 13*30 * 60 * 1000
C - 8:00 14:00 13:30 延迟时间 11*30 * 60 * 1000
6.2第一种方式创建具有超时功能且绑定死信交换机的消息队列 Bean public Queue directQueueLong(){ return QueueBuilder.durable(“业务队列名称”) .deadLetterExchange(“死信交换机名称”) .deadLetterRoutingKey(“死信队列 RoutingKey”) .ttl(20000) // 消息停留时间 //.maxLength(500) .build(); } 监听死信队列即可处理超时的消息队列
缺点
上述实现方式中ttl延时队列中所有的消息超时时间都是一样的如果不同消息想设置不一样的超时时间就需要建立多个不同超时时间的消息队列比较麻烦且不利于维护。 6.3第二种方式创建通用延时消息 rabbitTemplate.convertAndSend(“交换机名称”, “RoutingKey”,“对象”, message { message.getMessageProperties().setExpiration(String.valueOf(5000))return message;});缺点
该种方式可以创建一个承载不同超时时间消息的消息队列但是这种方式有一个问题如果消息队列中排在前面的消息没有到超时时间即使后面的消息到了超时时间先到超时时间的消息也不会进入死信队列而是先检查排在最前面的消息队列是否到了超时时间如果到了超时时间才会继续检查后面的消息。 6.4 第三种方式使用rabbitmq的延时队列插件实现同一个队列中有多个不同超时时间的消息并按时间超时顺序出队 6.4.1下载延迟插件 在 RabbitMQ 的 3.5.7 版本之后提供了一个插件rabbitmq-delayed-message-exchange来实现延迟队列 同时需保证 Erlang/OPT 版本为 18.0 之后。 添加链接描述 我这里 MQ 的版本是 3.10.0 现在去 GitHub 上根据版本号下载插件 6.4.2安装插件并启用 我用的是 Docker 客户端下载完成后直接把插件放在 /root 目录然后拷贝到容器内plugins目录下rabbitmq是容器的name也可以使用容器id
docker cp /home/208/rabbitmq_delayed_message_exchange-3.10.0.ez rabbitmq:/plugins 进入 Docker 容器
docker exec -it rabbitmq /bin/bash 在plugins内启用插件
#先执行解除防火墙限制增加文件权限 umask 0022 rabbitmq-plugins enable rabbitmq_delayed_message_exchange 退出容器
exit 重启 RabbitMQ
docker restart rabbitmq 通过UI查看
6.4.3原理
6.4.4如何使用 1、消费者
2、生产者
