当前位置：首页 > news >正文

golang redis第三方库github.com/go-redis/redis/v8实践

news 2025/6/16 20:57:03

Redis基本数据类型代码示例#

这里示例使用 go-redis v8 ，不过 go-redis latest 是 v9

安装v8：go get github.com/go-redis/redis/v8

Redis 5 种基本数据类型：

string 字符串类型；list列表类型；hash哈希表类型；set集合类型；zset有序集合类型

最基本的Set/Get操作#

setget.go

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// 设置 key 的值，0 表示永不过期

err = rdb.Set(ctx, "setkey-1", "value-1", 0).Err()

if err != nil {

panic(err)

}

// 设置 key 的值的过期时间为 30 秒

err = rdb.Set(ctx, "setkey-2", "value-2", time.Second*30).Err()

if err != nil {

panic(err)

}

// 获取key的值

val, err := rdb.Get(ctx, "setkey-1").Result()

if err == redis.Nil { // 如果返回 redis.Nil 说明key不存在

fmt.Println("key not exixt")

} else if err != nil {

fmt.Println("Get Val error: ", err)

panic(err)

}

fmt.Println("Get Val: ", val)

val, _ = rdb.Get(ctx, "setkey-2").Result()

fmt.Println("Get Val setkey-2: ", val)

}

string(s)字符串类型#

可以从 redis docs 的 COMMANDS 查询 string 的所有命令。

String 类型命令文档：Commands | Redis ，
更具体的用法比如详细语法，参数设置等，点击每一个命令然后进去查看。
比如点进去后 SET 的详细语法格式：

Copy

SET key value [NX | XX] [GET] [EX seconds | PX milliseconds |

EXAT unix-time-seconds | PXAT unix-time-milliseconds | KEEPTTL]

具体命令用法可以搜索上面 command 然后点进去查看，这里主要是代码示例，就不介绍具体命令用法了。

string 的底层是 SDS 数据结构，原理简析可以看这篇文章：https://www.cnblogs.com/jiujuan/p/15828302.html。

string 常用命令：

1.SET/GET：设置获取值。

2.SETNX/EXISTS：SETNX设置并指定过期时间仅key不存在，EXISTS 检查某个 key 是否存在。

3.MSET/MGET：批量设置获取值。

4.DEL：删除值。

5.INCR/INCRBY - DECR/DECRBY：INCR 原子加1，INCRBY 加具体数值。DECR/DECRBY 刚好相反。

6.GetRange：字符串截取，返回字符串的总长度。

7.Expire/ExpireAt/TTL：设置值的过期时间端/点。TTL 获取过期的时间。

8.StrLen：获取key的值长度

1、SET/GET：设置和获取值，见最上面SET/GET例子
2、SETNX/EXISTS

SETNX：设置并指定过期时间，仅当 key 不存在时候才设置有效。

EXISTS: 检查某个 key 是否存在

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// SetNX，设置并指定过期时间，仅当 key 不存在时候才设置有效

err = rdb.SetNX(ctx, "setnx-key", "setnx-val", 0).Err()

if err != nil {

fmt.Println("setnx value failed: ", err)

panic(err)

}

// 这里用SetNX设置值，第二次运行后 val2 返回 false，因为第二次运行时 setnx-key2 已经存在

val2, err := rdb.SetNX(ctx, "setnx-key2", "setnx-val2", time.Second*20).Result()

if err != nil {

panic(err)

}

fmt.Printf("val2: %v \n", val2)

// Exists，检查某个key是否存在

n, _ := rdb.Exists(ctx, "setnx-key").Result()

if n > 0 {

fmt.Println("n: ", n)

fmt.Println("set nx key exists")

} else {

fmt.Println("set nx key not exists")

}

val, _ := rdb.Get(ctx, "setnx-key").Result()

fmt.Println(val)

}

3、MSET/MGET：批量设置值，批量获取值

Copy

ctx = context.Background()// MSet 设置值

err = rdb.MSet(ctx, "mset-key1", "mset-val1", "mset-key2", "mset-val2", "mset-key3", "mset-val3").Err()if err != nil {

fmt.Println("MSet ERROR : ", err)

}// MGet 获取值

vals, err := rdb.MGet(ctx, "mset-key1", "mset-key2", "mset-key3").Result()if err != nil {

fmt.Println("MGet ERROR: ", err)

panic(err)

}

fmt.Println("vals: ", vals)

4、DEL：删除操作，支持删除多个 key 的操作

Copy

ctx = context.Background()

n, err := rdb.Del(ctx, "setkey", "setnx-key").Result()if err != nil {

panic(err)

}

fmt.Println("del nums: ", n)

5、INCR/INCRBY - DECR/DECRBY

INCR：对数字进行原子加 1 操作；INCRBY：加某个数值。

同理 DECR 都是相反操作

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

err = rdb.SetNX(ctx, "nums", 2, 0).Err()

if err != nil {

panic(err)

}

fmt.Println("set nums : ", 2)

// Incr

val, err := rdb.Incr(ctx, "nums").Result()

if err != nil {

panic(err)

}

fmt.Println("incr: ", val)

// IncrBy

val, err = rdb.IncrBy(ctx, "nums", 10).Result()

if err != nil {

panic(err)

}

fmt.Println("incrby: ", val)

