先上命令速查網站，菜鳥yyds
https://www.runoob.com/redis/redis-strings.html
操作redis的包是go-redis/redis
官方檔案 https://redis.uptrace.dev/guide/
github https://github.com/go-redis/redis
創建專案
創建test檔案夾
創建 Redis_test.go 檔案
直接上代碼，代碼解釋全寫在注釋里
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, //在啟動階段創建指定數量的Idle連接，并長期維持idle狀態的連接數不少于指定數量；，
//超時
//DialTimeout: 5 * time.Second, //連接建立超時時間，默認5秒，
//ReadTimeout: 3 * time.Second, //讀超時，默認3秒， -1表示取消讀超時
//WriteTimeout: 3 * time.Second, //寫超時，默認等于讀超時
//PoolTimeout: 4 * time.Second, //當所有連接都處在繁忙狀態時，客戶端等待可用連接的最大等待時長，默認為讀超時+1秒，
})
}
// 基礎使用
func Test_Base(t *testing.T) {
// 添加key
//0表示沒有過期時間
rdb.Set(ctx, "testKey", "xxx", 0)
// 獲取值
val, err := rdb.Get(ctx, "testKey").Result()
if err != nil {
fmt.Println("錯誤", err)
}
fmt.Println("值：", val)
// 設定key過期時間 成功true
rdb.Expire(ctx, "testKey", time.Second*60)
// 存在回傳1
rdb.Exists(ctx, "testKey")
// key不存在時設定值
rdb.SetNX(ctx, "unkey", "val", 0)
rdb.Set(ctx, "testKey2", "xxx", 0)
// 洗掉key 可洗掉多個
rdb.Del(ctx, "testKey2", "testKey")
}
// 字串
func Test_String(t *testing.T) {
// 設定值
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)
// 過期時間
rdb.TTL(ctx, "strKey")
// str*ey : *為任意字串
// str[kKac]ey : 匹配[] 內的單個字符 strkey,strKey,straey,strcey
// str?ey : ? 任意單個字符
// 掃描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)
// 以結構體存入 注意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,
}
// 結構體序列化反序列化map 你也可以用其他包進行轉化為map,但是注意轉化后的鍵名大小寫問題
m := make(map[string]interface{})
buf,_ := json.Marshal(user1)
_ = json.Unmarshal(buf,&m)
// 存入
rdb.HSet(ctx, "user4", m)
// 取出系結到結構體 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
// 根據索引獲取 系結到陣列
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
//隨機移除
var val string
rdb.SPop(ctx,"setKey1").Scan(&val)
fmt.Println(val)
// .....
}
// 管道
func Test_Pipe(t *testing.T) {
// 官方描述
// Redis 管道允許客戶端命令服務器通過執行任務而通過執行任務來提高您的性能，
// 在管道中，像命令命令一樣將撰寫 + 使用命令來執行任務，并將其用于執行任務，執行任務不是一個地執行100個命令，
// 理解為命令就像石頭，一次運送一個石頭
// 使用管道等于 用車裝石頭 Exec 時就運送過去
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())
}
其他操作都可以查看go-redis的原始碼或者直接打出rdb.命令，go-redis 的函式命名方式和redis的命令是差不多的
The end
本文來自博客園，作者：樹杉，轉載請注明原文鏈接：https://www.cnblogs.com/xushushan/p/16498266.html
選擇了程式員這條路，那就要學習一輩子
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/499926.html
標籤：其他
上一篇：事務
下一篇：MySQL實戰45講 4,5