Redis主从复制，哨兵机制、Redis集群

# 哨兵sentinel监控的redis主节点的 ip port

# master-name 可以自己命名的主节点名字 只能由字母A-z、数字0-9 、这三个字符".-_"组成。

# quorum 当这些quorum个数sentinel哨兵认为master主节点失联 那么这时 客观上认为主节点失联了

# sentinel monitor <master-name> <master ip> <master port> <quorum>

sentinel monitor mymaster 192.168.10.133 6379 1

# 哨兵sentinel实例运行的端口 默认26379

port 26379

# 哨兵sentinel的工作目录

dir /tmp

# 哨兵sentinel监控的redis主节点的 ip port

# master-name 可以自己命名的主节点名字 只能由字母A-z、数字0-9 、这三个字符".-_"组成。

# quorum 当这些quorum个数sentinel哨兵认为master主节点失联 那么这时 客观上认为主节点失联了

# sentinel monitor <master-name> <ip> <redis-port> <quorum>

sentinel monitor mymaster 127.0.0.1 6379 2

# 当在Redis实例中开启了requirepass foobared 授权密码 这样所有连接Redis实例的客户端都要提供密码

# 设置哨兵sentinel 连接主从的密码 注意必须为主从设置一样的验证密码

# sentinel auth-pass <master-name> <password>

sentinel auth-pass mymaster MySUPER--secret-0123passw0rd

# 指定多少毫秒之后 主节点没有应答哨兵sentinel 此时 哨兵主观上认为主节点下线 默认30秒

# sentinel down-after-milliseconds <master-name> <milliseconds>

sentinel down-after-milliseconds mymaster 30000

# 这个配置项指定了在发生failover主备切换时最多可以有多少个slave同时对新的master进行同步，

# 这个数字越小，完成failover所需的时间就越长，

# 但是如果这个数字越大，就意味着越 多的slave因为replication而不可用。

# 可以通过将这个值设为 1 来保证每次只有一个slave 处于不能处理命令请求的状态。

# sentinel parallel-syncs <master-name> <numslaves>

sentinel parallel-syncs mymaster 1

# 故障转移的超时时间 failover-timeout 可以用在以下这些方面：

#1. 同一个sentinel对同一个master两次failover之间的间隔时间。

#2. 当一个slave从一个错误的master那里同步数据开始计算时间。直到slave被纠正为向正确的master那里同步数据时。

#3.当想要取消一个正在进行的failover所需要的时间。

#4.当进行failover时，配置所有slaves指向新的master所需的最大时间。不过，即使过了这个超时，slaves依然会被正确配置为指向master，但是就不按parallel-syncs所配置的规则来了

# 默认三分钟

# sentinel failover-timeout <master-name> <milliseconds>

sentinel failover-timeout mymaster 180000

# SCRIPTS EXECUTION

#配置当某一事件发生时所需要执行的脚本，可以通过脚本来通知管理员，例如当系统运行不正常时发邮件通知相关人员。

#对于脚本的运行结果有以下规则：

#若脚本执行后返回1，那么该脚本稍后将会被再次执行，重复次数目前默认为10

#若脚本执行后返回2，或者比2更高的一个返回值，脚本将不会重复执行。

#如果脚本在执行过程中由于收到系统中断信号被终止了，则同返回值为1时的行为相同。

#一个脚本的最大执行时间为60s，如果超过这个时间，脚本将会被一个SIGKILL信号终止，之后重新执行。

#通知型脚本:当sentinel有任何警告级别的事件发生时（比如说redis实例的主观失效和客观失效等等），将会去调用这个脚本，这时这个脚本应该通过邮件，SMS等方式去通知系统管理员关于系统不正常运行的信息。调用该脚本时，将传给脚本两个参数，一个是事件的类型，一个是事件的描述。

#如果sentinel.conf配置文件中配置了这个脚本路径，那么必须保证这个脚本存在于这个路径，并且是可执行的，否则sentinel无法正常启动成功。

#通知脚本

# sentinel notification-script <master-name> <script-path>

sentinel notification-script mymaster /var/redis/notify.sh

# 客户端重新配置主节点参数脚本

# 当一个master由于failover而发生改变时，这个脚本将会被调用，通知相关的客户端关于master地址已经发生改变的信息。

# 以下参数将会在调用脚本时传给客户端:

# <master-name> <role> <state> <from-ip> <from-port> <to-ip> <to-port>

# 目前<state>总是“failover”,

# <role>是“leader”或者“observer”中的一个。

# 参数 from-ip, from-port, to-ip, to-port是用来和旧的master和新的master(即旧的slave)通信的

