springboot整合jedisCluster[通俗易懂]
JedisCluster jedis客户端提供的一个操作集群的连接对象; 底层封装了单个节点电连接对象, 封装了连接池的对外使用的集群对象;
测试连接代码 •收集节点信息(redis-cluster可以只提供若干个节点)
@Test
public void test(){
//收集若干个节点信息
Set<HostAndPort> set=new HashSet<HostAndPort>();
set.add(new HostAndPort("10.9.39.13", 8000));
set.add(new HostAndPort("10.9.39.13", 8001));
//jedisCluster对象的构造需要连接池的配置对象
JedisPoolConfig config=new JedisPoolConfig();
config.setMaxTotal(200);
config.setMaxIdle(8);
config.setMinIdle(2);
JedisCluster cluster
=new JedisCluster(set, config);
//调用方法,发送redis命令到集群执行;
//name对应的slot是5798
cluster.set("name", "王翠花");
System.out.println(cluster.get("gender"));}• 框架使用jedisCluster ○ 配置集群的连接信息
#redis集群的配置
spring.redis.cluster.nodes=10.9.39.13:8000,10.9.39.13:8001,10.9.39.13:8002
spring.redis.cluster.maxTotal=200
spring.redis.cluster.maxIdle=8
spring.redis.cluster.minIdle=2○ 配置类初始化构造一个JedisCluster对象
package com.jt.easymall.config;
import java.util.HashSet;
import java.util.Set;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 每个configuration的代码,都对应xml一部分配置
* @author admin
*/
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedisPool;
@Configuration
@ConfigurationProperties(prefix="spring.redis.cluster")
public class RedisClusterConfig {
private String nodes;
private Integer maxTotal;
private Integer maxIdle;
private Integer minIdle;
public String getNodes() {
return nodes;
}
public void setNodes(String nodes) {
this.nodes = nodes;
}
public Integer getMaxTotal() {
return maxTotal;
}
public void setMaxTotal(Integer maxTotal) {
this.maxTotal = maxTotal;
}
public Integer getMaxIdle() {
return maxIdle;
}
public void setMaxIdle(Integer maxIdle) {
this.maxIdle = maxIdle;
}
public Integer getMinIdle() {
return minIdle;
}
public void setMinIdle(Integer minIdle) {
this.minIdle = minIdle;
}
@Bean//初始化方法构造一个jedisCluster对象
public JedisCluster init(){
try{
Set<HostAndPort> set=new HashSet<HostAndPort>();
//"10.9.39.13:8000,10.9.39.13:8001"
String[] node = nodes.split(",");
for (String hostAndPort : node) {
//"10.9.39.13:8000",解析ip和port
String host=hostAndPort.split(":")[0];
int port=Integer.parseInt
(hostAndPort.split(":")[1]);
set.add(new HostAndPort(host,port));
}
//利用其它属性,编写config对象
JedisPoolConfig config=new JedisPoolConfig();
config.setMaxTotal(maxTotal);
config.setMaxIdle(maxIdle);
config.setMinIdle(minIdle);
return new JedisCluster(set,config);
}catch(Exception e){
//说明构造过程出现了一些问题,一般是因为没有提供
//redis相关配置
return null;}}}○ 二次封装 ○ 注入对象使用
测试jediscluster的高可用代码能力 编写一个简单的访问redis-cluster集群的功能; 一个访问,直接调用set/get方法
@Autowired
private JedisCluster cluster;
@RequestMapping("cluster")
public String setAndGet(String key){
cluster.set(key, "测试数据");
return cluster.get(key);}版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/181943.html原文链接：https://javaforall.cn
原文地址：https://cloud.tencent.com/developer/article/2151963
你可能想看：