//Decr

val, _ = rdb.Decr(ctx, "nums").Result()

fmt.Println("desc: ", val)

//DecrBy

val, _ = rdb.DecrBy(ctx, "nums", 5).Result()

fmt.Println("decrby: ", val)

}

6、GetRange：字符串截取，返回字符串的总长度

Copy

// GetRange，字符串截取操作，返回字符串截取后的值

val, _ = rdb.GetRange(ctx, "setkey-1", 1, 3).Result()

fmt.Println("get range: ", val)

可以放到GET/SET代码里去测试

7、Expire/ExpireAt/TTL 设置过期时间

Expire：设置某个时间段后过期。

ExpireAt：设置某个时间点过期。

TTL：获取剩余时间

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

rdb.Set(ctx, "setkey-expire-1", "value-expire-1", 0).Err()

rdb.Set(ctx, "setkey-expire-2", "value-expire-2", time.Second*40).Err()

// Expire, 设置key在某个时间段后过期

val1, _ := rdb.Expire(ctx, "setkey-expire-1", time.Second*20).Result()

fmt.Println("expire: ", val1)

// ExpireAt，设置key在某个时间点后过期

val2, _ := rdb.ExpireAt(ctx, "setkey-expire-2", time.Now().Add(time.Second*50)).Result()

fmt.Println("expire at: ", val2)

// TTL

expire, err := rdb.TTL(ctx, "setkey-expire-1").Result()

fmt.Println(expire, err)

}/**

expire: true

expire at: true

20s <nil>

**/

8、StrLen 获取key的值的长度

Copy

// STRLEN，获取key的值的长度

strlen, _ := rdb.StrLen(ctx, "setkey-1").Result()

fmt.Println("strlen: ", strlen)

list列表类型#

list 类型的操作命令文档：Commands | Redis 。

list 列表是一个字符串列表，可以从头部或尾部插入元素。

list 的源码简析可以看这篇文章：https://www.cnblogs.com/jiujuan/p/15839269.html。

list 常用命令：

1.LPUSH：list头部(左边)插入值，最后的值在最前面。LPUSHX 仅当列表值存在时才插入值

2.LPOP：移除列表的头部值并返回这个值

3.RPUSH：list尾部(右边)插入值。RPUSHX 仅当列表值存在才插入值

4.RPOP：移除列表的尾部值并返回这个值

5.LRANGE：返回key列表指定区间的值

6.BLPOP: 语法 BLPOP key [key ...] timeout，从 key 列表头部弹出一个值，没有就阻塞 timeout 秒，如果 timeout=0 则一直阻塞

7.BRPOP：与上面 BLPOP 用法相似，只不过 BRPOP 是从尾部弹出一个值

8.LLEN：返回列表的长度

9.LINSERT：在指定位置插入数据

10.LREM：删除列表中的数据

11.LINDEX：根据索引查询列表中的值

12.LSET：根据索引设置列表中的某个值

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// LPUSH 从头部(左边)插入数据，最后的值在最前面

count, err := rdb.LPush(ctx, "listkeyone", "one", "two", "three", "four").Result()

if err != nil {

fmt.Println("lpush err：", err)

}

fmt.Println("lpush count: ", count)

// LRANGE 返回列表范围数据。例子中返回 0 到 -1，就是返回所有数据

rangeval, err := rdb.LRange(ctx, "listkeyone", 0, -1).Result()

if err != nil {

panic(err)

}

fmt.Println("LRange values: ", rangeval)

// LLen 返回列表数据大小

len, err := rdb.LLen(ctx, "listkeyone").Result()

if err != nil {

panic(err)

}

fmt.Println("llen: ", len)

// LInsert 在指定位置插入数据

err = rdb.LInsert(ctx, "listkeyone", "before", "two", 2).Err()

if err != nil {

panic(err)

}

vals, _ := rdb.LRange(ctx, "listkeyone", 0, -1).Result()

fmt.Println("LInsert val: ", vals)

// RPUSH 在 list 尾部插入值

count, err := rdb.RPush(ctx, "listkeyone", "six", "five").Result()

if err != nil {

panic(err)

}

fmt.Println("RPush count: ", count)

// RPOP 删除list列表尾部(右边)值

val, err := rdb.RPop(ctx, "listkeyone").Result()

if err != nil {

panic(err)

}

fmt.Println("rpop val: ", val)

vals, _ = rdb.LRange(ctx, "listkeyone", 0, -1).Result()

fmt.Println("(rpop)lrange val: ", vals)

// LPOP 删除list列表头部(左边)值

val, err = rdb.LPop(ctx, "listkeyone").Result()

fmt.Println("rpop val: ", val)

// LIndex 根据索引查询值，索引是从0开始

val1, _ := rdb.LIndex(ctx, "listkeyone", 3).Result()

fmt.Println("LIndex val: ", val1)

// LSET 根据索引设置某个值，索引从0开始

val2, _ := rdb.LSet(ctx, "listkeyone", 3, "han").Result()

fmt.Println("lset: ", val2)

// LREM 删除列表中的数据

del, err := rdb.LRem(ctx, "listkeyone", 1, 5) // 从列表左边开始删除值 5，出现重复元素只删除一次

if err != nil {

panic(err)

}

fmt.Println("del : ", del)

