1.建立執行緒任務保證專案啟動就開始執行監聽redis訂閱任務,建立類redispubtaskservice:
**如下:
public class redispubtaskservice2.建立類redissubservice整合類jedispubsub;}
**如下:
@service3.建立乙個類負責啟動訂閱任務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)
}
**如下:
@servicepublic 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 之間的關...