springboot Redis集群使用

向右看齐 2023-05-31 07:45 13阅读 0赞

1.新建一个完整能启动的springboot项目，不细说。

2.pom.xml  添加依赖

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

3.application.properties 文件中配置

jedis.nodes=172.28.1.127:7000,172.28.1.127:7001,172.28.1.127:7002

4.新建 RedisClusterConfig.java

package jesper.search.redisconfig;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.util.Assert;
    import org.springframework.util.StringUtils;
    import redis.clients.jedis.HostAndPort;
    import redis.clients.jedis.JedisCluster;
    import redis.clients.jedis.JedisPoolConfig;
    
    import javax.annotation.Resource;
    import java.util.Arrays;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Set;
    
    /* ItcljApplication
     spring-boot工程启动文件，里面就是main方法，用于启动项目，项目启动过程中会自动扫描com.itclj包下的所有类
     ，扫描到RedisClusterConfig类的时候，由于public JedisCluster redisCluster()方法加了@Bean注解，
     spring会自动执行该方法实例化一个JedisCluster对象放入spring上下文，以后需要使用的时候在需要的类直接自动注入即可。
           */
    @Configuration
    public class RedisClusterConfig {
    
        @Resource
        private RedisClusterProperties jedisProperties;
    
        private static Thread shutdown = null;
        /**
         * jedis 连接池配置
         *
         * @return
         */
        public JedisPoolConfig jedisPoolConfig() {
            JedisPoolConfig config = new JedisPoolConfig();
            //最大连接数, 默认20个
            config.setMaxTotal(20);
            //最小空闲连接数, 默认0
            config.setMinIdle(0);
            //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted), 如果超时就抛异常, 小于零:阻塞不确定的时间, 默认 - 1
            config.setMaxWaitMillis(1000L);
            //最大空闲连接数, 默认20个
            config.setMaxIdle(5);
            //在获取连接的时候检查有效性, 默认false
            config.setTestOnBorrow(Boolean.TRUE);
            config.setTestOnReturn(Boolean.FALSE);
            //在空闲时检查有效性, 默认false
            config.setTestWhileIdle(Boolean.TRUE);
            //逐出连接的最小空闲时间 默认1800000毫秒(30分钟)
            config.setMinEvictableIdleTimeMillis(1800000);
            //每次逐出检查时 逐出的最大数目 如果为负数就是: idleObjects.size / abs(n), 默认3
            config.setNumTestsPerEvictionRun(3);
            //对象空闲多久后逐出, 当空闲时间 > 该值 且 空闲连接>最大空闲数 时直接逐出, 不再根据MinEvictableIdleTimeMillis判断 (默认逐出策略)
            config.setSoftMinEvictableIdleTimeMillis(1800000);
            //逐出扫描的时间间隔(毫秒) 如果为负数, 则不运行逐出线程, 默认 - 1
            config.setTimeBetweenEvictionRunsMillis(60000);
    
            config.setBlockWhenExhausted(true);
            return config;
        }
    
        /**
         * 集群配置
         * @return
         */
        @Bean
        public JedisCluster jedisCluster() {
            Set<HostAndPort> nodes = new HashSet<>();
            List<String> servers = jedisProperties.getNodes();
            servers.forEach(server -> {
                String[] hostport = server.split(":");
                nodes.add(new HostAndPort(hostport[0], Integer.valueOf(hostport[1])));
            });
    
            final JedisCluster cluster = new JedisCluster(nodes, jedisPoolConfig());
    
            if (shutdown == null) {
                shutdown = new Thread(new Runnable() {
    
                    private Logger logger = LoggerFactory.getLogger(this.getClass());
                    // Clean up at exit
                    @Override
                    public void run() {
                        logger.info(RedisClusterConfig.class.getSimpleName() + " shutdown");
    
                        try {
                            cluster.close();
                        } catch (Exception e) {
                            logger.error("shutdown jedis cluster", e);
                        }
                    }
                });
    
                Runtime.getRuntime().addShutdownHook(shutdown);
            }
            return cluster;
        }
    }

5.新建RedisClusterProperties.java

package jesper.search.redisconfig;
    
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.stereotype.Component;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /*把配置文件application.yml中redis cluster的配置项，映射到java对象中，方便直接使用*/
    @Component
    @ConfigurationProperties(prefix = "jedis")
    public class RedisClusterProperties {
    
       //集群节点
       private List<String> nodes=new ArrayList<>();
    
       public List<String> getNodes() {
          return nodes;
       }
    
       public void setNodes(List<String> nodes) {
          this.nodes = nodes;
       }
    }

6.新建测试类

package jesper.search.controller;
    
    import jesper.search.service.SolrService;
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    import redis.clients.jedis.JedisCluster;
    
    @RestController
    public class TestRedisController {
        @Autowired
         JedisCluster jedisCluster;
        @Autowired
        private SolrService solrService;
        private static final Log logger = LogFactory.getLog(TestRedisController.class);
    
    
        @RequestMapping(value = "/test", method= RequestMethod.GET)
        public void get(){
            jedisCluster.set("rediskey","redistest");
            logger.info("=============="+jedisCluster.get("rediskey"));
            logger.info("==============");
        }
    
    }

7.执行方法输出

2019-10-24 08:35:09.536 \[http-nio-8888-exec-1\] INFO  o.a.c.c.C.\[Tomcat\].\[localhost\].\[/solr-master\] - Initializing Spring FrameworkServlet 'dispatcherServlet'  
2019-10-24 08:35:09.537 \[http-nio-8888-exec-1\] INFO  org.springframework.web.servlet.DispatcherServlet - FrameworkServlet 'dispatcherServlet': initialization started  
2019-10-24 08:35:09.588 \[http-nio-8888-exec-1\] INFO  org.springframework.web.servlet.DispatcherServlet - FrameworkServlet 'dispatcherServlet': initialization completed in 51 ms  
2019-10-24 08:35:09.665 \[http-nio-8888-exec-1\] INFO  jesper.search.controller.TestRedisController - ==============redistest  
2019-10-24 08:35:09.665 \[http-nio-8888-exec-1\] INFO  jesper.search.controller.TestRedisController - ==============

8.方式二 新建RedisClusterUtil（等同于TestRedisController 使用方式，只是创建工具类）

package com.kry.xr.util;
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import redis.clients.jedis.JedisCluster;
    import java.util.Calendar;
    @Component
    public class RedisClusterUtil {
        private static final Log log = LogFactory.getLog(Calendar.class);
         @Autowired
         JedisCluster jedisCluster;
        public  void setKey(String key,String value){
              jedisCluster.set(key,value);
        }
    }
    调用

@Autowired
    RedisClusterUtil redisClusterUtil;

@RequestMapping("/test1")
    @ResponseBody
    public String test1(){
        redisClusterUtil.setKey("test1","test1");
        return "test1";
    }