前言：在上一文中，我讲到了---如何搭建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依赖(如若之前添加了，跳过此)
1 <!--spring整合redis --> 2 <dependency> 3 <groupId>redis.clients</groupId> 4 <artifactId>jedis</artifactId> 5 </dependency> 6 <dependency> 7 <groupId>org.springframework.data</groupId> 8 <artifactId>spring-data-redis</artifactId> 9 </dependency>
1.3redis集群测试实例
1 @Test 2 public void testCluster() { 3 Set<HostAndPort> nodes = new HashSet<HostAndPort>(); 4 nodes.add(new HostAndPort("192.168.126.166",7000)); 5 nodes.add(new HostAndPort("192.168.126.166",7001)); 6 nodes.add(new HostAndPort("192.168.126.166",7002)); 7 nodes.add(new HostAndPort("192.168.126.166",7003)); 8 nodes.add(new HostAndPort("192.168.126.166",7004)); 9 nodes.add(new HostAndPort("192.168.126.166",7005)); 10 JedisCluster jedisCluster = new JedisCluster(nodes); 11 jedisCluster.set("redisCluster","集群测试"); 12 System.out.println(jedisCluster.get("redisCluster")); 13 }
测试结果如下：
测试成功！！！
1.4编辑redis.properties文件
1#标识IP地址和端口号信息 IP:PORT 2redis.node=192.168.126.166:6379 3redis.nodes=192.168.126.166:6379,192.168.126.166:6380,192.168.126.166:6381 4redis.sentinel=192.168.126.166:26379 5redis.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配置类
1//标识配置类 2@Configuration 3@PropertySource("classpath:/properties/redis.properties") 4public class JedisConfig { 5 6 //集群 7 @Value("${redis.cluster}") 8 private String nodes; 9 @Bean 10 public JedisCluster jedisCluster() { 11 Set<HostAndPort> nodeSet = new HashSet<HostAndPort>(); 12 String[] nodeArray = nodes.split(","); 13 for(String node : nodeArray) {//node=host:port 14 String host = node.split(":")[0]; 15 int port = Integer.parseInt(node.split(":")[1]); 16 HostAndPort hostAndPort = new HostAndPort(host,port); 17 nodeSet.add(hostAndPort); 18 19 } 20 return new JedisCluster(nodeSet); 21 } 22 23 24}
1.6修改RedisAOP配置
最后进行测试，测试成功，那就Spring整合Redis集群成功！！！
3月25日改：
有朋友发私信问我该如何去测试，其实这个很简单。
你可以先查询那几台服务器中哪些是主机，然后宕掉其中的一台redis-cli -p 7000 shutdown，再十秒之后再去访问页面(在此之前你可以去看看7000主机的从机，现在是否是主机的了--redis-cli -p 7003>>>再输入info replication)，
如果能够正常的访问，说明
你整合Redis集群成功了，可以正常运行！！
如若你还有什么问题评论私信皆可！！！