rdb.LRem(ctx, "listkeyone", 2, 5) // 从列表头部(左边)开始删除值 5，如果存在多个值 5，则删除 2 个 5

rdb.LRem(ctx, "listkeyone", -3, 6) // 从列表尾部(右边)开始删除值 6，如果存在多个值 6，则删除 3 个 6

}

hash哈希表类型#

hash类型数据操作命令：Commands | Redis ，官方文档

hash类型原理简析：https://www.cnblogs.com/jiujuan/p/15944061.html 参考文档

hash 数据结构图：

hash 哈希表数据类型常用命令，redisdoc.com 这个地址把Redis分类列出来了，还有详细解释：

1.HSET 单个设置值。

2.HGET 单个获取值。

3.HMSET 批量设置。

4.HMGET 批量获取值。

5.HGETALL 获取所有值。

6.HDEL 删除字段，支持删除多个字段。

7.HLEN 获取hash表中key的值数量。

8.HEXISTS 判断元素是否存在。

9.HINCRBY 根据key的field字段的整数值加减一个数值。

10.HSETNX 如果某个字段不存在则设置该字段值。

更多命令请查看：Commands | Redis

代码示例：

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// HSET，根据key设置field字段值

err = rdb.HSet(ctx, "hashkey", "field-val", "value-one").Err()

if err != nil {

panic(err)

}

_ = rdb.HSet(ctx, "hashkey", "field1", "value1", "field2", "value2").Err()

_ = rdb.HSet(ctx, "hashkey", map[string]interface{}{"field3": "value3", "field4": "value4"}).Err()

_ = rdb.HSet(ctx, "hashkey-two", []string{"field0", "value0", "field1", "value1"}).Err()

// HSETNX，如果某个字段不存在则设置值

ok, err := rdb.HSetNX(ctx, "hashkey", "field1", "oneval").Result() // 字段 field1 已存在，所以返回ok值为false

if err != nil {

panic(err)

}

fmt.Println("HSetNX bool: ", ok)

// HGET，根据key和field查询值

val, err := rdb.HGet(ctx, "hashkey", "field-val").Result()

if err != nil {

panic(err)

}

fmt.Println("HGet: ", val)

val, _ = rdb.HGet(ctx, "hashkey-two", "field0").Result()

fmt.Println("HGet hashkey-two: ", val)

// HGETALL，获取key的所有field-val值

fieldvals, err := rdb.HGetAll(ctx, "hashkey").Result()

if err != nil {

panic(err)

}

fmt.Println("HGetAll: ", fieldvals) // 返回 map 类型

// HMSET，根据hash key设置多个字段值，与上面的 HSet 设置多个值很像

fieldvalues := make(map[string]interface{})

fieldvalues["age"] = 23

fieldvalues["firstname"] = "Chare"

fieldvalues["lastname"] = "Jimmy"

err = rdb.HMSet(ctx, "hmsetkey", fieldvalues).Err()

if err != nil {

panic(err)

}

/*//也可以像上面HSet直接设置map值

rdb.HMSet(ctx, "hmsetkey", map[string]interface{}{"age":23,"firstname":"Chare","LastName":"Jimmy"}).Err()

// HMGET, 根据hash key和多个字段获取值

vals, err := rdb.HMGet(ctx, "hmsetkey", "age", "lastname").Result()

if err != nil {

panic(err)

}

fmt.Println("HMGET vals: ", vals)

// HEXISTX，某个hashkey中字段field否存在

ok, _ = rdb.HExists(ctx, "hmsetkey", "lastname").Result()

fmt.Println("HExists: ", ok) // HExists: true

// HLen，获取hashkey的字段多少

len, _ := rdb.HLen(ctx, "hashkey").Result()

fmt.Println("HLen hashkey： ", len) // HLen hashkey: 5

// HIncrBy，根据key的field字段的整数值加减一个数值

age, err := rdb.HIncrBy(ctx, "hmsetkey", "age", -3).Result()

if err != nil {

panic(err)

}

fmt.Println("HIncrBy : ", age) // HIncrBy : 20

// HDel，删除字段，支持删除多个字段

rdb.HSet(ctx, "hashkeydel", map[string]interface{}{"field10": "value10", "field11": "value11", "field12": "value12", "field13": "value13"}).Err()

rdb.HDel(ctx, "hashkeydel", "field10", "field12") //删除多个字段

delvals, err := rdb.HGetAll(ctx, "hashkeydel").Result()

if err != nil {

panic(err)

}

fmt.Println("HGetAll hashkeydel: ", delvals)

}

/**

HSetNX bool: false

HGet: value-one

HGet hashkey-two: value0

HGetAll: map[field-val:value-one field1:value1 field2:value2 field3:value3 field4:value4]

HMGET vals: [23 Jimmy]

HExists: true

HLen hashkey： 5

HIncrBy : 20

HGetAll hashkeydel: map[field11:value11 field13:value13]

* */

set集合类型#

Redis 中的 set 集合类型是一个无序的唯一值集合，也就是说一个set集合中的值唯一，它的存储顺序不会按照插入顺序进行存储。

set与list的区别：

list 可以存储重复的元素，而 set 不能
list 可以按照元素先后顺序存储，而 set 不能

set 集合操作命令文档：

