Go 언어에서 Redis를 사용하는 방법

종속성 패키지 설치

Go 언어에서 타사 라이브러리 go-redis 사용

go-redis는 Sentinel 및 클러스터 모드 Redis에 대한 연결을 지원합니다.

다음 명령을 사용하여 다운로드하고 설치하세요.

go get -u github.com/go-redis/redis/v8

Connect redis

새 go 파일을 만들고 github.com/go-redis/redis/v8을 소개하세요. 프로젝트에 go文件，在项目中引入github.com/go-redis/redis/v8，

初始化redis.Client，废话不多说，直接上代码。

package main

import (
	"context"
	"fmt"
	"github.com/go-redis/redis/v8"
)

// 定义一个全局变量
var redisdb *redis.Client
var ctx = context.Background()

func initRedis()(err error){
	redisdb = redis.NewClient(&redis.Options{
		Addr: "127.0.0.1:6379",  // 指定
		Password: "",
		DB:0,		// redis一共16个库，指定其中一个库即可
	})
	_,err = redisdb.Ping(ctx).Result()
	return
}

func main() {
	err := initRedis()
	if err != nil {
		fmt.Printf("connect redis failed! err : %v\n",err)
		return
	}
	fmt.Println("redis连接成功！")
}

注意： 最新版本的go-redis库的相关命令都需要传递context.Context参数。

redis连接池

通过golang对redis操作，还可以通过redis连接池，流程如下：

（1）事先初始化一定数量的连接，投入到连接池；

（2）当go需要操作redis时，直接从连接池取出连接即可；

（3）这样可以节省临时获取redis的时间，从而提高效率；

go-redis

redis.Client를 초기화하고 더 이상 고민하지 말고 코드로 직접 이동해 보겠습니다. 🎜

redisdb = redis.NewClient(&redis.Options{
		Addr: "127.0.0.1:6379",  // 指定
		Password: "",
		DB:0,		// redis一共16个库，指定其中一个库即可

		//连接池容量及闲置连接数量
		PoolSize:     15, // 连接池最大socket连接数，默认为4倍CPU数， 4 * runtime.NumCPU
		MinIdleConns: 10, //在启动阶段创建指定数量的Idle连接，并长期维持idle状态的连接数不少于指定数量；。

		//超时
		DialTimeout:  5 * time.Second, //连接建立超时时间，默认5秒。
		ReadTimeout:  3 * time.Second, //读超时，默认3秒， -1表示取消读超时
		WriteTimeout: 3 * time.Second, //写超时，默认等于读超时
		PoolTimeout:  4 * time.Second, //当所有连接都处在繁忙状态时，客户端等待可用连接的最大等待时长，默认为读超时+1秒。

		//闲置连接检查包括IdleTimeout，MaxConnAge
		IdleCheckFrequency: 60 * time.Second, //闲置连接检查的周期，默认为1分钟，-1表示不做周期性检查，只在客户端获取连接时对闲置连接进行处理。
		IdleTimeout:        5 * time.Minute,  //闲置超时，默认5分钟，-1表示取消闲置超时检查
		MaxConnAge:         0 * time.Second,  //连接存活时长，从创建开始计时，超过指定时长则关闭连接，默认为0，即不关闭存活时长较长的连接

		//命令执行失败时的重试策略
		MaxRetries:      0,                      // 命令执行失败时，最多重试多少次，默认为0即不重试
		MinRetryBackoff: 8 * time.Millisecond,   //每次计算重试间隔时间的下限，默认8毫秒，-1表示取消间隔
		MaxRetryBackoff: 512 * time.Millisecond, //每次计算重试间隔时间的上限，默认512毫秒，-1表示取消间隔

		//可自定义连接函数
		Dialer: func(ctx context.Context, network, addr string) (net.Conn, error) {
			netDialer := &net.Dialer{
				Timeout:   5 * time.Second,
				KeepAlive: 5 * time.Minute,
			}
			return netDialer.Dial("tcp", "127.0.0.1:6379")
		},

		//钩子函数
		OnConnect: func(ctx context.Context, conn *redis.Conn) error { //仅当客户端执行命令时需要从连接池获取连接时，如果连接池需要新建连接时则会调用此钩子函数
			fmt.Printf("conn=%v\n", conn)
			return nil
		},
	})

🎜참고: go-redis 라이브러리 최신 버전의 관련 명령은 context.Context 매개변수를 전달해야 합니다. 🎜🎜redis 연결 풀🎜🎜golang을 통해 Redis를 운영할 수 있으며, Redis 연결 풀을 사용할 수도 있습니다. 과정은 다음과 같습니다. 🎜🎜(1) 미리 일정 개수의 연결을 초기화하여 연결 풀에 넣습니다. ; 🎜🎜(2) go가 redis를 작동해야 하는 경우 연결 풀에서 직접 연결을 제거하면 됩니다. 🎜🎜(3) 이렇게 하면 일시적으로 redis를 얻는 데 드는 시간이 절약되어 효율성이 향상됩니다. redis 모듈은 연결 풀과 함께 제공되며 모든 매개 변수는 선택 사항입니다. 매개 변수 구성 설명 예는 다음과 같습니다. 🎜rrreee

위 내용은 Go 언어에서 Redis를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!