如何在 Go 语言中使用 Redis 连接池
在创建连接池之后，起一个 goroutine，每隔一段 idleTime 发送一个 PING 到 Redis server。其中，idleTime 略小于 Redis server 的 timeout 配置。
连接池初始化部分代码如下：
p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() { for { p.Cmd("PING") time.Sleep(idelTime * time.Second) } }()
使用 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 }
其中，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...) }
这样，我们就有了 keepalive 的机制，不会出现 timeout 的连接了，从 redis 连接池里面取出的连接都是可用的连接了。看似简单的代码，却完美的解决了连接池里面超时连接的问题。同时，就算 Redis server 重启等情况，也能保证连接自动重连。
redis cluster集群部署
一.服务器设置准备
1. 将6379端口在防火墙看开启
[root@redis1 ~]#vi /etc/sysconfig/iptables
-A INPUT -m state --state NEW -m tcp -p tcp --dport 6379 -j ACCEPT
注：必须加在 REJECT 前面。
2.修改Selinux参数
[root@redis1 ~]#vi /etc/selinux/config
SELINUX=disabled
注：分别在其它几个节点上同样配置防火墙和 SELINUX。
二.安装Redis
1.安装系统组件
安装gcc、tcl
yum install –y gcc-c++
yum install –y tcl
2.安装redis
2.1.解压 Redis 到/usr/local目录下
[root@redis1 ~]# tar -zxvf /root/software/redis-3.2.6.tar.gz -C /usr/local/
2.2.在解压后的目录中进行 make 和 make test
[root@redis1 ~]# cd /usr/local/redis-3.2.6
[root@redis1 redis-3.2.6]# make
[root@redis1 redis-3.2.6]# make test
注：要检查 make 和 make test 的结果是否都正确，如果报错，针对性检查并安装系统缺少的组件。
2.3. 复制 redis-server 和 redis-cli 到/usr/local/bin 目录下：
[root@redis1 redis-3.2.6]# cd src
[root@redis1 src]# cp redis-server /usr/local/bin/
[root@redis1 src]# cp redis-cli /usr/local/bin/
2.4验证 Redis 安装是否成功：
[root@redis1 ~]# redis-server
[root@redis1 ~]# redis-cli
注：安装其它 5 台服务器
三.配置集群模式
1.配置 redis.conf
1.1 配置 redis.conf
[root@redis1 ~]# mkdir /etc/redis
[root@redis1 ~]# cd /etc/redis
[root@redis ~]# vi redis.conf
port 6379
daemonize yes
cluster-enabled yes
cluster-config-file /etc/redis/nodes.conf
cluster-node-timeout 5000
appendonly yes
requirepass Ab123456
注 1：cluster-node-timeout 是集群中各节点相互通讯时，允许“失联”的最大毫秒数，本演示
中配置的为 5 秒，如果超过 5 秒某个节点没有向其它节点汇报成功，认为该节点挂了。
注 2：requirepass 是 Redis 访问密码，为了安全起见，该参数建议必须配置，从但客户端
Jedis 版本必须使用 2.8.x 以上的版本，否则需要通过扩展 JedisCluster 来实现对密码访问的
支持。此外几个 Redis 节点的密码应该设置为相同的。
注 3：分别在其它几个节点上创建与上面相同的 redis.conf 文件，内容也相同。
注 4：重启/重建 Redis 集群时，必须删除去/etc/redis/nodes.conf 文件。
1.2以次启动所有节点
[root@redis1 ~]# redis-server /etc/redis/redis.conf
[root@redis2 ~]# redis-server /etc/redis/redis.conf
[root@redis3 ~]# redis-server /etc/redis/redis.conf
[root@redis4 ~]# redis-server /etc/redis/redis.conf
[root@redis5 ~]# redis-server /etc/redis/redis.conf
[root@redis6 ~]# redis-server /etc/redis/redis.conf
2.安装 Redis 集群所需的 Ruby 工具
2.1安装 Ruby 工具：
Redis 集群需要借助其它工具将相关节点加入到 Cluster 中，而这个工具是由 Redis 提供
一个名为 redis-trib.rb 的 ruby 脚本，否则接下来创建 cluster 会失败。
[root@redis1 ~]# cd /usr/local/redis-3.2.6/src
[root@redis1 src]# yum install –y ruby
[root@redis1 src]# yum install -y rubygems
[root@redis1 src]# gem install redis --version 3.0.0
[root@redis1 src]# gem list
2.2 设置 Ruby 连接 Redis 的密码：
[root@redis1 ~]# vi /usr/lib/ruby/gems/1.8/gems/redis-3.0.0/lib/redis/client.rb
:password = "Ab123456"
注：分别在其它几个节点上用同样的方式安装好 Ruby 工具
3 利用redis-trib.rb 创建 Redis集群
3. 1. 在 src 目录下运行以下脚本：
[root@redis1 ~]# cd /usr/local/redis-3.2.6/src
[root@redis1 src]# ./redis-trib.rb create --replicas 1 10.50.130.101:6379 10.50.130.102:6379
10.50.130.103:6379 10.50.130.104:6379 10.50.130.105:6379 10.50.130.106:6379
注 1：只需在其中某个个节点执行以上脚本（本例在第一个节点执行）。
注 2：利用 redis-trib 创建 Cluster，只需要操作一次即可，假设系统关机、重启，把所有的
节点全部关闭之后，下次重启后，即自动进入 Cluster 模式，不用现次执行 redis-trib.rb cteate
命令。
3.2查看 Cluster 进程：
[root@redis1 ~]# ps -ef|grep redis
[root@redis2 ~]# ps -ef|grep redis
[root@redis3 ~]# ps -ef|grep redis
[root@redis4 ~]# ps -ef|grep redis
[root@redis5 ~]# ps -ef|grep redis
[root@redis6 ~]# ps -ef|grep redis
3.3 查看节点属性（Master/Slave）
[root@redis1 ~]# cd /usr/local/redis-3.2.6/src
[root@redis1 src]# ./redis-trib.rb check 10.50.130.101:6379
[root@redis1 src]# ./redis-trib.rb check 10.50.130.102:6379
[root@redis1 src]# ./redis-trib.rb check 10.50.130.103:6379
[root@redis1 src]# ./redis-trib.rb check 10.50.130.104:6379
[root@redis1 src]# ./redis-trib.rb check 10.50.130.105:6379
[root@redis1 src]# ./redis-trib.rb check 10.50.130.106:6379
3.4查看节点/集群信息
redis-cli 客户端登录到任一个节点，查看:
4.Jedis 测试 Redis 集群
Redis集群模式2-RedisCluster模式
Redis哨兵集群模式，每个节点都保存全量同步数据，冗余的数据比较多。从Redis3.0开始官方推出了RedisCluster集群模式 ，采用分片集群模式，可以减少冗余数据，但也提高了集群成本，RedisCluster集群最大的优点： 动态扩容、缩容 。
以最简单的为例，分别搭建3组节点，每组1主2从，如上图示。因机器有限，3组节点分别搭在3个虚拟机中，3台虚拟机IP： 192.168.100.51、192.168.100.52、192.168.100.53 ，每组节点端口： 6381、6382、6383
配置文件基本和原来的一样，主要区别是要开启CLuster集群模式，
3台虚拟机，9个node节点分别启动
因为搭建在了 3台虚拟主机上，所以要先关闭防火墙
用命令将9台节点组成集群，在一台机器运行就行
连接集群和单机基本一样，但需要注意2点：
连接以后用 cluster nodes 命令查看节点信息，测试写入
杀死52上的主节点，等几秒钟，查看集群情况
然后重启，在查看集群情况，如下图：
集群减少一组主从节点，现在有3组，先把51:6381这一组去掉吧。
192.168.100.51:6381 的从节点分别是 192.168.100.52:6382 ， 192.168.100.53:6382 ，直接删除这2个，注意操作时都用到node id
主节点 192.168.100.51:6381 的slots转移到其他1个或多个节点，看硬件配置分配，这里就直接都给 192.168.100.53:6381 吧。
删除之前，先查看一遍节点信息，确认槽位已经转移，再删除
集群扩容肯定是增加一组，即主从一块增加
启动好要增加的服务节点，新增主节点，命令中第2个地址是现在集群中任一个node节点的，注意不要搞错
从节点有2个，分别添加
redis cluster命令cluster nodes怎么用
redis cluster配置好，并运行一段时间后，我们想添加节点，或者删除节点，该怎么办呢。
一，redis cluster命令行
查看复制打印?
//集群(cluster)
CLUSTER INFO 打印集群的信息
CLUSTER NODES 列出集群当前已知的所有节点（node），以及这些节点的相关信息。
//节点(node)
CLUSTER MEET ip port 将 ip 和 port 所指定的节点添加到集群当中，让它成为集群的一份子。
CLUSTER FORGET node_id 从集群中移除 node_id 指定的节点。
CLUSTER REPLICATE node_id 将当前节点设置为 node_id 指定的节点的从节点。
CLUSTER SAVECONFIG 将节点的配置文件保存到硬盘里面。
//槽(slot)
CLUSTER ADDSLOTS slot [slot ...] 将一个或多个槽（slot）指派（assign）给当前节点。
CLUSTER DELSLOTS slot [slot ...] 移除一个或多个槽对当前节点的指派。
CLUSTER FLUSHSLOTS 移除指派给当前节点的所有槽，让当前节点变成一个没有指派任何槽的节点。
CLUSTER SETSLOT slot NODE node_id 将槽 slot 指派给 node_id 指定的节点，如果槽已经指派给另一个节点，那么先让另一个节点删除该槽，然后再进行指派。
CLUSTER SETSLOT slot MIGRATING node_id 将本节点的槽 slot 迁移到 node_id 指定的节点中。
CLUSTER SETSLOT slot IMPORTING node_id 从 node_id 指定的节点中导入槽 slot 到本节点。
CLUSTER SETSLOT slot STABLE 取消对槽 slot 的导入（import）或者迁移（migrate）。
//键 (key)
CLUSTER KEYSLOT key 计算键 key 应该被放置在哪个槽上。
CLUSTER COUNTKEYSINSLOT slot 返回槽 slot 目前包含的键值对数量。
CLUSTER GETKEYSINSLOT slot count 返回 count 个 slot 槽中的键。
这些命令是集群所独有的。执行上述命令要先登录
查看复制打印?
[root@manage redis]# redis-cli -c -p 6382 -h 192.168.10.220 //登录
192.168.10.220:6382 cluster info //查看集群情况
cluster_state:ok
cluster_slots_assigned:16384
cluster_slots_ok:16384
cluster_slots_pfail:0
cluster_slots_fail:0
cluster_known_nodes:6
cluster_size:3
cluster_current_epoch:8
cluster_my_epoch:4
cluster_stats_messages_sent:82753
cluster_stats_messages_received:82754
二，添加节点
1，新配置二个测试节点
查看复制打印?
# cd /etc/redis
//新增配置
# cp redis-6379.conf redis-6378.conf sed -i "s/6379/6378/g" redis-6378.conf
# cp redis-6382.conf redis-6385.conf sed -i "s/6382/6385/g" redis-6385.conf
//启动
# redis-server /etc/redis/redis-6385.conf /var/log/redis/redis-6385.log 21
# redis-server /etc/redis/redis-6378.conf /var/log/redis/redis-6378.log 21
2，添加主节点
# redis-trib.rb add-node 192.168.10.219:6378 192.168.10.219:6379
注释：
192.168.10.219:6378是新增的节点
192.168.10.219:6379集群任一个旧节点
3，添加从节点
# redis-trib.rb add-node --slave --master-id 03ccad2ba5dd1e062464bc7590400441fafb63f2 192.168.10.220:6385 192.168.10.219:6379
注释：
--slave，表示添加的是从节点
--master-id 03ccad2ba5dd1e062464bc7590400441fafb63f2,主节点的node id，在这里是前面新添加的6378的node id
192.168.10.220:6385,新节点
192.168.10.219:6379集群任一个旧节点
4，重新分配slot
查看复制打印?
# redis-trib.rb reshard 192.168.10.219:6378 //下面是主要过程
How many slots do you want to move (from 1 to 16384)? 1000 //设置slot数1000
What is the receiving node ID? 03ccad2ba5dd1e062464bc7590400441fafb63f2 //新节点node id
Please enter all the source node IDs.
Type 'all' to use all the nodes as source nodes for the hash slots.
Type 'done' once you entered all the source nodes IDs.
Source node #1:all //表示全部节点重新洗牌
Do you want to proceed with the proposed reshard plan (yes/no)? yes //确认重新分
新增加的主节点，是没有slots的，
golang 如何连接redis --- 2022-04-03
下面介绍golang如何连接redis服务端。
1.golang连接redis
通过例子，我们知道主要通过Options配置redis的连接参数，下面对Options参数进行详细说明。
提示：go-redis包自带了连接池，会自动维护redis连接，因此创建一次client即可，不要查询一次redis就关闭client。
2.Options参数详解
以上内容为新媒号(sinv.com.cn)为大家提供！新媒号，坚持更新大家所需的互联网后端知识。希望您喜欢！
版权申明：新媒号所有作品（图文、音视频）均由用户自行上传分享，仅供网友学习交流，不声明或保证其内容的正确性，如发现本站有涉嫌抄袭侵权/违法违规的内容。请发送邮件至 k2#88.com(替换@) 举报，一经查实，本站将立刻删除。
