本文主要是介绍SpringBoot连接Redis集群教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
《SpringBoot连接Redis集群教程》:本文主要介绍SpringBoot连接Redis集群教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教...
1. 依赖
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
2. 修改配置文件
server.port=100 #redis集群节点信息 spring.redis.cluster.nodes=192.168.25.132:6379,192.168.25.132:6380,192.168.25.133:6379,192.168.25.133:js6380,192.168.25.134:6379,192.168.25.134:6380 #redis连接密码(默认空) spring.redis.passwowww.chinasem.cnrd= #redis连接池最大连接数(使用负值表示没有限制) spring.redis.jedis.pool.max-active=20 #redis连接池最大阻塞等待时间(使用负值表示没有限制) spring.redis.jedis.pool.max-wait=-1 #redis连接池最大空闲连接 spring.redis.jedis.pool.max-idle=200 #redis连接池最小空闲连接 spring.redis.jedis.pool.min-idle=20 #redis连接超时时间(毫秒) spring.redis.timeout=10000
3. 创android建RedisClusterConfig
@Configuration public class RedisClusterConfig { @Value("${spring.redis.cluster.nodes}") private String clusterNodes; @Value("${spring.redis.database}") private int database; @Value("${spring.redis.timeout}") private int timeout; @Value("${spring.redis.jedis.pool.max-idle}") private int maxIdle; @Value("${spring.redis.jedis.pool.min-idle}") private int minIdle; @Value("${spring.redis.jedis.pool.max-active}") private int maxActive; @Value("${spring.redis.jedis.pool.max-wait}") private long maxWait; @Bean public JedisCluster getJedisCluster() { return new JedisCluster(getNodes(), timeout, poolConfig()); } private JedisPoolConfig poolConfig() { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(maxIdle); config.setMinIdle(minIdle); config.setMaxTotal(maxActive); config.setMaxWaitMillis(maxWait); return config; } private Set<HostAndPort> getNodes() { String[] cNodes = clusterNodes.split(","); Set<HostAndPort> nodes = new HashSet<HostAndPort>(); // 分割出集群节点 String[] hp; for (String node : cNodes) { hp = node.split(":"); nodes.add(new HostAndPort(hp[0], Integer.parseInt(hp[1]))); } return nodes; } }
4. 测试
@RestController @RequestMapping("/redis/cluster") public class RedisClusterController { @Autowired private JedisCluster jedisCluste编程r; @GetMapping("/set") public void set(@RequestParam("key") String key, @RequestParam("value") String value){ jedisCluster.set(key, value); } }
这边就不python演示了,分别访问以下2个地址,能得到结果说明正常:
http://localhost:100/redis/cluster/set?key=name&value=zhangsan
http://localhost:100/redis/cluster/get?key=name
总结
这篇关于SpringBoot连接Redis集群教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!