Redis 第7章 主从复制 第8章 Jedis

1. 主从简介

配置多台Redis服务器,以主机和备机的身份分开。主机数据更新后,根据配置和策略,自动同步到备机的master/salver机制,Master以写为主,Slave以读为主,二者之间自动同步数据。

目的:

读写分离提高Redis性能;

避免单点故障,容灾快速恢复

原理:

每次从机联通后,都会给主机发送sync指令,主机立刻进行存盘操作,发送RDB文件,给从机

从机收到RDB文件后,进行全盘加载。之后每次主机的写操作,都会立刻发送给从机,从机执行相同的命令

2. 主从准备

除非是不同的主机配置不同的Redis服务,否则在一台机器上面跑多个Redis服务,需要配置多个Redis配置文件。

①准备多个Redis配置文件,每个配置文件,需要配置以下属性

daemonize yes: 服务在后台运行

port:端口号

pidfile:pid保存文件

logfile:日志文件(如果没有指定的话,就不需要)

dump.rdb: RDB备份文件的名称

appendonly 关掉,或者是更改appendonly文件的名称。

样本:

include /root/redis_repilication/redis.conf

port 6379

pidfile /var/run/redis_6379.pid

dbfilename dump_6379.rdb

②根据多个配置文件,启动多个Redis服务

原则是配从不配主。

3. 主从建立

3.1 临时建立

原则:配从不配主。

配置:在从服务器上执行SLAVEOF ip:port命令;

查看:执行info replication命令;

3.2 永久建立

在从机的配置文件中,编写slaveof属性配置!

3.3 恢复身份

    执行命令slaveof no noe恢复自由身!

4. 主从常见问题

①从机是从头开始复制主机的信息,还是只复制切入以后的信息?

答:从头开始复制,即完全复制。

②从机是否可以写?

答:不能

③主机shutdown后,从机是上位还是原地待命?

答:原地待命

④主机又回来了后,主机新增记录,从机还能否顺利复制?

答:可以

⑤从机宕机后,重启,宕机期间主机的新增记录,丛集是否会顺利复制?

答:可以

⑥其中一台从机down后重启,能否重认旧主? 

答:不一定,看配置文件中是否配置了slaveof

⑦如果两台从机都从主机同步数据,此时主机的IO压力会增大,如何解决? 

答:按照主—从(主)—从模式配置!

5. 哨兵模式

5.1 简介

作用

①Master状态检测

②如果Master异常,则会进行Master-Slave切换,将其中一个Slave作为Master,将之前的Master作为Slave

下线

①主观下线:Subjectively Down,简称 SDOWN,指的是当前 Sentinel 实例对某个redis服务器做出的下线判断。

②客观下线:Objectively Down, 简称 ODOWN,指的是多个 Sentinel 实例在对Master Server做出 SDOWN 判断,并且通过 SENTINEL is-master-down-by-addr 命令互相交流之后,得出的Master Server下线判断,然后开启failover.

 

工作原理

①每个Sentinel以每秒钟一次的频率向它所知的Master,Slave以及其他 Sentinel 实例发送一个 PING 命令 ;

②如果一个实例(instance)距离最后一次有效回复 PING 命令的时间超过 down-after-milliseconds 选项所指定的值, 则这个实例会被 Sentinel 标记为主观下线;

③如果一个Master被标记为主观下线,则正在监视这个Master的所有 Sentinel 要以每秒一次的频率确认Master的确进入了主观下线状态;

④当有足够数量的 Sentinel(大于等于配置文件指定的值)在指定的时间范围内确认Master的确进入了主观下线状态, 则Master会被标记为客观下线 ;

⑤在一般情况下, 每个 Sentinel 会以每 10 秒一次的频率向它已知的所有Master,Slave发送 INFO 命令

⑥当Master被 Sentinel 标记为客观下线时,Sentinel 向下线的 Master 的所有 Slave 发送 INFO 命令的频率会从 10 秒一次改为每秒一次 ;

⑦若没有足够数量的 Sentinel 同意 Master 已经下线, Master 的客观下线状态就会被移除;

若 Master 重新向 Sentinel 的 PING 命令返回有效回复, Master 的主观下线状态就会被移除;

5.2 配置

哨兵模式需要配置哨兵的配置文件!

sentinel monitor mymaster 127.0.0.1 6379 1

 

