Go操作redis與redigo的方法-Redis-PHP中文網

Go-操作redis

安裝

連接

使用

設定key過期時間

批次取得mget、批次設定mset

清單動作

hash操作

Pipelining(管道)

redis發布會訂閱模式

交易操作

萬能操作

連接redis

寫入

讀取

全部程式碼

首頁

資料庫

Redis

Go操作redis與redigo的方法

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

May 30, 2023 pm 09:25 PM

redis go redigo

Go-操作redis

安裝

golang作業redis的客戶端套件有多個例如redigo、go-redis，github上Star最多的莫屬redigo。

go get github.com/garyburd/redigo/redis
import "github.com/garyburd/redigo/redis"

登入後複製

連接

Conn接口是與Redis協作的主要接口，可以使用Dial,DialWithTimeout或NewConn函數來建立連接，當任務完成時，應用程式必須呼叫Close函數來完成操作。

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
}

登入後複製

使用

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
    _, err = conn.Do("SET", "name", "wd")
    if err != nil {
        fmt.Println("redis set error:", err)
    }
    name, err := redis.String(conn.Do("GET", "name"))
    if err != nil {
        fmt.Println("redis get error:", err)
    } else {
        fmt.Printf("Got name: %s \n", name)
    }
}

登入後複製

設定key過期時間

  _, err = conn.Do("expire", "name", 10) //10秒过期
    if err != nil {
        fmt.Println("set expire error: ", err)
        return
    }

登入後複製

批次取得mget、批次設定mset

_, err = conn.Do("MSET", "name", "wd","age",22)
    if err != nil {
        fmt.Println("redis mset error:", err)
    }
    res, err := redis.Strings(conn.Do("MGET", "name","age"))
    if err != nil {
        fmt.Println("redis get error:", err)
    } else {
        res_type := reflect.TypeOf(res)
        fmt.Printf("res type : %s \n", res_type)
        fmt.Printf("MGET name: %s \n", res)
        fmt.Println(len(res))
    }
//结果：
//res type : []string 
//MGET name: [wd 22] 
//2

登入後複製

清單動作

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
    "reflect"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
    _, err = conn.Do("LPUSH", "list1", "ele1","ele2","ele3")
    if err != nil {
        fmt.Println("redis mset error:", err)
    }
    res, err := redis.String(conn.Do("LPOP", "list1"))
    if err != nil {
        fmt.Println("redis POP error:", err)
    } else {
        res_type := reflect.TypeOf(res)
        fmt.Printf("res type : %s \n", res_type)
        fmt.Printf("res  : %s \n", res)
    }
}
//res type : string 
//res  : ele3

登入後複製

hash操作

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
    "reflect"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
    _, err = conn.Do("HSET", "student","name", "wd","age",22)
    if err != nil {
        fmt.Println("redis mset error:", err)
    }
    res, err := redis.Int64(conn.Do("HGET", "student","age"))
    if err != nil {
        fmt.Println("redis HGET error:", err)
    } else {
        res_type := reflect.TypeOf(res)
        fmt.Printf("res type : %s \n", res_type)
        fmt.Printf("res  : %d \n", res)
    }
}
//res type : int64 
//res  : 22

登入後複製

Pipelining(管道)

透過使用Send()、Flush()和Receive()三個方法，可以以並發方式執行管道操作。客戶端可以使用send()方法一次向伺服器發送一個或多個命令，命令發送完畢時，使用flush()方法將緩衝區的命令輸入一次性發送到伺服器，客戶端再使用Receive()方法依次按照先進先出的順序讀取所有指令操作結果。

Send(commandName string, args ...interface{}) error
Flush() error
Receive() (reply interface{}, err error)

登入後複製

Send：發送指令至緩衝區
#Flush：清除緩衝區，將指令一次傳送至伺服器
Recevie：依序讀取伺服器回應結果，當讀取的命令未回應時，該操作會阻塞。

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
    conn.Send("HSET", "student","name", "wd","age","22")
    conn.Send("HSET", "student","Score","100")
    conn.Send("HGET", "student","age")
    conn.Flush()
    res1, err := conn.Receive()
    fmt.Printf("Receive res1:%v \n", res1)
    res2, err := conn.Receive()
    fmt.Printf("Receive res2:%v\n",res2)
    res3, err := conn.Receive()
    fmt.Printf("Receive res3:%s\n",res3)
}
//Receive res1:0 
//Receive res2:0
//Receive res3:22

