注：加载lua文件
在com.example.repo.impl下增加PersonRepoImpl，主要包括属性private RedisTemplate redisTemplate(该属性存在setterXXX方法，对应property属性);
利用redisTemplate.opsForHash().put()即可完成对Redis Cluster的操作。
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new ClassPathResource("resources/spring-config.xml").getPath());
Repo repo =(Repo)context.getBean("personRepo");(2)采用RedisClusterConfiguration(PropertySource propertySource)方式构造RedisClusterConfiguration
代码目录结构如下所示：
src
com.redis.cluster.support.config
MonitorConfig
resources
spring-config.xml
redis.properties
A.在resources目录下增加spring-config.xml配置，配置如下：
B.添加redis.properties文件
spring.redis.cluster.nodes=10.48.193.201:7389,10.48.193.201:7388
spring.redis.cluster.timeout=2000
spring.redis.cluster.max-redirects=8
C.编写初始化JedisConnectionFactory连接工厂的java类
@Configuration
public class MonitorConfig {
@Value("${spring.redis.cluster.nodes}")
private String clusterNodes;
@Value("${spring.redis.cluster.timeout}")
private Long timeout;
@Value("${spring.redis.cluster.max-redirects}")
private int redirects;
@Bean
public RedisClusterConfiguration getClusterConfiguration() {
Map source = new HashMap();
source.put("spring.redis.cluster.nodes", clusterNodes);
source.put("spring.redis.cluster.timeout", timeout);
source.put("spring.redis.cluster.max-redirects", redirects);
return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source));
}
@Bean
public JedisConnectionFactory getConnectionFactory() {
return new JedisConnectionFactory(getClusterConfiguration());
}
@Bean
public JedisClusterConnection getJedisClusterConnection() {
return (JedisClusterConnection) getConnectionFactory().getConnection();
}
@Bean
public RedisTemplate getRedisTemplate() {
RedisTemplate clusterTemplate = new RedisTemplate();
clusterTemplate.setConnectionFactory(getConnectionFactory());
clusterTemplate.setKeySerializer(new DefaultKeySerializer());
clusterTemplate.setDefaultSerializer(new GenericJackson2JsonRedisSerializer());
return clusterTemplate;
}
}D.通过注解方式使用JedisClusterConnection和RedisTemplate
@Autowired
JedisClusterConnection clusterConnection;
@Autowired
RedisTemplate redisTemplate;
三、简单集成Spring
自己编写jedisCluster的工厂类JedisClusterFactory,然后通过Spring注入的方式获取jedisCluster,实现客户端使用Redis3.0版本的集群特性。
请参考：https://www.jb51.net/article/128895.htm
使用时,直接通过注解或者XML注入即可，如下所示：
@Autowired
JedisCluster jedisCluster;
或者
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new ClassPathResource("resources/spring-config.xml").getPath());
TestRedis testRedis=(TestRedis)context.getBean("testRedis");四、Redis Cluster调试中常见错误
(1)当客户端与集群服务器不在同一台服务器上时，有如下错误Could not get a resource from the Cluster
一般当客户端与集群服务器在同一台服务器上时，操作Redis Cluster正常； 当二者不在同一台服务器上时报如上错误，可能是clusterTimeOut时间设置过小；
(2)操作Redis时报Too many cluster redirections
初始化JedisCluster时，设定JedisCluster的maxRedirections.
JedisCluster(Set jedisClusterNode, int timeout, int maxRedirections) ;
JedisCluster jc = new JedisCluster(jedisClusterNodes,5000,1000);
(3)Redis Cluster数据写入慢
检查在通过./redis-trib命令建立集群时,如果是通过127.0.0.1的方式建立的集群，那么在往Redis Cluster中写入数据时写入速度比较慢。可以通过配置真实的IP来规避此问题。
看完了这篇文章，相信你对“Spring-data-redis如何操作redis cluster”有了一定的了解，如果想了解更多相关知识，欢迎关注创新互联行业资讯频道，感谢各位的阅读！
标题名称：Spring-data-redis如何操作rediscluster
转载来源：http://cxhlcq.com/article/iggcoo.html
重庆分公司
重庆分公司
