我观察到了同样的问题,即订阅后订阅线程就会阻塞。为了解决这个问题,我使用Netty实现了一个优化的发布/
订阅客户端,并将其合并到此处的Jedis分支中。这不是一个全面的解决方案,我还没有时间真正完成它,但是它适用于基本的频道和模式订阅。
使用以下命令获取pubsub实例:
public static OptimizedPubSub getInstance(String host, int port, String auth, long timeout)
使用以下方式发布/取消模式订阅:
public ChannelFuture psubscribe(String... patterns)public ChannelFuture punsubscribe(String... patterns)
您可以忽略返回的ChannelFuture,除非您想100%确定您的请求通过了(这是异步的)。
使用以下方式发布/取消频道订阅:
public ChannelFuture subscribe(String... channels)public ChannelFuture unsubscribe(String... channels)
然后实现SubListener实例:
public interface SubListener { public void onChannelMessage(String channel, String message); public void onPatternMessage(String pattern, String channel, String message);}并使用以下方法注册/取消注册侦听器:
public void registerListener(SubListener listener)public void unregisterListener(SubListener listener)
OptimizedPubSub永远不会阻止,并且事件会异步传递到已注册的SubListeners。
叉子现在有点旧了,所以它在当前形式下可能对您没有用,但是您可以轻松地从该包中提取源代码并独立构建它。依赖关系是Jedis和Netty。
抱歉,我没有更全面的解决方案。



