application.properties

加入redis账户配置以及redis连接池配置，本地默认没有密码 ： localhost:6379

  1. #thymeleaf
  2. spring.thymeleaf.prefix=classpath:/templates/
  3. spring.thymeleaf.suffix=.html
  4. spring.thymeleaf.cache=false
  5. spring.thymeleaf.content-type=text/html
  6. spring.thymeleaf.enabled=true
  7. spring.thymeleaf.encoding=UTF-8
  8. spring.thymeleaf.mode=HTML5
  9. # mybatis
  10. mybatis.type-aliases-package=com.fengqiuhua.pro.entity
  11. mybatis.configuration.map-underscore-to-camel-case=true
  12. mybatis.configuration.default-fetch-size=100
  13. mybatis.configuration.default-statement-timeout=3000
  14. mybatis.mapperLocations = classpath:com/fengqiuhua/pro/mapper/xml/*.xml
  15. # druid
  16. spring.datasource.url=jdbc:mysql://mysql-test.agilenaas.net:3307/company?useOldAliasMetadataBehavior=true&useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
  17. spring.datasource.username=root
  18. spring.datasource.password=ags@2020
  19. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
  20. spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
  21. spring.datasource.filters=stat
  22. spring.datasource.maxActive=1000
  23. spring.datasource.initialSize=100
  24. spring.datasource.maxWait=60000
  25. spring.datasource.minIdle=500
  26. spring.datasource.timeBetweenEvictionRunsMillis=60000
  27. spring.datasource.minEvictableIdleTimeMillis=300000
  28. spring.datasource.validationQuery=select 'x'
  29. spring.datasource.testWhileIdle=true
  30. spring.datasource.testOnBorrow=false
  31. spring.datasource.testOnReturn=false
  32. spring.datasource.poolPreparedStatements=true
  33. spring.datasource.maxOpenPreparedStatements=20
  34. #redis
  35. redis.host=localhost
  36. redis.port=6379
  37. redis.timeout=10
  38. #redis.password=123456
  39. redis.poolMaxTotal=1000
  40. redis.poolMaxIdle=500
  41. redis.poolMaxWait=500

将配置参数封装成到类RedisConfig

ConfigurationProperties注解在springboot启动时会扫描配置文件中以redis为前缀的参数，并将值注入到类变量中

  1. @Component
  2. @ConfigurationProperties(prefix="redis")
  3. public class RedisConfig {
  4.     private String host;
  5.     private int port;
  6.     private int timeout;//秒
  7.     private String password;
  8.     private int poolMaxTotal;
  9.     private int poolMaxIdle;
  10.     private int poolMaxWait;//秒
  11.     public String getHost() {
  12.         return host;
  13.     }
  14.     public void setHost(String host) {
  15.         this.host = host;
  16.     }
  17.     public int getPort() {
  18.         return port;
  19.     }
  20.     public void setPort(int port) {
  21.         this.port = port;
  22.     }
  23.     public int getTimeout() {
  24.         return timeout;
  25.     }
  26.     public void setTimeout(int timeout) {
  27.         this.timeout = timeout;
  28.     }
  29.     public String getPassword() {
  30.         return password;
  31.     }
  32.     public void setPassword(String password) {
  33.         this.password = password;
  34.     }
  35.     public int getPoolMaxTotal() {
  36.         return poolMaxTotal;
  37.     }
  38.     public void setPoolMaxTotal(int poolMaxTotal) {
  39.         this.poolMaxTotal = poolMaxTotal;
  40.     }
  41.     public int getPoolMaxIdle() {
  42.         return poolMaxIdle;
  43.     }
  44.     public void setPoolMaxIdle(int poolMaxIdle) {
  45.         this.poolMaxIdle = poolMaxIdle;
  46.     }
  47.     public int getPoolMaxWait() {
  48.         return poolMaxWait;
  49.     }
  50.     public void setPoolMaxWait(int poolMaxWait) {
  51.         this.poolMaxWait = poolMaxWait;
  52.     }
  53. }

自定义连接池JedisPool

  1. @Component
  2. public class RedisPoolFactory {
  4.     @Autowired
  5.     RedisConfig redisConfig;
  7.     @Bean
  8.     public JedisPool JedisPoolFactory() {
  9.         JedisPoolConfig poolConfig = new JedisPoolConfig();
  10.         poolConfig.setMaxIdle(redisConfig.getPoolMaxIdle());
  11.         poolConfig.setMaxTotal(redisConfig.getPoolMaxTotal());
  12.         poolConfig.setMaxWaitMillis(redisConfig.getPoolMaxWait() * 1000);
  13.         JedisPool jp = new JedisPool(poolConfig, redisConfig.getHost(), redisConfig.getPort(),
  14.                 redisConfig.getTimeout()*1000, redisConfig.getPassword(), 0);
  15.         return jp;
  16.     }
  18. }

编写redis服务类 RedisService

可以通过JedisPool获取到jedis客户端了，随后就可以set ，get 了。

这种方式优于通过RedisTemplate模板 直接 set get。

  1. @Service
  2. public class RedisService {
  4.     @Autowired
  5.     JedisPool jedisPool;
  7.     /**
  8.      * 获取当个对象
  9.      * */
  10.     public <T> T get(KeyPrefix prefix, String key, Class<T> clazz) {
  11.          Jedis jedis = null;
  12.          try {
  13.              jedis =  jedisPool.getResource();
  14.              //生成真正的key
  15.              String realKey  = prefix.getPrefix() + key;
  16.              String str = jedis.get(realKey);
  17.              T t =  stringToBean(str, clazz);
  18.              return t;
  19.          }finally {
  20.               returnToPool(jedis);
  21.          }
  22.     }
  24.     /**
  25.      * 设置对象
  26.      * */
  27.     public <T> boolean set(KeyPrefix prefix, String key, T value) {
  28.          Jedis jedis = null;
  29.          try {
  30.              jedis =  jedisPool.getResource();
  31.              String str = beanToString(value);
  32.              if(str == null || str.length() <= 0) {
  33.                  return false;
  34.              }
  35.             //生成真正的key
  36.              String realKey  = prefix.getPrefix() + key;
  37.              int seconds =  prefix.expireSeconds();
  38.              if(seconds <= 0) {
  39.                  jedis.set(realKey, str);
  40.              }else {
  41.                  jedis.setex(realKey, seconds, str);
  42.              }
  43.              return true;
  44.          }finally {
  45.               returnToPool(jedis);
  46.          }
  47.     }
  49.     /**
  50.      * 判断key是否存在
  51.      * */
  52.     public <T> boolean exists(KeyPrefix prefix, String key) {
  53.          Jedis jedis = null;
  54.          try {
  55.              jedis =  jedisPool.getResource();
  56.             //生成真正的key
  57.              String realKey  = prefix.getPrefix() + key;
  58.             return  jedis.exists(realKey);
  59.          }finally {
  60.               returnToPool(jedis);
  61.          }
  62.     }
  64.     /**
  65.      * 删除
  66.      * */
  67.     public boolean delete(KeyPrefix prefix, String key) {
  68.          Jedis jedis = null;
  69.          try {
  70.              jedis =  jedisPool.getResource();
  71.             //生成真正的key
  72.             String realKey  = prefix.getPrefix() + key;
  73.             long ret =  jedis.del(realKey);
  74.             return ret > 0;
  75.          }finally {
  76.               returnToPool(jedis);
  77.          }
  78.     }
  80.     /**
  81.      * 增加值
  82.      * */
  83.     public <T> Long incr(KeyPrefix prefix, String key) {
  84.          Jedis jedis = null;
  85.          try {
  86.              jedis =  jedisPool.getResource();
  87.             //生成真正的key
  88.              String realKey  = prefix.getPrefix() + key;
  89.             return  jedis.incr(realKey);
  90.          }finally {
  91.               returnToPool(jedis);
  92.          }
  93.     }
  95.     /**
  96.      * 减少值
  97.      * */
  98.     public <T> Long decr(KeyPrefix prefix, String key) {
  99.          Jedis jedis = null;
  100.          try {
  101.              jedis =  jedisPool.getResource();
  102.             //生成真正的key
  103.              String realKey  = prefix.getPrefix() + key;
  104.             return  jedis.decr(realKey);
  105.          }finally {
  106.               returnToPool(jedis);
  107.          }
  108.     }
  110.     public boolean delete(KeyPrefix prefix) {
  111.         if(prefix == null) {
  112.             return false;
  113.         }
  114.         List<String> keys = scanKeys(prefix.getPrefix());
  115.         if(keys==null || keys.size() <= 0) {
  116.             return true;
  117.         }
  118.         Jedis jedis = null;
  119.         try {
  120.             jedis = jedisPool.getResource();
  121.             jedis.del(keys.toArray(new String[0]));
  122.             return true;
  123.         } catch (final Exception e) {
  124.             e.printStackTrace();
  125.             return false;
  126.         } finally {
  127.             if(jedis != null) {
  128.                 jedis.close();
  129.             }
  130.         }
  131.     }
  133.     public List<String> scanKeys(String key) {
  134.         Jedis jedis = null;
  135.         try {
  136.             jedis = jedisPool.getResource();
  137.             List<String> keys = new ArrayList<String>();
  138.             String cursor = "0";
  139.             ScanParams sp = new ScanParams();
  140.             sp.match("*"+key+"*");
  141.             sp.count(100);
  142.             do{
  143.                 ScanResult<String> ret = jedis.scan(cursor, sp);
  144.                 List<String> result = ret.getResult();
  145.                 if(result!=null && result.size() > 0){
  146.                     keys.addAll(result);
  147.                 }
  148.                 //再处理cursor
  149.                 cursor = ret.getCursor();
  150.             }while(!cursor.equals("0"));
  151.             return keys;
  152.         } finally {
  153.             if (jedis != null) {
  154.                 jedis.close();
  155.             }
  156.         }
  157.     }
  159.     public static <T> String beanToString(T value) {
  160.         if(value == null) {
  161.             return null;
  162.         }
  163.         Class<?> clazz = value.getClass();
  164.         if(clazz == int.class || clazz == Integer.class) {
  165.              return ""+value;
  166.         }else if(clazz == String.class) {
  167.              return (String)value;
  168.         }else if(clazz == long.class || clazz == Long.class) {
  169.             return ""+value;
  170.         }else {
  171.             return JSON.toJSONString(value);
  172.         }
  173.     }
  175.     @SuppressWarnings("unchecked")
  176.     public static <T> T stringToBean(String str, Class<T> clazz) {
  177.         if(str == null || str.length() <= 0 || clazz == null) {
  178.              return null;
  179.         }
  180.         if(clazz == int.class || clazz == Integer.class) {
  181.              return (T) Integer.valueOf(str);
  182.         }else if(clazz == String.class) {
  183.              return (T)str;
  184.         }else if(clazz == long.class || clazz == Long.class) {
  185.             return  (T) Long.valueOf(str);
  186.         }else {
  187.             return JSON.toJavaObject(JSON.parseObject(str), clazz);
  188.         }
  189.     }
  191.     private void returnToPool(Jedis jedis) {
  192.          if(jedis != null) {
  193.              jedis.close();
  194.          }
  195.     }
  197. }

controller测试redis

先不用redis service。
直接用从pool中获取一个jedis ，然后进行set，get。

  2.     @Autowired
  3.     JedisPool jedisPool;
  5.     @GetMapping("/setRedis")
  6.     @ResponseBody
  7.     public Result<Object> setRedis(){
  8.         Jedis resource = jedisPool.getResource();
  9.         resource.set("test","1111");
  10.         return Result.success(resource.get("test"));
  11.     }