1.用redis中的List可以實現佇列，這樣可以用來做訊息處理和任務排程的佇列

2.程式碼模擬

1. /** 
2.  *  
3.  */
4. package scheduleTest;  
5. import java.util.Random;  
6. import java.util.UUID;  
7. import redis.clients.jedis.Jedis;  
8. /** 
9.  * 模擬一個生產者 
10.  * <p>Title: TaskProducer</p> 
11.  * <p>Description: </p> 
12.  * <p>Company: </p>
     
13.  * @author 夏 傑 
14.  * @date 2015年12月11日 下午4:26:48 
15.  * @vesion 1.0 
16. */
17. publicclass TaskProducer implements Runnable{  
18.     Jedis jedis = new Jedis("120.55.195.177",6379);  
19.     publicvoid run() {  
20.         Random random = new Random();  
21.         while(true){  
22.             try{  
23.                 Thread.sleep(random.nextInt(600
    ) + 600);  
24.                 // 模擬生成一個任務
25.                 UUID taskid = UUID.randomUUID();  
26.                 //將任務插入任務佇列：task-queue
27.                 jedis.lpush("task-queue", taskid.toString());  
28.                 System.out.println("插入了一個新的任務： " + taskid);  
29.             }catch(Exception e){  
30.                 e.printStackTrace();  
31.             }  
32.         }  
33.     }  
34. }  

1. /** 
2.  *  
3.  */
4. package scheduleTest;  
5. import java.util.Random;  
6. import redis.clients.jedis.Jedis;  
7. /** 
8.  * 模擬消費者 
9.  * <p>Title: TaskConsumer</p> 
10.  * <p>Description: </p> 
11.  * <p>Company: </p> 
12.  * @author 夏 傑 
13.  * @date 2015年12月11日 下午4:44:23 
14.  * @vesion 1.0 
15. */
16. publicclass TaskConsumer implements Runnable {  
17.     Jedis jedis = new Jedis("120.55.195.177",6379);  
18.     publicvoid run() {  
19.         Random random = new Random();  
20.         while(true){  
21.             //從任務佇列"task-queue"中獲取一個任務，並將該任務放入暫存佇列"tmp-queue"
22.             String taskid = jedis.rpoplpush("task-queue", "tmp-queue");  
23.             // 處理任務----純屬業務邏輯，模擬一下：睡覺
24.             try {  
25.                 Thread.sleep(1000);  
26.             } catch (InterruptedException e) {  
27.                 e.printStackTrace();  
28.             }  
29.             //模擬成功和失敗的偶然現象
30.             if(random.nextInt(13) % 7 == 0){// 模擬失敗的情況,概率為2/13
31.                 //將本次處理失敗的任務從暫存佇列"tmp-queue"中，彈回任務佇列"task-queue"
32.                 jedis.rpoplpush("tmp-queue", "task-queue");  
33.                 System.out.println(taskid + "處理失敗，被彈回任務佇列");  
34.             } else {// 模擬成功的情況
35.                 // 將本次任務從暫存佇列"tmp-queue"中清除
36.                 jedis.rpop("tmp-queue");  
37.                 System.out.println(taskid+"處理成功，被清除");  
38.             }     
39.         }  
40.     }  
41. }  

1. /** 
2.  *  
3.  */
4. package scheduleTest;  
5. /** 
6.  * <p>Title: TaskShedulerSystem</p> 
7.  * <p>Description: </p> 
8.  * <p>Company: </p> 
9.  * @author 夏 傑 
10.  * @date 2015年12月11日 下午4:19:09 
11.  * @vesion 1.0 
12. */
13. publicclass TaskShedulerSystem {  
14.     publicstaticvoid main(String[] args) throws Exception {  
15.         // 啟動一個生產者執行緒，模擬任務的產生
16.         new Thread(new TaskProducer()).start();  
17.         Thread.sleep(15000);  
18.         //啟動一個執行緒者執行緒，模擬任務的處理
19.         new Thread(new TaskConsumer()).start();  
20.         //主執行緒休眠
21.         Thread.sleep(Long.MAX_VALUE);  
22.     }  
23. }