溫馨提示×

如何利用redis做消息隊(duì)列

小新
118
2020-12-28 18:35:30
欄目: 云計(jì)算

如何利用redis做消息隊(duì)列

利用redis做消息隊(duì)列的示例：

1.生產(chǎn)者模擬程序，代碼：

package scheduleTest; 
import java.util.Random; 
import java.util.UUID; 
import redis.clients.jedis.Jedis; 
/** 
* 模擬一個(gè)生產(chǎn)者 
* 
Title: TaskProducer
 
* 
Description: 
 
* 
Company: 
 
* @author 夏 杰 
* @date 2020年12月8日 下午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); 
// 模擬生成一個(gè)任務(wù) 
UUID taskid = UUID.randomUUID(); 
//將任務(wù)插入任務(wù)隊(duì)列：task-queue 
jedis.lpush("task-queue", taskid.toString()); 
System.out.println("插入了一個(gè)新的任務(wù)： " + taskid); 
}catch(Exception e){ 
e.printStackTrace(); 
} 
} 
} 
}

2.消費(fèi)者模擬程序，代碼：

 
package scheduleTest; 
import java.util.Random; 
import redis.clients.jedis.Jedis; 
/** 
* 模擬消費(fèi)者 
* 
Title: TaskConsumer
 
* 
Description: 
 
* 
Company: 
 
* @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ù)隊(duì)列"task-queue"中獲取一個(gè)任務(wù)，并將該任務(wù)放入暫存隊(duì)列"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ù)從暫存隊(duì)列"tmp-queue"中，彈回任務(wù)隊(duì)列"task-queue" 
jedis.rpoplpush("tmp-queue", "task-queue"); 
System.out.println(taskid + "處理失敗，被彈回任務(wù)隊(duì)列"); 
} else {// 模擬成功的情況 
// 將本次任務(wù)從暫存隊(duì)列"tmp-queue"中清除 
jedis.rpop("tmp-queue"); 
System.out.println(taskid+"處理成功，被清除"); 
} 
} 
} 
}

3.調(diào)度主程序，代碼：

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

0 踩