u1 = Redis.new

u2 = Redis.new

u1.subscribe "channel1" do |on|
    on.subscribe do |channel, subscriptions|
        puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
    end

    on.message do |channel, msg|
        puts "#{channel}: #{msg}"
    end
end

#Subscribed to #channel1 (1 subscriptions)

u2.publish 'channel1', 'hello'

#Subscribed to #channel1 (1 subscriptions)
#channel1: hello

redis.subscribe(:one, :two) do |on|
    #channel:当前的频道，subscriptions: 第几个频道
    on.subscribe do |channel, subscriptions|
      puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
    end
    #channel:当前的频道，message: 消息内容
    on.message do |channel, message|
      puts "##{channel}: #{message}"
      redis.unsubscribe if message == "exit"
    end
    #
    on.unsubscribe do |channel, subscriptions|
      puts "Unsubscribed from ##{channel} (#{subscriptions} subscriptions)"
    end
  end

redis.psubscribe('c*') do |on|
    on.psubscribe do |channel, subscriptions|
      puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
    end

    on.pmessage do |pattern, channel, message|
      puts "##{channel}: #{message}"
      redis.unsubscribe if message == "exit"
    end

    on.punsubscribe do |channel, subscriptions|
      puts "Unsubscribed from ##{channel} (#{subscriptions} subscriptions)"
    end
  end