一、准备

1. 关于redis的一些安装，可以查看我的几篇文章自行安装：Redis目录。
   
   
   
2. 一个web项目，我这边一直用的一个github项目是：https://github.com/gubaijin/buildmavenweb
   
   
   
3. 导入java的Redis客户端依赖包Jedis:

   <dependency>
               <groupId>redis.clients</groupId>
               <artifactId>jedis</artifactId>
               <version>2.9.0</version>
           </dependency>

   
   
   
   

二、单机Redis

三、代码中连接redis集群

//使用jedis在代码中连接redis集群，因为是集群，可以自动发现，也同样只要一个地址就行了
        Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
        //Jedis Cluster will attempt to discover cluster nodes automatically
        jedisClusterNodes.add(new HostAndPort("192.168.240.142", 6379));
        JedisCluster jc = new JedisCluster(jedisClusterNodes);
        jc.set("foo", "bar");
        String value = jc.get("foo");
        System.out.println(value);

用redis客户端到redis集群中查看验证，存入时我们连接的是142，此时我们在144上进行验证：

四、spring-data-redis连接redis集群

因为实际中我们不可能每次使用的时候都去new一下，然后连接，所以这边推荐使用spring集成redis，并且使用较新的包（版本较低的可能不支持redis集群）。

1. 导入jedis包后，还要导入spring-data-redis：

   <dependency>
               <groupId>org.springframework.data</groupId>
               <artifactId>spring-data-redis</artifactId>
               <version>1.7.2.RELEASE</version>
           </dependency>

   
   
   
   
   
   
2. 创建一个redisCluster.properties:

   #redis setting
   redis.host1=192.168.240.142
   redis.port1=6379
   
   #jedis setting
   jedis.maxIdle=6
   jedis.minEvictableIdleTimeMillis=300000
   jedis.numTestsPerEvictionRun=3
   jedis.timeBetweenEvictionRunsMillis=60000

   
   
   
   
   
   
3. 创建一个spring-redisCluster.xml:

   <?xml version="1.0" encoding="UTF-8"?>
   <beans xmlns="http://www.springframework.org/schema/beans"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
          xmlns:mvc="http://www.springframework.org/schema/mvc"
          xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
           http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"
          default-lazy-init="true">
   
       <context:component-scan base-package="com.spring.demo.redis" />
   
       <!-- 引入redis配置文件 -->
       <context:property-placeholder location="classpath:redisCluster.properties" />
   
       <!-- 连接池配置 -->
       <bean id="jedisPoolConfig">
           <!-- 连接池中最大空闲的连接数 -->
           <property name="maxIdle" value="${jedis.maxIdle}"></property>
           <!-- 连接空闲的最小时间，达到此值后空闲连接将可能会被移除。负值(-1)表示不移除. -->
           <property name="minEvictableIdleTimeMillis" value="${jedis.minEvictableIdleTimeMillis}"></property>
           <!-- 对于“空闲链接”检测线程而言，每次检测的链接资源的个数。默认为3 -->
           <property name="numTestsPerEvictionRun" value="${jedis.numTestsPerEvictionRun}"></property>
           <!-- “空闲链接”检测线程，检测的周期，毫秒数。如果为负值，表示不运行“检测线程”。默认为-1. -->
           <property name="timeBetweenEvictionRunsMillis" value="${jedis.timeBetweenEvictionRunsMillis}"></property>
       </bean>
   
       <!-- 集群配置 -->
       <bean id="jedisCluster">
           <constructor-arg>
               <set>
                   <bean>
                   <constructor-arg name="host" value="${redis.host1}"/>
                   <constructor-arg name="port" value="${redis.port1}"/>
               </bean>
               </set>
           </constructor-arg>
           <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>
       </bean>
   </beans>

   
   
   
   