登入後複製

redis發布會訂閱模式

package main
import (
    "github.com/garyburd/redigo/redis"
    "fmt"
    "time"
)
func Subs() {  //订阅者
    conn, err := redis.Dial("tcp", "10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :", err)
        return
    }
    defer conn.Close()
    psc := redis.PubSubConn{conn}
    psc.Subscribe("channel1") //订阅channel1频道
    for {
        switch v := psc.Receive().(type) {
        case redis.Message:
            fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
        case redis.Subscription:
            fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
        case error:
            fmt.Println(v)
            return
        }
    }
}
func Push(message string)  { //发布者
    conn, _ := redis.Dial("tcp", "10.1.210.69:6379")
    _,err1 := conn.Do("PUBLISH", "channel1", message)
       if err1 != nil {
             fmt.Println("pub err: ", err1)
                 return
            }

}
func main()  {
    go Subs()
    go Push("this is wd")
    time.Sleep(time.Second*3)
}
//channel1: subscribe 1
//channel1: message: this is wd

登入後複製

交易操作

MULTI, EXEC,DISCARD和WATCH是構成Redis事務的基礎，當然我們使用go語言對redis進行事務操作的時候本質也是使用這些指令。

MULTI：開啟交易

EXEC：執行交易

DISCARD：取消交易

WATCH：監視交易中的鍵變化，一旦有改變就取消事務。

範例：

package main
import (
"github.com/garyburd/redigo/redis"
"fmt"
)
func main()  {
    conn,err := redis.Dial("tcp","10.1.210.69:6379")
    if err != nil {
        fmt.Println("connect redis error :",err)
        return
    }
    defer conn.Close()
    conn.Send("MULTI")
    conn.Send("INCR", "foo")
    conn.Send("INCR", "bar")
    r, err := conn.Do("EXEC")
    fmt.Println(r)
}
//[1, 1]

登入後複製

萬能操作

連接redis

conn,err := redis.Dial(
  "tcp",
  "10.0.3.100:6379",
  redis.DialPassword("EfcHGSzKqg6cfzWq"),
  redis.DialDatabase(8))
if err != nil {
  fmt.Println("connect redis error :",err)
  return
}
defer conn.Close()

登入後複製

寫入

//写入
//_, err = conn.Do("LPUSH", "list1", "ele1","ele2","ele3")
_, err = conn.Do("reids写入方法", "key名字", "内容1","内容2","内容3")
if err != nil {
  fmt.Println("redis set error:", err)
}

登入後複製

讀取

//读取
redis.Strings：返回多个
redis.String：返回一个
redis.int:返回统计的数字
//获取集合所有成员
//name, err := redis.Strings(conn.Do("smembers", "beautiful_user"))
// 返回集合成员数
//name, err := redis.Int(conn.Do("scard", "beautiful_user"))
name, err := redis.方法名(conn.Do("redis读取方法", "key名字"))
if err != nil {
  fmt.Println("redis get error:", err)
} else {
  fmt.Printf("Got name: %s \n", name)
}

登入後複製

全部程式碼

package main
import (
	"fmt"
	"github.com/garyburd/redigo/redis"
)
func main()  {
	conn,err := redis.Dial("tcp","10.0.3.100:6379",redis.DialPassword("EfcHGSzKqg6cfzWq"),redis.DialDatabase(8))
	if err != nil {
		fmt.Println("connect redis error :",err)
		return
	}
	defer conn.Close()
	//写入
	_, err = conn.Do("LPUSH", "list1", "ele1","ele2","ele3")
	if err != nil {
		fmt.Println("redis set error:", err)
	}
	//读取
	name, err := redis.Strings(conn.Do("smembers", "beautiful_user"))
	if err != nil {
		fmt.Println("redis get error:", err)
	} else {
		fmt.Printf("Got name: %s \n", name)
	}
}

登入後複製

以上是Go操作redis與redigo的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！

本網站聲明

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

熱AI工具

熱工具

熱門話題

gmail信箱登陸入口在哪裡

7455

CakePHP 教程

1375

steam的賬戶名稱是什麼格式

win11激活密鑰永久

