经典的广播/订阅模式，看看Redis的java如何实现：

 

JedisPubSub是一个抽象类，一般应该继承它，实现自己的逻辑，实现抽象方法，

在抽象方法中调用自己的逻辑即可。

• 订阅

@Test

    public void subscribe_test() {         JedisPool pool = new JedisPool(new JedisPoolConfig(), host, port,                 timeout);

        Jedis jedis = pool.getResource();

        JedisPubSub jedisPubSub = new JedisPubSub() {             @Override             public void onUnsubscribe(String channel, int number) {                 System.out.println("channel: "+channel);                 System.out.println("number :"+number);             }             @Override             public void onSubscribe(String channel, int number) {                 System.out.println("channel: "+channel);                 System.out.println("number :"+number);             }             @Override             public void onPUnsubscribe(String arg0, int arg1) {             }             @Override             public void onPSubscribe(String arg0, int arg1) {             }             @Override             public void onPMessage(String arg0, String arg1, String arg2) {             }             @Override             public void onMessage(String channel, String msg) {                 System.out.println("收到频道 : 【" + channel +" 】的消息 ：" + msg);             }         };         jedis.subscribe(jedisPubSub, new String[]{"channel1","channel2"});         pool.returnResource(jedis);     }

 

• 发布
      @Test
      public void publish_test() {
          JedisPool pool = new JedisPool(new JedisPoolConfig(), host, port,
                  timeout);

        Jedis jedis = pool.getResource();

        long i = jedis.publish("channel1", "channel1的朋友们，你们好吗？亲");         System.out.println(i+" 个订阅者接受到了 channel1 消息");         i = jedis.publish("channel2", "你好呀，亲");         System.out.println(i+" 个订阅者接受到了 channel2 消息");         pool.returnResource(jedis);     }