zoukankan      html  css  js  c++  java
  • JedisCluster和springboot整合

    maven依赖

    springboot整合jedisCluster相当简单,maven依赖如下:

    <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-redis</artifactId>
      </dependency>

    加了这一个依赖之后就不要再加上jedis的这一个依赖了:

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

    加这个可能在本身测试的时候,可能会导致jedisCluster对象正常,但是在测试的时候会发现set数据的时候会出现问题,我把jedis的依赖去掉之后,这个问题解决,因此不要加上jedis的这一个依赖,spring-boot-starter-redis这一个引入相关jedis需要的包。

    application.properties配置

    这里的配置相当简单,只需要天上redis的相关地址就行了,如下:

    #redis cluster
    spring.redis.cache.clusterNodes=192.168.xx.xx:6379,192.168.xx.:6380,192.168.xx.xx:6381
    spring.redis.cache.commandTimeout=5000

    相当简单只需要几个redis的地址和端口的字符串就可以了。

    redisProperties

    在这里取springboot中的配置办法相当多,可以使用如下方法:

    @Inject
     private Environment environment;
     String properties = environment.getproperties("xxx")

    或者是在加上注解,@Value(“”)会在配置文件中取相关名字的配置。

    但在本文中决定使用另外一种方法,定义一个类命名问RedisProperties,在里面定义的字段与配置文件中相对应,即可取到配置,如下:

    @Component
    @ConfigurationProperties(prefix = "spring.redis.cache")
    @Data
    public class RedisProperties {
    
        private String clusterNodes;
        private Integer   commandTimeout;
    }

    如上,在使用时就能正常取到相关配置。

    JedisClusterConfig

     /**
        * 获取JedisCluster的配置
     */
    @Configuration
    @ConditionalOnClass({JedisCluster.class})
    @EnableConfigurationProperties(RedisProperties.class)
    public class JedisClusterConfig {
    
        @Inject
        private RedisProperties redisProperties;
    
        @Bean
        @Singleton
        public JedisCluster getJedisCluster() {
            String[] serverArray = redisProperties.getClusterNodes().split(",");
            Set<HostAndPort> nodes = new HashSet<>();
            for (String ipPort: serverArray) {
                String[] ipPortPair = ipPort.split(":");
                nodes.add(new HostAndPort(ipPortPair[0].trim(),Integer.valueOf(ipPortPair[1].trim())));
            }
            return new JedisCluster(nodes, redisProperties.getCommandTimeout());
        }

    如上,配置就完成,现在进行测试一次。

    测试

    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringApplicationConfiguration(classes = SpringBootWebApplication.class)
    @WebAppConfiguration
    public class TestJedisCluster {
    
        @Inject
        private JedisCluster jedisCluster;
    
        @Test
        public void testJedis() {
            jedisCluster.set("test_jedis_cluster", "38967");
            Assert.assertEquals("38967", jedisCluster.get("test_jedis_cluster"));
            jedisCluster.del("test_jedis_cluster");
        }
    }
  • 相关阅读:
    求s=a+aa+aaa+aaaa+aa...a的值,其中a是一个数字。
    getchar函数
    计算机网络04-ip与子网划分
    计算机网络03-传输层、可靠数据传输、UDP与TCP
    计算机网络02-应用层(http、email、dns)
    游戏-图形学学习路线
    markDown 入门
    webpack 入门级 傻瓜式教学
    npm 切换 cnpm 切换淘宝镜像源
    vue 父组件在接收子组件的同时传递一个当前的数据
  • 原文地址:https://www.cnblogs.com/alter888/p/8878892.html
Copyright © 2011-2022 走看看