package test
import (
	"context"
	"encoding/json"
	"fmt"
	"github.com/go-redis/redis/v8"
	"testing"
	"time"
)
var ctx = context.Background()
var rdb *redis.Client
func init() {
	rdb = redis.NewClient(&redis.Options{
		//	端口需要改，這里是docker的端口
		Addr:	  "localhost:49153",
		Password: "redispw", // no password set
		DB:		  0,  // use default DB
		PoolSize:15,
		MinIdleConns: 10, //在啟動(dòng)階段創(chuàng)建指定數(shù)量的Idle連接，并長(zhǎng)期維持idle狀態(tài)的連接數(shù)不少于指定數(shù)量；。
		//超時(shí)
		//DialTimeout:  5 * time.Second, //連接建立超時(shí)時(shí)間，默認(rèn)5秒。
		//ReadTimeout:  3 * time.Second, //讀超時(shí)，默認(rèn)3秒， -1表示取消讀超時(shí)
		//WriteTimeout: 3 * time.Second, //寫超時(shí)，默認(rèn)等于讀超時(shí)
		//PoolTimeout:  4 * time.Second, //當(dāng)所有連接都處在繁忙狀態(tài)時(shí)，客戶端等待可用連接的最大等待時(shí)長(zhǎng)，默認(rèn)為讀超時(shí)+1秒。
	})
}
//	基礎(chǔ)使用
func Test_Base(t *testing.T) {
	//	添加key
	//0表示沒有過期時(shí)間
	rdb.Set(ctx, "testKey", "xxx", 0)
	//	獲取值
	val, err := rdb.Get(ctx, "testKey").Result()
	if err != nil {
		fmt.Println("錯(cuò)誤", err)
	}
	fmt.Println("值：", val)
	//	設(shè)置key過期時(shí)間 成功true
	rdb.Expire(ctx, "testKey", time.Second*60)
	//	存在返回1
	rdb.Exists(ctx, "testKey")
	//	key不存在時(shí)設(shè)置值
	rdb.SetNX(ctx, "unkey", "val", 0)
	rdb.Set(ctx, "testKey2", "xxx", 0)
	//	刪除key 可刪除多個(gè)
	rdb.Del(ctx, "testKey2", "testKey")
}
//	字符串
func Test_String(t *testing.T) {
	//	設(shè)置值
	rdb.Set(ctx, "strKey", 100, 0)
	rdb.Set(ctx, "straey", 100, 0)
	//	key自增1
	rdb.Incr(ctx, "strKey")
	//	增加 66
	rdb.IncrBy(ctx, "straey", 66)
	//	-1
	rdb.Decr(ctx, "straey")
	//	-5
	rdb.DecrBy(ctx, "straey", 5)
	//	過期時(shí)間
	rdb.TTL(ctx, "strKey")
	//	str*ey		: *為任意字符串
	//	str[kKac]ey : 匹配[] 內(nèi)的單個(gè)字符 strkey,strKey,straey,strcey
	//	str?ey		: ? 任意單個(gè)字符
	//	掃描key
	iter := rdb.Scan(ctx, 0, "str?ey", 0).Iterator()
	for iter.Next(ctx) {
		fmt.Println("keys", iter.Val(), ": val", rdb.Get(ctx, iter.Val()).Val())
	}
	if err := iter.Err(); err != nil {
		panic(err)
	}
}
//	哈希
func Test_Hash(t *testing.T) {
	rdb.HMSet(ctx,"hkey1","name","shushan","age",99,"b",true)
	//	以結(jié)構(gòu)體存入 注意redis tag
	type User struct {
		Name string `json:"name,omitempty" redis:"name"`
		Age  int    `json:"age,omitempty" redis:"age"`
		B    bool   `json:"b,omitempty" redis:"b"`
		//...
	}
	user1 := User{
		Name: "shushan2",
		Age:  55,
		B:    true,
	}
	//	結(jié)構(gòu)體序列化反序列化map 你也可以用其他包進(jìn)行轉(zhuǎn)化為map,但是注意轉(zhuǎn)化后的鍵名大小寫問題
	m := make(map[string]interface{})
	buf,_ := json.Marshal(user1)
	_ = json.Unmarshal(buf,&m)
	//	存入
	rdb.HSet(ctx, "user4", m)
	//	取出綁定到結(jié)構(gòu)體 map也行
	var user User
	rdb.HGetAll(ctx,"user4").Scan(&user)
	fmt.Printf(" %#v \n ",user)
	//	test.User{Name:"shushan2", Age:55, B:true}
	//	獲取key下的所有值   *匹配方式與string的所有原理一樣
	iter := rdb.HScan(ctx,"user4",0,"*",0).Iterator()
	for iter.Next(ctx) {
		fmt.Println("keys", iter.Val())
	}
	if err := iter.Err(); err != nil {
		panic(err)
	}
}
//	列表
func Test_List(t *testing.T) {
	//	添加
	rdb.LPush(ctx,"listKey1",111,222,333,444)
	rdb.RPush(ctx,"listKey1",5555)
	//	不存在不添加
	rdb.LPushX(ctx,"unlistKey",111)
	var intf []int
	//	根據(jù)索引獲取 綁定到數(shù)組
	rdb.LRange(ctx,"listKey1",0,10).ScanSlice(&intf)
	fmt.Println(intf)
	var i int
	//	彈出
	rdb.LPop(ctx,"listKey1").Scan(&i)
	fmt.Println(i)
	//....
}
//	集合
func Test_Set(t *testing.T) {
	//	添加
	rdb.SAdd(ctx,"setKey1","m1","onlyk1")
	rdb.SAdd(ctx,"setKey2","m2","xca")
	sl,_:= rdb.SDiff(ctx,"setKey1","setKey2").Result()
	fmt.Println(sl)
	// onlyk1,m1
	//隨機(jī)移除
	var val string
	rdb.SPop(ctx,"setKey1").Scan(&val)
	fmt.Println(val)
	// .....
}
//	管道
func Test_Pipe(t *testing.T) {
	// 	官方描述
	// 	Redis 管道允許客戶端命令服務(wù)器通過執(zhí)行任務(wù)而通過執(zhí)行任務(wù)來提高您的性能。
	//	在管道中，像命令命令一樣將編寫 + 使用命令來執(zhí)行任務(wù)，并將其用于執(zhí)行任務(wù)，執(zhí)行任務(wù)不是一個(gè)地執(zhí)行100個(gè)命令。
	//	理解為命令就像石頭，一次運(yùn)送一個(gè)石頭
	//	使用管道等于 用車裝石頭  Exec 時(shí)就運(yùn)送過去
	pipe := rdb.Pipeline()
	incr := pipe.Set(ctx, "pip_test","bt",0)
	pipe.Expire(ctx, "pip_test", time.Hour)
	//	提交
	cmds, err := pipe.Exec(ctx)
	if err != nil {
		fmt.Println(err)
	}
	for _, cmd := range cmds {
		fmt.Println(cmd.String())
	}
	// 該值得Exec提交后有效
	fmt.Println(incr.Val())
}