4. 新建一个 RedisClusterUtils.class用来存放一些统一的redis集群操作：

   package com.spring.demo.redis;
   
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.stereotype.Component;
   import redis.clients.jedis.JedisCluster;
   
   import java.util.List;
   
   @Component
   public class RedisClusterUtils {
   
       @Autowired
       private JedisCluster jedisCluster;
   
       /**
        * 得到指定key值的value
        * @param key
        */
       public Object get(String key){
           return jedisCluster.get(key);
       }
   
       /**
        * 保存指定key值的value
        * @param key
        * @param value
        */
       public void set(String key, String value){
           jedisCluster.set(key, value);
       }
   
       /**
        * 保存指定key值的value
        * @param key
        * @param list
        */
       public void set(String key, List<String> list){
           jedisCluster.rpush(key, (String[]) list.toArray());
       }
   
       /**
        * 删除指定key的value
        * @param key
        */
       public void del(String key){
           jedisCluster.del(key);
       }
   }
   

   
   
   
   
5. 代码运行验证：

           //spring集成redis集群
           ApplicationContext ctx = new ClassPathXmlApplicationContext("/spring-redisCluster.xml");
           RedisClusterUtils redisClusterUtils = (RedisClusterUtils) ctx.getBean("redisClusterUtils");
           redisClusterUtils.set("redisCluster", "RedisClusterUtils");
           System.out.println(redisClusterUtils.get("redisCluster"));

   
   
   
   
   
   
6. 客户端命令行连接集群验证，这次我们选择143进行验证
   

五、资料地址：

环境

single master 模式

• 三台机作ip与主机名的映射关系

vim /etc/hosts   -- 加入以下内容
192.168.144.10 apenglinux-001.cn
192.168.144.20 apenglinux-002.cn
192.168.144.30 apenglinux-003.cn

• 单主master主机为apenglinux-001.cn

  vim /etc/my.cnf      -- 加入以下内容
  server_id=100
  gtid_mode=on
  enforce_gtid_consistency=on
  transaction_write_set_extraction=XXHASH64
  log_bin=apenglinux
  binlog_checksum=none
  binlog_format=row
  log_slave_updates=on
  master_info_repository=table
  relay_log_info_repository=table
  loose_group_replication_group_name=‘70546c9a-5a52-46a4-84ee-141ca4359966‘
  loose_group_replication_local_address=‘apenglinux-001.cn:10001‘
  loose_group_replication_start_on_boot=off
  loose_group_replication_group_seeds=‘apenglinux-001.cn:10001,apenglinux-002.cn:10002,apenglinux-003.cn:10003‘
  loose_group_replication_group_bootstrap_group=off

• 重启MysqLd
• 连接MysqL，到(apenglinux-001.cn)MysqL里的操作如下

MysqL> set sql_log_bin=off;
MysqL> grant replication slave on *.* to [email protected]‘192.168.144.%‘ identified by ‘123456‘;
MysqL> flush privileges;
MysqL> set sql_log_bin=on;
MysqL> change master to master_user=‘repl‘,master_password=‘123456‘ for channel ‘group_replication_recovery‘;
MysqL> install plugin group_replication soname ‘group_replication.so‘;
MysqL> set global group_replication_bootstrap_group=on;
MysqL> start group_replication;
MysqL> set global group_replication_bootstrap_group=off;
MysqL> select * from performance_schema.replication_group_members;     -- 以下是查询到的内容
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST       | MEMBER_PORT | MEMBER_STATE |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| group_replication_applier | 8ea873c2-8f71-11e9-bbb4-000c298347f1 | apenglinux-001.cn |        3306 | ONLINE       |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+

