Redigo:当redis服务器关闭时，失败速度很快

Redigo是一个Go语言编写的Redis客户端库，用于与Redis服务器进行通信。当Redis服务器关闭时，Redigo会在连接建立时尝试与服务器建立连接，如果连接失败，则会立即返回错误信息，速度非常快。

Redigo的优势包括：

高性能：Redigo使用Go语言编写，具有高效的并发处理能力，能够快速处理大量的请求。
简单易用：Redigo提供了简洁的API，使用起来非常方便，开发者可以快速上手。
支持丰富的功能：Redigo支持Redis的各种功能，包括字符串、哈希、列表、集合、有序集合等数据结构的操作，以及发布订阅、事务等高级功能。
可靠性高：Redigo具有自动重连机制，当连接断开时会自动重新连接，确保与Redis服务器的稳定通信。

Redigo适用于以下场景：

缓存：Redis作为一种高性能的缓存数据库，可以用于缓存热点数据，提高系统的读取性能。Redigo可以方便地与Redis进行通信，实现缓存功能。
分布式锁：Redis的分布式锁可以用于解决多个进程或线程之间的并发访问问题。Redigo提供了对分布式锁的支持，可以方便地使用Redis实现分布式锁。
计数器：Redis的原子操作可以用于实现计数器功能，例如统计网站的访问量、用户的点赞数等。Redigo可以方便地与Redis进行交互，实现计数器功能。

腾讯云提供了云数据库Redis版（TencentDB for Redis）产品，可以满足用户对Redis的需求。具体产品介绍和文档可以参考腾讯云官网：https://cloud.tencent.com/product/redis

相关·内容

Go操作Redis

此外，当数据库高并发查询的情况下，单位时间内所需的数据量也是很大的，此时可能会受到磁盘带宽的影响，影响磁盘的查询速度。...,应该没人用. # 2. allkeys-lru: 当内存不足以容纳新写入数据时，在键空间中，移除最少使用的那个key.推荐使用 # 3. allkeys-random: 当内存不足以容纳新写入数据时，...: 当内存不足以容纳新写入数据时，在设置了过期时间的键空间中，随机移除某个key，依然不推荐. # 6. volatile-ttl: 当内存不足以容纳新写入数据时，在设置了过期时间的键空间中，有更早过期的...当客户端连接数到达限制时，Redis会关闭新的连接并向客户端返回 max number of clients reached 错误信息 maxclients 128 # 指定Redis最大内存限制，.../redigo/redis" 连接 Conn接口是与Redis协作的主要接口，可以使用Dial,DialWithTimeout或者NewConn函数来创建连接，当任务完成时，应用程序必须调用Close

2K7 0

Golang 官方推荐使用的 Redis 客户端 redigo

使用 go get 命令安装 redigo： go get github.com/gomodule/redigo/redis redigo 库中的 Conn 接口是操作 Redis 的主要接口。...= nil { fmt.Printf("redis.Dial() error:%v", err) return } // 关闭连接 defer c.Close() 阅读上面这段代码，我们使用...Dial 函数创建连接，需要注意的是，我们不要忘记关闭连接。...03 string 操作 redigo 执行 Redis 命令的通用方法是使用 Conn 接口的 Do 函数，Do 函数可以发送命令给 Redis 服务器，并返回 Redis 服务器的回复。...Values 和 ScanStruct，将 Redis 服务器的回复解析到 struct，redigo 还提供了助手函数 ScanSlice 将 Redis 服务器的回复解析到 slice。

8.7K4 0

Go实战项目-Beego的Session、日志文件的使用和redis的选择使用

开始使用的时候，必须是最主流的第三方框架，redigo,引入还是照旧：”github.com/garyburd/redigo/redis”，直接导入就好。...go-redis的使用谷歌出品的，支持集群和哨兵方式等的连接。这也是比redigo更吸引的地方。...，默认为0，即不关闭存活时长较长的连接 //命令执行失败时的重试策略 MaxRetries: 0, // 命令执行失败时...) error { //仅当客户端执行命令时需要从连接池获取连接时，如果连接池需要新建连接时则会调用此钩子函数 fmt.Printf("conn=%v\n", conn)...，默认为0，即不关闭存活时长较长的连接 //命令执行失败时的重试策略 MaxRetries: 0, // 命令执行失败时

1.8K3 0

Go项目优化——动态缓存Redis的使用

