[go-redis] go操作redis資料庫

来源:https://www.cnblogs.com/xushushan/archive/2022/07/20/16498266.html
-Advertisement-
Play Games

先上命令速查網站,菜鳥yyds https://www.runoob.com/redis/redis-strings.html 操作redis的包是go-redis/redis 官方文檔 https://redis.uptrace.dev/guide/ github https://github.c ...


先上命令速查網站,菜鳥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

選擇了程式員這條路,那就要學習一輩子


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Linux 的基本操作 -許可權 許可權: 文件的屬性: d:表示目錄-:表示文件 l:連接文件 b:設備文件,提供存儲的介面設備 c:設備文件,提供串列的介面設備--鍵盤,滑鼠 r:可讀,查看目錄下有哪些文件或文件夾,查看文件內容 w :可寫,在目錄中新普文件夾/文件 修改/刪除文件a/文件內容移動文 ...
  • less 命令: 查看文件內容 概念 less 與 more 類似,less 可以隨意瀏覽文件,支持翻頁和搜索,支持向上翻頁和向下翻頁。而使用 more 命令瀏覽文件內容時,只能不斷向後翻看。 介紹 用法: less [OPTION]... [FILE]... 常用參數: 常用選項及含義 | Key ...
  • zCommander for Mac是一款功能全面的文件管理軟體,為你提供文件列表視圖雙窗格功能,且每個窗格可以有多個選項卡,您只需使用鍵盤界面即可完成大多數文件操作,因此操作簡單且快速,為你的工作提供了不少方便! 詳情:zCommander for Mac(文件管理軟體) 功能特色 -熟悉的文件列 ...
  • 鏡像下載、功能變數名稱解析、時間同步請點擊 阿裡雲開源鏡像站 安裝前準備工作 因為Nginx依賴於gcc的編譯環境,所以,需要安裝編譯環境來使Nginx能夠編譯起來 yum install gcc-c++ Nginx的http模塊需要使用pcre來解析正則表達式,需要安裝pcre yum install - ...
  • PDF Reader Pro mac版是一款全面且強大的pdf閱讀器,該軟體支持PDF閱讀,編輯,註釋,創建/填寫表格,轉換,創建,OCR和簽署PDF文件等,滿足您的所有PDF文檔需求。簡便高效,大大提升您的工作效率。 詳情:PDF Reader Pro for mac(全能pdf閱讀器) 軟體特色 ...
  • 鏡像下載、功能變數名稱解析、時間同步請點擊 阿裡雲開源鏡像站 系統版本:CentOS Linux release 7.6.1810 (Core) docker版本:20.10.12 docker-compose版本:v2.3.2 一、安裝docker-compose: 把在百度網盤下載的docker-com ...
  • Clobbr是一款開發人員必備的工具,使用它可以測試您的api端點,以查看它們在多個請求(破壞您的 api!)下的執行情況,順序或並行,滿足您測試REST、GraphQL、雲函數、Clobbr 的需求。可以輕鬆向多個端點發出請求;輕鬆配置動詞(GET、PUT、POST 等);為每個請求配置標頭;擁有 ...
  • 04 | 深入淺出索引(上) 索引的出現其實就是為了提高數據查詢的效率,就像書的目錄一樣 索引的常見模型 哈希表、有序數組和搜索樹 哈希表 User2 和 User4 根據身份證號算出來的值都是 N,但沒關係,後面還跟了一個鏈表。 需要註意的是,圖中四個 ID_card_n hash 出來的值並不是 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...