Advertisement

Redisson的RSoredeedSortedSet结构用于构建延时队列系统

阅读量:

1、实现思路

在进行对象存储操作时,采用时间戳作为对象的评分依据,评分值最低的对象将被置于集合的最前端,并优先被取出

伪代码如下

复制代码
  RScoredSortedSet<String> set = redissonClient.getScoredSortedSet("simple");

    
     set.add(System.currentTimeMillis() + 10000,"1");
    
     set.add(System.currentTimeMillis() + 30000,"2");
    
     set.add(System.currentTimeMillis() + 20000,"3");
    
    
    
    
    AI写代码java
    
    运行

2、在项目初始化阶段,将启动多个线程以循环方式从set集合中获取对象,其伪代码示例如下

复制代码
 package com.ahies.stm.app.init;

    
  
    
 import com.ahies.stm.app.centerControl.control.queueHandler.CentralControlQueueHandler;
    
 import org.redisson.api.Rediss

全部评论 (0)

还没有任何评论哟~