论坛 › Redis › Redis 中 PubSub 的初步使用示例

发表于 2018-11-7 08:45:33

Redis 中 PubSub 的初步使用示例

　　JedisPoolpool = new JedisPool(new JedisPoolConfig(), "192.168.28.153");
　　Jedis jedis =pool.getResource();
　　Stringchannel = "muc-a";
　　jedis.subscribe(new JedisPubSub()
　　{
　　@Override
　　publicvoid onUnsubscribe(String channel, int subscribedChannels)
　　{
　　System.out.println("onUnsubscribe - " + channel + "|" +subscribedChannels);
　　}
　　@Override
　　publicvoid onSubscribe(String channel, int subscribedChannels)
　　{
　　System.out.println("onSubscribe - " + channel + "|" +subscribedChannels);
　　}
　　@Override
　　publicvoid onPUnsubscribe(String pattern, int subscribedChannels)
　　{
　　System.out.println("onPUnsubscribe - " + pattern + "|" +subscribedChannels);
　　}
　　@Override
　　publicvoid onPSubscribe(String pattern, int subscribedChannels)
　　{
　　System.out.println("onPSubscribe - " + pattern + "|" +subscribedChannels);
　　}
　　@Override
　　publicvoid onPMessage(String pattern, String channel, Stringmessage)
　　{
　　System.out.println("onPMessage - " + pattern + "|" +channel + "|" + message);
　　}
　　@Override
　　publicvoid onMessage(String channel, String message)
　　{
　　System.out.println("onMessage - " + channel + "|" +message);
　　}
　　}, channel);
　　pool.returnResource(jedis);
　　pool.destroy();

查看完整版本: Redis 中 PubSub 的初步使用示例