谷歌地图网站代码,化妆品网站网页设计,韩城网站建设韩城网站推广,手机在线制作图片前言#xff1a;
延迟队列是一个内部有序的数据结构#xff0c;其主要功能体现在其延时特性上。这种队列存储的元素都设定了特定的处理时间#xff0c;意味着它们需要在规定的时间点或者延迟之后才能被取出并进行相应的处理。简而言之#xff0c;延时队列被设计用于存放那…前言
延迟队列是一个内部有序的数据结构其主要功能体现在其延时特性上。这种队列存储的元素都设定了特定的处理时间意味着它们需要在规定的时间点或者延迟之后才能被取出并进行相应的处理。简而言之延时队列被设计用于存放那些需要在特定时间到达时才处理的元素。
使用场景
1、定时任务调度在任务调度系统中延时队列可以用来安排任务在未来的某个时间点执行比如定时发送邮件、消息推送、定时刷新缓存等。2、订单超时取消在电子商务网站中未在规定时间内完成的订单可以通过延时队列来设置超时取消如果订单在队列规定的延迟时间内没有被支付系统将会自动取消订单。3、消息重试机制在消息队列中如果消息处理失败了可以将消息放入延时队列中等待一段时间后再次尝试处理以实现重试机制。4、缓存数据过期对于缓存系统延时队列可以用来管理数据的过期时间当数据在队列中的时间超过了设定的延迟时间就将其从缓存中移除。5、会话管理在Web应用中可以使用延时队列来管理用户会话的过期时间当会话超过设定的有效时间后系统将自动销毁会话。6、任务延迟执行有些任务可能需要在特定的时间窗口之后执行比如数据分析任务可能需要在当天结束后才能进行延时队列可以用来实现这种延迟执行。7、权限验证Token过期在安全系统中发放的Token通常有有效时间延时队列可以用来检测Token是否过期并在过期时将其从系统中移除。
配置类
配置文件 启动创建延迟队列和交换机 /*** 延迟队列*/
Configuration
public class DelayedQueueConfig {/** 队列 */public static final String DELAYED_QUEUE_NAMEdelayed_queue;/** 交换机 */public static final String DELAYED_EXCHANGE_NAMEdelayed_exchange;/** 交换机类型 */public static final String DELAYED_EXCHANGE_TYPEx-delayed-message;/** 交换机路由键 */public static final String DELAYED_ROUTING_KEYdelayed;/** 声明延迟队列 */Beanpublic Queue delayedQueue() {return new Queue(DELAYED_QUEUE_NAME);}/** 声明延迟队列交换机 */Beanpublic CustomExchange delayedExchange() {MapString, Object map new HashMap();map.put(x-delayed-type, direct);/*** 声明自定义交换机* 第一个参数: 交换机名称* 第二个参数: 交换机类型* 第三个参数: 是否需要持久化* 第四个参数: 是否自动删除* 第五个参数: 其他参数*/return new CustomExchange(DELAYED_EXCHANGE_NAME, DELAYED_EXCHANGE_TYPE, true, false, map);}/** 绑定队列和延迟交换机 */Beanpublic Binding delayedQueueBindingDelayedExchange(Qualifier(delayedQueue) Queue delayedQueue,Qualifier(delayedExchange) Exchange delayedExchange) {return BindingBuilder.bind(delayedQueue).to(delayedExchange).with(DELAYED_ROUTING_KEY).noargs();}} 生产者 示例商城项目生成订单后超过30分钟不支付自动取消订单 第一个参数交换机名称 第二个参数路由键 第三个参数消息体 第四个参数消息后处理器
//将订单id放入延迟队列 延迟30分钟后没有支付取消订单 释放库存 rabbitTemplate.convertAndSend(DelayedQueueConfig.DELAYED_EXCHANGE_NAME,DelayedQueueConfig.DELAYED_ROUTING_KEY,mallOrder.getId(),message - {//设置到期时间 方便测试这里设置30秒message.getMessageProperties().setDelay(10000);return message;});
消费者
RabbitListener(queuesToDeclare Queue(DelayedQueueConfig.DELAYED_QUEUE_NAME))public void consume(Integer orderId, Message message, Channel channel) {log.info(延时队列监听到消息,订单id为{}, orderId);long deliveryTag message.getMessageProperties().getDeliveryTag();//接收消息后代码try {//手动提交channel.basicAck(deliveryTag, false);} catch (IOException e) {throw new RuntimeException(e);}}
