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:6380,192.168.25.134:6379,192.168.25.134:6380 #redis连接密码(默认空) spring.redis.password= #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. 创建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 jediscluster; @getmapping("/set") public void set(@requestparam("key") string key, @requestparam("value") string value){ jediscluster.set(key, value); } }
这边就不演示了,分别访问以下2个地址,能得到结果说明正常:
http://localhost:100/redis/cluster/set?key=name&value=zhangsan
http://localhost:100/redis/cluster/get?key=name
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论