组件分享之后端组件——Redis数据库的一个Go客户端redigo

组件分享之后端组件——Redis数据库的一个Go客户端redigo

组件分享之后端组件——Redis数据库的一个Go客户端redigo

背景

近期正在探索前端、后端、系统端各类常用组件与工具，对其一些常见的组件进行再次整理一下，形成标准化组件专题，后续该专题将包含各类语言中的一些常用组件。欢迎大家进行持续关注。

组件基本信息

组件：​​redigo​​开源协议：​​ Apache-2.0 license​​

内容

本节分享一个Redis数据库的一个Go客户端​​redigo​​

它具有以下特征一个​​类似打印的​​API，支持所有 Redis 命令。​​流水线​​，包括流水线交易。​​发布/订阅​​。​​连接池​​。乐观使用 EVALSHA 的​​脚本助手类型。​​用于处理命令回复的​​辅助函数。​​

使用起来也非常简单，案例如下： 1、安装

go get github.com/gomodule/redigo/redis

2、使用

type Redis struct { Addr string `toml:"addr"` //redis地址因为需要考虑单机版和集成的情况下 地址使用[]string Password string `toml:"password"` //密码 没有则为空 DB int `toml:"db"` //使用的数据库 DialConnectionTimeout time.Duration `toml:"dialConnectionTimeout"` DialReadTimeout time.Duration `toml:"dialReadTimeout"` DialWriteTimeout time.Duration `toml:"dialWriteTimeout"` IdleTimeout time.Duration `toml:"idleTimeout"` MaxIdle int `toml:"maxIdle"` // 连接池中的最大空闲连接数 MaxActive int `toml:"maxActive"` // 连接池在给定时间内分配的最大连接数。0没有限制 }func initRedis() (*redis.Pool, error) { log.Println("-----------开始初始化redis通用客户端") // 获取配置信息 redisConfig := config.Get().Redis redisUrl := fmt.Sprintf("redis://%s", redisConfig.Addr) // 建立连接池 redisClient := &redis.Pool{ Dial: func() (redis.Conn, error) { con, err := redis.DialURL( redisUrl, redis.DialPassword(redisConfig.Password), redis.DialDatabase(redisConfig.DB), redis.DialConnectTimeout(redisConfig.DialConnectionTimeout*time.Second), redis.DialReadTimeout(redisConfig.DialReadTimeout*time.Second), redis.DialWriteTimeout(redisConfig.DialWriteTimeout*time.Second), ) if err != nil { return nil, err } return con, nil }, TestOnBorrow: func(c redis.Conn, t time.Time) error { _, err := c.Do("PING") if err != nil { log.Printf("ping redis error: %s", err) return err } return nil }, MaxIdle: redisConfig.MaxIdle, MaxActive: redisConfig.MaxActive, IdleTimeout: redisConfig.IdleTimeout * time.Second, Wait: true, MaxConnLifetime: 0, } log.Printf("[redis util] init end !!!") return redisClient, nil}

redisClient,_ := initRedis()c := redisClient.Get()defer c.Close()n, err := c.Do("APPEND", "key", "value")c.Send("SET", "foo", "bar")c.Send("GET", "foo")c.Flush()c.Receive() // reply from SETv, err = c.Receive() // reply from GET

更多前后端组件，可以持续关注我，我将持续给大家分享各种各样的组件包。

88x31.png

​​知识共享许可协议​​

本作品由 ​​cn華少​​ 采用 ​​知识共享署名-非商业性使用 4.0 国际许可协议​​ 进行许可。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。