1.Commands | Redis

2.集合 — Redis 命令参考

set 常用命令：

SADD：SADD key member [member...]，将一个或多个元素数据添加到集合 key 中
SISMEMBER: SISMEMBER key member，判断 member 是否是集合 key 的成员
SMEMBERS: SMEMBERS key，获取 key 中的所有元素数据
SREM：SREM key member [member ...]，删除 key 中的一个或多个数据
SPOP：SPOP key，随机移除集合中的一个数据并返回
SCARD：SCARD key，获取集合 key 中元素的数量
SDIFF：SDIFF key [key...]，计算多个集合的差集
SUNION：SUNION key [key...]，计算多个集合的并集
SINTER：SINTER key [key...]，计算多个集合的交集

代码例子：

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// SADD，将一个或多个元素数据添加到集合中

err = rdb.SAdd(ctx, "setkey:1", 20, "dog").Err()

if err != nil {

panic(err)

}

rdb.SAdd(ctx, "setkey:1", []string{"hanmeimei", "lilei", "tom", "dog", "one"}) // 切片增加数据，dog只有一个数据

rdb.SAdd(ctx, "setkey:2", []string{"jimmy", "pig", "dog", "lilei"})

// SMEMBERS，获取集合中的所有元素数据

smembers, err := rdb.SMembers(ctx, "setkey:1").Result()

if err != nil {

panic(err)

}

fmt.Println("SMembers，setkey:1: ", smembers)

// SCARD，获取集合中的元素数量

scards, err := rdb.SCard(ctx, "setkey:2").Result()

if err != nil {

panic(err)

}

fmt.Println("SCard,setkey:2: ", scards)

// SPOP，随机移除一个数据并返回这个数据

rdb.SAdd(ctx, "setkey:3", []string{"one", "two", "three", "four", "six"})

spop, _ := rdb.SPop(ctx, "setkey:3").Result()

res, _ := rdb.SMembers(ctx, "setkey:3").Result()

fmt.Println("spop: ", spop, ", SMembers: ", res)

// SPOPN，随机移除多个元素并返回

spopn, _ := rdb.SPopN(ctx, "setkey:3", 2).Result()

res, _ = rdb.SMembers(ctx, "setkey:3").Result()

fmt.Println("spopn: ", spopn, ", SMembers: ", res)

// SISMEMBER，判断元素是否在集合中

ok, err := rdb.SIsMember(ctx, "setkey:3", "two").Result()

if err != nil {

panic(err)

}

fmt.Println("SIsMember, two : ", ok)

// SDIFF,差集，SDIFF key1,key2 与 SDIFF key1,key2 差集是不同，看下面的例子

diff, _ := rdb.SDiff(ctx, "setkey:1", "setkey:2").Result()

fmt.Println("sdiff: ", diff)

diff2, _ := rdb.SDiff(ctx, "setkey:2", "setkey:1").Result()

fmt.Println("sdiff2: ", diff2)

// SUNION,并集

union, _ := rdb.SUnion(ctx, "setkey:1", "setkey:2").Result()

fmt.Println("union: ", union)

// SINTER,交集

inter, _ := rdb.SInter(ctx, "setkey:1", "setkey:2").Result()

fmt.Println("inter: ", inter)

// SREM , 删除值，返回删除元素个数

rdb.SAdd(ctx, "setkey:4", []string{"one", "two", "three"})

count, err := rdb.SRem(ctx, "setkey:4", "one", "three").Result()

if err != nil {

panic(err)

}

fmt.Println("SRem: ", count)

}

SMembers，setkey:1: [20 hanmeimei one lilei tom dog]

SCard,setkey:2: 4

spop: six , SMembers: [four three one two]

spopn: [one two] , SMembers: [four three]

SIsMember, two : false

sdiff: [tom 20 hanmeimei one]

sdiff2: [jimmy pig]

union: [hanmeimei one jimmy lilei tom dog 20 pig]

inter: [lilei dog]

SRem: 2

zset有序集合类型#

zset 是一个不重复值的有序集合，与 set 集合一样值是不能重复。

zset 排序集是按照相关分数排序的唯一字符串（成员）的集合。它的底层数据结构是由压缩列表或跳表（skiplist）实现的。

如果有序集合元素个数小于 128 且每个元素值小于 64 字节，redis 会使用压缩列表作为 zset 类型的底层数据结构；如果不满足上面的条件，那么就用跳表作为底层数据结构。

跳表的原理简析：https://www.cnblogs.com/jiujuan/p/12884824.html

zset 有序集合命令列表：

Commands | Redis
ZADD key score member [[score member] [score member] …] — Redis 命令参考

zset有序集合图：

zset 有序集合常用命令：

