Redis在Golang开发中的应用：如何处理高并发场景

连接Redis服务器：

import "github.com/go-redis/redis"

func main() {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // Redis密码
DB: 0, // 选择的数据库编号
})

// 测试连接是否成功
pong, err := client.Ping().Result()
if err != nil {
fmt.Println("连接Redis服务器失败：", err)
} else {
fmt.Println("连接Redis服务器成功，返回：", pong)
}

// 关闭连接
defer client.Close()
}

登录后复制

存储缓存数据：

func main() {
// 连接Redis服务器...

err := client.Set("key", "value", 0).Err() // 存储键为"key"，值为"value"的数据到Redis中，永不过期
if err != nil {
fmt.Println("存储缓存数据失败：", err)
} else {
fmt.Println("存储缓存数据成功")
}

// 关闭连接...
}

登录后复制

读取缓存数据：

func main() {
// 连接Redis服务器...

value, err := client.Get("key").Result() // 读取键为"key"的数据
if err == redis.Nil { // 找不到数据
fmt.Println("找不到缓存数据")
} else if err != nil { // 读取数据出错
fmt.Println("读取缓存数据失败：", err)
} else { // 读取数据成功
fmt.Println("缓存数据的值为：", value)
}

// 关闭连接...
}

登录后复制

分布式锁：

func main() {
// 连接Redis服务器...

lockKey := "lockKey"
lockValue := "lockValue"
lockExpire := time.Second * 10 // 锁的过期时间为10秒

success, err := client.SetNX(lockKey, lockValue, lockExpire).Result()
if err != nil {
fmt.Println("获取分布式锁失败：", err)
} else if !success { // 未获取到锁
fmt.Println("未获取到分布式锁")
} else { // 成功获取到锁
defer client.Del(lockKey) // 使用defer语句在结束时释放锁
fmt.Println("成功获取到分布式锁，进行业务处理")
}

// 关闭连接...
}

登录后复制

计数器：

func main() {
// 连接Redis服务器...

err := client.Incr("counter").Err() // 计数器自增
if err != nil {
fmt.Println("计数器自增失败：", err)
}

counter, err := client.Get("counter").Int64() // 获取计数器的值
if err != nil {
fmt.Println("获取计数器的值失败：", err)
} else {
fmt.Println("计数器的值为：", counter)
}

// 关闭连接...
}

登录后复制