這篇文章主要介紹java如何實(shí)現(xiàn)redis的發(fā)布訂閱，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

創(chuàng)新互聯(lián)建站服務(wù)項(xiàng)目包括安慶網(wǎng)站建設(shè)、安慶網(wǎng)站制作、安慶網(wǎng)頁制作以及安慶網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，安慶網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到安慶省份的部分城市，未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

redis的應(yīng)用場景實(shí)在太多了，現(xiàn)在介紹一下它的幾大特性之一   發(fā)布訂閱（pub/sub）。

特性介紹：

什么是redis的發(fā)布訂閱（pub/sub）？   Pub/Sub功能（means Publish, Subscribe）即發(fā)布及訂閱功能?；谑录南到y(tǒng)中，Pub/Sub是目前廣泛使用的通信模型，它采用事件作為基本的通信機(jī)制，提供大規(guī)模系統(tǒng)所要求的松散耦合的交互模式：訂閱者(如客戶端)以事件訂閱的方式表達(dá)出它有興趣接收的一個(gè)事件或一類事件；發(fā)布者(如服務(wù)器)可將訂閱者感興趣的事件隨時(shí)通知相關(guān)訂閱者。熟悉設(shè)計(jì)模式的朋友應(yīng)該了解這與23種設(shè)計(jì)模式中的觀察者模式極為相似。

同樣,Redis的pub/sub是一種消息通信模式，主要的目的是解除消息發(fā)布者和消息訂閱者之間的耦合,  Redis作為一個(gè)pub/sub的server, 在訂閱者和發(fā)布者之間起到了消息路由的功能。

如果沒聽懂上述的專業(yè)解釋，沒關(guān)系，其實(shí)我也沒太聽懂。

簡單來講，這里面還有個(gè)channel的概念，這里就是頻道的意思，比如你訂閱了銀行的頻道，當(dāng)你的資金發(fā)生變動時(shí)，你就會接受到銀行就會通過它的頻道給你發(fā)送信息，在這里，你是屬于被動接收的，而不是向銀行索要信息，這個(gè)例子中，你就是sub（訂閱者），而銀行就是pub（發(fā)布者）。

項(xiàng)目運(yùn)用場景：

一直都認(rèn)為你會一樣技術(shù)之前，都必須先明白這樣一種技術(shù)在哪些地方會被用到，不能盲目的學(xué)東西。

看到發(fā)布訂閱的特性，用來做一個(gè)簡單的實(shí)時(shí)聊天系統(tǒng)再適合不過了。這是其中之一，當(dāng)然這樣的東西，我們開發(fā)中很少涉及到。再舉一個(gè)常用的，在我們的分布式架構(gòu)中，常常會遇到讀寫分離的場景，在寫入的過程中，就可以使用redis發(fā)布訂閱，使得寫入值及時(shí)發(fā)布到各個(gè)讀的程序中，就保證數(shù)據(jù)的完整一致性。再比如，在一個(gè)博客網(wǎng)站中，有100個(gè)粉絲訂閱了你，當(dāng)你發(fā)布新文章，就可以推送消息給粉絲們拉?？傊畧鼍昂芏啵枰ネ诰?。。

回顧java如何操作redis：

redis是一種緩存數(shù)據(jù)庫，它也是C/S的結(jié)構(gòu)，也就是客戶端和服務(wù)端，一般來說，在java中，我們通常使用 jedis（客戶端）去操作redis（服務(wù)端），這其中操作的時(shí)候，兩者之間肯定要建立連接，就像數(shù)據(jù)庫鏈接一樣，在關(guān)系型數(shù)據(jù)庫中，我們一般都維護(hù)一個(gè)連接池，以達(dá)到鏈接的復(fù)用，來省去建立連接和關(guān)閉連接的時(shí)間。所以在jedis中，同樣也存在一個(gè)jedispool（jedis連接池）的概念，我們都是從池中去取連接使用。

上代碼：

想使用jedis先引入依賴

redis.clients
jedis
2.9.0

建立一個(gè)Publisher (發(fā)布者)

public class Publisher extends Thread{

  private final JedisPool jedisPool;

  public Publisher(JedisPool jedisPool) {
    this.jedisPool = jedisPool;
  }
  
  @Override
  public void run() {
    BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
    Jedis jedis = jedisPool.getResource();  //連接池中取出一個(gè)連接
    while (true) {
      String line = null;
      try {
        line = reader.readLine();
        if (!"quit".equals(line)) {
          jedis.publish("mychannel", line);  //從 mychannel 的頻道上推送消息
        } else {
          break;
        }
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
}

再建立一個(gè)訂閱者

public class Subscriber extends JedisPubSub {
  public Subscriber(){}
  @Override
  public void onMessage(String channel, String message) {    //收到消息會調(diào)用
    System.out.println(String.format("receive redis published message, channel %s, message %s", channel, message));
  }
  @Override
  public void onSubscribe(String channel, int subscribedChannels) {  //訂閱了頻道會調(diào)用
    System.out.println(String.format("subscribe redis channel success, channel %s, subscribedChannels %d",
        channel, subscribedChannels));
  }
  @Override
  public void onUnsubscribe(String channel, int subscribedChannels) {  //取消訂閱 會調(diào)用
    System.out.println(String.format("unsubscribe redis channel, channel %s, subscribedChannels %d",
        channel, subscribedChannels));

  }
}

這里訂閱者需要繼承JedisPubSub，來重寫它的三個(gè)方法。用途 注釋上已經(jīng)寫了，很簡單。

我們這里只是定義了一個(gè)訂閱者，下面去訂閱頻道。

public class SubThread extends Thread {
  private final JedisPool jedisPool;
  private final Subscriber subscriber = new Subscriber();

  private final String channel = "mychannel";

  public SubThread(JedisPool jedisPool) {
    super("SubThread");
    this.jedisPool = jedisPool;
  }

  @Override
  public void run() {
    System.out.println(String.format("subscribe redis, channel %s, thread will be blocked", channel));
    Jedis jedis = null;
    try {
      jedis = jedisPool.getResource();  //取出一個(gè)連接
      jedis.subscribe(subscriber, channel);  //通過subscribe 的api去訂閱，入?yún)⑹怯嗛喺吆皖l道名
    } catch (Exception e) {
      System.out.println(String.format("subsrcibe channel error, %s", e));
    } finally {
      if (jedis != null) {
        jedis.close();
      }
    }
  }
}

最后，再寫一個(gè)測試類去跑一下。鍵盤輸入消息，訂閱者就會觸發(fā)onMessage方法

public class PubSubDemo {
  public static void main( String[] args )
  {
    // 連接redis服務(wù)端
    JedisPool jedisPool = new JedisPool(new JedisPoolConfig(), "127.0.0.1", 6379);
    
    System.out.println(String.format("redis pool is starting, redis ip %s, redis port %d", "127.0.0.1", 6379));

    SubThread subThread = new SubThread(jedisPool); //訂閱者
    subThread.start();

    Publisher publisher = new Publisher(jedisPool);  //發(fā)布者
    publisher.start();
  }
}

看打印結(jié)果

以上是“java如何實(shí)現(xiàn)redis的發(fā)布訂閱”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！