Golang go-redis cluster模式下不断创建新连接,效率下降问题解决
2023-09-11 14:16:27 时间
前言
至于go-redis的cluster模式怎么调用,我就不多说了。可以参考我的另一篇文章:Go语学习笔记 - redis cluster集群模式 | Web框架Gin(十三)_的博客-CSDN博客
在我测试集群模式下redis调用的时候发现效率不如单一节点模式。
我们先复现一下问题是怎么出现的。
问题复现
先初始化构建一个cluster集群连接。
package connect
import (
"context"
"fmt"
"github.com/go-redis/redis/v8"
"time"
)
var Cluster *redis.ClusterClient
func init() {
Cluster = redis.NewClusterClient(&redis.ClusterOptions{
Addrs: []string{
"xxxxx:7379",
"xxxxx:7380",
},
Password: "123456",
//DialTimeout: 100 * time.Microsecond,
ReadTimeout: 100 * time.Microsecond,
//WriteTimeout: 100 * time.Microsecond,
DialTimeout: 5 * time.Second, //连接建立超时时间,默认5秒。
//ReadTimeout: 3 * time.Second, //读超时,默认3秒, -1表示取消读超时
WriteTimeout: 3 * time.Second, //写超时,默认等于读超时
OnConnect: func(ctx context.Context, conn *redis.Conn) error {
fmt.Printf("创建新的连接: %v
", conn)
return nil
},
})
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
Cluster.Ping(ctx).Result()
}
写一个简单的测试redis使用的demo。
package demo
import (
"RedisCluster/connect"
"context"
"fmt"
"time"
)
const Key = "test-111"
func SampleDemo() {
// 第一次写入数据,并设置10分钟缓存
connect.Cluster.Set(context.TODO(), Key, "666", 10*time.Minute)
cmd := connect.Cluster.Get(context.TODO(), Key)
result, _ := cmd.Result()
fmt.Println("result:", result)
// 第二次写入数据,并设置10分钟缓存
start := time.Now().UnixMilli()
connect.Cluster.Set(context.TODO(), Key, "777", 10*time.Minute)
end := time.Now().UnixMilli()
fmt.Println("set ->", (end - start))
cmd = connect.Cluster.Get(context.TODO(), Key)
end1 := time.Now().UnixMilli()
fmt.Println("get ->", (end1 - end))
result, _ = cmd.Result()
fmt.Println("result:", result)
}
代码说明
1、启动的时候会对Cluster进行初始化,我们先存取一次,然后接着存取第二次。主要看一下第二次的耗时情况。
2、在创建Cluster的时候建了一个钩子函数,如果创建新连接会打印一句话。
执行结果
可以看到在第二次执行的时候,创建了多个连接,直接导致设置key的时间到了150ms。
问题解决
我在网上找了挺久,类似问题没怎么找到,我开始试着看一遍入参。
最终是将ReadTimeout调整为3秒后,正常了。
代码调整如下:
//DialTimeout: 100 * time.Microsecond,
ReadTimeout: 3000 * time.Microsecond,
//WriteTimeout: 100 * time.Microsecond,
DialTimeout: 5 * time.Second, //连接建立超时时间,默认5秒。
//ReadTimeout: 3 * time.Second, //读超时,默认3秒, -1表示取消读超时
WriteTimeout: 3 * time.Second, //写超时,默认等于读超时
执行结果
小结
以后有时间还是要看看具体原因。
先自我介绍一下,小编13年上师交大毕业,曾经在小公司待过,去过华为OPPO等大厂,18年进入阿里,直到现在。深知大多数初中级java工程师,想要升技能,往往是需要自己摸索成长或是报班学习,但对于培训机构动则近万元的学费,着实压力不小。自己不成体系的自学效率很低又漫长,而且容易碰到天花板技术停止不前。因此我收集了一份《java开发全套学习资料》送给大家,初衷也很简单,就是希望帮助到想自学又不知道该从何学起的朋友,同时减轻大家的负担。添加下方名片,即可获取全套学习资料哦
相关文章
- Redigo--Go连接Redis
- 【Go命令教程】5. go clean
- 【Go命令教程】4. go get
- windows redis:Uncaught exception 'RedisException' with message 'Redis server went away'
- Nacos Go 微服务生态系列(一)| Dubbo-go 云原生核心引擎探索
- Redis学习(8)-redis其他特性
- Ubuntu下安装配置redis
- redis-3.2.5 make 报错
- redis绑定ip以及启动和查看启动状态
- 【Go语言】【8】GO语言的条件语句和选择语句
- 【Go语言】【2】Sublime配置GO开发环境
- 【Go语言】【15】GO语言的面向对象
- go安装goctl进行Go Dockefile的自动生成
- Go gin内嵌静态资源go-bindata的安装及使用(GVA)
- 【Java案例】-Jedis操作redis教程
- 〖Python 数据库开发实战 - Redis篇⑥〗- Redis数据结构 - 字符串类型
- 〖Python 数据库开发实战 - Python与Redis交互篇⑦〗- 利用 redis-py 实现缓存学生考试信息
- 【Go基础】理解go语言类型
- 【Go】go实现 — 选择排序
- redis 重启服务丢失 密码设置 现象 与 解决过程
- HBase vs Redis
- SpringBoot缓存技术整合SpringData Redis
- 面试官:讲讲Redis的五大数据类型?如何使用?(内含完整测试源码)
- 【云原生 | Kubernetes 系列】Redis单机和Redis-cluster的K8S实现
- redis缓存内容
- Redis 5.0 redis-cli --cluster help说明
- Redis 漏斗限流 (redis-cell)
- 饿了么这样跳过Redis Cluster遇到的“坑”
- GO-REDIS的一些高级用法
- go使用go-redis操作redis 连接类型,pipline, 发布订阅
- 聊聊GO-REDIS的一些高级用法
- 结合实践总结Docker安装Redis
- Redis_16_Redis服务器中的数据库(键值对的存放和生存时间的存放)
- 【redis源码分析】Redis Sentinel 是如何实际解决分布式共识问题的
- 带上问题来学redis,看到不吃亏(什么是redis?缓存问题、数据一致性、redis配置文件汉化版)