golang redis的模式订阅
2015-11-30 18:32
495 查看
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 } }
相关文章推荐
- Codis VS redis-cluster简单比较
- Redis_jedis高版本的JedisPoolConfig没有maxActive和maxWait
- 01Redis入门指南笔记(简介、安装、配置)
- Redis的异常采取的措施。(代码如下)
- redis开篇
- redis C#客户端
- 初学Redis(2)——用Redis作为Mysql数据库的缓存
- redis 单台cluster下解决set报错问题
- 初学Redis(1)——认识Redis
- Redis作者谈Redis应用场景
- Redis 环境搭建与使用(C#)
- 第2讲 Redis常用命令与高级应用
- 第1讲 Redis部署与基本操作
- PHP中使用redis执行lua脚本示例
- redis安装
- 利用未授权的redis写webshell
- redis下载
- redis 定义
- redis过期时间
- Redis简明教程-要点