redigo是Go语言的Redis客户端,可以用来操作Redis数据库。以下是一些常见的redigo操作示例:
- 连接Redis数据库
import "github.com/gomodule/redigo/redis"
func main() {
// 创建连接池
pool := &redis.Pool{
MaxIdle: 10,
MaxActive: 1000,
IdleTimeout: 240 * time.Second,
Dial: func() (redis.Conn, error) {
return redis.Dial("tcp", "localhost:6379")
},
}
defer pool.Close()
// 获取连接
conn := pool.Get()
defer conn.Close()
// 执行命令
_, err := conn.Do("SET", "key", "value")
}
- 设置和获取键值对
// 设置键值对
_, err = conn.Do("SET", "key", "value")
// 获取键值对
value, err := redis.String(conn.Do("GET", "key"))
if err != nil {
fmt.Println("error getting value from redis:", err)
} else {
fmt.Println(value)
}
- 列表操作
// 将元素添加到列表尾部
_, err = conn.Do("RPUSH", "list_key", "item")
// 获取列表长度
length, err := redis.Int(conn.Do("LLEN", "list_key"))
// 获取指定范围内的元素
items, err := redis.Strings(conn.Do("LRANGE", "list_key", 0, -1))
- 集合操作
// 添加元素到集合中
_, err = conn.Do("SADD", "set_key", "value1", "value2")
// 获取集合元素个数
count, err := redis.Int(conn.Do("SCARD", "set_key"))
// 判断元素是否在集合中
exist, err := redis.Bool(conn.Do("SISMEMBER", "set_key", "value1"))
- 哈希表操作
// 设置哈希表字段值
_, err = conn.Do("HSET", "hash_key", "field1", "value1")
// 获取哈希表字段值
value, err := redis.String(conn.Do("HGET", "hash_key", "field1"))
// 获取所有哈希表字段和值
items, err := redis.Strings(conn.Do("HGETALL", "hash_key"))
- 事务操作
conn.Send("MULTI")
conn.Send("SET", key1, value1)
conn.Send("SET", key2, value2)
reply, err := conn.Do("EXEC")
if reply == nil || err != nil {
fmt.Println(err)
} else {
fmt.Println(reply)
}
- 发布/订阅操作
pubsubConn := redis.PubSubConn{Conn: conn}
pubsubConn.Subscribe(channel)
for {
switch v := pubsubConn.Receive().(type) {
case redis.Message:
fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
case redis.Subscription:
fmt.Printf("%s: %d\n", v.Channel, v.Count)
case error:
return v
}
}
以上是一些常见的redigo操作示例,更多细节可以参考redigo官方文档:https://github.com/gomodule/redigo