golang-redis之sorted set類(lèi)型操作詳解
更新時(shí)間：2020年12月22日 11:03:02 作者：代碼界的小姑娘
這篇文章主要介紹了golang-redis之sorted set類(lèi)型操作詳解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
1：安裝redigo
go get github.com/garyburd/redigo/redis
2：引用redigo
import （ "github.com/garyburd/redigo/redis" )
3：連接Redis
c, err := redis.Dial("tcp", "192.168.2.225:6379")
if err != nil {
fmt.Println("connect to redis err", err.Error())
return
}
defer c.Close()
4：命令
n,err := c.Do("zadd","key","score","member") //寫(xiě)
result,err := redis.Values(c.Do("zrange","key",0,-1))//讀
5：sorted set簡(jiǎn)單操作
zadd(key, score1,member1,...scoreN,memberN) 向有序結(jié)合添加（更新）一個(gè)或多個(gè)成員 zcard(key)：獲取有序集合的成員 zcount(key,start,end):計(jì)算指定區(qū)間的成員數(shù) zincrby(key,increment,member):成員member增加increment zinterstore(dst,numkey,src1,src2..srcN)：求交集，并將結(jié)果存儲(chǔ)新的結(jié)合 zlexcount(key,start,end):計(jì)算字典區(qū)間成員數(shù)(分?jǐn)?shù)都相同，按照字典排序) zrange(key,start,end):獲取索引區(qū)間的成員 zrangebylex (key,start,end):通過(guò)字典區(qū)間返回區(qū)間內(nèi)有序集合成員 zrangebyscore(key,start,end):通過(guò)分?jǐn)?shù)返回區(qū)間內(nèi)的有序集合 zrank (key,member):返回有序結(jié)合的索引 zrem(key,members1...membersN):刪除一個(gè)或多個(gè)成員 zremrangebylex(key,start,end):移除集合中給定字典區(qū)間的成員 zremrangebyrank(key,start,end):移除有序集合中給定的排名區(qū)間的所有成員 zremrangebyscore(key,start,end)：移除給定分?jǐn)?shù)區(qū)間的所有元素 zrevange(key,start,end):通過(guò)索引，分?jǐn)?shù)由高到低，返回指定區(qū)域的元素 zrevrangebyscore(key,member)：分?jǐn)?shù)由高向低返回指定區(qū)間的成員數(shù) zrevrank(key,member):分?jǐn)?shù)從小到大，返回指定成員的排名 zscore(key,member):返回有序集中，成員的分?jǐn)?shù)值 zunionstore(dst,numkeys,key1...keyN):返回給定的一個(gè)或多個(gè)集合的并集，并存儲(chǔ)在新的集合中 zscan(key,cursor):迭代有序結(jié)合中的元素（包括元素成員和元素分值）
6：示例
6.1：zadd
_, err1 := c.Do("zadd", "curbike", 1, "mobike", 2, "xiaolan", 3, "ofo", 4, "xiaoming")
_, err2 := c.Do("zadd", "tmpdata", 0, "mobike", 0, "xiaolan", 0, "mysql", 0, "redis", 0, "mongo", 0, "xiaoming")
if err1 != nil || err2 != nil {
fmt.Println("zadd failed", err.Error())
}
6.2：zcard
num, err := c.Do("zcard", "curbike")
if err != nil {
fmt.Println("zcard failed", err.Error())
} else {
fmt.Printf("curbike's size is %s:", num)
}
6.3：zcount
num, err = c.Do("zcount", "curbike", 1, 3)
if err != nil {
fmt.Println("zcount failed ", err.Error())
} else {
fmt.Println("zcount num is :", num)
}
6.4：zincrby
num, err = c.Do("zincrby", "curbike", 3, "xiaolan")
fmt.Println(reflect.TypeOf(num))
if err != nil {
fmt.Println("zincrby failed", err.Error())
} else {
fmt.Println("after zincrby the :", num)
}
6.5：zinterstore
_, err = c.Do("zinterstore", "internewset", 2, "curbike", "tmpdata")
if err != nil {
fmt.Println("zinterstore failed", err.Error())
} else {
result, err := redis.Values(c.Do("zrange", "internewset", 0, 10))
if err != nil {
fmt.Println("interstore failed", err.Error())
} else {
fmt.Printf("interstore newset elsements are:")
for _, v := range result {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
}
6.6：zlexcount
num, err = c.Do("zlexcount", "tmpdata", "[mongo", "[xiaoming")
if err != nil {
fmt.Println("zlexcount failed", err.Error())
} else {
fmt.Println("zlexcount in tmpdata is :", num)
}
6.7：
res, err := redis.Values(c.Do("zrange", "curbike", 0, -1, "withscores"))
if err != nil {
fmt.Println("zrange in curbike failed", err.Error())
} else {
fmt.Printf("curbike's element are follow:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
6.8：zrangebylex
res, err = redis.Values(c.Do("zrangebylex", "tmpdata", "[mobike", "[redis"))
if err != nil {
fmt.Println("zrangebylex failed", err.Error())
} else {
fmt.Printf("zrangebylex in tmpdata:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
6.9：zrangebyscore
res, err = redis.Values(c.Do("zrangebyscore", "curbike", "(1", "(5"))
if err != nil {
fmt.Println("zrangebyscore failed", err.Error())
} else {
fmt.Printf("zrangebyscore's element:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
6.10：zrank
num, err = c.Do("zrank", "internewset", "xiaoming")
if err != nil {
fmt.Println("zrank failed ", err.Error())
} else {
fmt.Println("xiaoming's score is ", num)
}
6.11：
_, err = c.Do("zunionstore", "unewzset", 2, "curbike", "tmpdata")
if err != nil {
fmt.Println("zunionstore failed", err.Error())
} else {
res, err = redis.Values(c.Do("zrange", "unewzset", 0, 10))
if err != nil {
fmt.Println("zunionstore failed", err.Error())
} else {
fmt.Printf("union set are:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
}
6.12：zscore
ret, err := c.Do("zscore", "internewset", "xiaolan")
if err != nil {
fmt.Println("zscore failed", err.Error())
} else {
fmt.Printf("curbike 's xiaolan score is:%s\n", ret)
}
6.13：zrevrank
num, err = c.Do("zrevrank", "curbike", "ofo")
if err != nil {
fmt.Println("zrevrank failed", err.Error())
} else {
fmt.Println("ofo's zrevrank is :", num)
}
6.14：zrevrangebyscore
res, err = redis.Values(c.Do("zrevrangebyscore", "unewzset", 10, 2))
if err != nil {
fmt.Println("zrevrangebyscore failed", err.Error())
} else {
fmt.Printf("zrevrangebyscore are:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
6.15：zrevrange
res, err = redis.Values(c.Do("zrevrange", "unewzset", 0, 10))
err != nil {
fmt.Println("zrevrange failed：", err.Error())
} else {
fmt.Printf("zrevrange element:")
for _, v := range res {
fmt.Printf("%s ", v.([]byte))
}
fmt.Println()
}
6.16：zrem
num, err = c.Do("zrem", "unewzset", "mysql")
if err != nil {
fmt.Println("zrem failed", err.Error())
} else {
fmt.Println("zrem result is:", num)
}
6.17：zremrangebyrank
num, err = c.Do("zremrangebyrank", "unewzset", 1, 4)
if err != nil {
fmt.Println("zremrangebyrank failed", err.Error())
} else {
fmt.Println("zremrangebyrank result:", num)
}
6.18：zremrangebyscore
num, err = c.Do("zremrangebyscore", "curbike", 2, 5)
if err != nil {
fmt.Println("zremrangebyscore failed", err.Error())
} else {
fmt.Println("zremrangebyscore result:", num)
}
7：示例結(jié)果
補(bǔ)充：go-redis使用之ZSet有序集合
ZSet（sorted set）：有序不重復(fù)集合
ZSet的每個(gè)元素都會(huì)關(guān)聯(lián)一個(gè)float64類(lèi)型的分?jǐn)?shù)。redis正是通過(guò)分?jǐn)?shù)來(lái)為集合中的成員進(jìn)行從小到大的排序。
有序集合的成員是唯一的,但分?jǐn)?shù)(score)卻可以重復(fù)。
集合是通過(guò)哈希表實(shí)現(xiàn)的，所以添加，刪除，查找的復(fù)雜度都是O(1)。 集合中最大的成員數(shù)為2的32次方 - 1
func GetRedisClient() *redis.Client {
return redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "",
DB: 0,
})
}
// redisZsetTest Zset(sorted set有序不重復(fù)集合)
func redisZsetTest(cli *redis.Client){
lang := []redis.Z{
redis.Z{Score: 90.0, Member: "java"},
redis.Z{Score: 80.0, Member: "go"},
redis.Z{Score: 70.0, Member: "python"},
redis.Z{Score: 60.0, Member: "php"},
redis.Z{Score: 50.0, Member: "ruby"},
}
l1:= struct {
Score float64
Member interface{}
}{
40,
"javaScript",
}
//l2 :=redis.Z{
// Score: 30,
// Member: "Object-C",
//}
// 添加一個(gè)值
cli.ZAdd("lang",l1)
// 添加多個(gè)值
_,err:=cli.ZAdd("lang",lang...).Result()
if err != nil {
panic(err)
}
//升序：查詢(xún)zset中指定區(qū)間的成員,-1代表取到最后
fmt.Println("ZRange:",cli.ZRange("lang",0,3).Val()) //[javaScript ruby php python]
//降序：查詢(xún)zset中指定區(qū)間的成員,-1代表取到最后
fmt.Println("ZRevRange:",cli.ZRevRange("lang",0,-1).Val()) // [java go python php ruby javaScript]
// [Go javaScript ruby php python go java]
opt:=redis.ZRangeBy{
Min: "50", //最小分?jǐn)?shù)
Max: "90", //最大分?jǐn)?shù)
Offset: 2, //在滿(mǎn)足條件的范圍，從offset下標(biāo)處開(kāi)始取值
Count: 3, //查詢(xún)結(jié)果集個(gè)數(shù)
}
//升序：根據(jù)opt條件查詢(xún)Member成員
fmt.Println(cli.ZRangeByScore("lang",opt).Val()) // [python go java]
//降序：根據(jù)opt條件查詢(xún)Member成員
fmt.Println(cli.ZRevRangeByScore("lang",opt).Val()) //[python php ruby]
//升序:根據(jù)下標(biāo)范圍返回的redis.Z結(jié)構(gòu)體切片
fmt.Println(cli.ZRangeWithScores("lang",0,3).Val()) //[{40 javaScript} {50 ruby} {60 php} {70 python}]
//降序：根據(jù)下標(biāo)范圍返回的redis.Z結(jié)構(gòu)體切片
fmt.Println(cli.ZRevRangeWithScores("lang",0,-1).Val())//[{90 java} {80 go} {70 python} {60 php} {50 ruby} {40 javaScript}]
//升序：根據(jù)opt條件，返回的redis.Z結(jié)構(gòu)體切片
fmt.Println(cli.ZRangeByScoreWithScores("lang",opt).Val())
//降序：根據(jù)opt條件，返回的redis.Z結(jié)構(gòu)體切片
fmt.Println(cli.ZRevRangeByScoreWithScores("lang",opt).Val())
fmt.Println(cli.ZRangeByLex("lang",opt).Val())
fmt.Println(cli.ZRevRangeByLex("lang",opt).Val())
// 獲取指定成員的score
f:=cli.ZScore("lang","go").Val()
fmt.Println(f) // 80
// 獲取指定成員的下標(biāo)
fmt.Println(cli.ZRank("lang","python").Val()) //3
// 返回指定區(qū)間的成員個(gè)數(shù)
fmt.Println(cli.ZCount("lang","50","80").Val())//4
// 返回集合中成員的個(gè)數(shù)
fmt.Println(cli.ZCard("lang").Val()) //6
// 根據(jù)成員名稱(chēng)，移除指定成員（可以多個(gè)): 0:失敗 0<：成功
fmt.Println(cli.ZRem("lang","c++").Val())//0
fmt.Println(cli.ZRem("lang","javaScript","java").Val())//2
fmt.Println(cli.ZRange("lang",0,-1).Val()) // [ruby php python go]
// 升序：根據(jù)下標(biāo)區(qū)間移除指定成員
fmt.Println(cli.ZRemRangeByRank("lang",1,2).Val()) //2:表示移除了兩個(gè)
fmt.Println(cli.ZRangeWithScores("lang",0,-1).Val()) // [{50 ruby} {80 go}]
// 升序：根據(jù)分?jǐn)?shù)區(qū)間移除指定成員
fmt.Println(cli.ZRemRangeByScore("lang","70","90").Val()) //1:表示移除了一個(gè)
fmt.Println(cli.ZRangeWithScores("lang",0,-1).Val()) // [{50 ruby}]
}
func main() {
rdb := GetRedisClient()
defer rdb.Close()
pong := rdb.Ping().Val()
fmt.Printf("數(shù)據(jù)庫(kù)連接狀態(tài)：%v\n", pong) // 數(shù)據(jù)連接狀態(tài)：PONG
redisZsetTest(rdb)
}
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。
相關(guān)文章
完美解決golang go get私有倉(cāng)庫(kù)的問(wèn)題
這篇文章主要介紹了完美解決golang go get私有倉(cāng)庫(kù)的問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-05-05
利用 Go 語(yǔ)言編寫(xiě)一個(gè)簡(jiǎn)單的 WebSocket 推送服務(wù)
這篇文章主要介紹了利用 Go 語(yǔ)言編寫(xiě)一個(gè)簡(jiǎn)單的 WebSocket 推送服務(wù),需要的朋友可以參考下2018-04-04
這篇文章主要為大家介紹了Go?1.21中引入的新包maps和cmp功能作用詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-11-11
Golang熔斷器的開(kāi)發(fā)過(guò)程詳解
Golang熔斷器是一種用于處理分布式系統(tǒng)中服務(wù)調(diào)用的故障保護(hù)機(jī)制,它可以防止故障服務(wù)的連鎖反應(yīng),提高系統(tǒng)的穩(wěn)定性和可靠性,本文將給大家詳細(xì)的介紹一下Golang熔斷器的開(kāi)發(fā)過(guò)程,需要的朋友可以參考下2023-09-09
在ubuntu下安裝go開(kāi)發(fā)環(huán)境的全過(guò)程
Go語(yǔ)言是谷歌公司開(kāi)發(fā)的編程語(yǔ)言,雖然安裝和配置go很簡(jiǎn)單,但是很多初學(xué)者在第一次安裝go環(huán)境時(shí)會(huì)遇到各種坑,下面這篇文章主要給大家介紹了關(guān)于在ubuntu下安裝go開(kāi)發(fā)環(huán)境的相關(guān)資料,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2022-08-08
關(guān)于golang中死鎖的思考與學(xué)習(xí)
本文主要介紹了關(guān)于golang中死鎖的思考與學(xué)習(xí)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-03-03
通過(guò)案例簡(jiǎn)單聊聊為什么說(shuō)Go中的字符串是不能被修改的
在接觸Go這么語(yǔ)言，可能你經(jīng)常會(huì)聽(tīng)到這樣一句話(huà)，對(duì)于字符串不能修改，可能你很納悶，日常開(kāi)發(fā)中我們對(duì)字符串進(jìn)行修改也是很正常的，為什么又說(shuō)Go中的字符串不能進(jìn)行修改呢，本文就來(lái)通過(guò)實(shí)際案例給大家演示，為什么Go中的字符串不能進(jìn)行修改2023-07-07
詳解Go語(yǔ)言Sync.Pool為何不加鎖也能夠?qū)崿F(xiàn)線(xiàn)程安全
在這篇文章中，我們將剖析sync.Pool內(nèi)部實(shí)現(xiàn)中，介紹了sync.Pool比較巧妙的內(nèi)部設(shè)計(jì)思路以及其實(shí)現(xiàn)方式。在這個(gè)過(guò)程中，也間接介紹了為何不加鎖也能夠?qū)崿F(xiàn)線(xiàn)程安全，感興趣的可以學(xué)習(xí)一下2023-04-04
go web 預(yù)防跨站腳本的實(shí)現(xiàn)方式
這篇文章主要介紹了go web 預(yù)防跨站腳本的實(shí)現(xiàn)方式,文中給大家介紹XSS最佳的防護(hù)應(yīng)該注意哪些問(wèn)題，本文通過(guò)實(shí)例代碼講解的非常詳細(xì)，需要的朋友可以參考下2021-06-06
這篇文章主要為大家詳細(xì)介紹了如何在Go語(yǔ)言中調(diào)用C語(yǔ)言源代碼，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)或工作有一定的幫助，需要的可以參考一下2022-05-05