5

我正在努力创建一个 Jedis 客户端的概念，该客户端作为 Redis pubsub 频道的订阅者无限地监听并在消息进入时处理它们。

我的问题是，在一段时间不活动后，服务器会停止静默响应。我认为这是由于我订阅的 Jedis 客户端发生超时。

这可能真的是这样吗？如果是这样，有没有办法将这个特定的 Jedis 客户端配置为不超时？（虽然其他 Jedispools 不受某些全局设置超时的影响）或者，是否有另一种（最佳实践）方法可以实现我想要实现的目标？

这是我的代码，（修改/剥离显示）：

在网络服务器启动期间执行：

new Thread(AkkaStarter2.getSingleton()).start();

AkkaStarter2.java

   private Jedis sub;
   private AkkaListener akkaListener;

   public static AkkaStarter2 getSingleton(){
      if(singleton==null){
        singleton = new AkkaStarter2();
      }
      return singleton;
    }

    private AkkaStarter2(){
      sub = new Jedis(REDISHOST, REDISPORT);
      akkaListener = new AkkaListener();
    }

    public void run() {
      //blocking
      sub.psubscribe(akkaListener, AKKAPREFIX + "*");
    }

    class AkkaListener extends JedisPubSub {
        ....
        public void onPMessage(String pattern, String akkaChannel,String jsonSer) {
          ...
        }
    }

谢谢。

4

1 回答 1

7

ermmm，下面解决了这一切。确实这是绝地武士的事情

private AkkaStarter2(){
  //0 specifying no timeout.. Overlooked this 100 times
  sub = new Jedis(REDISHOST, REDISPORT,0); 
  akkaListener = new AkkaListener();
}
于 2011-12-23T21:05:27.103 回答