Spring + JedisCluster操作Redis（集群）

1.maven依赖：

<dependency>  <groupId>redis.clients</groupId>  <artifactId>jedis</artifactId>  <version>2.7.3</version>
</dependency>

2.增加spring 配置

<!-- ==========================JedisCluster配置=========================== -->
<bean name="genericObjectPoolConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig">  <property name="maxWaitMillis" value="-1"></property>  <property name="maxTotal" value="1000"></property>  <property name="minIdle" value="8"></property>  <property name="maxIdle" value="100"></property>
</bean>
<bean id="jedisCluster" class="com.atguigu.crud.util.JedisClusterFactory">  <property name="addressConfig">  <value>classpath:redis-nodes.properties</value>  </property>  <!-- 属性文件里 key的前缀 -->  <property name="addressKeyPrefix" value="address" />  <property name="timeout" value="300000" />  <property name="maxRedirections" value="6" />  <property name="genericObjectPoolConfig" ref="genericObjectPoolConfig" />
</bean>

3.增加connect-redis.properties 配置文件

这里配置了6个节点

address1=192.168.221.128:7000
address2=192.168.221.128:7001
address3=192.168.221.128:7002
address4=192.168.221.129:7003
address5=192.168.221.129:7004
address6=192.168.221.129:7005

4.增加java类

import java.util.HashSet;
import java.util.Properties;
import java.util.Set;
import java.util.regex.Pattern;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.core.io.Resource;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;  public class JedisClusterFactory implements FactoryBean<JedisCluster>, InitializingBean {  private Resource addressConfig;  private String addressKeyPrefix ;  private JedisCluster jedisCluster;  private Integer timeout;  private Integer maxRedirections;  private GenericObjectPoolConfig genericObjectPoolConfig;  private Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");  @Override  public JedisCluster getObject() throws Exception {  return jedisCluster;  }  @Override  public Class<? extends JedisCluster> getObjectType() {  return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);  }  @Override  public boolean isSingleton() {  return true;  }  private Set<HostAndPort> parseHostAndPort() throws Exception {  try {  Properties prop = new Properties();  prop.load(this.addressConfig.getInputStream());  Set<HostAndPort> haps = new HashSet<HostAndPort>();  for (Object key : prop.keySet()) {  if (!((String) key).startsWith(addressKeyPrefix)) {  continue;  }  String val = (String) prop.get(key);  Boolean isIpPort = p.matcher(val).matches();  if (!isIpPort) {  throw new IllegalArgumentException("ip 或 port 不合法");  }  String[] ipAndPort = val.split(":");  HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));  haps.add(hap);  }  return haps;  }  catch (IllegalArgumentException ex) {  throw ex;  }  catch (Exception ex) {  throw new Exception("解析 jedis 配置文件失败", ex);  }  }  @Override  public void afterPropertiesSet() throws Exception {  Set<HostAndPort> haps = this.parseHostAndPort();  jedisCluster = new JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);  }  public void setAddressConfig(Resource addressConfig) {  this.addressConfig = addressConfig;  }  public void setTimeout(int timeout) {  this.timeout = timeout;  }  public void setMaxRedirections(int maxRedirections) {  this.maxRedirections = maxRedirections;  }  public void setAddressKeyPrefix(String addressKeyPrefix) {  this.addressKeyPrefix = addressKeyPrefix;  }  public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {  this.genericObjectPoolConfig = genericObjectPoolConfig;  }
}

5.到此配置完成

使用时，直接注入即可，如下所示：

@Autowired
JedisCluster jedisCluster;

Spring + JedisCluster操作Redis（集群）相关推荐

[由零开始]Spring boot 整合redis集群
Spring boot 整合redis集群一.环境搭建 Redis集群环境搭建:https://blog.csdn.net/qq497811258/article/details/108124697 ...
python操作redis集群_python 连接管理作redis集群
python的redis库是不支持集群操作的,推荐库:redis-py-cluster. 安装 pip3 install redis-py-cluster 连接redis集群 #!/usr/bin/e ...
python 操作redis集群
python 操作redis集群一.连接redis集群 python的redis库是不支持集群操作的,推荐库:redis-py-cluster,一直在维护.还有一个rediscluster库,看Gi ...
代码操作redis集群报错：(error) MOVED 解决方法
记录一下今天搭建完本地redis集群以后,使用C++代码测试redis集群搭建是否成功. 在初始化.链接等一系列成功后,我开开心心进行写操作: 这时候报错: Run 382 Redis Set Err ...
使用predis操作redis集群
先搭建好redis集群,我的搭建好了,给你们看下我的是3主3从. 接下来我们用predis来测试集群.predis是php生态里面的一个composer包 <?phprequire __DIR ...
python操作redis集群_python操作redis集群
strictRedis对象方法用于连接redis 指定主机地址,port与服务器连接,默认db是0,redis默认数据库有16个,在配置文件中指定database 16 上代码 1.对redis的单实 ...
Redis（四）：Spring + JedisCluster操作Redis（集群）
1.maven依赖: <dependency> <groupId>redis.clients</groupId> <artifactId>jedis&l ...
java redis集群操作,java操作redis3.0集群
java(JedisCluster)操作redis集群这里只是几个简单的demo,直接上代码吧,没啥好说的 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 ...
超完整！Springboot整合redis集群（Sentine），spring boot自动配置集成redis集群（Sentine）
1.添加maven依赖注意maven版本依赖,版本要相互匹配,如不知道如何查看相对应的版本时,可进入博主主页查看博主上一篇博文. <parent><groupId>org.s ...
玩转Redis集群(下)
接上一篇<玩转Redis集群(上)>,我们来继续玩~ Redis集群操作实践数据的分布性从上面的操作,你可以看到,当存储某一个数据的时候,会分配一个slot,而这个slot从属于某一个 ...

Spring + JedisCluster操作Redis（集群）

Spring + JedisCluster操作Redis（集群）相关推荐

最新文章

热门文章