2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

1.由于redis是單線程因此可以用用redis中的List可以實現(xiàn)隊列

2.代碼模擬

代碼結(jié)構(gòu)

?

生產(chǎn)者模擬程序

/** * */ package scheduleTest; import java.util.Random; import java.util.UUID; import redis.clients.jedis.Jedis; /** * 模擬一個生產(chǎn)者 * <p>Title: TaskProducer</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:26:48 * @vesion 1.0 */ public class TaskProducer implements Runnable{ Jedis jedis = new Jedis("120.55.195.177",6379); public void run() { Random random = new Random(); while(true){ try{ Thread.sleep(random.nextInt(600) + 600); // 模擬生成一個任務(wù) UUID taskid = UUID.randomUUID(); //將任務(wù)插入任務(wù)隊列：task-queue jedis.lpush("task-queue", taskid.toString()); System.out.println("插入了一個新的任務(wù)： " + taskid); }catch(Exception e){ e.printStackTrace(); } } } }

消費者模擬程序

/** * */ package scheduleTest; import java.util.Random; import redis.clients.jedis.Jedis; /** * 模擬消費者 * <p>Title: TaskConsumer</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:44:23 * @vesion 1.0 */ public class TaskConsumer implements Runnable { Jedis jedis = new Jedis("120.55.195.177",6379); public void run() { Random random = new Random(); while(true){ //從任務(wù)隊列"task-queue"中獲取一個任務(wù)，并將該任務(wù)放入暫存隊列"tmp-queue" String taskid = jedis.rpoplpush("task-queue", "tmp-queue"); // 處理任務(wù)----純屬業(yè)務(wù)邏輯，模擬一下：睡覺 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } //模擬成功和失敗的偶然現(xiàn)象 if(random.nextInt(13) % 7 == 0){// 模擬失敗的情況,概率為2/13 //將本次處理失敗的任務(wù)從暫存隊列"tmp-queue"中，彈回任務(wù)隊列"task-queue" jedis.rpoplpush("tmp-queue", "task-queue"); System.out.println(taskid + "處理失敗，被彈回任務(wù)隊列"); } else {// 模擬成功的情況 // 將本次任務(wù)從暫存隊列"tmp-queue"中清除 jedis.rpop("tmp-queue"); System.out.println(taskid+"處理成功，被清除"); } } } }

調(diào)度主程序

/** * */ package scheduleTest; /** * <p>Title: TaskShedulerSystem</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:19:09 * @vesion 1.0 */ public class TaskShedulerSystem { public static void main(String[] args) throws Exception { // 啟動一個生產(chǎn)者線程，模擬任務(wù)的產(chǎn)生 new Thread(new TaskProducer()).start(); Thread.sleep(15000); //啟動一個線程者線程，模擬任務(wù)的處理 new Thread(new TaskConsumer()).start(); //主線程休眠 Thread.sleep(Long.MAX_VALUE); } }

運行結(jié)果

轉(zhuǎn)載于:https://my.oschina.net/dolphinboy/blog/1492860

總結(jié)

以上是生活随笔為你收集整理的利用Redis实现消息队列原理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。