1. 程式人生 > >用Redis做訊息佇列

用Redis做訊息佇列

一、訊息佇列的適用場景

非同步處理,應用解耦,流量削鋒和訊息通訊 四個場景。

二、藉助 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);
        }
    }
}

測試效果: