java实现消息队列以及延迟消息(队列DelayQueue)

createh53个月前 (02-01)技术教程23

1.java实现延迟消息(队列DelayQueue)

DelayQueue是一个支持延时获取元素的无界阻塞队列。队列使用PriorityQueue来实现。队列中的元素必须实现Delayed接口,在创建元素时可以指定多久才能从队列中获取当前元素。只有在延迟期满时才能从队列中提取元素。

缓存系统的设计:这里使用DelayQueue保存缓存元素的有效期,一个线程(生产者)设置失效实现循环添加消息,使用一个线程(消费者)循环查询

DelayQueue,一旦能从DelayQueue中获取元素时,表示缓存有效期到了

应用场景:

消息生产和消费有时间窗口要求,例如在电商交易中超时未支付关闭订单的场景,在订单创建时会发送一条延时消息。这条消息将会在 30 分钟以后投递给消费者,消费者收到此消息后需要判断对应的订单是否已完成支付。如支付未完成,则关闭订单。如已完成支付则忽略。

通过消息触发一些定时任务,例如在某一固定时间点向用户发送提醒消息。

前提条件:放置在DelayQueue的元素需要实现Delayed接口,Delayed接口使对象成为延迟对象,它使存放在DelayQueue类中的对象具有了激活日期

2.实现Delayed接口

3.生产者

4.消费者

5.main方法

6.效果

原文链接:https://blog.csdn.net/Violet_201903027/article/details/114116206

相关文章

SpringBoot之旅第四篇-web开发(springboot webjars)

一、引言有了自动配置,springboot使web开发变得简单,这个在springboot之旅中的第一篇中就有体现,实际的开发中当然不会这么简单,很多时候我们都需要自己去定制一些东西。web开发的东西...

Java Web开发的学习路径与实践策略

在信息技术的海洋里,Java Web开发犹如一座富饶的岛屿,吸引着无数求知者前来探索。对于那些渴望踏入这片领域的人来说,如何构建一个合理的学习规划是首要考虑的问题。学习Java Web不仅仅是掌握一系...

如果通过Java来完成大数据开发,需要学习哪些内容

首先,当前大数据领域的开发岗位确实比较多,近两年有不少大数据方向的研究生也会从事大数据开发岗位,而Java语言则是大数据开发人员的常用工具,所以如果要从事大数据开发岗位,可以重点学习一下Java语言。...

javaweb宿舍管理系统开发详细教程

本文章向大家介绍javaweb宿舍管理系统,主要包括javaweb宿舍管理系统使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。 宿舍管理是高校管理的重要组...

使用maven开发javaweb项目(maven如何使用)

想重新学习一下java web的知识,之前也学习过一些但是也没有用在开发中所以也忘的七七八八了,因为从事Android开发免不了要与服务器打交道,有时候想自己写一个小DEMO需要服务器的时候感觉真是很...

使用IntelliJ IDEA开发Java Web HelloWorld

1. 下载Tomcat首先,下载Apache Tomcat并解压到本地计算机,可存放于任何位置。另外,需要在系统中环境 JRE_HOME 环境变量,以保证Tomcat可以正常启动,具体配置方式请参考其...