怎么利用Jedis實(shí)現(xiàn)Redis的訂閱與發(fā)布

SUBSCRIBE study

PUBLISH study "message1-go go go"

PSUBSCRIBE study*

PUBLISH study "message2"

PUBLISH study:java "I hate java forever"

127.0.0.1:6379> PUBSUB channels

1) "study"

private Logger logger = LoggerFactory.getLogger(PublishMessage.class);

@Resource
private JedisCluster jedisCluster;

/**
 * 發(fā)布消息
 *
 * @param channel 頻道
 * @param message 信息
 */
public void sendMessage(final String channel, final String message) {
  Thread thread = new Thread(() -> {
    Long publish = jedisCluster.publish(channel, message);
    logger.info("服務(wù)器在: {} 頻道發(fā)布消息{} - {}", channel, message, publish);
  });
  logger.info("發(fā)布線程啟動(dòng):");
  thread.setName("publishThread");
  thread.start();
}

private Logger logger = LoggerFactory.getLogger(ChatSubscribe.class);

// 取得訂閱的消息后的處理
@Override
public void onMessage(String channel, String message) {
  logger.info("訂閱成功,接收到的消息為:頻道-{},消息-{}", channel, message);
  RedisString.message = message;
}

// 取得按表達(dá)式的方式訂閱的消息后的處理
@Override
public void onPMessage(String pattern, String channel, String message) {
  System.out.println("-----取得按表達(dá)式的方式訂閱的消息后的處理-----");
  System.out.println(pattern + "=" + channel + "=" + message);
}

// 初始化按表達(dá)式的方式訂閱時(shí)候的處理
@Override
public void onPSubscribe(String pattern, int subscribedChannels) {
  System.out.println("-----初始化按表達(dá)式的方式訂閱時(shí)候的處理-----");
  System.out.println(pattern + "=" + subscribedChannels);
}

// 取消按表達(dá)式的方式訂閱時(shí)候的處理
@Override
public void onPUnsubscribe(String pattern, int subscribedChannels) {
  System.out.println("-----取消按表達(dá)式的方式訂閱時(shí)候的處理-----");
  System.out.println(pattern + "=" + subscribedChannels);
}

@Override
public void onPong(String pattern) {
  super.onPong(pattern);
}

// 初始化訂閱時(shí)候的處理
@Override
public void onSubscribe(String channel, int subscribedChannels) {
  logger.info("初始化訂閱信息:頻道-{},訂閱頻道-{}", channel, subscribedChannels);
}

// 取消訂閱時(shí)候的處理
@Override
public void onUnsubscribe(String channel, int subscribedChannels) {
  logger.info("已取消訂閱頻道{}", channel);
}

private Logger logger = LoggerFactory.getLogger(SubScribeMessage.class);

private ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

@Resource
private JedisCluster jedisCluster;
/**
   * 訂閱頻道
   *
   * @param channel     頻道
   * @param roomSubListerner
   */
  public void subscribeChannel(final String channel, final ChatSubscribe roomSubListerner) {

    cachedThreadPool.execute(new Runnable() {
      @Override
      public void run() {
        jedisCluster.subscribe(roomSubListerner, channel);
      }
    });
  }

jedisCluster是否封裝工具類，取自各位看官，核心代碼已給出，請(qǐng)各位看官根據(jù)自身業(yè)務(wù)與邏輯，自行更改與優(yōu)化代碼。

本次示例程序采用tomcat 9.0 + spring + springmvc

使用了諸如：@RestController,@GetMapping等相關(guān)注解，便于開發(fā)，有興趣可自行查閱spring相關(guān)資料。