Spring该如何整合Redis集群

前言：在上一文中，我讲到了---如何搭建redis集群---让集群拥有分片的数据内存的扩容和哨兵的高可用。今天给你们讲解一下Spring如何整合Redis集群

---

在这里首先给你们说一说分片和哨兵的特色：

• 1.分片的主要的做用 实现内存数据的扩容
• 2.哨兵主要的做用,能够实现redis的高可用.
• 3.若是redis分片中有一个redis节点宕机,则整个redis分片将不能正常运行.
• 4.Redis哨兵虽然能够实现Redis的高可用,可是哨兵自己没办法实现高可用,程序调用存在风险.

而集群确包含了分片和哨兵的二者的优势，既实现了内存数据的扩容，也实现了redis的高可用，并且集群确保了一个或必定数量的redis宕机，也可以让程序正常的运行，这也是为何咱们运用的集群，而不是分片或哨兵。
           --------废话有点多啊，下面进入今天的主题

---

1.Spring整合Redis集群

1.1在linux系统上开启redis集群 --- sh start.sh

以后ps -ef |grep redis 检测全部的redis服务器是否开启

1.2添加redis依赖(如若以前添加了，跳过此)

<!--spring整合redis -->
		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
		</dependency>

1.3redis集群测试实例

@Test
        public void testCluster() {
            Set<HostAndPort> nodes = new HashSet<HostAndPort>();
            nodes.add(new HostAndPort("192.168.126.166",7000));
            nodes.add(new HostAndPort("192.168.126.166",7001));
            nodes.add(new HostAndPort("192.168.126.166",7002));
            nodes.add(new HostAndPort("192.168.126.166",7003));
            nodes.add(new HostAndPort("192.168.126.166",7004));
            nodes.add(new HostAndPort("192.168.126.166",7005));
            JedisCluster jedisCluster = new JedisCluster(nodes);
            jedisCluster.set("redisCluster","集群测试");
            System.out.println(jedisCluster.get("redisCluster"));
        }

测试结果以下：

测试成功！！！

1.4编辑redis.properties文件

#标识IP地址和端口号信息 IP:PORT
redis.node=192.168.126.166:6379
redis.nodes=192.168.126.166:6379,192.168.126.166:6380,192.168.126.166:6381
redis.sentinel=192.168.126.166:26379
redis.cluster=192.168.126.166:7000,192.168.126.166:7001,192.168.126.166:7002,192.168.126.166:7003,192.168.126.166:7004,192.168.126.166:7005

1.5编辑redis配置类

//标识配置类
@Configuration
@PropertySource("classpath:/properties/redis.properties")
public class JedisConfig {
	
	//集群
	@Value("${redis.cluster}")
	private String nodes;
	@Bean
	public JedisCluster jedisCluster() {
		Set<HostAndPort> nodeSet = new HashSet<HostAndPort>();
		String[] nodeArray = nodes.split(",");
		for(String node : nodeArray) {//node=host:port
		    String host = node.split(":")[0];
		    int port = Integer.parseInt(node.split(":")[1]);
		    HostAndPort hostAndPort = new HostAndPort(host,port);
		    nodeSet.add(hostAndPort);
		
		}
		return new JedisCluster(nodeSet);
	}
	
	
}

1.6修改RedisAOP配置

最后进行测试，测试成功，那就Spring整合Redis集群成功！！！

3月25日改：
有朋友发私信问我该如何去测试，其实这个很简单。
你能够先查询那几台服务器中哪些是主机，而后宕掉其中的一台redis-cli -p 7000 shutdown，再十秒以后再去访问页面(在此以前你能够去看看7000主机的从机，如今是不是主机的了--redis-cli -p 7003>>>再输入info replication)，

若是可以正常的访问，说明
你整合Redis集群成功了，能够正常运行！！

如若你还有什么问题评论私信皆可！！！