ZADD：ZADD key score member [[score member] [score member] …]，将一个或多个member元素以及score加入到有序集合key中
ZSCORE：ZSCORE key member，返回集合 key 中 member 成员的分数
ZRANGE：ZRANGE key start stop [WITHSCORES]，返回集合 key 中指定区间的元素，score 从小到大排序，start 和 stop 都是 0 开始。
ZREVRANGE：ZREVRANGE key start stop [WITHSCORES]，与 zrange 相反，返回集合 key 中指定区间元素，score 从大到小排序。
ZRANGEBYSCORE：ZRANGEBYSCORE key min max [WITHSCORES] [LIMIT offset count]，返回结果的数量区间，score 从小到大排序，LIMIT 参数指定返回结果集的数量和区间，后面可选的 [limit offset count] 像 SQL 中的 select ... limit offset,count。
ZREVRANGEBYSCORE：与上面 ZRANGEBYSCORE 几乎相同，不同是 score 是从大到小排序
ZREVRANGEBYSCOREWITHSCORES：和 ZRANGEBYSCORE 一样，区别是它不仅返回集合元素，也返回元素对应分数
ZREM：删除元素
ZREMRANGEBYRank：根据索引范围删除
ZREMRANGEBYSCORE：根据分数区间删除

还有 ZCOUNT 获取区间内元素个数；ZCARD 获取元素个数；ZINCRBY 增加元素分数；ZRANK 根据元素查询在集合中的排名，分数从小到大排序查询。

代码示例：

Copy

package main

import (

"context"

"fmt"

"time"

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

)

func main() {

rdb := redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

IdleTimeout: 350,

PoolSize: 50, // 连接池连接数量

})

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)

defer cancel()

_, err := rdb.Ping(ctx).Result() // 检查连接redis是否成功

if err != nil {

fmt.Println("Connect Failed: %v \n", err)

panic(err)

}

ctx = context.Background()

// ZADD，添加一个或多个数据到集合中

//* 添加一个*/

n, err := rdb.ZAdd(ctx, "zsetkey", &redis.Z{23.0, "tom"}).Result()

/* 或把字段写上

member := &redis.Z{

Score: 23.0,

Member: "tom",

}

n, err := rdb.ZAdd(ctx, "zsetkey", member).Result()

if err != nil {

panic(err)

}

fmt.Println("zadd: ", n)

val, _ := rdb.ZRange(ctx, "zsetkey", 0, -1).Result()

fmt.Println("ZRange, zsetkey: ", val)

//* ZADD批量增加*/

fruits_price_z := []*redis.Z{

&redis.Z{Score: 5.0, Member: "apple"},

&redis.Z{Score: 3.5, Member: "orange"},

&redis.Z{Score: 6.0, Member: "banana"},

&redis.Z{Score: 9.1, Member: "peach"},

&redis.Z{Score: 19.0, Member: "cherry"},

}

num, err := rdb.ZAdd(ctx, "fruits_price", fruits_price_z...).Result()

if err != nil {

panic(err)

}

fmt.Println("zadd : ", num)

// ZRANGE，索引范围返回元素，分数从小到大， 0 到 -1 就是所有元素

vals, err := rdb.ZRange(ctx, "fruits_price", 0, -1).Result()

if err != nil {

panic(err)

}

fmt.Println("ZRange,fruits_price: ", vals)

// ZREVRANGE，分数从大到小

vals, err = rdb.ZRevRange(ctx, "fruits_price", 0, -1).Result()

if err != nil {

panic(err)

}

fmt.Println("ZRevRange,fruits_price: ", vals)

// ZRANGEBYSCORE ， offset 和 count 可用于分页

rangbyscore := &redis.ZRangeBy{

Min: "3", // 最小分数

Max: "7", // 最大分数

Offset: 0, // 开始偏移量

Count: 4, // 一次返回多少数据

}

vals, err = rdb.ZRangeByScore(ctx, "fruits_price", rangbyscore).Result()

if err != nil {

panic(err)

}

fmt.Println("ZRangeByScore: ", vals)

// ZCOUNT ，统计某个分数内的元素个数

count, _ := rdb.ZCount(ctx, "fruits_price", "3", "7").Result()

fmt.Println("ZCount: ", count)

// ZREVRANGEBYSCOREWITHSCORES, 和 ZRANGEBYSCORE 一样，区别是它不仅返回集合元素，也返回元素对应分数

rangbyscorewithscores := &redis.ZRangeBy{

Min: "3", // 最小分数

Max: "7", // 最大分数

Offset: 0, // 开始偏移量

Count: 4, // 一次返回多少数据

}

keyvals, err := rdb.ZRangeByScoreWithScores(ctx, "fruits_price", rangbyscorewithscores).Result()

if err != nil {

panic(err)

}

fmt.Println("ZRangeByScoreWithScores: ", keyvals)

// ZCRORE, 查询集合中元素的分数

score, _ := rdb.ZScore(ctx, "fruits_price", "peach").Result()

fmt.Println("ZScore: ", score)

// ZRANK 根据元素查询在集合中的排名，分数从小到大排序查询

rank, _ := rdb.ZRank(ctx, "fruits_price", "peach").Result()

fmt.Println("ZRank: ", rank)

// ZREM，根据Member删除值，一次可以删除一个或多个

age_z := []*redis.Z{

&redis.Z{Score: 20, Member: "tom"},

&redis.Z{Score: 34, Member: "jim"},

&redis.Z{Score: 23, Member: "lilei"},

&redis.Z{Score: 43, Member: "hanxu"},

&redis.Z{Score: 30, Member: "jimmy"},

&redis.Z{Score: 55, Member: "MA"},

&redis.Z{Score: 50, Member: "MB"},

&redis.Z{Score: 52, Member: "MC"},

&redis.Z{Score: 54, Member: "MD"},

&redis.Z{Score: 59, Member: "ME"},

&redis.Z{Score: 70, Member: "MF"},

&redis.Z{Score: 75, Member: "MG"},

}

