Jedis实现Redis的Publish/Subscribe功能

Redis 天涯孤鸟 2102℃ 0评论

一、前言

Redis为我们提供了publish/subscribe(发布/订阅)功能。我们可以对某个channel(频道)进行subscribe(订阅),当有人在这个channel上publish(发布)消息时,redis就会通知我们,这样我们可以收到别人发布的消息,然后再进行处理。
同样的,Jedis作为Redis的客户端,也提供了publish/subscribe的接口,接下来这一篇介绍如果通过Jedis来实现Redis的 Publish/Subscribe功能。

二、定义监听类

Jedis定义了抽象类JedisPubSub,在这个类中,定义publish/subsribe的回调方法。通过继承JedisPubSub类并重新实现这些回调方法,当publish/subsribe事件发生时,我们可以定制自己的处理逻辑。

三、定义客户端订阅类

四、定义消息发布类

五、启动监听

先启动订阅类:

再启动消息发布类:

可以看到,订阅类已经接收到订阅的消息:

转载请注明:猫头鹰工作室 » Jedis实现Redis的Publish/Subscribe功能

喜欢 (0)or分享 (0)
Avatar
发表我的评论
取消评论

表情

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址