public static void main(String[] args) { Jedis jedis = new Jedis("10.0.130.103",6379); jedis.lpush("task-queue", "123");//装入队列 jedis.lpush("task-queue", "456");//装入队列 //获取队列消息 System.out.println(jedis.rpoplpush("task-queue", "tmp-queue")); //获取队列消息 System.out.println(jedis.rpoplpush("task-queue", "tmp-queue")); // 将本次任务从暂存队列"tmp-queue"中清除 jedis.rpop("tmp-queue"); System.out.println("处理成功,被清除"); }
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Redis实现简单消息队列 - Python技术站