Redis: 1.1 简介： garyburd/redigo 包是网上很多博文都在推荐使用的一个高Star的Redis连接包，项目已经迁移到了gomodule/redigo，同时包的获取也理所当然地改成了...go get github.com/gomodule/redigo/redis，总之，暂时不管这两个包的详细区别，以下就以新包为准，介绍下redigo包使用。...不然的话，每当要操作redis时，建立连接，用完后再关闭，会导致大量的连接处于TIME_WAIT状态（redis连接本质上就是tcp）。...import ( "fmt" "github.com/gomodule/redigo/redis" "time" ) var redisPoll *redis.Pool func initRedis...= nil { return nil, err } return c, nil }, // 最大的空闲连接数， // 表示即使没有redis连接时依然可以保持N个空闲的连接

5152 0

go语言使用redis（redigo）

原文作者:laijh 来源：简书 go的redis client用的比较多两个包是redix和redigo，因为beego cache模块里redis使用的是redigo，所以我也就使用这个包了。...当把整体分析，会发现提供给开发者使用的内容非常巧妙。...点击下载 Demo: 1package main 2 3import ( 4 "fmt" 5 "github.com/gomodule/redigo/redis" 6 "log...: nil returned") 暴露给开发者的目的是，因为从redis服务器获取数据的时候可能遇到值为空的情况。...redis服务器连接时，进行参数设置。

5K2 0

redigo 连接池代码分析

