一 前言

雖然有消息隊(duì)列，我們還是要了解一下redis發(fā)布訂閱模式喲！！！！！

二發(fā)布訂閱模式

PUBLISH 命令向通道發(fā)送信息，此客戶(hù)端稱(chēng)為publisher 發(fā)布者；

SUBSCRIBE 向命令通道訂閱信息，此客戶(hù)端稱(chēng)為subscriber 訂閱者；

redis 中 發(fā)布訂閱模塊的名字叫著 PubSub，也就是 PublisherSubscriber；

一個(gè)發(fā)布者向一個(gè)通道發(fā)送消息，訂閱者可以向多個(gè)通道訂閱消息；當(dāng)發(fā)布者向通道發(fā)布消息后，如果有訂閱者訂閱該通道，訂閱者就會(huì)收到消息；這有點(diǎn)像電臺(tái)，我收聽(tīng)了一個(gè)電臺(tái)的頻道，當(dāng)頻道發(fā)送消息后，我就能收到消息；

三PUBSub模塊命令subscribe： 訂閱一個(gè)或者多個(gè)頻道；

unsubscribe: 退訂一個(gè)或者多個(gè)頻道；

publish: 向通道發(fā)送消息；

psubscribe: 訂閱給定模式相匹配的所有頻道；

punsubscribe: 退訂 給定模式所有的頻道，若未指定模式，退訂所有頻道；

具體的命令使用方式 可以使用 help 命令 ;示例如下：

help subscribe

四客戶(hù)端實(shí)現(xiàn)

通過(guò)指令SUBSCRIBE訂閱一個(gè)頻道，如果頻道不存在時(shí)則新建一個(gè)頻道；此時(shí)此客戶(hù)端就是訂閱者127.0.0.1:6379> subscribe zszxz

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "zszxz"

3) (integer) 1

?

通過(guò)指令publish向通道發(fā)送一個(gè)消息；此時(shí)客戶(hù)端就是發(fā)布者127.0.0.1:6379> publish zszxz "l miss you"

(integer) 1

127.0.0.1:6379>

我們?cè)倏纯?客戶(hù)端就收到消息了127.0.0.1:6379> subscribe zszxz

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "zszxz"

3) (integer) 1

1) "message"

2) "zszxz"

3) "l miss you"

五java 實(shí)現(xiàn)

定義2個(gè)訂閱者用于訂閱頻道的消息，在使用jedis 時(shí) 需要 繼承 JedisPubSub 類(lèi)， 并重寫(xiě) onMessage 方法； 訂閱者可以在該方法里面進(jìn)行消息的業(yè)務(wù)邏輯處理；

訂閱者 1/\*\*

\* @Author lsc

\*

訂閱者1號(hào)

\*/

@Component

public class Sub1 extends JedisPubSub {

?

@Override

public void onMessage(String channel, String message) {

System.out.println("sub1 channel is :"+ channel+ " mesage is :"+message);

}

}

訂閱者2/\*\*

\* @Author lsc

\*

訂閱者2號(hào)

\*/

@Component

public class Sub2 extends JedisPubSub {

?

@Override

public void onMessage(String channel, String message) {

System.out.println("sub2 channel is :"+ channel+ " mesage is :"+message);

}

}

發(fā)布者/\*\*

\* @Author lsc

\*

\*/

@Component

public class Pub {

?

public void publishMessage(Jedis jedis, String channel, String msg) {

jedis.publish(channel,msg);

}

}

測(cè)試類(lèi)、

注意redis 的 發(fā)布訂閱模式 是阻塞模式 ，一個(gè)訂閱者需要 重新起一個(gè)線(xiàn)程；@Autowired

Pub pub;

?

@Autowired

JedisUtil jedisUtil;

?

@Autowired

Sub1 sub1;

?

@Autowired

Sub1 sub2;

?

@Test

public void test(){

?

new Thread(()\-> {

while (true){

jedisUtil.getJedis().subscribe(sub1,"zszxz");

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

//jedisUtil.getJedis().subscribe(sub2,"zszxz");

}).start();

pub.publishMessage(jedisUtil.getJedis(),"zszxz","l miss you");

}

六 缺點(diǎn)PubSub 的生產(chǎn)者來(lái)一個(gè)消息會(huì)直接傳遞給消費(fèi)者。如果沒(méi)有消費(fèi)者，消息會(huì)直接丟棄。如果有多個(gè)消費(fèi)者，一個(gè)消費(fèi)者突然掛掉，生產(chǎn)者會(huì)繼續(xù)發(fā)送消息，另外的消費(fèi)者可以持續(xù)收到消息。但是掛掉的消費(fèi)者重新連上后，斷連期間的消息會(huì)徹底丟失；

如果 Redis 停機(jī)重啟，PubSub 的消息是不會(huì)持久化

求關(guān)注

總結(jié)

以上是生活随笔為你收集整理的java 阅发布模式_redis发布订阅模式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。