• 从服务器(apenglinux-002.cn)的配置

  vim /etc/my.cnf    --  跟 apenglinux-001.cn一样的配置，只需要修改以下两行
  server_id=101
  loose_group_replication_local_address=‘apenglinux-002.cn:10002‘
  重启MysqLd
  连接msyql，到MysqL里的操作如下
  MysqL> set sql_log_bin=off;
  MysqL> grant replication slave on *.* to [email protected]‘192.168.144.%‘ identified by ‘123456‘;
  MysqL> flush privileges;
  MysqL> set sql_log_bin=on;
  MysqL> change master to master_user=‘repl‘,master_password=‘123456‘ for channel ‘group_replication_recovery‘;
  MysqL>  install plugin group_replication soname ‘group_replication.so‘;
  MysqL> set global group_replication_allow_local_disjoint_gtids_join=on;
  MysqL> start group_replication;
  MysqL> select * from performance_schema.replication_group_members;
  +---------------------------+--------------------------------------+-------------------+-------------+--------------+
  | CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST       | MEMBER_PORT | MEMBER_STATE |
  +---------------------------+--------------------------------------+-------------------+-------------+--------------+
  | group_replication_applier | 8ea873c2-8f71-11e9-bbb4-000c298347f1 | apenglinux-001.cn |        3306 | ONLINE       |
  | group_replication_applier | a049b503-8f72-11e9-ba4b-000c2906c8f7 | apenglinux-002.cn |        3306 | ONLINE       |
  +---------------------------+--------------------------------------+-------------------+-------------+--------------+

• 从服务器apenglinux-003.cn的配置(与apenglinux-002.cn一样的配置)，下面是要修改的

vim /etc/my.cnf
server_id=102
loose_group_replication_local_address=‘apenglinux-003.cn:10003‘

MysqL> select * from performance_schema.replication_group_members;
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST       | MEMBER_PORT | MEMBER_STATE |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| group_replication_applier | 8ea873c2-8f71-11e9-bbb4-000c298347f1 | apenglinux-001.cn |        3306 | ONLINE       |
| group_replication_applier | a049b503-8f72-11e9-ba4b-000c2906c8f7 | apenglinux-002.cn |        3306 | ONLINE       |
| group_replication_applier | d9fd5ea2-8f73-11e9-8f3b-000c29096feb | apenglinux-003.cn |        3306 | ONLINE       |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+

• 查看单主模式的主节点(所有的节点都可以查看)

  MysqL> show global status like ‘%primary%‘;
  +----------------------------------+--------------------------------------+
  | Variable_name                    | Value                                |
  +----------------------------------+--------------------------------------+
  | group_replication_primary_member | 8ea873c2-8f71-11e9-bbb4-000c298347f1 |
  +----------------------------------+--------------------------------------+

MGR的多主模式

在 apenglinux-001.cn主机上的设置：
停止MGR，关掉单主模式，开启多主模式，开启引导组，开启mgr，关闭引导组

MysqL> stop group_replication;
MysqL> set global group_replication_single_primary_mode=off;
MysqL> set global group_replication_enforce_update_everywhere_checks=on;
MysqL> set global group_replication_bootstrap_group=on;
MysqL> start group_replication;
MysqL> set global group_replication_bootstrap_group=off;

在apenglinux-002.cn,apenglinux-003.cn上的设置：
停止mgr，允许写入，加入组，关掉单主模式，开启多主模式，开启mgr

MysqL> stop group_replication;
MysqL> set global read_only=off,super_read_only=off;
MysqL> set global group_replication_allow_local_disjoint_gtids_join=on;
MysqL> set global group_replication_single_primary_mode=off;
MysqL> set global group_replication_enforce_update_everywhere_checks=on;
MysqL> start group_replication;

查看成员信息

MysqL> select * from performance_schema.replication_group_members;
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST       | MEMBER_PORT | MEMBER_STATE |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+
| group_replication_applier | 8ea873c2-8f71-11e9-bbb4-000c298347f1 | apenglinux-001.cn |        3306 | ONLINE       |
| group_replication_applier | a049b503-8f72-11e9-ba4b-000c2906c8f7 | apenglinux-002.cn |        3306 | ONLINE       |
| group_replication_applier | d9fd5ea2-8f73-11e9-8f3b-000c29096feb | apenglinux-003.cn |        3306 | ONLINE       |
+---------------------------+--------------------------------------+-------------------+-------------+--------------+