结构体分析 type Pool struct { // 用来创建redis连接的方法 Dial func() (Conn, error) // 如果设置了给func,那么每次...IdleTimeout time.Duration // 当可用连接数为0是，那么当wait=true,那么当调用p.Get()时，会阻塞等待，否则，返回nil....mu sync.Mutex // 用来条件控制，这里主要是当链接被关闭时，提醒在等待的进程可以使用了，或者可以自行创建了 cond *sync.Cond // 当前连接池是否已经关闭...(idleConn).c.Close() } return nil } 释放一个链接 func (p *Pool) release() { // 当链接超时，或者ping不通，或者创建失败...server c, err := dial() // 连接失败关闭之 if err !

1.8K8 0

2种Go Redis客户端使用对比

redis底层的类型进行统一，编译时就可以帮助检查参数类型并且它的响应统一采用 Result 的接口返回，确保了返回参数类型的正确性，对用户更加友好；图片性能对比BenchmarkRedis/redigo_client_Benchmark...46451 ns/op从上图可以看出, go-redis虽然每次操作会比redigo慢10%左右, 但是redigo需要显示申请/关闭连接,所以总体上二者的性能差异其实不大Redigo库介绍redigo...（300秒不使用自动关闭） Dial: func() (redis.Conn, error) { //要连接的redis数据库 return redis.Dial("tcp"...，具体的用法直接查看接口的申请就可以了，使用成本低；其次它对数据类型按照redis底层的类型进行统一，编译时就可以帮助检查参数类型, 并且它的响应统一采用 Result 的接口返回，确保了返回参数类型的正确性...秒不使用自动关闭） Dial: func() (redis.Conn, error) { //要连接的redis数据库 return redis.Dial("tcp", "localhost

5.6K3 0

Redis 学习笔记9 - 使用 redigo 访问 redis

1.redigo 介绍 redigo 是一个连接 Redis 数据库的客户端框架 Github地址：https://github.com/gomodule/redigo 它是被 redis 官方网站推荐的框架...基本操作实例 2.1 导入包 Import: import "github.com/gomodule/redigo/redis" 2.2 连接 Conn接口是使用Redis的主要接口。...当使用完后，必须调用connection Close方法。 Dial函数 c, err := redis.Dial("tcp", ":6379") if err !...v, err = c.Receive() // reply from GET 2.7 发布和订阅 Publish and Subscribe 使用Send、Flush和Receive方法实现发布/订阅服务器.../gomodule/redigo/redis#pkg-examples](https://godoc.org/github.com/gomodule/redigo/redis#pkg-examples)

1.3K2 0

线上一次大量 CLOSE_WAIT 复盘

说明服务端还没有调用 recv 读取，并且在客户端关闭连接后，CLOSE_WAIT 依然不会消失，只能说明服务端 HANG 在了某处，没有调用 close。.../gomodule/redigo/redis..../gomodule/redigo/redis....发生 block 时，几乎全都是阻塞在了 <-p.ch 上，还没有走到执行 redis 命令的时刻，也就不会有什么保护机制了。.../gomodule/redigo/redis.

1.4K3 1

Redigo--用池管理redis连接

在golang的项目中，若要频繁的用redis（或者其他类似的NoSQL）来存取数据，最好用redigo自带的池来管理连接。...不然的话，每当要操作redis时，建立连接，用完后再关闭，会导致大量的连接处于TIME_WAIT状态（redis连接本质上就是tcp）。...以下为redis连接池的golang实现： import ( "github.com/garyburd/redigo/redis" "github.com/astaxie/beego...) return c, nil }, } } 其中，各参数的解释如下： MaxIdle：最大的空闲连接数，表示即使没有redis连接时依然可以保持...MaxActive：最大的激活连接数，表示同时最多有N个连接 IdleTimeout：最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭 Dial：建立连接使用连接池时的代码： // 从池里获取连接

2.4K6 0

golang重构博客统计服务

而统计阅读次数的场景对接口处理的速度还是有一定的要求的，因此楼主选择了redis作为阅读次数统计的db。下面就是redis操作的基础代码，比较简单楼主贴一下代码，不做进一步的阐述。...redigo依赖下载 go get github.com/gomodule/redigo/redis redis操作的工具类 func initRedisPool() { // 建立连接池.../garyburd/redigo/redis" "log" "net/http" "time" "strings" ) const RedisAddress = "127.0.0.1:6379...Code int `json:"code"` Data string `json:"data"` } 实现过程中遇到的坑出现的问题使用golang原生的json工具序列化时，出现序列化失败的问题...`json:"msg"` code int `json:"code"` data string `json:"data"` } 问题解决最终楼主通过各种姿势的排查，发现是结构体定义有问题，当定义结构体时首字母必须大写才能序列化成功

5932 0

基于redisgo的redis客户端的封装示例

redis命令，其内容如下： package cache import ( "fmt" "log" "time" "github.com/gomodule/redigo/redis" "ybu.cn.../iot/common" ) // https://godoc.org/github.com/gomodule/redigo/redis#pkg-examples // https://github.com.../gomodule/redigo // RedisClient redis client instance type RedisClient struct { pool *redis.Pool...close(r.chanRx) // 关闭redis线程池 r.pool.Close() } // Write 向redis中写入多组数据 func (r *RedisClient) Write...，并且redis密码改成自己阿里云服务器上的redis配置，运行结果如下图所示： ?

1.9K3 0

redisgo 封装实例

+UUUzlpkBYO0= github.com/gomodule/redigo/redis v0.0.0-do-not-use h1:J7XIp6Kau0WoyT4JtXHT3Ei0gA1KkSc6bc87j9v9WIo.../redigo/redis" "ybu.cn/iot/common" ) // https://godoc.org/github.com/gomodule/redigo/redis#pkg-examples...// https://github.com/gomodule/redigo // RedisClient redis client instance type RedisClient struct {...close(r.chanRx) // 关闭redis线程池 r.pool.Close() } // Write 向redis中写入多组数据 func (r *RedisClient...，并且redis密码改成自己阿里云服务器上的redis配置，运行结果如下图所示：测试结果最终的代码我已经上传至我的github仓库：https://github.com/ccf19881030/

1K0 0

连接redis

使用Redigo这个库 package main import ( "fmt" "redis" "time" "strconv" ) var ( server string = "192.168.1.105...) (redis.Conn, error) { c, err := redis.Dial("tcp", server) if err !...return err }, } } func main() { pool = poolInit() for i:=0;i<1000000;i++ { test(i) } } 如果服务器端口不可用或者服务...i不可用，则c.Do会返回错误，端口不可用立即返回Connection Refused，而服务器不可达会等待一段时间超时再返回。...下面这段代码实现先查找缓存，查询失败时查询mysql type Record struct { Key string Val string } func fetch_key(key string

1.5K9 0

Linux下Redis数据库安装使用及Go语言操作Redis

Redis 优势 1）性能极高 – Redis能读的速度是110000次/s,写的速度是81000次/s 。...slaveof 服务器端和客户端命令 服务器端 服务器端的命令为redis-server 可以使⽤help查看帮助⽂档 redis-server --help 推荐使⽤服务的⽅式管理redis服务启动...redis 查看redis服务器进程 sudo kill -9 pid 杀死redis服务器 sudo redis-server /etc/redis/redis.conf 指定加载的配置文件客户端...test.go，之后在redis中查找到键c1值为hello，说明安装成功 package main import ( "github.com/gomodule/redigo/redis") func..., "c1", "hello") } 操作方法 Go操作redis文档https://godoc.org/github.com/gomodule/redigo/redis 连接数据库 Dial(network

6471 0

redis分布式锁原理面试(数据库索引用的什么数据结构)

分布式锁原理分布式锁：当多个进程不在同一个系统中，多个进程共同竞争同一个资源，用分布式锁控制多个进程对资源的互斥访问。...采用Redis服务器存储锁信息（即SET一个Key表示已加锁），可以实现多进程的并发读锁的状态，如果没有锁，则只允许一个进程加锁。...失败的情况，网络恢复后可以自动重连轮询实现方案方案一：采用Redis的原子性命令“SET key value EX expire-time NX”可以实现分布式锁的基本功能，其中的NX（Not...package main import ( "fmt" "time" "github.com/gomodule/redigo/redis" ) func main() { rds...", err) return } result, err = redis.String(result, err) // 加锁失败，

3022 0

redis客户端对比redigo go-redis

redigo对于连接池支持稍弱连接池应用程序调用Get方法从池中获取连接，并使用连接的Close方法将连接的资源返回到池。...= nil { fmt.Println("get err:", err) } else { fmt.Println(get_res) } } 输出： OK true redigo go-redis...创建一个时间间隔为 frequency 的计时器，在连接池关闭时关闭该计时器循环判断计时器是否到时和连接池是否关闭移除空闲连接队列中的过期连接 ---- 建立与关闭连接建立连接 func (p *...removeConnWithLock 函数的工作流程如下：连接队列上锁遍历连接队列找到要关闭的连接，并将其移除出连接队列更新连接池统计数据检查连接池最小空闲连接数量连接队列解锁关闭连接，先执行关闭连接时的回调函数...（创建连接池时的配置选项传入），再关闭连接 ---- 获取与放回连接获取 // Get returns existed connection from the pool or creates a new

1.5K2 0

Redis主从复制原理

使用Redis主从复制的原因主要是单台Redis节点存在以下的局限性：（1）Redis虽然读写的速度都很快，单节点的Redis能够支撑QPS大概在5w左右，如果上千万的用户访问，Redis就承载不了...（3）当连接断开时，slave服务器会重新连接上master服务器，然后请求继续复制。...但从Redis 2.8开始，从服务器会周期性的应答从复制流中处理的数据量。（2）Redis主从复制不阻塞master服务器。也就是说当若干个从服务器在进行初始同步时，主服务器仍然可以处理外界请求。...当master服务器进行初始同步时，slave服务器返回的是以前旧版本的数据，如果你不想这样，那么在启动redis配置文件中进行设置，那么从redis在同步过程中来自外界的查询请求都会返回错误给客户端；...当不能这么做时，比如考虑到延迟的问题，应该将master服务器配置为避免自动重启。否则，在关闭master服务器持久化机制并开始自动重启的情况下，会造成主从服务器数据被清空的情况。

5104 0

Redis 持久化之RDB持久化

Redis 相对于其他NoSQL 内存数据库而言，除了更富的数据结构和速度快之外，Redis 的丰富的持久化方案也就一个很显著的优势，Redis 支持RDB、AOF、混合持久化三种模式。...本篇讲的是RDB持久化：上面提到了RDB文件实际上是一种内存快照，直接截取某个时间点的Redis中的全部数据，很显然特点是恢复速度会很快（将快照加载到内存中），然后RDB文件是一个很紧凑的二进制文件适合保存...当启用了RDB且最后一次后台保存数据失败，Redis是否停止接收数据。这会让用户意识到数据没有正确持久化到磁盘上，否则没有人会注意到灾难（disaster）发生了。...image.png 总体来说，就是达到save的触发条件时，默认bgsave 将内存快照保存到当前redis.conf 同级目录下。...手动触发 save 这个命令会阻塞Redis 服务器，一直到save命令执行完才会接受其他的新的处理命令。 bgsave bgsave时会创建一个fork一个子进程，RDB持久化工作由子进程进行。

5992 0

Twemproxy——针对MemCached与Redis的代理

Twemproxy是一个代理服务器，可以通过它减少Memcached或Redis服务器所打开的连接数。 Twemproxy有何用途呢？...它可以：通过代理的方式减少缓存服务器的连接数自动在多台缓存服务器间共享数据通过不同的策略与散列函数支持一致性散列通过配置的方式禁用失败的结点运行在多个实例上，客户端可以连接到首个可用的代理服务器...特性前就让Redis集群发挥作用，而在大多数情况下都不会丧失太多的性能： Twemproxy的强大之处在于可以通过配置的方式让它禁用掉失败的结点，同时还能在一段时间后进行重试，抑或使用指定的键->服务器映射...这意味着在将Redis用作数据存储时，它可以对Redis数据集进行分片（禁用掉结点驱逐）；在将Redis用作缓存时，它可以启用结点驱逐以实现简单的高可用性。...Twemproxy速度很快，真的很快，它几乎与直接访问Redis速度一样快。我敢说在最差的情况下，性能也只不过才损失20%而已。

6599 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云