队列Redis Java实现的过期队列（redisjava过期）

Redis是一个高效的分布式缓存系统，它可用来存储键值对数据，可以轻松实现其它缓存技术无法满足的高并发场景。它也可以用作过期队列。

使用Redis作为过期队列，可以实现任务放入过期队列，由一个定时程序不断扫描过期队列，一旦发现过期的任务，就将其从过期队列中删除并处理，最后由定时程序将处理完毕的任务从过期队列中删除。

Redis的Java API可以很容易的被使用来实现过期队列，以下是实现的一个例子：

public class ExpireQueue {

public static final String REDIS_KEY = “expire_queue”;

/**

* 将任务加入过期队列

* @param ttl 过期时间

* @param data 过期数据

* @return

*/

public boolean addExpireTask(int tt1,String data) {

Jedis jedis = null;

try {

jedis = RedisUtils.getJedis();

jedis.zadd(REDIS_KEY, System.currentTimeMillis()+tt1 ,data);

return true;

} catch (Exception e){

e.printStackTrace();

return false;

} finally {

if (jedis != null) {

jedis.close();

}

}

}

/**

* 定时任务，每隔一定时间扫描一次过期队列

*/

public ScanResult scanExpireTask() {

Jedis jedis = null;

try {

jedis =RedisUtils.getJedis();

long curTime = System.currentTimeMillis();

ScanParams params = new ScanParams();

params.count(10);

//扫描过期的过期任务

params.match(“*:”+curTime);

String cursor = “0”;

ScanResult result;

do {

result = jedis.zscan(REDIS_KEY, cursor, params);

List datas = result.getResult();

if (datas != null && datas.size() > 0) {

for (String va : datas) {

/**

* 将任务取出并进行处理，处理完成后从过期队列中删除

*/

//处理任务

//删除任务

jedis.zrem(REDIS_KEY,va);

}

}

// 继续下次迭代

cursor = result.getStringCursor();

} while (!cursor.equals(“0”));

return result;

}catch (Exception e){

e.printStackTrace();

return null;

}finally{

if (jedis != null) {

jedis.close();

}

}

}

}

以上就是使用Redis的Java API实现的过期队列，用来实现在一定时间内产生的任务过期并可得到处理的过期队列。实现过期队列后，便可以用来处理各种方案中不可或缺的持久化任务了。