快捷導(dǎo)航

Golang操作Redis的實(shí)現(xiàn)示例

更新時(shí)間：2025年11月07日 11:32:47 作者：兩片空白

本文介紹了Redis作為高性能key-value數(shù)據(jù)庫的特性,包括數(shù)據(jù)持久化、豐富的數(shù)據(jù)結(jié)構(gòu)、高并發(fā)性能、原子操作以及連接池管理,通過實(shí)例展示了使用Redis進(jìn)行String、List和Hash操作,以及設(shè)置過期時(shí)間和連接池的管理,感興趣的可以了解一下

一. Redis介紹

1.1 簡(jiǎn)介

Redis是完全開源免費(fèi)的，遵循BSD協(xié)議，是一個(gè)高性能的key-value數(shù)據(jù)庫。

Redis與其它的key-value緩存產(chǎn)品有以下三個(gè)特點(diǎn)：

Redis支持?jǐn)?shù)據(jù)持久化，可以見內(nèi)存中的數(shù)據(jù)報(bào)錯(cuò)在磁盤中，重啟的時(shí)候可以再次加載進(jìn)行使用。
Redis不僅僅支持簡(jiǎn)單的key-value類型的數(shù)據(jù)，同時(shí)還提供string，list(鏈表)，set(集合)，hash表等數(shù)據(jù)結(jié)構(gòu)的存儲(chǔ)。
Redis支持?jǐn)?shù)據(jù)備份，即master-slave模式的數(shù)據(jù)備份。

1.2 Redis優(yōu)勢(shì)

性能極高——Redis能讀的速度是110000次/秒，寫的速度是81000次/秒，單機(jī)可以達(dá)到15w qps，通常適合做緩存。
豐富的數(shù)據(jù)類型——Redis支持二進(jìn)制案例的strings，lists，hashes，sets及ordered sets數(shù)據(jù)類型操作。
原子——Redis的所有操作都是原子的，意思就是要么成功執(zhí)行，要么失敗完全不執(zhí)行。單個(gè)操作是原子的。多操作也支持事務(wù)，即原子性，通過MULTI和EXEC指令包起來。
豐富的特性——Redis還支持publish/subscribe，通知，key過期等特性。

Redis與其它的key-value存儲(chǔ)有什么不同？

Redis有著更為復(fù)雜的數(shù)據(jù)結(jié)構(gòu)并且提供對(duì)他們的原子操作，這是一個(gè)不同于其它數(shù)據(jù)庫的進(jìn)化路徑。Redis的數(shù)據(jù)類型都是基于基本數(shù)據(jù)結(jié)構(gòu)的同時(shí)對(duì)程序員透明，無需進(jìn)行額外的抽象。

Redis運(yùn)行在內(nèi)存中但是可以持久化到磁盤，所以對(duì)不同數(shù)據(jù)集進(jìn)行高速讀寫時(shí)需要權(quán)衡內(nèi)存，因?yàn)閿?shù)據(jù)量不能大于內(nèi)存大小。在內(nèi)存數(shù)據(jù)庫方面的另一個(gè)優(yōu)點(diǎn)是，相比在磁盤上相同的復(fù)雜數(shù)據(jù)結(jié)構(gòu)，在內(nèi)存中操作起來簡(jiǎn)單，這樣Redis可以做很多內(nèi)部復(fù)雜性很強(qiáng)的事情。同時(shí)，在磁盤格式方面他們是緊湊的以追加的方式產(chǎn)生，因?yàn)樗麄儾恍枰M(jìn)行隨機(jī)訪問。

1.3 redis的使用

使用第三方開源的redis庫：github.com/garyburd/redigo/redis

命令行輸入：

go get github.com/garyburd/redigo/redis

二. 鏈接Redis

package main

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil {
		fmt.Println("conn redis fail ", err)
		return
	}
	defer c.Close()

	fmt.Println("conn redis succ")
}

三. String類型的Set，Get操作

package main

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil {
		fmt.Println("conn redis fail ", err)
		return
	}
	defer c.Close()

	_, err = c.Do("Set", "abc", 100)
	if err != nil {
		fmt.Println("set fail", err)
		return
	}

	//將返回結(jié)果轉(zhuǎn)為int類型
	r, err := redis.Int(c.Do("Get", "abc"))
	if err != nil {
		fmt.Println("get fail", err)
		return
	}
	fmt.Println(r)
}

輸出結(jié)果：

命令行輸出：

四. String批量操作

五. 設(shè)置過期時(shí)間

package main

import (
	"fmt"
	"time"

	"github.com/garyburd/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil {
		fmt.Println("conn redis fail ", err)
		return
	}
	defer c.Close()

	_, err = c.Do("set", "k1", 1)
	if err != nil {
		fmt.Println("set fail ", err)
		return
	}
	//設(shè)置過期時(shí)間10秒
	_, err = c.Do("expire", "k1", 10)
	if err != nil {
		fmt.Println("expire fail", err)
		return
	}

	r, err := redis.Int(c.Do("get", "k1"))
	if err != nil {
		fmt.Println("get fail ", err)
		return
	}
	fmt.Printf("k1=%d\n", r)

	time.Sleep(10 * time.Second)
	//過10秒已經(jīng)過期 再獲得失敗
	r, err = redis.Int(c.Do("get", "k1"))
	if err != nil {
		fmt.Println("get fail ", err)
		return
	}
	fmt.Printf("k1=%d\n", r)
}

輸出：

六. List隊(duì)列操作

七. Hash表

八. Redis連接池

package main

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

var pool *redis.Pool

func init() {
	pool = &redis.Pool{
		MaxIdle: 16, //最初的連接數(shù)量
		//MaxActive: 1000000, //最大連接數(shù)量
		MaxActive:   0,   //連接池最大連接數(shù)量，不確定可以使用0(0表示自動(dòng)定義)，按需分配
		IdleTimeout: 300, //連接關(guān)閉時(shí)間300秒，(300秒內(nèi)不使用自動(dòng)關(guān)閉)
		Dial: func() (redis.Conn, error) { //要連接的數(shù)據(jù)庫
			return redis.Dial("tcp", "127.0.0.1:6379")
		},
	}
}

func main() {
	c := pool.Get() //從連接池中取一個(gè)連接
	_, err := c.Do("set", "k1", "v1")
	if err != nil {
		fmt.Println("set fail ", err)
		return
	}

	v, err := redis.String(c.Do("get", "k1"))
	if err != nil {
		fmt.Println("get fail ", err)
		return
	}
	fmt.Println(v)
	pool.Close() //關(guān)閉連接池
}