redis實現訊息佇列

2021-09-11 04:34:38 字數 1006 閱讀 1493

模擬生產者 - 消費者

// 生產者 - 往list資料型別中放入key為product的資料

public static void main(string args)

// 消費者 - 使用堵塞命令實時獲取product的資料

public static void main(string args)

} catch (exception e) finally

}}

redis工具類

/**

* redisutil redis工具類

*/public class redisutil

public synchronized static jedis getjedis() else }

/**

* **jedis物件資源

* - 使用者redis都要使用該方法釋放資源, 否則一直占有例項資源

* * @param jedis

*/

public synchronized static void returnresource(jedis jedis)

} }

pom依賴

org.springframework.boot

spring-boot-starter-data-redis

org.springframework.session

spring-session-data-redis

redis.clients

jedis

2.9.0

jarcompile

org.apache.commons

commons-pool2

org.apache.commons

commons-lang3

redis實現訊息佇列

用redis實現乙個訊息通知系統,總結了一下技術細節,其中演示 如果沒有特殊說明,使用的都是phpredis擴充套件來實現的。記憶體 比如要推送一條全域性訊息,如果真的給所有使用者都推送一遍的話,那麼會占用很大的記憶體,實際上不管粘性有多高的產品,活躍使用者同全部使用者比起來,都會小很多,所以如果只...

redis 實現訊息佇列

redis 實現訊息佇列 測試 component public class timetask object obj null for int i 0 i 10 i 封裝redis工具類 slf4j component public class redisutil catch exception e...

Redis實現訊息佇列

佇列本身其實是個有序的列表,而redis是支援list的,可以利用redis的列表 list 來實現簡單佇列。一般有兩種方式 1 lpush 頭部插入 和rpop 尾部彈出 2 rpush 尾部插入 和lpop 頭部彈出 兩種均可,下面示例使用的是 第一種 lpush和rpop。一般開發的時候我們會...