SpringBoot配置Redis连接池

我就是我 2022-06-03 04:50 631阅读 0赞

首先是redis各个参数的配置，在 application-dev.properties中配置如下：

  1. #redis配置
  2. redis.server.host=192.168.50.162
  3. redis.server.port=6379
  4. redis.server.password=password
  5. redis.server.timeOut=5000
  6. redis.server.maxIdle=50
  7. redis.server.maxWaitMillis=5000
  8. redis.server.maxTotal=500

对 redis 配置参数进行读取和绑定，配置属性注入到 JedisProperties 

  1. import org.springframework.boot.context.properties.ConfigurationProperties;
  3. @ConfigurationProperties(prefix = JedisProperties.JEDIS_PREFIX)
  4. public class JedisProperties {
  6.     public static final String JEDIS_PREFIX = "redis.server";
  8.     private String host;
  10.     private int port;
  12.     private String password;
  14.     private int maxTotal;
  16.     private int maxIdle;
  18.     private int maxWaitMillis;
  20.     private int timeOut;
  22.     public int getTimeOut() {
  23.         return timeOut;
  24.     }
  26.     public void setTimeOut(int timeOut) {
  27.         this.timeOut = timeOut;
  28.     }
  30.     public String getPassword() {
  31.         return password;
  32.     }
  34.     public void setPassword(String password) {
  35.         this.password = password;
  36.     }
  38.     public String getHost() {
  39.         return host;
  40.     }
  42.     public void setHost(String host) {
  43.         this.host = host;
  44.     }
  46.     public int getPort() {
  47.         return port;
  48.     }
  50.     public void setPort(int port) {
  51.         this.port = port;
  52.     }
  54.     public int getMaxTotal() {
  55.         return maxTotal;
  56.     }
  58.     public void setMaxTotal(int maxTotal) {
  59.         this.maxTotal = maxTotal;
  60.     }
  62.     public int getMaxIdle() {
  63.         return maxIdle;
  64.     }
  66.     public void setMaxIdle(int maxIdle) {
  67.         this.maxIdle = maxIdle;
  68.     }
  70.     public int getMaxWaitMillis() {
  71.         return maxWaitMillis;
  72.     }
  74.     public void setMaxWaitMillis(int maxWaitMillis) {
  75.         this.maxWaitMillis = maxWaitMillis;
  76.     }
  78. }

配置了 Redis 连接池之后，将 Redis 连接池 注入到 RedisClient 中，并生成 RedisClient Bean

  1. import com.mljr.auth.config.properties.JedisProperties;
  2. import com.mljr.auth.util.RedisClient;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.beans.factory.annotation.Qualifier;
  7. import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
  8. import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
  9. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  10. import org.springframework.context.annotation.Bean;
  11. import org.springframework.context.annotation.Configuration;
  12. import redis.clients.jedis.JedisPool;
  13. import redis.clients.jedis.JedisPoolConfig;
  15. @Configuration
  16. @EnableConfigurationProperties(JedisProperties.class)
  17. @ConditionalOnClass(RedisClient.class)
  18. public class JedisConfig {
  20.     private Logger logger = LoggerFactory.getLogger(JedisConfig.class);
  22.     @Autowired
  23.     private JedisProperties prop;
  25.     @Bean(name = "jedisPool")
  26.     public JedisPool jedisPool() {
  27.         JedisPoolConfig config = new JedisPoolConfig();
  28.         config.setMaxTotal(prop.getMaxTotal());
  29.         config.setMaxIdle(prop.getMaxIdle());
  30.         config.setMaxWaitMillis(prop.getMaxWaitMillis());
  31.         return new JedisPool(config, prop.getHost(), prop.getPort(), prop.getTimeOut(), prop.getPassword());
  32.     }
  34.     @Bean
  35.     @ConditionalOnMissingBean(RedisClient.class)
  36.     public RedisClient redisClient(@Qualifier("jedisPool") JedisPool pool) {
  37.         logger.info("初始化……Redis Client==Host={},Port={}", prop.getHost(), prop.getPort());
  38.         RedisClient redisClient = new RedisClient();
  39.         redisClient.setJedisPool(pool);
  40.         return redisClient;
  41.     }
  43. }

配置一些常用的 redis 的操作：

  1. import redis.clients.jedis.Jedis;
  2. import redis.clients.jedis.JedisPool;
  4. public class RedisClient {
  6.     private JedisPool jedisPool;
  8.     public void set(String key, Object value) {
  9.         Jedis jedis = null;
  10.         try {
  11.             jedis = jedisPool.getResource();
  12.             jedis.set(key, value.toString());
  13.         }catch (Exception e){
  14.             e.printStackTrace();
  15.         }finally {
  16.             jedis.close();
  17.         }
  18.     }
  20.     /**
  21.      * 设置过期时间 
  22.      * @param key
  23.      * @param value
  24.      * @param exptime
  25.      * @throws Exception
  26.      */
  27.     public void setWithExpireTime(String key, String value, int exptime) {
  28.         Jedis jedis = null;
  29.         try {
  30.             jedis = jedisPool.getResource();
  31.             jedis.set(key, value, "NX", "EX", 300);
  32.         } catch (Exception e){
  33.             e.printStackTrace();
  34.         }finally {
  35.             jedis.close();
  36.         }
  37.     }
  39.     public String get(String key) {
  41.         Jedis jedis = null;
  42.         try {
  43.             jedis = jedisPool.getResource();
  44.             return jedis.get(key);
  45.         } catch (Exception e){
  46.             e.printStackTrace();
  47.         }finally {
  48.             if (jedis != null)
  49.             jedis.close();
  50.         }
  51.         return null;
  52.     }
  53.     public JedisPool getJedisPool() {
  54.         return jedisPool;
  55.     }
  57.     public void setJedisPool(JedisPool jedisPool) {
  58.         this.jedisPool = jedisPool;
  59.     }
  61. }

大功告成，使用注解的方式引入就可以使用了

  1. @Autowired
  2.     private RedisClient redisClient;
  3.     ....
  4.     ....
  5.     ....

发表评论

表情：
评论列表 （有 0 条评论，631人围观）

还没有评论，来说两句吧...

相关阅读