redis队列实现高并发下数据ID读取
id数据预生成
id数据预生成：根据业务逻辑，预生成ID数据，通过redis队列存储，在id被取出的过程中，选取时间节点，继续生产ID并存入队列，这样就保证队列中始终有数据（秒杀系统也可以使用这套逻辑，只是秒杀系统的队列数据不再增加）
id数据读取
通过redis单线程特性及队列特性，通过redis客户端Jedis读取队列中的id（LPOP/RPOP 操作返回队列一端数据并从队列中删除数据）
测试代码
放入测试数据
public class QueueOpt{
public static void main(String[] args) {
// JedisPoolConfig config = new JedisPoolConfig();
// config.setMaxTotal(4);
// config.setMaxIdle(4);
// JedisPool pool = new JedisPool(config, "192.168.222.169",6379);
// Jedis jedis = pool.getResource();
Jedis jedis= new Jedis("192.168.222.188",6379);
for (int i=0;i<676;i++){
jedis.lpush("task-queue",String.valueOf(i));
}
}
测试类
public class test{
public static void main(String[] args) {
JedisPoolConfig config= new JedisPoolConfig();
config.setMaxTotal(1000);
config.setMaxIdle(1000);
config.setMaxWaitMillis(50000);
JedisPool pool= new JedisPool(config, "192.168.222.188",6379);
ExecutorService executorService=Executors.newFixedThreadPool(1000);
for (int i= 0; i< 1000; i++) {
executorService.execute(new IdGenerateThread(pool,i));
}
}
线程类
public class IdGenerateThreadimplements Runnable{
private Jedisjedis;
private int i;
public IdGenerateThread(JedisPoolpool,int i){
this.jedis = pool.getResource();
this.i = i;
}
@Override
public void run() {
String key= jedis.lpop("task-queue");
System.out.println("线程="+this.i + " key="+key);
}
}