# 这个脚本应该是通用的，能被多次调用，不是针对性的。

# sentinel client-reconfig-script <master-name> <script-path>

sentinel client-reconfig-script mymaster /var/redis/reconfig.sh

./redis-sentinel sentinel.conf

cd 7001

        ./redis-server redis.conf

        cd ..

        cd 7002

        ./redis-server redis.conf

        cd ..

        cd 7003

        ./redis-server redis.conf

        cd ..

        cd 7004

        ./redis-server redis.conf

        cd ..

        cd 7005

        ./redis-server redis.conf

        cd ..

        cd 7006

        ./redis-server redis.conf

        cd .. 

        ```

放到和节点同级目录  

![](https://img-blog.csdnimg.cn/20200610215958443.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk0NzM3OA==,size_16,color_FFFFFF,t_70)  

 chmod u+x start-cluster.sh （授权可执行）

*   第五步：所有节点启动后创建Redis集群```

    ./redis-cli --cluster create 192.168.10.135:7001 192.168.10.135:7002

    192.168.10.135:7003 192.168.10.135:7004 192.168.10.135:7005

    192.168.10.135:7006 --cluster-replicas 1

    # --cluster-replicas：代表每个主节点有几个从节点

    >>> Creating cluster

    Connecting to node 192.168.10.133:7001: OK

    Connecting to node 192.168.10.133:7002: OK

    Connecting to node 192.168.10.133:7003: OK

    Connecting to node 192.168.10.133:7004: OK

    Connecting to node 192.168.10.133:7005: OK

    Connecting to node 192.168.10.133:7006: OK

    >>> Performing hash slots allocation on 6 nodes...

    Using 3 masters:

    192.168.10.133:7001

    192.168.10.133:7002

    192.168.10.133:7003

    Adding replica 192.168.10.133:7004 to 192.168.10.133:7001

    Adding replica 192.168.10.133:7005 to 192.168.10.133:7002

    Adding replica 192.168.10.133:7006 to 192.168.10.133:7003

    M: d8f6a0e3192c905f0aad411946f3ef9305350420 192.168.10.133:7001

    slots:0-5460 (5461 slots) master

    M: 7a12bc730ddc939c84a156f276c446c28acf798c 192.168.10.133:7002

    slots:5461-10922 (5462 slots) master

    M: 93f73d2424a796657948c660928b71edd3db881f 192.168.10.133:7003

    slots:10923-16383 (5461 slots) master

    S: f79802d3da6b58ef6f9f30c903db7b2f79664e61 192.168.10.133:7004

    replicates d8f6a0e3192c905f0aad411946f3ef9305350420

    S: 0bc78702413eb88eb6d7982833a6e040c6af05be 192.168.10.133:7005

    replicates 7a12bc730ddc939c84a156f276c446c28acf798c

    S: 4170a68ba6b7757e914056e2857bb84c5e10950e 192.168.10.133:7006

    replicates 93f73d2424a796657948c660928b71edd3db881f

    Can I set the above configuration? (type 'yes' to accept): yes

    >>> Nodes configuration updated

    >>> Assign a different config epoch to each node

    >>> Sending CLUSTER MEET messages to join the cluster

    Waiting for the cluster to join....

    >>> Performing Cluster Check (using node 192.168.10.133:7001)

    M: d8f6a0e3192c905f0aad411946f3ef9305350420 192.168.10.133:7001

    slots:0-5460 (5461 slots) master

    M: 7a12bc730ddc939c84a156f276c446c28acf798c 192.168.10.133:7002

    slots:5461-10922 (5462 slots) master

    M: 93f73d2424a796657948c660928b71edd3db881f 192.168.10.133:7003

    slots:10923-16383 (5461 slots) master

    M: f79802d3da6b58ef6f9f30c903db7b2f79664e61 192.168.10.133:7004

    slots: (0 slots) master

    replicates d8f6a0e3192c905f0aad411946f3ef9305350420

    M: 0bc78702413eb88eb6d7982833a6e040c6af05be 192.168.10.133:7005

    slots: (0 slots) master

    replicates 7a12bc730ddc939c84a156f276c446c28acf798c

    M: 4170a68ba6b7757e914056e2857bb84c5e10950e 192.168.10.133:7006

    slots: (0 slots) master

    replicates 93f73d2424a796657948c660928b71edd3db881f

    [OK] All nodes agree about slots configuration.

    >>> Check for open slots...

    >>> Check slots coverage...

    [OK] All 16384 slots covered.

    [root@localhost-0723 redis]#

./redis-cli –h 127.0.0.1 –p 7001 –c

./redis-cli -p 7006 -c

