标签：
发布和订阅
订阅的命令如下：
// 订阅一个或多个频道
subscribe channel1 channel2 channel3 ...
// 模式订阅，频道参数类似正则表达式
psubscribe abc* xyz* ...
发布命令如下：
publish channel msg
启动一个订阅者客户端 X
订阅 cctv-1 返回三个参数：subscribe 订阅成功，订阅的频道是 cctv-1，当前订阅的频道个数为 1；
订阅 cctv-2 返回三个参数：subscribe 订阅成功，订阅的频道是 cctv-2，当前订阅的频道个数为 2。
启动一个订阅者客户端 Y
订阅 cctv-* 返回三个参数：psubcribe 订阅成功，订阅的频道 cctv-*，当前客户端订阅的频道数量 1。
启动一个发布者客户端，发布频道 cctv-1 的消息
订阅者客户端 X 收到订阅信息，返回三个参数：收到消息成功，频道，收到的消息
订阅者客户端 Y 收到订阅信息，返回四个参数：收到消息成功，模式订阅频道，收到消息的频道，收到的消息
取消订阅
UNSUBSCRIBE cctv-1
PUNSUBSCRIBE cctv-*
取消订阅在官方给的客户端上是无法模拟的。
查看订阅
// 查看订阅的所有频道 pubsub channels; pubsub channels msg*; // 查看该频道的订阅人数 pubsub numsub channel1 channel2 ... ;
1 public class MySub extends JedisPubSub{ 2 3 @Override 4 public void onMessage(String channel, String msg) { 5 System.out.println("onMessage - " + channel +" - " +msg); 6 } 7 8 @Override 9 public void onPMessage(String pattern, String channel, String msg) { 10 System.out.println("onPMessage - " + pattern +" - "+ channel +" - " +msg); 11 } 12 13 @Override 14 public void onPSubscribe(String channel, int msg) { 15 System.out.println("onPsubscribe - " + channel +" - "+ msg); 16 } 17 18 @Override 19 public void onPUnsubscribe(String arg0, int arg1) {} 20 21 @Override 22 public void onSubscribe(String channel, int number) { 23 System.out.println("onSubscribe - " + channel +" - "+ number); 24 25 } 26 27 @Override 28 public void onUnsubscribe(String arg0, int arg1) {} 29 }
订阅者客户端 A
1 public class SubClient { 2 public static void main(String[] args) { 3 MySub sub = new MySub(); 4 Jedis jedis = new Jedis("127.0.0.1", 6379); 5 jedis.subscribe(sub, "cctv-1"); 6 } 7 }
订阅者客户端 B （模式订阅）
1 public class PsubClient { 2 public static void main(String[] args) { 3 MySub sub = new MySub(); 4 Jedis jedis = new Jedis("127.0.0.1", 6379); 5 jedis.psubscribe(sub, "cctv*"); 6 } 7 }
发布者客户端 C
1 public class PubClient { 2 public static void main(String[] args) { 3 Jedis jedis = new Jedis("127.0.0.1", 6379); 4 jedis.publish("cctv-1", "hello,this is cctv-1"); 5 } 6 }
依次运行客户端 ABC
A 端输出
onSubscribe - cctv-1 - 1 onMessage - cctv-1 - hello,this is cctv-1
B 端输出
onPsubscribe - cctv* - 1 onPMessage - cctv* - cctv-1 - hello,this is cctv-1
学无止境，多学多记。
标签：
原文地址：http://www.cnblogs.com/xmsx/p/5360171.html
