在Redis重新启动时自动将Storm拓扑重新连接到Redis群集

Question

我创建了一个Storm拓扑，它使用Jedis库连接到Redis Cluster。 Storm组件总是希望Redis启动并运行，然后才连接到Redis并订阅事件。目前我们使用Redis的pub-sub策略。

下面是代码示例，它解释了Storm中为Redis提供的Jedis连接。

try {
    jedis.psubscribe(listener, pattern);
} catch(Exception ex) {
    //catch statement here.
} finally {
    pool.returnResource(jedis);
}

....

pool = new JedisPool(new JedisPoolConfig(), host, port); //redis host port

ListenerThread listener = new ListenerThread(queue, pool, pattern);
listener.start();

预期的行为

一旦Redis去世并重新上线，预计Storm将确定Redis的状态。如果Redis死机并上线，则无需重启。

实际行为

一旦Redis因任何原因重新启动，我总是必须重新启动Storm拓扑，然后才开始收听Redis。

题

Redis重启后，如何让Storm监听并重新连接到Redis？任何指导将不胜感激，即。 docs，论坛答案。

Answer 1

这是apache-storm的一个常见问题，其中连接线程处于过时状态，尽管您正在消耗的源是关闭/重新启动的。理想情况下，它应该重新创建新的连接线程，而不是重用现有的连接线程。因此，想法是通过检测异常（例如，在JMS的情况下为JMSConnectionError）使其自动化。

请参考这个Failover Consumer Example，它将简要介绍在这种情况下该怎么做。（P.S这是JMS，你的情况下将是JMS。）

步骤就是这样的。

1. 在ERROR或连接丢失的情况下捕获异常。
2. 来自catch的初始连接（如果不是由程序自动关闭）。
3. 如果异常进入第1步。