rdb.ZAdd(ctx, "people_age", age_z...).Err()

rdb.ZRem(ctx, "people_age", "jim").Err() // 删除一个

// rdb.ZRem(ctx, "people_age", "jim", "jimmy").Err() // 删除多个

agevals, _ := rdb.ZRange(ctx, "people_age", 0, -1).Result()

fmt.Println("ZRem, ZRange age: ", agevals)

//ZREMRANGEBYSCORE，根据分数区间删除

// rdb.ZRemRangeByScore("people_age", "20", "30").Err() // 删除 20<=分数<=30

rdb.ZRemRangeByScore(ctx, "people_age", "20", "(30").Err() // 删除 20<=分数<30

agevals, _ = rdb.ZRange(ctx, "people_age", 0, -1).Result()

fmt.Println("ZRemRangeByScore, ZRange age: ", agevals)

// ZREMRANGEBYRANK，根据分数排名删除

// 从低分到高分进行排序，然后按照索引删除

rdb.ZRemRangeByRank(ctx, "people_age", 6, 7) // 低分到高分排序，删除第6个元素到第7个元素

agevals, _ = rdb.ZRange(ctx, "people_age", 0, -1).Result()

fmt.Println("ZRemRangeByRank, ZRange age: ", agevals)

// 如果写成负数，那么从高分开始删除

// rdb.ZRemRangeByRank(ctx, "people_age", -6, -7)

// ZIncrBy, 增加分数

rdb.ZIncrBy(ctx, "people_age", 12, "MG").Err()

score, _ = rdb.ZScore(ctx, "people_age", "MG").Result()

fmt.Println("ZScore: ", score)

}

zadd: 0

ZRange, zsetkey: [tom]

zadd : 0

ZRange,fruits_price: [orange apple banana peach cherry]

ZRevRange,fruits_price: [cherry peach banana apple orange]

ZRangeByScore: [orange apple banana]

ZCount: 3

ZRangeByScoreWithScores: [{3.5 orange} {5 apple} {6 banana}]

ZScore: 9.1

ZRank: 3

ZRem, ZRange age: [tom lilei jimmy hanxu MB MC MD MA ME MF MG]

ZRemRangeByScore, ZRange age: [jimmy hanxu MB MC MD MA ME MF MG]

ZRemRangeByRank, ZRange age: [jimmy hanxu MB MC MD MA MG]

ZScore: 87

golang redis第三方库github.com/go-redis/redis/v8实践

Redis基本数据类型代码示例# 这里示例使用 go-redis v8 ，不过 go-redis latest 是 v9 安装v8：go get github.com/go-redis/redis/v8 Redis 5 种基本数据类型： string 字符串类型；list列表类型；hash哈希表类型&#…...

编程日记 2023/7/11 5:09:30

校园网WiFi IPv6免流上网

ipv6的介绍 IPv6是国际协议的最新版本，用它来取代IPv4主要是为了解决IPv4网络地址枯竭的问题，也在其他很多方面对IPv4有所改进，比如网络的速度和安全性。 IPv4是一个32位的地址，随着用户的增加在2011年国家报道说IPv4的网络地址即…...

编程日记 2023/7/11 4:36:09

java 阿里云直播配置及推拉流地址获取

一、开通阿里云直播首先进入阿里云直播产品主页：https://www.aliyun.com/product/live 。点击下方的“立即开通”。如果是还未注册的用户请按照页面提示进行完成注册并实名认证。 2、首次进入会提示开通服务，点击“开通服务”，然后选择计…...

编程日记 2023/7/11 4:02:48

PostgreSql 限制

参考：https://www.postgresql.org/docs/current/limits.html 项目上限说明单个数据库尺寸无限制null单个实例中数据库数量4,294,950,911null单个数据库中关系数量1,431,650,303null单个关系尺寸32 TB数据块为8k时单个表行数受4,294,967,295页的元组数量限制null单个…...

编程日记 2023/7/11 3:29:27

2023年java还是golang还是c#？

前言我们可以先来看一下这三门语言各自的优劣学习曲线：如果你是初学者或对编程相对陌生，Java可能是一个较好的选择。它有广泛的学习资源和社区支持，易于上手。Go也有简单易学的特点，但由于相对较年轻，相关的学习资…...

编程日记 2023/7/11 2:56:06

微服务、SpringBoot、SpringCloud 三者的区别

🎈 作者：Linux猿 🎈 简介：CSDN博客专家🏆，华为云享专家🏆，Linux、C/C、云计算、物联网、面试、刷题、算法尽管咨询我，关注我，有问题私聊！ &…...

编程日记 2023/7/11 2:22:45

2023-07-10 cmake管理的项目中使用vcpkg管理第三方库

一、安装从Github上克隆Vcpkg仓库然后执行安装命令即可： git clone https://github.com/microsoft/vcpkg .\vcpkg\bootstrap-vcpkg.bat 安装自己需要的第三方库 .\vcpkg\vcpkg install [packages to install] 更多教学可参考： https://learn.microsoft…...

编程日记 2023/7/11 1:49:24

【剑指offer】学习计划day3

