本文所有流程都是经过实际操作跑通,主要如下图。
Redis 离线安装
1) 官网下载指定版本的redis 安装包
wget https://download.redis.io/releases/redis-6.2.1.tar.gz
2) 解压
tar -zxvf redis-6.2.1.tar.gz
3) 编译 (操作加sudo ,避免权限不够一些文件创建不了)
cd redis-6.2.1sudo make && sudo make install
集群配置修改
redis.conf 主要几个配置需要修改 (不同节点,根据情况修改相关配置,如port )
daemonize yesport 6370cluster-enabled yescluster-node-timeout 15000cluster-config-file nodes_6370.conf
本次实验一台机器部署6个节点, 三主三从,配置如下
主节点 | 从节点 | 槽 |
127.0.0.1:6370 | 127.0.0.1:6371 | {0..5461} |
127.0.0.1:6372 | 127.0.0.1:6373 | {5462..10922} |
127.0.0.1:6374 | 127.0.0.1:6375 | {10923..16383} |
运行6个redis 实例 此时这个6个节点还是各自为政。
redis-server /opt/redis_cluster/redis_6370/conf/redis.confredis-server /opt/redis_cluster/redis_6371/conf/redis.confredis-server /opt/redis_cluster/redis_6372/conf/redis.confredis-server /opt/redis_cluster/redis_6373/conf/redis.confredis-server /opt/redis_cluster/redis_6374/conf/redis.confredis-server /opt/redis_cluster/redis_6375/conf/redis.conf
加入集群
连接上任意一个redis 节点 redis-cli -p 6370
然后通过cluster meet 加入集群,此时再通过 cluster nodes 查看集群节点信息,
刚刚6个节点都已经在集群中了,但都是主节点,接下来需要配置从节点
从节点配置
命令如下 ,节点id 就是上面一张图 cluster nodes 结果第一列一长串字符串,按照前面表格配置,一次进入对应redis 节点,配置从节点。再看cluster nodes ,返回集群节点信息,已经是三个master ,三个slave 。
cluster replicate 节点id
槽分派
此时尝试执行set 命令报错,因为还需要给三个主节点配置 槽,配置成功后,集群可以正常工作了
测试一下集群
连接时加上 -c ,会自动自动重定向,都在不在当前节点槽范围内会报错。
Spring 集成
引入依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.7.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.9.6</version> </dependency>
配置类
@Configurationpublic class RedisConfig { @Bean public JedisConnectionFactory connectionFactory() { RedisClusterConfiguration clusterConfig = new RedisClusterConfiguration(Arrays.asList("ip:6370","ip:6371", "ip:6372","ip:6373" ,"ip:6374","ip:6375")); clusterConfig.setMaxRedirects(3); return new JedisConnectionFactory(clusterConfig); } //编写我们自己的redisTemplate @Bean("redisTemplate") public RedisTemplate<String, String> redisTemplate() { RedisTemplate<String, String> template = new RedisTemplate<>(); template.setConnectionFactory(connectionFactory()); template.setKeySerializer(StringRedisSerializer.UTF_8); //hash的key也采用string的序列化方式 template.setValueSerializer(new Jackson2JsonRedisSerializer<>(String.class)); template.setHashKeySerializer(new Jackson2JsonRedisSerializer<>(String.class)); template.setValueSerializer(new Jackson2JsonRedisSerializer<>(String.class)); template.afterPropertiesSet(); return template; } }
测试一下
@SpringBootApplicationpublic class RedisApplication { public static void main(String[] args) { ConfigurableApplicationContext context = SpringApplication.run(RedisApplication.class, args); RedisTemplate redisTemplate = context.getBean("redisTemplate",RedisTemplate.class); ValueOperations valueOperations = redisTemplate.opsForValue(); valueOperations.set("test01","value01"); System.out.println(valueOperations.get("test01")); }}
常见问题
集群连接不上常见的排查解决方案
1) redis.conf bind ip修改
bind 127.0.0.1 ::1 改为 bind 0.0.0.0 ::1 (实际可以设置为固定外网ip)
2)关闭防火墙
3)redis.conf 中 protected-mode yes 改为 protected-mode no
4) 如果单个节点客户端工具可以连上,但是Spring 连接报错
Cluster retry deadline exceeded.; nested exception is redis.clients.jedis.exceptions.JedisClusterOperationException: Cluster retry deadline exceeded
需要检查集群的nodes.conf
将里面127.0.0.1 改为外网ip