NYT連接提示和答案

Related knowledge

redis集群模式怎麼搭建 Apr 10, 2025 pm 10:15 PM

Redis集群模式通過分片將Redis實例部署到多個服務器，提高可擴展性和可用性。搭建步驟如下：創建奇數個Redis實例，端口不同；創建3個sentinel實例，監控Redis實例並進行故障轉移；配置sentinel配置文件，添加監控Redis實例信息和故障轉移設置；配置Redis實例配置文件，啟用集群模式並指定集群信息文件路徑；創建nodes.conf文件，包含各Redis實例的信息；啟動集群，執行create命令創建集群並指定副本數量；登錄集群執行CLUSTER INFO命令驗證集群狀態；使

redis底層怎麼實現 Apr 10, 2025 pm 07:21 PM

Redis 使用哈希表存儲數據，支持字符串、列表、哈希表、集合和有序集合等數據結構。 Redis 通過快照 (RDB) 和追加只寫 (AOF) 機制持久化數據。 Redis 使用主從復制來提高數據可用性。 Redis 使用單線程事件循環處理連接和命令，保證數據原子性和一致性。 Redis 為鍵設置過期時間，並使用 lazy 刪除機制刪除過期鍵。

redis查詢的key怎麼唯一 Apr 10, 2025 pm 07:03 PM

Redis採用五種策略確保鍵的唯一性：1. 名稱空間分隔；2. HASH數據結構；3. SET數據結構；4. 字符串鍵的特殊字符；5. Lua腳本驗證。具體策略的選擇取決於數據組織、性能和擴展性需求。

redis集群是如何實現的 Apr 10, 2025 pm 05:27 PM

Redis集群是一種分佈式部署模式，允許水平擴展Redis實例，通過節點間通信、哈希槽劃分鍵空間、節點選舉、主從復制和命令重定向來實現：節點間通信：通過集群總線實現虛擬網絡通信。哈希槽：將鍵空間劃分為哈希槽，確定負責鍵的節點。節點選舉：至少需要三個主節點，通過選舉機制確保僅有一個活動主節點。主從復制：主節點負責寫請求，從節點負責讀請求和數據複製。命令重定向：客戶端連接到負責鍵的節點，節點重定向不正確的請求。故障處理：故障檢測、標記下線和重新

redis如何查看版本號 Apr 10, 2025 pm 05:57 PM

要查看 Redis 版本號，可以使用以下三種方法：(1) 輸入 INFO 命令，(2) 使用 --version 選項啟動服務器，(3) 查看配置文件。

redis怎麼查看所有的key Apr 10, 2025 pm 07:15 PM

要查看 Redis 中的所有鍵，共有三種方法：使用 KEYS 命令返回所有匹配指定模式的鍵；使用 SCAN 命令迭代鍵並返回一組鍵；使用 INFO 命令獲取鍵的總數。

redis命令行怎麼用 Apr 10, 2025 pm 10:18 PM

使用 Redis 命令行工具 (redis-cli) 可通過以下步驟管理和操作 Redis：連接到服務器，指定地址和端口。使用命令名稱和參數向服務器發送命令。使用 HELP 命令查看特定命令的幫助信息。使用 QUIT 命令退出命令行工具。

redis zset怎麼使用 Apr 10, 2025 pm 07:27 PM

Redis 有序集合（ZSet）用於存儲有序元素集合，並按關聯分數進行排序。 ZSet 的用法步驟包括：1. 創建 ZSet；2. 添加成員；3. 獲取成員分數；4. 獲取排名；5. 獲取排名範圍的成員；6. 刪除成員；7. 獲取元素個數；8. 獲取分數範圍內的成員個數。

See all articles

Go操作redis與redigo的方法

Go-操作redis

安裝

連接

使用

設定key過期時間

批次取得mget、批次設定mset

清單動作

hash操作

Pipelining(管道)

redis發布會訂閱模式

交易操作

萬能操作

連接redis

寫入

讀取

全部程式碼

熱AI工具

Undresser.AI Undress

AI Clothes Remover

Undress AI Tool

Clothoff.io

AI Hentai Generator

熱門文章

熱工具

記事本++7.3.1

SublimeText3漢化版

禪工作室 13.0.1

Dreamweaver CS6

SublimeText3 Mac版

熱門話題