目录一. 前言二.替换空格 a.题目 b.题解分析 c.AC代码三. 左旋转字符串 a.题目 b.题解分析 c.AC代码一. 前言本系列是针对Leetcode中剑指offer学习计划的记录与思路讲解。详情查看以下链接： 剑指offer-学习计划https://leetcode.cn/stud…...

编程日记 2023/7/11 1:16:02

做一个窗口界面 #include "mainwindow.h" #include "ui_mainwindow.h"MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow) {ui->setupUi(this);//设置窗口标题、图标this->setWindowTitle("Fly_Chat")…...

编程日记 2023/7/11 0:42:41

Mybatis-puls——条件查询的三种格式+条件查询null判定+查询投影

前言在mybatis_plus的封装中的Wrapper<T>接口参数就是用于封装查询条件在测试类中启动如上一个简单的查询，然后控制台运行会输出一大堆无关日志，这里先把这些日志关闭去除无关日志文件先新建一个XML配置文件然后变成如下，这里…...

编程日记 2023/7/11 0:09:20

网络安全（黑客）自学

建议一：黑客七个等级黑客，对很多人来说充满诱惑力。很多人可以发现这门领域如同任何一门领域，越深入越敬畏，知识如海洋，黑客也存在一些等级，参考知道创宇 CEO ic（世界顶级黑客团队 0x557 成员…...

编程日记 2023/7/10 23:35:59

通过一个实际例子说明Django中的数据库操作方法OneToOneField()的用法【数据表“一对一”关系】

当我们在Django中定义一个模型时，可以使用OneToOneField来建立一个一对一的关系。这种关系表示两个模型之间的一种特殊关联，其中一个模型的实例只能与另一个模型的实例关联。让我们以一个简单的示例来说明OneToOneField的用法。假设我们正在构建一个简…...

编程日记 2023/7/10 23:02:38

HarmonyOS学习路之开发篇—数据管理（对象关系映射数据库）

HarmonyOS对象关系映射（Object Relational Mapping，ORM）数据库是一款基于SQLite的数据库框架，屏蔽了底层SQLite数据库的SQL操作，针对实体和关系提供了增删改查等一系列的面向对象接口。应用开发者不必再去编写复杂的SQ…...

编程日记 2023/7/10 22:29:17

实验：验证TCP套接字传输的数据不存在数据边界

来源：《TCP/IP网络编程》学习ing 自己动手，把坑踩一遍，也可以学习到很多。 Linux环境下: 客户端： #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <…...

编程日记 2023/7/10 21:55:56

【网络】协议的定制与Json序列化和反序列化

文章目录应用层初识TCP协议通讯流程定制协议再谈协议网络版本计算器Protocal.hppCalServerCalClient Json的安装应用层我们程序员写的一个个解决我们实际问题, 满足我们日常需求的网络程序, 都是在应用层初识TCP协议通讯流程建立链接和断开链接基于TCP协议&#xff0c…...

编程日记 2023/7/10 21:22:35

浙大数据结构第一周最大子列和问题

题目详情： 给定K个整数组成的序列{ N1, N2, ..., NK }，“连续子列”被定义为{ Ni, Ni1, ..., Nj }，其中 1≤i≤j≤K。“最大子列和”则被定义为所有连续子列元素的和中最大者。例如给定序列{ -2, 11, -4, 13, -5, -2 }&#xff…...

编程日记 2023/7/10 20:49:12

Selenium基础 — Selenium自动化测试框架介绍

1、什么是selenium Selenium是一个用于Web应用程序测试的工具。只要在测试用例中把预期的用户行为与结果都描述出来，我们就得到了一个可以自动化运行的功能测试套件。Selenium测试套件直接运行在浏览器中，就像真正的用户在操作浏览器一样。Selenium也是…...

编程日记 2023/7/10 20:15:51

力扣竞赛勋章 | 排名分数计算脚本

文章目录力扣竞赛勋章介绍竞赛评分算法脚本（本文的重点内容）运行结果代码修改自：https://leetcode.cn/circle/discuss/6gnvEj/ 原帖子的代码无法正常运行。力扣竞赛勋章介绍 https://leetcode.cn/circle/discuss/0fKGDu/ 如果你想知道自…...

编程日记 2023/7/10 19:42:29

win10 远程 ubuntu 18.04 桌面

win10 远程 ubuntu 18.04 桌面我们要在Windows 10上远程连接到Ubuntu 18.04，您需要按照以下步骤进行设置： 1. 在Ubuntu 18.04上安装并启用远程桌面服务。打开终端，并运行以下命令来安装xrdp： sudo apt update sudo apt instal…...

编程日记 2023/7/10 19:09:08

c++ -- STL

【C/C】STL详解_cstl_沉晓的博客-CSDN博客 Learning Record have done assignment class template An excellent programmer only needs to know how to use containers to improve program encapsulation and reduce coupling, without understanding the underlying pri…...

编程日记 2023/7/10 18:35:47

oracle与MySQL数据库之间数据同步的技术要点

Oracle与MySQL数据库之间的数据同步是一个涉及多个技术要点的复杂任务。由于Oracle和MySQL的架构差异，它们的数据同步要求既要保持数据的准确性和一致性，又要处理好性能问题。以下是一些主要的技术要点： 数据结构差异数据类型差异&#xff…...

