跳至主要内容
版本: valkey_v0.x.x

Redis

Release Discord Test Security Linter

一个使用 go-redis/redis 的 Redis 存储驱动。

注意:需要 Go 1.19 及以上版本

目录

签名

func New(config ...Config) Storage
func (s *Storage) Get(key string) ([]byte, error)
func (s *Storage) Set(key string, val []byte, exp time.Duration) error
func (s *Storage) Delete(key string) error
func (s *Storage) Reset() error
func (s *Storage) Close() error
func (s *Storage) Conn() redis.UniversalClient
func (s *Storage) Keys() ([][]byte, error)

安装

Redis 在支持模块的最新两个 Go 版本上进行了测试。如果你还没做的话,请先确保初始化一个。

注意:你也可以使用 DragonflyDB 作为 Redis 的替代品。由于 DragonflyDB 与 Redis API 完全兼容,你可以像使用 Redis 一样使用它,无需任何代码更改示例

go mod init github.com/<user>/<repo>

然后安装 Redis 实现

go get github.com/gofiber/storage/redis/v3

示例

导入存储包。

import "github.com/gofiber/storage/redis/v3"

你可以使用以下任一选项创建 Redis 存储

// Initialize default config
store := redis.New()

// Initialize custom config
store := redis.New(redis.Config{
Host: "127.0.0.1",
Port: 6379,
Username: "",
Password: "",
Database: 0,
Reset: false,
TLSConfig: nil,
PoolSize: 10 * runtime.GOMAXPROCS(0),
})

// Initialize Redis Failover Client
store := redis.New(redis.Config{
MasterName: "master-name",
Addrs: []string{":6379"},
})

// Initialize Redis Cluster Client
store := redis.New(redis.Config{
Addrs: []string{":6379", ":6380"},
})

// Create a client with support for TLS
cer, err := tls.LoadX509KeyPair("./client.crt", "./client.key")
if err != nil {
log.Println(err)
return
}
tlsCfg := &tls.Config{
MinVersion: tls.VersionTLS12,
InsecureSkipVerify: true,
Certificates: []tls.Certificate{cer},
}
store = redis.New(redis.Config{
URL: "redis://<user>:<pass>@127.0.0.1:6379/<db>",
TLSConfig: tlsCfg,
Reset: false,
})

// Create a client with a Redis URL with all information.
store = redis.New(redis.Config{
URL: "redis://<user>:<pass>@127.0.0.1:6379/<db>",
Reset: false,
})

配置

type Config struct {
// Host name where the DB is hosted
//
// Optional. Default is "127.0.0.1"
Host string

// Port where the DB is listening on
//
// Optional. Default is 6379
Port int

// Server username
//
// Optional. Default is ""
Username string

// Server password
//
// Optional. Default is ""
Password string

// Database to be selected after connecting to the server.
//
// Optional. Default is 0
Database int

// URL standard format Redis URL. If this is set all other config options, Host, Port, Username, Password, Database have no effect.
//
// Example: redis://<user>:<pass>@localhost:6379/<db>
// Optional. Default is ""
URL string

// Either a single address or a seed list of host:port addresses, this enables FailoverClient and ClusterClient
//
// Optional. Default is []string{}
Addrs []string

// MasterName is the sentinel master's name
//
// Optional. Default is ""
MasterName string

// ClientName will execute the `CLIENT SETNAME ClientName` command for each conn.
//
// Optional. Default is ""
ClientName string

// SentinelUsername
//
// Optional. Default is ""
SentinelUsername string

// SentinelPassword
//
// Optional. Default is ""
SentinelPassword string

// Reset clears any existing keys in existing Collection
//
// Optional. Default is false
Reset bool

// TLS Config to use. When set TLS will be negotiated.
//
// Optional. Default is nil
TLSConfig *tls.Config

// Maximum number of socket connections.
//
// Optional. Default is 10 connections per every available CPU as reported by runtime.GOMAXPROCS.
PoolSize int
}

默认配置

var ConfigDefault = Config{
Host: "127.0.0.1",
Port: 6379,
Username: "",
Password: "",
URL: "",
Database: 0,
Reset: false,
TLSConfig: nil,
PoolSize: 10 * runtime.GOMAXPROCS(0),
Addrs: []string{},
MasterName: "",
ClientName: "",
SentinelUsername: "",
SentinelPassword: "",
}

示例:使用 DragonflyDB

注意:你可以像使用 Redis 一样使用 DragonflyDB
只需启动一个 DragonflyDB 服务器并像配置 Redis 一样配置它。然后调用 New() 并像使用 Redis 一样使用它。