网站开发合同模板,重庆施工员证书查询网,二级网站免费建,什么做书籍的网站示例业务场景#xff1a; 场景1#xff1a;客户下单后#xff0c;15分钟内未支付取消订单#xff01; 场景2#xff1a;客户下单支付成功后#xff0c;5分钟内商家未处理订单#xff0c;需要推送一条消息提醒商家。如依旧未处理#xff0c;则需要每隔2分钟消息提醒一下…示例业务场景 场景1客户下单后15分钟内未支付取消订单 场景2客户下单支付成功后5分钟内商家未处理订单需要推送一条消息提醒商家。如依旧未处理则需要每隔2分钟消息提醒一下商家 这两种场景都是可以使用延迟消息来实现rabbitMq 提供了2种实现延迟消息的方式死信队列 和 延迟插件
使用docker 安装部署 rabbitMq 1下载rabbitMq镜像
docker pull rabbitmq2启动rabbitMq 容器
docker run -d --name rabbit001 -p 15672:15672 -p 5672:5672 rabbitmq -v rabbitMq:/etc/rabbitmq rabbitmq3运行完成后rabbitMq 服务通过ip15762 访问后管平台 如果访问不了则需要在容器内安装可视化插件在容器内的/plugins 目录内执行
rabbitmq-plugins enable rabbitmq_management4安装延迟插件 1在官网内下载对应版本的延迟插件上传到服务器内例如在官网下载的延迟插件放在了/home/rabbitmq目录内
docker cp /home/rabbitmq/rabbitmq_delayed_message_exchange-3.12.0.ez 4296be33b41e:plugins/2然后再进入容器内安装延迟插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange5重启rabbitMq容器再通过ip15672 访问即可初始登录账户密码guest/guest
6修改默认密码
1进入容器内
2查看用户列表rabbitmqctl list_users
3修改guest密码尽量设置复杂点rabbitmqctl change_password guest #20231126%*7通过死信队列实现延迟消息配置
1建立交换机order-reserve-echage
2建立队列 dead-queues参数如下设置x-dead-letter-exchange: order-reserve-echagex-dead-letter-routing-key: key2x-message-ttl: 900000durable: true
3建立队列 receivedq无其他参数
4再进到刚刚建立的交换机 order-reserve-echage 内去绑定路由键dead-queues key1 receivedq key28使用延时插件创建延迟队列
1建立延迟交换机delayed-exchange注意Type 是 x-delayed-messages 类型添加一个参数x-delayed-type direct2,然后建立一个队列: delayed-queue ,无其他参数3然后再进到交换机 delayed-exchange 内去绑定路由键delayed-queue delayed-routing-key以上 rabbitMq 安装配置好之后做以下介绍 问什么是死信队列
就是一个普通的队列只不过我们自行做两点约束
1设置了队列、或发往队列内的消息要有过期时间
2要确保没有消费者主动订阅消费该队列内的消息问死信队列如何实现延迟消息的
需要创建2个队列一个死信队列一个普通的队列。且需要创建一个交换机去绑定这两个队列。在创建死信队列时需要指定一个 x-dead-letter-routing-key 也就是消息过期后需要重新发往的队列。
我们发送消息到死信队列内消息过期后会由交换机转发到 死信队列绑定的 x-dead-letter-routing-key 上。这个时候我们只需要监听普通队列即可。
例如我们想要发一条消息 15 分钟后收到这条消息。那么我们就可以发送一条过期时间为15分钟的消息到 死信队列在没有任何消费者消费的情况下15分钟后这条消息会过期过期后会由交换机转发给绑定的普通队列内这时我们在 普通队列接受到的消息就是15分钟前发送的消息问死信队列 和 延迟插件 实现的延迟消息有什么不同
死信队列先发的消息会先收到后发的消息会后收到不会受设置的消息过期时间控制
例如我先往死信队列内发一条15分钟后后期的消息再发一条 3分钟后过期的消息。我们肯定是想先收到3分钟过期的消息但是受队列特性的影响先入先出
我们只有在消费了先发的15分钟过期的消息后才能收到那条3分钟的消息延迟插件不会出现以上情况以设置的过期时间先后顺序接收到消息先发了 一条 15分钟延迟消息再发一条 3分钟过期消息会先收到 3分钟过期的消息以上两种业务场景实现思路 场景1客户下单后15分钟内未支付取消订单
1客户下单后发送一条15分钟的延迟消息消息内带有 订单的id;
2监听到延时消息后拿到消息id去查询一下订单信息如还未支付则取消订单。场景2客户下单支付成功后5分钟内商家未处理订单需要推送一条消息提醒商家。如依旧未处理则需要每隔2分钟消息提醒一下商家
1客户下单支付成功后发送一条5分钟的延时消息消息内带有订单id
25分钟后监听到消息则去判断下当前订单是否有没有被处理如果还没被处理则提醒商家。并且再发一条2分钟的延时消息
32分钟后再次监听到该消息后重复此步骤如果商家未处理则提醒并且再发延迟消息
