redisキュー


  • redis関連パッケージをロードします.
  • コードpackage com.test; import redis.clients.jedis.Jedis; public class RedisTest{public static void main(String[]args){Jedisjedis=new Jeddis("172.7.2.2.252",6379);////キュー書き込みtry{////タスクキューにタスクを挿入するタスクキュー:task-queue-生産者jeddis.select(1);jeddis.lpush("task-queue","q 00001");jeddis.lpush("task-queue","q 00002");jeddis.lpush("task-queue","q 00002");jeddis.lpush("task-queue","task-queue","q 000q 00003);jedis.lpush(「task-queue」,「q 00004」);
         //   
         //       ,       task-queue   ,    tmp-queue
         String value_task = jedis.rpoplpush("task-queue","tmp-queue");
    
         String value_tmp = jedis.rpop("tmp-queue");  
         Long l = jedis.llen("tmp-queue"); 
    
         System.out.println("value_task====" + value_task + " tast len: " + jedis.llen("task-queue"));
         System.out.println("value_tmp=====" + value_tmp + " tmp len: " + jedis.llen("tmp-queue") );
    
    
     }catch(Exception e){  
         e.printStackTrace();  
     }  
    
    } }
  • 実行結果:value_task====q00001 tast len: 3 value_tmp=====q00001 tmp len: 0