火遍全网的“多线程核心技术”，吊打面试官

你的名字 2021-07-20 23:27 220阅读 0赞

# 思维导图 #

![4af1c79dca822f271a6c80a9675625ff.png][]

# 前言 #

在很多时候，我们都可以在各种框架应用中看到ZooKeeper的身影，比如Kafka中间件，Dubbo框架，Hadoop等等。为什么到处都看到ZooKeeper？

## Redis主从复制 ##

### 概念 ###

Redis的主从复制概念和MySQL的主从复制大概类似。一台`主机master`，一台`从机slaver`。master主机数据更新后根据配置和策略，自动同步到slaver从机，Master以`写为主`，Slave以`读为主`。

![513eca7fb46947b44f310eca4a0fe864.png][]

#### 主要用途 ####

*  `读写分离`：适用于读多写少的应用，增加多个从机，提高读的速度，提高程序并发
 *  `数据容灾恢复`：从机复制主机的数据，相当于数据备份，如果主机数据丢失，那么可以通过从机存储的数据进行恢复。
 *  `高并发、高可用集群实现的基础`：在高并发的场景下，就算主机挂了，从机可以进行`主从切换`，从机自动成为主机对外提供服务。

### 一主多从配置 ###

![83be4cfc926fbb310263e24bcd33d9b8.png][]

#### 环境准备 ####

老哥太穷了，就用一台机器模拟三个机器。

*  `第一步：`将redis.conf复制3份，分别是redis6379.conf、redis6380.conf、redis6381.conf
 *  `第二步：` 修改三个redis.conf文件里的port端口、pid文件名、日志文件名、rdb文件名
 *  `第三步：` 分别打开三个窗口模拟三台服务器，并开启redis服务。

#### 查看当前3台机器主从角色 ####

先用命令`info replication`看看3台机器目前的`角色`是什么。

# 三台机器都是这个状态
    127.0.0.1:6379> info replication
    # 角色是master主机
    role:master
    # 从机个数为0
    connected_slaves:0

#### 设置主从关系 ####

这里注意，我们只设置从机就可以了，不用设置主机。我们选择`6380`和`6381`作为`从机`。`6379`作为`主机`。

# 6380 端口
    127.0.0.1:6380> SLAVEOF 127.0.0.1 6379
    
    # 6381 端口
    127.0.0.1:6381> SLAVEOF 127.0.0.1 6379
    
    # 6381 端口
    127.0.0.1:6381> SLAVEOF 127.0.0.1 6379

#### 再次查看3台机器目前角色 ####

再次执行命令：`info replication`

# 主机
    127.0.0.1:6379> info replication
    role:master # 角色：主机
    connected_slaves:2 #连接的从机个数，以及从机IP和端口
    slave0:ip=127.0.0.1,port=6380,state=online,offset=98,lag=1
    slave1:ip=127.0.0.1,port=6381,state=online,offset=98,lag=1
    
    # 从机1
    127.0.0.1:6380> info replication
    role:slave # 角色：从机
    master_host:127.0.0.1 # 主机的IP和端口
    master_port:6379
    
    # 从机2
    127.0.0.1:6381> info replication
    role:slave # 角色：从机
    master_host:127.0.0.1 # 主机的IP和端口
    master_port:6379

#### 搭建成功，试验一把 ####

*  `全量复制：` 从机会把主机之前的数据全部都同步过来，大家可以在从机上get 某key试试。
 *  `增量复制：` 当主机新增数据时，从机会将该新增数据同步过来，大家可以在主机上执行命令set key value，然后在从机上get 该key，看是否能获取到。

#### 读写分离 ####

Redis的从机`默认`不允许进行`写操作`，大家可以在从机上执行命令`set key value`，会报错。

# 6380从机
    127.0.0.1:6380> set k3 v3
    (error) READONLY You can't write against a read only slave.

**「呼，好累」**，主从复制写的差不多了！！

### 主从复制原理 ###

![0c968ef9229e3db2617856e45a3890e8.png][]

#### 全量复制 ####

![5afa5efe16fdd767fd8de2bb2ed46c8a.png][]

\*\*「①」\*\*slave发送psync，由于是第一次复制，不知道master的runid，自然也不知道offset，所以发送psync ？ -1

\*\*「②」\*\*master收到请求，发送master的runid和offset给从节点。

\*\*「③」\*\*从节点slave保存master的信息

\*\*「④」\*\*主节点bgsave保存rdb文件

\*\*「⑤」\*\*主机点发送rdb文件

并且在\*\*「④」**和**「⑤」\*\*的这个过程中产生的数据，会写到复制缓冲区repl\_back\_buffer之中去。

\*\*「⑥」\*\*主节点发送上面两个步骤产生的buffer到从节点slave

\*\*「⑦」\*\*从节点清空原来的数据，如果它之前有数据，那么久会清空数据

\*\*「⑧」\*\*从节点slave把rdb文件的数据装载进自身。

