欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

golang-redis之sorted set類型操作詳解

 更新時間:2020年12月22日 11:03:02   作者:代碼界的小姑娘  
這篇文章主要介紹了golang-redis之sorted set類型操作詳解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧

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") //寫

result,err := redis.Values(c.Do("zrange","key",0,-1))//讀

5:sorted set簡單操作

zadd(key, score1,member1,...scoreN,memberN) 向有序結合添加(更新)一個或多個成員
zcard(key):獲取有序集合的成員
zcount(key,start,end):計算指定區(qū)間的成員數(shù)
zincrby(key,increment,member):成員member增加increment
zinterstore(dst,numkey,src1,src2..srcN):求交集,并將結果存儲新的結合
zlexcount(key,start,end):計算字典區(qū)間成員數(shù)(分數(shù)都相同,按照字典排序)
zrange(key,start,end):獲取索引區(qū)間的成員
zrangebylex (key,start,end):通過字典區(qū)間返回區(qū)間內(nèi)有序集合成員
zrangebyscore(key,start,end):通過分數(shù)返回區(qū)間內(nèi)的有序集合
zrank (key,member):返回有序結合的索引
zrem(key,members1...membersN):刪除一個或多個成員
zremrangebylex(key,start,end):移除集合中給定字典區(qū)間的成員
zremrangebyrank(key,start,end):移除有序集合中給定的排名區(qū)間的所有成員
zremrangebyscore(key,start,end):移除給定分數(shù)區(qū)間的所有元素
zrevange(key,start,end):通過索引,分數(shù)由高到低,返回指定區(qū)域的元素
zrevrangebyscore(key,member):分數(shù)由高向低返回指定區(qū)間的成員數(shù)
zrevrank(key,member):分數(shù)從小到大,返回指定成員的排名
zscore(key,member):返回有序集中,成員的分數(shù)值
zunionstore(dst,numkeys,key1...keyN):返回給定的一個或多個集合的并集,并存儲在新的集合中
zscan(key,cursor):迭代有序結合中的元素(包括元素成員和元素分值)

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:示例結果

完整代碼路徑

補充:go-redis使用之ZSet有序集合

ZSet(sorted set):有序不重復集合

ZSet的每個元素都會關聯(lián)一個float64類型的分數(shù)。redis正是通過分數(shù)來為集合中的成員進行從小到大的排序。

有序集合的成員是唯一的,但分數(shù)(score)卻可以重復。

集合是通過哈希表實現(xiàn)的,所以添加,刪除,查找的復雜度都是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有序不重復集合)
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",
	//}
	// 添加一個值
	cli.ZAdd("lang",l1)
	// 添加多個值
	_,err:=cli.ZAdd("lang",lang...).Result()
	if err != nil {
		panic(err)
	}
	//升序:查詢zset中指定區(qū)間的成員,-1代表取到最后
	fmt.Println("ZRange:",cli.ZRange("lang",0,3).Val())		//[javaScript ruby php python]
	//降序:查詢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",	//最小分數(shù)
		Max:  "90",	//最大分數(shù)
		Offset: 2,		//在滿足條件的范圍,從offset下標處開始取值
		Count: 3,		//查詢結果集個數(shù)
	}
	//升序:根據(jù)opt條件查詢Member成員
	fmt.Println(cli.ZRangeByScore("lang",opt).Val())	// [python go java]
	//降序:根據(jù)opt條件查詢Member成員
	fmt.Println(cli.ZRevRangeByScore("lang",opt).Val())	//[python php ruby]
	//升序:根據(jù)下標范圍返回的redis.Z結構體切片
	fmt.Println(cli.ZRangeWithScores("lang",0,3).Val())	//[{40 javaScript} {50 ruby} {60 php} {70 python}]
	//降序:根據(jù)下標范圍返回的redis.Z結構體切片
	fmt.Println(cli.ZRevRangeWithScores("lang",0,-1).Val())//[{90 java} {80 go} {70 python} {60 php} {50 ruby} {40 javaScript}]
	//升序:根據(jù)opt條件,返回的redis.Z結構體切片
	fmt.Println(cli.ZRangeByScoreWithScores("lang",opt).Val())
	//降序:根據(jù)opt條件,返回的redis.Z結構體切片
	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
	// 獲取指定成員的下標
	fmt.Println(cli.ZRank("lang","python").Val())	//3
	// 返回指定區(qū)間的成員個數(shù)
	fmt.Println(cli.ZCount("lang","50","80").Val())//4
	// 返回集合中成員的個數(shù)
	fmt.Println(cli.ZCard("lang").Val())	//6
	// 根據(jù)成員名稱,移除指定成員(可以多個): 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ù)下標區(qū)間移除指定成員
	fmt.Println(cli.ZRemRangeByRank("lang",1,2).Val())		//2:表示移除了兩個
	fmt.Println(cli.ZRangeWithScores("lang",0,-1).Val())	// [{50 ruby} {80 go}]
	// 升序:根據(jù)分數(shù)區(qū)間移除指定成員
	fmt.Println(cli.ZRemRangeByScore("lang","70","90").Val())	//1:表示移除了一個
	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ù)庫連接狀態(tài):%v\n", pong) // 數(shù)據(jù)連接狀態(tài):PONG
	redisZsetTest(rdb)
}

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