编程新知 2025/6/15 15:49:13

Robots.txt 文件

什么是robots.txt？ robots.txt 是一个位于网站根目录下的文本文件（如：https://example.com/robots.txt），它用于指导网络爬虫（如搜索引擎的蜘蛛程序）如何抓取该网站的内容。这个文件遵循 Robots…...

编程新知 2025/6/16 20:28:37

CMake 从 GitHub 下载第三方库并使用

有时我们希望直接使用 GitHub 上的开源库，而不想手动下载、编译和安装。可以利用 CMake 提供的 FetchContent 模块来实现自动下载、构建和链接第三方库。 FetchContent 命令官方文档✅ 示例代码我们将以 fmt 这个流行的格式化库为例，演示如何：使用 FetchContent 从 GitH…...

编程新知 2025/6/15 21:39:40

网络编程（UDP编程）

思维导图 UDP基础编程（单播） 1.流程图服务器：短信的接收方创建套接字 (socket)-----------------------------------------》有手机指定网络信息-----------------------------------------------》有号码绑定套接字 (bind)--------------…...

编程新知 2025/6/15 16:57:47

3-11单元格区域边界定位(End属性)学习笔记

返回一个Range 对象，只读。该对象代表包含源区域的区域上端下端左端右端的最后一个单元格。等同于按键 End 向上键(End(xlUp))、End向下键(End(xlDown))、End向左键(End(xlToLeft)End向右键(End(xlToRight)) 注意：它移动的位置必须是相连的有内容的单元格…...

编程新知 2025/6/15 11:18:42

STM32HAL库USART源代码解析及应用

STM32HAL库USART源代码解析前言STM32CubeIDE配置串口USART和UART的选择使用模式参数设置GPIO配置DMA配置中断配置硬件流控制使能生成代码解析和使用方法串口初始化__UART_HandleTypeDef结构体浅析HAL库代码实际使用方法使用轮询方式发送使用轮询方式接收使用中断方式发送使用中…...

编程新知 2025/6/16 17:23:17

Vue ③-生命周期 || 脚手架

生命周期思考：什么时候可以发送初始化渲染请求？（越早越好） 什么时候可以开始操作dom？（至少dom得渲染出来） Vue生命周期： 一个Vue实例从创建到销毁的整个过程。生命周期四个…...

编程新知 2025/6/16 6:03:03

tomcat指定使用的jdk版本

说明有时候需要对tomcat配置指定的jdk版本号，此时，我们可以通过以下方式进行配置设置方式找到tomcat的bin目录中的setclasspath.bat。如果是linux系统则是setclasspath.sh set JAVA_HOMEC:\Program Files\Java\jdk8 set JRE_HOMEC:\Program Files…...

编程新知 2025/6/10 21:11:28

C# winform教程(二)----checkbox

一、作用提供一个用户选择或者不选的状态，这是一个可以多选的控件。二、属性其实功能大差不差，除了特殊的几个外，与button基本相同，所有说几个独有的 checkbox属性名称内容含义appearance控件外观可以变成按钮形状checkali…...

编程新知 2025/6/16 16:19:56

Mac flutter环境搭建

一、下载flutter sdk 制作 Android 应用 | Flutter 中文文档 - Flutter 中文开发者网站 - Flutter 1、查看mac电脑处理器选择sdk 2、解压 unzip ~/Downloads/flutter_macos_arm64_3.32.2-stable.zip \ -d ~/development/ 3、添加环境变量命令行打开配置环境变量文件 ope…...

编程新知 2025/6/15 20:01:31

golang redis第三方库github.com/go-redis/redis/v8实践

Redis基本数据类型代码示例#

最基本的Set/Get操作#

string(s)字符串类型#

list列表类型#

hash哈希表类型#

set集合类型#

zset有序集合类型#

相关文章：

golang redis第三方库github.com/go-redis/redis/v8实践

校园网WiFi IPv6免流上网

java 阿里云直播配置及推拉流地址获取

PostgreSql 限制

2023年java还是golang还是c#？

微服务、SpringBoot、SpringCloud 三者的区别

2023-07-10 cmake管理的项目中使用vcpkg管理第三方库

【剑指offer】学习计划day3

QT DAY1

Mybatis-puls——条件查询的三种格式+条件查询null判定+查询投影

网络安全（黑客）自学

通过一个实际例子说明Django中的数据库操作方法OneToOneField()的用法【数据表“一对一”关系】

HarmonyOS学习路之开发篇—数据管理（对象关系映射数据库）

实验：验证TCP套接字传输的数据不存在数据边界

【网络】协议的定制与Json序列化和反序列化

浙大数据结构第一周最大子列和问题

Selenium基础 — Selenium自动化测试框架介绍

力扣竞赛勋章 | 排名分数计算脚本

win10 远程 ubuntu 18.04 桌面

c++ -- STL

oracle与MySQL数据库之间数据同步的技术要点

Robots.txt 文件

CMake 从 GitHub 下载第三方库并使用

网络编程（UDP编程）

3-11单元格区域边界定位(End属性)学习笔记

STM32HAL库USART源代码解析及应用

Vue ③-生命周期 || 脚手架

tomcat指定使用的jdk版本

C# winform教程(二)----checkbox

Mac flutter环境搭建