golang 调用redis hset命令
时间: 2023-07-05 19:28:40 浏览: 69
在 Golang 中调用 Redis 的 HSET 命令,可以使用第三方库 go-redis。以下是示例代码:
```go
import (
"github.com/go-redis/redis/v8"
"context"
)
func main() {
ctx := context.Background()
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // 如果没有设置密码则为空
DB: 0, // 默认数据库
})
err := client.HSet(ctx, "hash-key", "field1", "value1").Err()
if err != nil {
panic(err)
}
}
```
以上代码连接到本地的 Redis 服务,将值 "value1" 存储在哈希表 "hash-key" 的字段 "field1" 中。你可以根据你实际的需要修改代码中的参数。
相关问题
golang 调用redis集群
在 Golang 中使用 Redis 集群,可以使用官方提供的 Redis 客户端库 Redigo。Redigo 提供了连接池、管道、事务等功能,非常适合高并发场景下的 Redis 操作。
以下是一个使用 Redigo 连接 Redis 集群的示例:
```go
package main
import (
"fmt"
"time"
"github.com/gomodule/redigo/redis"
)
func main() {
cluster := &redis.Cluster{
MaxRedirects: 8,
StartupNodes: []string{
"redis://node1:6379",
"redis://node2:6379",
"redis://node3:6379",
},
DialTimeout: 10 * time.Second,
ReadTimeout: 100 * time.Millisecond,
WriteTimeout: 100 * time.Millisecond,
}
conn, err := cluster.Get()
if err != nil {
panic(err)
}
defer conn.Close()
_, err = conn.Do("SET", "key", "value")
if err != nil {
panic(err)
}
value, err := redis.String(conn.Do("GET", "key"))
if err != nil {
panic(err)
}
fmt.Println(value)
}
```
在以上示例中,我们使用了 `redis.Cluster` 结构体来连接 Redis 集群,`MaxRedirects` 指定了最大重定向次数,`StartupNodes` 指定了集群中的节点地址,`DialTimeout`、`ReadTimeout`、`WriteTimeout` 分别指定了建立连接、读取数据、写入数据的超时时间。
使用 `cluster.Get()` 方法可以获取一个连接,使用完后需要调用 `conn.Close()` 方法释放连接。在获取到连接后,我们可以使用 `conn.Do()` 方法来执行 Redis 命令,也可以使用 `redis.String()`、`redis.Int()` 等方法来获取命令执行结果。
需要注意的是,在 Redis 集群中使用 `SET`、`GET` 等单个键操作命令时,Redigo 会自动进行分片操作,将请求发送到正确的节点。但是在使用一些不支持分片的命令时,需要手动指定节点。例如使用 `MGET` 命令时,需要使用 `redis.MultiConn.Do()` 方法并手动指定节点。
golang 调用redis集群给任务加锁
在 Golang 中使用 Redis 集群给任务加锁可以使用 Redsync 库。Redsync 是一个基于 Redis 的分布式互斥锁实现,它通过 Redis 集群提供了一种简单的方法来实现分布式锁。
以下是一个简单的示例代码,使用 Redsync 实现 Redis 集群分布式锁:
```go
package main
import (
"github.com/go-redsync/redsync/v4"
"github.com/go-redsync/redsync/v4/redis"
"github.com/gomodule/redigo/redis"
"time"
)
func main() {
// 创建 Redis 集群客户端
pool := &redis.Pool{
Dial: func() (redis.Conn, error) {
return redis.Dial("tcp", "your-redis-cluster-address:6379")
},
}
cluster := redis.NewCluster(nil, []*redis.Pool{pool})
// 创建 Redsync 实例
rs := redsync.New(cluster)
// 获取互斥锁
mutex := rs.NewMutex("my-lock")
// 尝试获取互斥锁,等待 10 秒
if err := mutex.LockEx(time.Second * 10); err != nil {
panic(err)
}
// 任务代码...
// 释放互斥锁
if _, err := mutex.Unlock(); err != nil {
panic(err)
}
}
```
在上面的示例中,我们首先创建了一个 Redis 集群客户端,然后使用该客户端创建了 Redsync 实例。接下来,我们创建了一个名为 "my-lock" 的互斥锁,并尝试在 10 秒内获取该锁。如果获取成功,代码将进入任务代码块,执行完成后会释放该锁。