saas 开源开发框架

package com.haoyou.tosaas.redis; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.data.redis.core.*; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; import redis.clients.jedis.BinaryClient; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.SortingParams; import java.io.*; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; /** * Created by wf on 2018-10-27. */ @Component @Slf4j public class RedisUtils { @Autowired private JedisPool jedisPool; public String makeSessionKey(String name,String token){ String key = String.format("session_%s_%s",name,token); return key; } /** * <p> * 通过key获取储存在redis中的value * </p> * <p> * 并释放连接 * </p> * * @param key * @param indexdb 选择redis库 0-15 * @return 成功返回value 失败返回null */ public String get(String key) { Jedis jedis = null; String value = null; try { jedis = jedisPool.getResource(); value = jedis.get(key); log.info(value); } catch (Exception e) { log.error(e.getMessage()); } finally { returnResource(jedisPool, jedis); } return value; } /** * <p> * 通过key获取储存在redis中的value * </p> * <p> * 并释放连接 * </p> * * @param key * @param indexdb 选择redis库 0-15 * @return 成功返回value 失败返回null */ public byte[] get(byte[] key) { Jedis jedis = null; byte[] value = null; try { jedis = jedisPool.getResource(); value = jedis.get(key); } catch (Exception e) { log.error(e.getMessage()); } finally { returnResource(jedisPool, jedis); } return value; } /** * <p> * 设置key value并制定这个键值的有效期 * </p> * * @param key * @param value * @param seconds * 单位:秒 * @return 成功返回OK 失败和异常返回null */ public String set(String key, String value, Integer seconds) { Jedis jedis = null; String res = null; try { jedis = jedisPool.getResource(); if(seconds!=null && seconds>0) res = jedis.setex(key, seconds, value); else res = jedis.set(key,value); } catch (Exception e) { log.error(e.getMessage()); } finally { returnResource(jedisPool, jedis); } return res; } /** * <p> * 向redis存入key和value,并释放连接资源 * </p> * <p> * 如果key已经存在 则覆盖 * </p> * * @param key * @param value * @param seconds 单位秒 * @return 成功 返回OK 失败返回 0 */ public String set(byte[] key, byte[] value, Integer seconds) { Jedis jedis = null; try { jedis = jedisPool.getResource(); if(seconds!=null && seconds>0) return jedis.setex(key,seconds,value); else return jedis.set(key, value); } catch (Exception e) { log.error(e.getMessage()); return "0"; } finally { returnResource(jedisPool, jedis); } } /** * <p> * 删除指定的key,也可以传入一个包含key的数组 * </p> * * @param keys 一个key 也可以使 string 数组 * @return 返回删除成功的个数 */ public Long del(String... keys) { Jedis jedis = null; try { jedis = jedisPool.getResource(); return jedis.del(keys); } catch (Exception e) { log.error(e.getMessage()); return 0L; } finally { returnResource(jedisPool, jedis); } } /** * <p> * 通过key向指定的value值追加值 * </p> * * @param key * @param str * @return 成功返回 添加后value的长度 失败 返回 添加的 value 的长度 异常返回0L */ public Long append(String key, String str) { Jedis jedis = null; Long res = null; try { jedis = jedisPool.getResource(); res = jedis.append(key, str); } catch (Exception e) { log.error(e.getMessage()); return 0L; } finally { returnResource(jedisPool, jedis); } return res; } /** * <p> * 判断key是否存在 * </p> * * @param key * @return true OR false */ public Boolean exists(String key) { Jedis jedis = null; try { jedis = jedisPool.getResource(); return jedis.exists(key); } catch (Exception e) { log.error(e.getMessage()); return false; } finally { returnResource(jedisPool, jedis); } } /** * <p> * 清空当前数据库中的所有 key,此命令从不失败。 * </p> * * @return 总是返回 OK */ public String flushDB() { Jedis jedis = null; try { jedis = jedisPool.getResource(); return jedis.flushDB(); } catch (Exception e) { log.error(e.getMessage()); } finally { returnResource(jedisPool, jedis); } return null; } /** * <p> * 为给定 key 设置生存时间，当 key 过期时(生存时间为 0 )，它会被自动删除。 * </p> * * @param key * @param value * 过期时间，单位：秒 * @return 成功返回1 如果存在 和 发生异常 返回 0 */ public Long expire(String key, int value) { Jedis jedis = null; try { jedis = jedisPool.getResource(); return jedis.expire(key, value); } catch (Exception e) { log.error(e.getMessage()); return 0L; } finally { returnResource(jedisPool, jedis); } } /** * <p> * 以秒为单位，返回给定 key 的剩余生存时间 * </p> * * @param key * @return 当 key 不存在时，返回 -2 。当 key 存在但没有设置剩余生存时间时，返回 -1 。否则，以秒为单位，返回 key * 的剩余生存时间。 发生异常 返回 0 */ public Long ttl(String key,int indexdb) { Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.select(indexdb); return jedis.ttl(key); } catch (Exception e) { log.error(e.getMessage()); return 0L; } finally { returnResource(jedisPool, jedis); } } /** * <p> * 移除给定 key 的生存时间，将这个 key 从『易失的』(带生存时间 key )转换成『持久的』(一个不带生存时间、永不过期的 key ) * </p> * * @param key * @return 当生存时间移除成功时，返回 1 .如果 key 不存在或 key 没有设置生存时间，返回 0 ， 发生异常 返回 -1 */ public Long persist(String key) { Jedis jedis = null; try { jedi