Redis 作為一個publish/subscribe server，起到了訊息路由的功能，訂閱者可以通過subscribe和psubscribe命令向Redis server訂閱自己感興趣的訊息型別，當發布者通過publish命令向Redis server發送特定型別的訊息時，訂閱該訊息型別的全部client都會收到此訊息，這里訊息的傳遞是多對多的，一個client可以訂閱多個channel,也可以向多個channel發送訊息，
下圖為大家展示了Redis訊息機制的體系架構，
發布者和訂閱者都是Redis客戶端，Channel則為Redis服務器端，發布者將訊息發送到某個的頻道，訂閱了這個頻道的訂閱者就能接收到這條訊息，Redis的這種發布訂閱機制與基于主題的發布訂閱類似，Channel相當于主題，
下面列出來了Redis發布訊息、訂閱訊息的相關命令，
publish：
發送訊息：Redis采用PUBLISH命令發送訊息，其回傳值為接收到該訊息的訂閱者的數量，
subscribe：
訂閱某個頻道：Redis采用SUBSCRIBE命令訂閱某個頻道，其回傳值包括客戶端訂閱的頻道，目前已訂閱的頻道數量，以及接收到的訊息，其中subscribe表示已經成功訂閱了某個頻道，
psubscribe：
模式匹配：模式匹配功能允許客戶端訂閱符合某個模式的頻道，Redis采用PSUBSCRIBE訂閱符合某個模式所有頻道，用“”表示模式，“”可以被任意值代替，
案例一：一個訊息生產者，兩個訊息消費者
案例二：兩個訊息生產者，一個訊息消費者
案例三：Redis訊息機制的Java API
添加依賴：
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.1.0</version> </dependency>
訊息監聽器類：
import redis.clients.jedis.JedisPubSub; public class RedisMsgPubSubListener extends JedisPubSub { @Override public void unsubscribe() { super.unsubscribe(); } @Override public void unsubscribe(String... channels) { super.unsubscribe(channels); } @Override public void subscribe(String... channels) { super.subscribe(channels); } @Override public void psubscribe(String... patterns) { super.psubscribe(patterns); } @Override public void punsubscribe() { super.punsubscribe(); } @Override public void punsubscribe(String... patterns) { super.punsubscribe(patterns); } @Override public void onMessage(String channel, String message) { System.out.println("channel:" + channel + "receives message :" + message); this.unsubscribe(); } @Override public void onPMessage(String pattern, String channel, String message) { } @Override public void onSubscribe(String channel, int subscribedChannels) { System.out.println("channel:" + channel + "is been subscribed:" + subscribedChannels); } @Override public void onPUnsubscribe(String pattern, int subscribedChannels) { } @Override public void onPSubscribe(String pattern, int subscribedChannels) { } @Override public void onUnsubscribe(String channel, int subscribedChannels) { System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels); } }
測驗程式：
import redis.clients.jedis.Jedis; public class TestMain { @Test public void testSubscribe() throws Exception{ Jedis jedis = new Jedis("localhost"); RedisMsgPubSubListener listener = new RedisMsgPubSubListener(); jedis.subscribe(listener, "redisChatTest"); //other code } @Test public void testPublish() throws Exception{ Jedis jedis = new Jedis("localhost"); jedis.publish("redisChatTest", "Hello World"); Thread.sleep(5000); jedis.publish("redisChatTest", "Hello Redis"); } }
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/4601.html
標籤：NoSQL