启动哨兵:redis-sentinel sentinel.conf

5.3 主机宕机后

+sdown master mymaster 127.0.0.1 6379 【主观下线】

+odown master mymaster 127.0.0.1 6379 #quorum 1/1【客观下线】

……

+vote-for-leader 17818eb9240c8a625d2c8a13ae9d99ae3a70f9d2 1【选举leader】

……

+failover-state-send-slaveof-noone slave 127.0.0.1:6381 127.0.0.1 6381 @ mymaster 127.0.0.1 6379【把一个从机设置为主机】

 

————-挂掉的主机又重新启动———————

-sdown slave 127.0.0.1:6379 127.0.0.1 6379 @ mymaster 127.0.0.1 6381【离开主观下线状态】

+convert-to-slave slave 127.0.0.1:6379 127.0.0.1 6379 @ mymaster 127.0.0.1 6381【转换为从机】

8Jedis

1. 简介

Jedis指通过Java连接Redis客户端。需要导入jar包:

MySQL

Redis

Connection对象

Jedis对象

连接池/数据源

连接池

Connection对象每次用完需要关闭

Jedis对象每次用完需要关闭

2. 配置

①导包:

②在所连接的Redis客户端的配置文件中:

  • 注释掉bind0.0.1
  • 关闭保护模式,将ptotect-mode设置为no
  • 禁用Linux防火墙,执行service iptables stop

③ 测试连接

@Test

public void testConnect() {

//连接指定的redis,需要ip地址和端口号

Jedis jedis=new Jedis(“192.168.162.128”, 6379);

String ping = jedis.ping();

System.out.println(ping);

}

3. 常用API

3.1 测试key

@Test

public void testKeys() {

//连接指定的redis,需要ip地址和端口号

Jedis jedis=new Jedis(“192.168.162.128”, 6379);

//获取所有key

Set<String> keys = jedis.keys(“*”);

for (String key : keys) {

System.out.println(key);

}

//判断是否存在某个key

System.out.println(“是否存在k2:”+jedis.exists(“k2”));

//测试某个key的过期时间

System.out.println(“k1的存活时间:”+jedis.ttl(“k2”));

jedis.close();

}

3.2 测试string

@Test

public void testString() {

//连接指定的redis,需要ip地址和端口号

Jedis jedis=new Jedis(“192.168.162.128”, 6379);

System.out.println(“获取K1的值:”+jedis.get(“k1”));

jedis.msetnx(“k11″,”v12″,”k22″,”v22″,”k33″,”v33”);

System.out.println(jedis.mget(“k11″,”k22″,”k33”));

//关闭连接

jedis.close();

}

3.3 测试list

3.5 测试se

3.5 测试hash

3.6 测试zset

4. 使用连接池

连接池的好处:节省每次连接redis服务带来的消耗,将创建好的连接实例反复利用;

4.1 连接池常用参数

参数

含义

MaxTotal

控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;如果赋值为-1,则表示不限制;如果pool已经分配了MaxTotal个jedis实例,则此时pool的状态为exhausted。

maxIdle

控制一个pool最多有多少个状态为idle(空闲)的jedis实例。

MaxWaitMillis

表示当borrow一个jedis实例时,最大的等待毫秒数,如果超过等待时间,则直接抛JedisConnectionException。

testOnBorrow

获得一个jedis实例的时候是否检查连接可用性(ping());如果为true,则得到的jedis实例均是可用的。

4.2 示例

@Test

public void testPool(){

//默认的连接池配置

GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();

System.out.println(poolConfig);

JedisPool jedisPool=new JedisPool(poolConfig, “192.168.4.128”, 6379,60000);

Jedis jedis = jedisPool.getResource();

String ping = jedis.ping();

System.out.println(ping);

//如果是从连接池中获取的,那么执行close方法只是将连接放回到池中

jedis.close();

jedisPool.close();}

 


上一篇:
下一篇:
关于尚硅谷
教育理念
名师团队
学员心声
资源下载
视频下载
资料下载
工具下载
加入我们
招聘岗位
岗位介绍
招贤纳师
联系我们
电话:010-56253825
邮箱:info@atguigu.com
地址:北京市昌平区宏福科技园综合楼6层(北京校区)

 深圳市宝安区西部硅谷大厦B座C区一层(深圳校区)

上海市松江区谷阳北路166号大江商厦6层(上海校区)