用Redis做訊息佇列
阿新 • • 發佈:2018-11-19
一、訊息佇列的適用場景
非同步處理,應用解耦,流量削鋒和訊息通訊 四個場景。
二、藉助 Redis 阻塞佇列實現簡單的訊息佇列功能
redis相關:java程式碼操作redis資料庫
1、引入redis 依賴包。
2、java程式碼操作redis阻塞佇列。
java程式碼測試如下:
package com.cjh.test.redis; import redis.clients.jedis.Jedis; import java.io.IOException; import java.util.List; /** * Redis實現簡單訊息佇列 * @author chen jia hao */ public class RedisMQTest { public static void main(String[] args) throws IOException, InterruptedException { //獲取redis客戶端物件 Jedis jedis = RedisUtils.getJedis(); System.out.println("佇列啟動..."); while(true){ //如果阻塞列表沒有資料,將會一直等待 List<String> list = jedis.blpop(0, "list"); //處理具體業務邏輯... System.out.println("當前讀取資料---> "+list.get(1)); Thread.sleep(1000); } } }
測試效果: