我正在尝试使用pub/sub impl。关于绝地武士获得大师下落的信息,但我不知道如何订阅哨兵频道。
我的出版商课程:

public Publisher(Jedis publisherJedis, String channels, String clusterName) {
    this.publisherJedis = publisherJedis;
    this.channels = channels;
    this.clusterName = clusterName;
}

public void start() {
    log.info("publishing on channel +odown");
    try {
        while(true) {
            if(JedisPoolFactory.getMasterDown(clusterName)) {
                publisherJedis.publish("+odown", "master down, master down");
            }
        }
    } catch(Exception ex) {
        log.error("failure with end of stream catching.", ex);
    }
}

我必须注册我的哨兵作为一个出版商,我需要做的是解码消息每次有主故障转移。我该如何订阅哨兵频道?

最佳答案

正如安蒂雷斯所说,你可以用普通的绝地实例连接哨兵,并订阅频道。这与redis pub/sub完全相同。

10-04 20:31