首页 > 其他 > 详细

golang redis的模式订阅

时间:2015-11-30 20:16:19      阅读:353      评论:0      收藏:0      [点我收藏+]
c := redisPool.Get()
    psc := redis.PubSubConn{c}
    psc.PSubscribe("aa*")
    for {
        switch v := psc.Receive().(type) {
        case redis.Subscription:
            fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
        case redis.Message://单个订阅subscribe
            fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
        case redis.PMessage://模式订阅psubscribe
            fmt.Printf("PMessage: %s %s %s\n", v.Pattern, v.Channel, v.Data)
        case error:
            return

        }

    }

 

golang redis的模式订阅

原文:http://www.cnblogs.com/liughost/p/5008029.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!