127.0.0.1:7006> set key1 123

-> Redirected to slot [9189] located at 127.0.0.1:7002

OK

127.0.0.1:7002>

127.0.0.1:7003> 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:6

cluster_my_epoch:3

cluster_stats_messages_sent:926

cluster_stats_messages_received:926

127.0.0.1:7003> cluster nodes

7a12bc730ddc939c84a156f276c446c28acf798c 127.0.0.1:7002 master - 0 1443601739754 2 connected 5461-10922

93f73d2424a796657948c660928b71edd3db881f 127.0.0.1:7003 myself,master - 0 0 3 connected 10923-16383

d8f6a0e3192c905f0aad411946f3ef9305350420 127.0.0.1:7001 master - 0 1443601741267 1 connected 0-5460

4170a68ba6b7757e914056e2857bb84c5e10950e 127.0.0.1:7006 slave 93f73d2424a796657948c660928b71edd3db881f 0 1443601739250 6 connected

f79802d3da6b58ef6f9f30c903db7b2f79664e61 127.0.0.1:7004 slave d8f6a0e3192c905f0aad411946f3ef9305350420 0 1443601742277 4 connected

0bc78702413eb88eb6d7982833a6e040c6af05be 127.0.0.1:7005 slave 7a12bc730ddc939c84a156f276c446c28acf798c 0 1443601740259 5 connected

127.0.0.1:7003>

./redis-cli --cluster add-node 127.0.0.1:7007 127.0.0.1:7001

cluster nodes

./redis-cli --cluster del-node 127.0.0.1:7008 41592e62b83a8455f07f7797f1d5c071cffedb50

service iptables stop

@Test

public void testJedisCluster() throws Exception {

    //创建一连接，JedisCluster对象,在系统中是单例存在

    Set<HostAndPort> nodes = new HashSet<>();

    nodes.add(new HostAndPort("192.168.10.133", 7001));

    nodes.add(new HostAndPort("192.168.10.133", 7002));

    nodes.add(new HostAndPort("192.168.10.133", 7003));

    nodes.add(new HostAndPort("192.168.10.133", 7004));

    nodes.add(new HostAndPort("192.168.10.133", 7005));

    nodes.add(new HostAndPort("192.168.10.133", 7006));

    JedisCluster cluster = new JedisCluster(nodes);

    //执行JedisCluster对象中的方法，方法和redis一一对应。

    cluster.set("cluster-test", "my jedis cluster test");

    String result = cluster.get("cluster-test");

    System.out.println(result);

    //程序结束时需要关闭JedisCluster对象

    cluster.close();

}

<!-- 连接池配置 -->

<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

    <!-- 最大连接数 -->

    <property name="maxTotal" value="30" />

    <!-- 最大空闲连接数 -->

    <property name="maxIdle" value="10" />

    <!-- 每次释放连接的最大数目 -->

    <property name="numTestsPerEvictionRun" value="1024" />

    <!-- 释放连接的扫描间隔（毫秒） -->

    <property name="timeBetweenEvictionRunsMillis" value="30000" />

    <!-- 连接最小空闲时间 -->

    <property name="minEvictableIdleTimeMillis" value="1800000" />

    <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->

    <property name="softMinEvictableIdleTimeMillis" value="10000" />

    <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->

    <property name="maxWaitMillis" value="1500" />

    <!-- 在获取连接的时候检查有效性, 默认false -->

    <property name="testOnBorrow" value="true" />

    <!-- 在空闲时检查有效性, 默认false -->

    <property name="testWhileIdle" value="true" />

    <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->

    <property name="blockWhenExhausted" value="false" />

</bean>

<!-- redis集群 -->

<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">

    <constructor-arg index="0">

        <set>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7001"></constructor-arg>

            </bean>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7002"></constructor-arg>

            </bean>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7003"></constructor-arg>

            </bean>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7004"></constructor-arg>

            </bean>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7005"></constructor-arg>

            </bean>

            <bean class="redis.clients.jedis.HostAndPort">

                <constructor-arg index="0" value="192.168.101.3"></constructor-arg>

                <constructor-arg index="1" value="7006"></constructor-arg>

            </bean>

        </set>

    </constructor-arg>

    <constructor-arg index="1" ref="jedisPoolConfig"></constructor-arg>

</bean>

private ApplicationContext applicationContext;

@Before

public void init() {

    applicationContext = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");

}

// redis集群

@Test

public void testJedisCluster() {

    JedisCluster jedisCluster = (JedisCluster) applicationContext.getBean("jedisCluster");

    jedisCluster.set("name", "zhangsan");

    String value = jedisCluster.get("name");

    System.out.println(value);

}