分布式专栏中间件:Redis主从架构-技术圈

主从原理

1、复制一份redis.conf文件2、将相关配置修改为如下值：port 6380pidfile /var/run/redis_6380.pid # 把pid进程号写入pidfile配置的文件logfile "6380.log"dir /usr/local/redis‐5.0.3/data/6380 # 指定数据存放目录# 需要注释掉bind# bind 127.0.0.1（bind绑定的是自己机器网卡的ip，如果有多块网卡可以配多个ip，代表允许客户端通过机器的哪些网卡ip去访问，内网一般可以不配置bind，注释掉即可）
3、配置主从复制replicaof 192.168.0.60 6379 # 从本机6379的redis实例复制数据，Redis 5.0之前使用slaveof13 replica‐read‐only yes # 配置从节点只读4、启动从节点redis‐server redis.conf5、连接从节点redis‐cli ‐p 63806、测试在6379实例上写数据，6380实例是否能及时同步新修改数据7、可以自己再配置一个6381的从节点

如果你为master配置了一个slave，不管这个slave是否是第一次连接上Master，它都会发送一个PSYNC命令给master请求复制数据。master收到PSYNC命令后，会在后台进行数据持久化通过bgsave生成最新的rdb快照文件，持久化期间，master会继续接收客户端的请求，它会把这些可能修改数据集的请求缓存在内存中。当持久化进行完毕以后，master会把这份rdb文件数据集发送给slave，slave会把接收到的数据进行持久化生成rdb，然后再加载到内存中。然后，master再将之前缓存在内存中的命令发送给slave。

当master与slave之间的连接由于某些原因而断开时，slave能够自动重连Master，如果master收到了多个slave并发连接请求，它只会进行一次持久化，而不是一个连接一次，然后再把这一份持久化的数据发送给多个并发连接的slave。

数据部分复制

当master和slave断开重连后，一般都会对整份数据进行复制。但从redis2.8版本开始，redis改用可以支持部分数据复制的命令PSYNC去master同步数据，slave与master能够在网络连接断开重连后只进行部分数据复制(断点续传)。

master会在其内存中创建一个复制数据用的缓存队列，缓存最近一段时间的数据，master和它所有的slave都维护了复制的数据下标offset和master的进程id，因此，当网络连接断开后，slave会请求master继续进行未完成的复制，从所记录的数据下标开始。如果master进程id变化了，或者从节点数据下标offset太旧，已经不在master的缓存队列里了，那么将会进行一次全量数据的复制。

import org.junit.Test;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;
import java.util.List;import java.util.Map;import java.util.Set;
public class DemoTest {    @Test    public void set(){        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();         jedisPoolConfig.setMaxTotal(20);         jedisPoolConfig.setMaxIdle(10);         jedisPoolConfig.setMinIdle(5);
         // timeout，这里既是连接超时又是读写超时，从Jedis 2.8开始有区分connectionTimeout和soTimeout的构造函数         JedisPool jedisPool = new JedisPool(jedisPoolConfig, "192.168.0.60", 6379, 3000,                null);
         Jedis jedis = null;         try {             //从redis连接池里拿出一个连接执行命令             jedis = jedisPool.getResource();
             System.out.println(jedis.set("single", "zhuge"));             System.out.println(jedis.get("single"));
             //管道示例             //管道的命令执行方式：cat redis.txt | redis‐cli ‐h 127.0.0.1 ‐a password ‐ p 6379 ‐‐pipe             /*             Pipeline pl = jedis.pipelined(); for (int i = 0; i < 10; i++) { pl.incr("pipelineKey"); pl.set("zhuge" + i, "zhuge"); } List<Object> results = pl.syncAndReturnAll(); System.out.println(results);*/
             //lua脚本模拟一个商品减库存的原子操作             //lua脚本命令执行方式：redis‐cli ‐‐eval /tmp/test.lua , 10             /*jedis.set("product_count_10016", "15"); //初始化商品10016的库存 String script = " local count = redis.call('get', KEYS[1]) " + " local a = tonumber(count) " + " local b = tonumber(ARGV[1]) " + " if a >= b then " + " redis.call('set', KEYS[1], a‐b) " + " return 1 " + " end " + " return 0 "; Object obj = jedis.eval(script, Arrays.asList("product_count_10016"),Arrays.asList("10")); System.out.println(obj);*/
             } catch (Exception e) {             e.printStackTrace();            } finally {          //注意这里不是关闭连接，在JedisPool模式下，Jedis会被归还给资源池。           if (jedis != null)            jedis.close();             }    }    }    }

管道（Pipeline）

客户端可以一次性发送多个请求而不用等待服务器的响应，待所有命令都发送完后再一次性读取服务的响应，这样可以极大的降低多条命令执行的网络传输开销，管道执行多条命令的网络开销实际上只相当于一次命令执行的网络开销。需要注意到是用pipeline方式打包命令发送，redis必须在处理完所有命令前先缓存起所有命令的处理结果。打包的命令越多，缓存消耗内存也越多。所以并不是打包的命令越多越好。

Redis Lua脚本目的

较少网络开销
原子操作
替代Redisde 事务功能