锐客网

  1. 首页 > 睿知 > it技术 > >

go语言redis库 golang redisson

IT技术连接

Go语言与Docker操作Redis首选go语言redis库 ， 如果之前使用过redis容器go语言redis库，我们需要先remove掉之前的容器
然后创建redis容器 ， 并运行
进入redis容器中
接着我们通过 redis-cli 连接测试使用 redis 服务
setex指令 可以设置数据存在的时间，setex key second value
MSET一次设置多个key-value
MGET一次获取多个key-value
HGET
HGETALL
Hlen和hexist
Lpush 和 Lrange
Lpop和Rpop 从链表取出并移走数据
删除链表所有数据 DEL
字符串无序 不能重复
从连接池中Get出一个conn连接
如何在 Go 语言中使用 Redis 连接池一、关于连接池
一个数据库服务器只拥有有限的资源，并且如果go语言redis库你没有充分使用这些资源，go语言redis库你可以通过使用更多的连接来提高吞吐量 。一旦所有的资源都在使用，那么你就不 能通过增加更多的连接来提高吞吐量 。事实上，吞吐量在连接负载较大时就开始下降go语言redis库了 。通常可以通过限制与可用的资源相匹配的数据库连接的数量来提高延迟和吞 吐量 。
如何在Go语言中使用Redis连接池
如果不使用连接池，那么，每次传输数据，我们都需要进行创建连接，收发数据 ， 关闭连接 。在并发量不高的场景，基本上不会有什么问题，一旦并发量上去go语言redis库了 ， 那么，一般就会遇到下面几个常见问题：
性能普遍上不去
CPU 大量资源被系统消耗
网络一旦抖动，会有大量 TIME_WAIT 产生，不得不定期重启服务或定期重启机器
服务器工作不稳定，QPS 忽高忽低
要想解决这些问题，我们就要用到连接池了 。连接池的思路很简单，在初始化时，创建一定数量的连接，先把所有长连接存起来，然后，谁需要使用，从这里取走 ， 干完活立马放回来 。如果请求数超出连接池容量，那么就排队等待、退化成短连接或者直接丢弃掉 。
二、使用连接池遇到的坑
最近在一个项目中，需要实现一个简单的 Web Server 提供 Redis 的 HTTP interface，提供 JSON 形式的返回结果 。考虑用 Go 来实现 。
首先，去看一下 Redis 官方推荐的 Go Redis driver 。官方 Star 的项目有两个：Radix.v2 和 Redigo 。经过简单的比较后，选择了更加轻量级和实现更加优雅的 Radix.v2 。
Radix.v2 包是根据功能划分成一个个的 sub package，每一个 sub package 在一个独立的子目录中，结构非常清晰 。我的项目中会用到的 sub package 有 redis 和 pool 。
由于我想让这种被 fork 的进程最好简单点，做的事情单一一些，所以，在没有深入去看 Radix.v2 的 pool 的实现之前，我选择了自己实现一个 Redis pool 。(这里，就不贴代码了 。后来发现自己实现的 Redis pool 与 Radix.v2 实现的 Redis pool 的原理是一样的，都是基于 channel 实现的, 遇到的问题也是一样的 。)
不过在测试过程中，发现了一个诡异的问题 。在请求过程中经常会报 EOF 错误 。而且是概率性出现，一会有问题 ， 一会又好了 。通过反复的测试，发现 bug 是有规律的，当程序空闲一会后，再进行连续请求 ， 会发生3次失败，然后之后的请求都能成功，而我的连接池大小设置的是3 。再进一步分析，程序空闲300秒 后，再请求就会失败，发现我的 Redis server 配置了 timeout 300，至此，问题就清楚了 。是连接超时 Redis server 主动断开了连接 。客户端这边从一个超时的连接请求就会得到 EOF 错误 。
然后我看了一下 Radix.v2 的 pool 包的源码 ， 发现这个库本身并没有检测坏的连接，并替换为新server{location/pool{content_by_lua_block{localredis=require"resty.redis"localred=redis:new()localok,err=red:connect("127.0.0.1",6379)ifnotokthenngx.say("failedtoconnect:",err)returnendok,err=red:set("hello","world")ifnotokthenreturnendred:set_keepalive(10000,100)}}}
发现有个 set_keepalive 的方法，查了一下官方文档，方法的原型是 syntax: ok, err = red:set_keepalive(max_idle_timeout, pool_size) 貌似 max_idle_timeout 这个参数，就是我们所缺少的东西，然后进一步跟踪源码，看看里面是怎么保证连接有效的 。
function_M.set_keepalive(self,...)localsock=self.sockifnotsockthenreturnnil,"notinitialized"endifself.subscribedthenreturnnil,"subscribedstate"endreturnsock:setkeepalive(...)end
至此，已经清楚了，使用了 tcp 的 keepalive 心跳机制 。
于是，通过与 Radix.v2 的作者一些讨论，选择自己在 redis 这层使用心跳机制，来解决这个问题 。
四、最后的解决方案
在创建连接池之后，起一个 goroutine，每隔一段 idleTime 发送一个 PING 到 Redis server 。其中，idleTime 略小于 Redis server 的 timeout 配置 。连接池初始化部分代码如下：
p,err:=pool.New("tcp",u.Host,concurrency)errHndlr(err)gofunc(){for{p.Cmd("PING")time.Sleep(idelTime*time.Second)}}()
使用 redis 传输数据部分代码如下：
funcredisDo(p*pool.Pool,cmdstring,args...interface{})(reply*redis.Resp,errerror){reply=p.Cmd(cmd,args...)iferr=reply.Err;err!=nil{iferr!=io.EOF{Fatal.Println("redis",cmd,args,"erris",err)}}return}
其中，Radix.v2 连接池内部进行了连接池内连接的获取和放回，代码如下：
//Cmdautomaticallygetsoneclientfromthepool,executesthegivencommand//(returningitsresult),andputstheclientbackinthepoolfunc(p*Pool)Cmd(cmdstring,args...interface{})*redis.Resp{c,err:=p.Get()iferr!=nil{returnredis.NewResp(err)}deferp.Put(c)returnc.Cmd(cmd,args...)}
这样，我们就有了 keepalive 的机制，不会出现 timeout 的连接了 ， 从 redis 连接池里面取出的连接都是可用的连接了 。看似简单的代码，却完美的解决了连接池里面超时连接的问题 。同时，就算 Redis server 重启等情况，也能保证连接自动重连 。
golang 如何连接redis --- 2022-04-03下面介绍golang如何连接redis服务端 。
1.golang连接redis
通过例子，我们知道主要通过Options配置redis的连接参数 ， 下面对Options参数进行详细说明 。
提示：go-redis包自带了连接池，会自动维护redis连接，因此创建一次client即可 ， 不要查询一次redis就关闭client 。
2.Options参数详解
GO语言使用 Redis数据库可以参考go语言redis库： windows环境下redisgo语言redis库的安装
启动redis服务器go语言redis库：redis-server.exe redis.windows.conf
获取包go语言redis库：
导入包
访问：
如何在go语言中使用redis连接池1.在创建连接池之后 ， 起一个 go routine，每隔一段 idleTime 发送一个 PING 到 Redis server 。其中，idleTime 略小于 Redis server 的 timeout 配置 。
2.连接池初始化部分代码如下：
p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() {for {p.Cmd("PING")time.Sleep(idelTime * time.Second)} }()
【go语言redis库 golang redisson】3.使用 redis 传输数据部分代码如下：
func redisDo(p *pool.Pool, cmd string, args ...interface{}) (reply *redis.Resp, err error) {reply = p.Cmd(cmd, args...)if err = reply.Err; err != nil {if err != io.EOF {Fatal.Println("redis", cmd, args, "err is", err)}}return }
4.其中，Radix.v2 连接池内部进行了连接池内连接的获取和放回，代码如下：
// Cmd automatically gets one client from the pool, executes the given command // (returning its result), and puts the client back in the pool func (p *Pool) Cmd(cmd string, args ...interface{}) *redis.Resp {c, err := p.Get()if err != nil {return redis.NewResp(err)}defer p.Put(c)return c.Cmd(cmd, args...) }
这样 ， 就有了系统 keep alive 的机制 ， 不会出现 time out 的连接了 ， 从 redis 连接池里面取出的连接都是可用的连接了 。看似简单的代码，却完美的解决了连接池里面超时连接的问题 。同时 ， 就算 Redis server 重启等情况 ， 也能保证连接自动重连 。
go语言redis库的介绍就聊到这里吧 ， 感谢你花时间阅读本站内容，更多关于golang redisson、go语言redis库的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：如何在局域网中查找服务器？ 怎么查局域网服务器

    下一篇：pg数据库可以存什么类型数据，pg数据库可以存什么类型数据文件