[TOC] # 任務隊列簡介  # 命令行  # 代碼 ## 生成隊列-生產者 ~~~ //創建一個jedis客戶端對象(redis的客戶端連接) Jedis jedis = new Jedis("127.0.0.1", 6379); //設置auth密碼 jedis.auth("root"); Random random = new Random(); while (true) { int nextInt = random.nextInt(1000); Thread.sleep(1000 + nextInt); //生成一個任務的id String taskid = UUID.randomUUID().toString(); jedis.lpush("task-queue", taskid); System.out.println("生成了一個任務" + taskid); } ~~~ ## 消耗隊列 ~~~ @Test public void testList() throws InterruptedException { //其他方法 Jedis jedis = init(); Random random = new Random(); while (true) { //消耗速度 Thread.sleep(1500); //從任務隊列中取出一個任務,同時放入到暫存隊列中 String taskid = jedis.rpoplpush("task-queue", "tmp-queue"); //處理任務 if (random.nextInt(19) % 9 == 0) { //模擬失敗 //失敗情況下,需要將任務從暫存隊列彈回任務隊列 jedis.rpoplpush("tmp-queue", "task-queue"); System.out.println("該任務處理失敗: " + taskid); } else { //模擬成功 //成功的情況下,只需要將任務從暫存隊列清除 jedis.rpop("tmp-queue"); System.out.println("任務處理成功: " + taskid); } } } ~~~