jedis的發布訂閱 spring

2021-08-21 08:58:49 字數 1226 閱讀 6005

1.建立執行緒任務保證專案啟動就開始執行監聽redis訂閱任務,建立類redispubtaskservice:

**如下:

public class redispubtaskservice 

}

2.建立類redissubservice整合類jedispubsub;

**如下:

@service

public class redissubservice extends jedispubsub

/*** 監聽訂閱頻道收到的訊息

** @param

pattern

* @param

channel

頻道* @param

message

訊息體*/

@override

public void

onpmessage(string pattern, string channel, string message)

}@override

public void

onsubscribe(string pattern, int subscribedchannels)

@override

public void

onunsubscribe(string s, int i)

@override

public void

onpunsubscribe(string s, int i)

@override

public void

onpsubscribe(string s, int i)

}

3.建立乙個類負責啟動訂閱任務

**如下:

@service

public class rediscommentsublistener else

jedis jedis = pool.getresource();

jedis.psubscribe(redissubservice

, "miniprogram_msg_list");

} catch (exception e)

}},

20, timeunit.seconds

);system.out

.println("****startredi***pirelistenerservice 構造結束");

}}

Redis(五)之整合Jedis與Spring

思路 建立乙個redis操作的介面。分別建立兩個實現類對應redis 的單機版和集群版。當使用單機版redis時,配置單機版的實現類,當使用集群版本的時候,配置集群版的實現類。redis客戶端介面,在這裡新增常用方法 public inte ce jedisclient redis客戶端單機版實現類...

mysql訊息訂閱與發布 發布 訂閱配置

public ibus bus public void handle mymessage message bus.publish e e.someproperty xyz 公共汽車 屬性將自動由基礎設施。這就是所謂的 依賴注入 所有開發完成了nservicebus利用這些模式。技術作為nservic...

Redis的發布訂閱

一般不用做訊息發布訂閱。簡介redis發布訂閱 pub sub 是一種訊息通訊模式 傳送者 pub 傳送訊息,訂閱者 sub 接收訊息。redis客戶端可以訂閱任意數量的頻道。下圖展示了頻道 channel1 以及訂閱這個頻道的三個客戶端 client2 client5 和 client1 之間的關...