相關文章

  • 完美解決golang go get私有倉庫的問題

    完美解決golang go get私有倉庫的問題

    這篇文章主要介紹了完美解決golang go get私有倉庫的問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-05-05
  • 利用 Go 語言編寫一個簡單的 WebSocket 推送服務

    利用 Go 語言編寫一個簡單的 WebSocket 推送服務

    這篇文章主要介紹了利用 Go 語言編寫一個簡單的 WebSocket 推送服務,需要的朋友可以參考下
    2018-04-04
  • Go?1.21中引入的新包maps和cmp功能作用詳解

    Go?1.21中引入的新包maps和cmp功能作用詳解

    這篇文章主要為大家介紹了Go?1.21中引入的新包maps和cmp功能作用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-11-11
  • Golang熔斷器的開發(fā)過程詳解

    Golang熔斷器的開發(fā)過程詳解

    Golang熔斷器是一種用于處理分布式系統(tǒng)中服務調(diào)用的故障保護機制,它可以防止故障服務的連鎖反應,提高系統(tǒng)的穩(wěn)定性和可靠性,本文將給大家詳細的介紹一下Golang熔斷器的開發(fā)過程,需要的朋友可以參考下
    2023-09-09
  • 在ubuntu下安裝go開發(fā)環(huán)境的全過程

    在ubuntu下安裝go開發(fā)環(huán)境的全過程

    Go語言是谷歌公司開發(fā)的編程語言,雖然安裝和配置go很簡單,但是很多初學者在第一次安裝go環(huán)境時會遇到各種坑,下面這篇文章主要給大家介紹了關于在ubuntu下安裝go開發(fā)環(huán)境的相關資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下
    2022-08-08
  • 關于golang中死鎖的思考與學習

    關于golang中死鎖的思考與學習

    本文主要介紹了關于golang中死鎖的思考與學習,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2023-03-03
  • 通過案例簡單聊聊為什么說Go中的字符串是不能被修改的

    通過案例簡單聊聊為什么說Go中的字符串是不能被修改的

    在接觸Go這么語言,可能你經(jīng)常會聽到這樣一句話,對于字符串不能修改,可能你很納悶,日常開發(fā)中我們對字符串進行修改也是很正常的,為什么又說Go中的字符串不能進行修改呢,本文就來通過實際案例給大家演示,為什么Go中的字符串不能進行修改
    2023-07-07
  • 詳解Go語言Sync.Pool為何不加鎖也能夠實現(xiàn)線程安全

    詳解Go語言Sync.Pool為何不加鎖也能夠實現(xiàn)線程安全

    在這篇文章中,我們將剖析sync.Pool內(nèi)部實現(xiàn)中,介紹了sync.Pool比較巧妙的內(nèi)部設計思路以及其實現(xiàn)方式。在這個過程中,也間接介紹了為何不加鎖也能夠實現(xiàn)線程安全,感興趣的可以學習一下
    2023-04-04
  • go web 預防跨站腳本的實現(xiàn)方式

    go web 預防跨站腳本的實現(xiàn)方式

    這篇文章主要介紹了go web 預防跨站腳本的實現(xiàn)方式,文中給大家介紹XSS最佳的防護應該注意哪些問題,本文通過實例代碼講解的非常詳細,需要的朋友可以參考下
    2021-06-06
  • 詳解如何在Go語言中調(diào)用C源代碼

    詳解如何在Go語言中調(diào)用C源代碼

    這篇文章主要為大家詳細介紹了如何在Go語言中調(diào)用C語言源代碼,文中的示例代碼講解詳細,對我們學習或工作有一定的幫助,需要的可以參考一下
    2022-05-05

最新評論