#### 全量复制的开销 ####

\*\*「①」\*\*bgsave时间

\*\*「②」\*\*rdb文件网络传输时间

\*\*「③」\*\*从节点清空数据的

\*\*「④」\*\*从节点加载rdb的时间

\*\*「⑤」\*\*可能的aof重写时间，这是针对从节点，例如开启了aof之后，从节点添加buffer数据时候，可能需要aof重写

基于上面的原因，有的情况下不适合使用全量复制，例如网络抖动之后，从节点只需要传送一部分数据，不需要传送全部数据，`redis2.8`之后实现了部分复制功能

#### 部分复制 ####

![373fef83792c88751756a238c6865b1a.png][]

\*\*「①」\*\*假设发送网络抖动或者别的情况，暂时失去了连接

\*\*「②」\*\*这个时候，master还在继续往buffer里面写数据

\*\*「③」\*\*slave重新连接上了master

\*\*「④」\*\*slave向master发送自己的offset和runid

\*\*「⑤」\*\*master判断slave的offset是否在buffer的队列里面，如果是，那就返回continue给slave，否则需要进行全量复制（因为这说明已经错过了很多数据了）

\*\*「⑥」\*\*master发送从slave的offset开始到缓冲区队列结尾的数据给slave  
![274d2c6089ed9d4c0d7beccdf487b01a.png][]

# **Java高频面试专题合集解析：** #

![阿里Java岗面试百题：Spring 缓存 JVM 微服务 数据库 RabbitMQ等][Java_Spring _ JVM _ _ RabbitMQ]

当然在这还有更多整理总结的Java进阶学习笔记和面试题未展示，在这也是免费分享给那些有需要的朋友，其中囊括了**Dubbo、Redis、Netty、zookeeper、Spring cloud、分布式、高并发等架构资料和完整的Java架构学习进阶导图！**

**这些资料都以整理成了PDF文档，如果有需要可以[狂戳这里免费下载][Link 1]即可！**

![阿里Java岗面试百题：Spring 缓存 JVM 微服务 数据库 RabbitMQ等][Java_Spring _ JVM _ _ RabbitMQ 1]

**更多Java架构进阶资料展示**

![阿里Java岗面试百题：Spring 缓存 JVM 微服务 数据库 RabbitMQ等][Java_Spring _ JVM _ _ RabbitMQ 2]

![阿里Java岗面试百题：Spring 缓存 JVM 微服务 数据库 RabbitMQ等][Java_Spring _ JVM _ _ RabbitMQ 3]

com/doc/DSmxTbFJ1cmN1R2dB)即可！\*\*

\[外链图片转存中…(img-N9Aqf24r-1618150682161)\]

**更多Java架构进阶资料展示**

\[外链图片转存中…(img-CIk7kxrP-1618150682161)\]

\[外链图片转存中…(img-P1YLscB9-1618150682162)\]

![阿里Java岗面试百题：Spring 缓存 JVM 微服务 数据库 RabbitMQ等][Java_Spring _ JVM _ _ RabbitMQ 4]

[4af1c79dca822f271a6c80a9675625ff.png]: /images/20210720/13e2dc7fbd9a46a7b5854ecad2ffd7f8.png
[513eca7fb46947b44f310eca4a0fe864.png]: /images/20210720/80802579c9814d4a8470b9589a8514bf.png
[83be4cfc926fbb310263e24bcd33d9b8.png]: /images/20210720/3c8fc064db9f42dfacb648804da90fe2.png
[0c968ef9229e3db2617856e45a3890e8.png]: /images/20210720/c6c4b77ada8f43b584d0792786e9478a.png
[5afa5efe16fdd767fd8de2bb2ed46c8a.png]: /images/20210720/60252595b1b24376b55083636f59f4b2.png
[373fef83792c88751756a238c6865b1a.png]: /images/20210720/c8ef332eb8e449d0a010f9db64be5506.png
[274d2c6089ed9d4c0d7beccdf487b01a.png]: /images/20210720/8ee43fa660e04cf394422ef9f04d1eb4.png
[Java_Spring _ JVM _ _ RabbitMQ]: /images/20210720/94ec8fb2d1e446e0b73c12c5a2e67ec0.png
[Link 1]: https://docs.qq.com/doc/DSmxTbFJ1cmN1R2dB
[Java_Spring _ JVM _ _ RabbitMQ 1]: /images/20210720/d7e2bbec94e94b73b70ed9c5ec3762d4.png
[Java_Spring _ JVM _ _ RabbitMQ 2]: /images/20210720/0f5b8e95621c499ba09ae3b9ebf1947c.png
[Java_Spring _ JVM _ _ RabbitMQ 3]: /images/20210720/f061750b340f4554ac828de7c42dc2fc.png
[Java_Spring _ JVM _ _ RabbitMQ 4]: /images/20210720/efc1e31755fe440291d2ebd6cae51d31.png