程序包 com.cdkjframework.redis

类 RedisUtils

java.lang.Object
com.cdkjframework.redis.RedisUtils
@Component @Order(-2147483647) public class RedisUtils extends Object

  • 构造器详细资料

    • RedisUtils

      public RedisUtils(io.lettuce.core.cluster.api.async.RedisAdvancedClusterAsyncCommands<String,String> clusterAsyncCommands, io.lettuce.core.api.async.RedisAsyncCommands<String,String> asyncCommands, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String> redisSubscribeConnection, io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String> clusterSubscribeConnection, RedisConfig redisConfig)
      构造函数
      参数:
      clusterAsyncCommands - 集群模式
      asyncCommands - 单点模式
      redisSubscribeConnection - 单点订阅
      clusterSubscribeConnection - 集群订阅
      redisConfig - 配置

  • 方法详细资料

    • syncExpire

      public static boolean syncExpire(String key, long time)
      指定缓存失效时间
      参数:
      key - 键
      time - 时间(秒)
      返回:
      IntegerConsts.ZERO

    • publish

      public static Long publish(String key, String message)
      发布订阅
      参数:
      key - 主键值
      message - 消息
      返回:
      返回结果

    • sisMember

      public static boolean sisMember(String key, String value)
      sis成员是否存在
      返回:
      返回结果

    • sadd

      public static long sadd(String key, String value)
      sis成员添加
      返回:
      返回结果

    • srem

      public static long srem(String key, String value)
      sis成员添加
      返回:
      返回结果

    • lpush

      public static Long lpush(String key, String message)
      低压脉冲
      参数:
      key - 主键值
      message - 消息
      返回:
      返回结果

    • rpop

      public static String rpop(String key)
      队列消息
      参数:
      key - 键
      返回:
      返回结果

    • brpop

      public static io.lettuce.core.KeyValue<String,String> brpop(String key)
      订阅消息
      参数:
      key - 键
      返回:
      返回结果

    • syncExists

      public static boolean syncExists(String... keys)
      根据key 获取过期时间
      参数:
      keys - 键 不能为nullogUtils* @return 时间(秒) 返回0代表为永久有效

    • syncDel

      public static void syncDel(String... keys)
      删除缓存
      参数:
      keys - 可以传一个值 或多个

    • hGet

      public static String hGet(String key, String value)
      获取参数值
      参数:
      key - 键
      value - 值
      返回:
      返回结果

    • hSet

      public static boolean hSet(String key, String value)
      设置
      参数:
      key - 键
      value - 值
      返回:
      返回是否成功

    • hSet

      public static boolean hSet(String key, String field, String value)
      设置
      参数:
      key - 键
      field - 字段
      value - 值
      返回:
      返回是否成功

    • hDel

      public static Long hDel(String key, String field)
      删除数据
      参数:
      key - 键
      field - 字段
      返回:
      返回是否成功

    • syncAppend

      public static Long syncAppend(String key, String value)
      追加数据
      参数:
      key - 主键
      value - 值

    • hvals

      public static List<String> hvals(String key)
      获取参数值
      参数:
      key - 键
      返回:
      返回结果

    • syncGet

      public static String syncGet(String key)
      普通缓存获取
      参数:
      key - 键
      返回:
      值

    • syncSet

      public static boolean syncSet(String key, String value)
      普通缓存放入
      参数:
      key - 键
      value - 值
      返回:
      true成功 false失败

    • syncSet

      public static String syncSet(String key, String value, io.lettuce.core.SetArgs setArgs)
      普通缓存放入
      参数:
      key - 键
      value - 值
      setArgs - 设置参数
      返回:
      true成功 false失败

    • syncSet

      public static boolean syncSet(String key, String value, long time)
      普通缓存放入并设置时间
      参数:
      key - 键
      value - 值
      time - 时间(秒) time要大于0 如果time小于等于0 将设置无限期
      返回:
      true成功 false 失败

    • syncIncr

      public static long syncIncr(String key, long delta)
      递增
      参数:
      key - 键
      delta - 要增加几(大于0)
      返回:
      返回增加值

    • syncDecr

      public static long syncDecr(String key, long delta)
      递减
      参数:
      key - 键
      delta - 要减少几(小于0)
      返回:

    • syncHashGet

      public static Map<String,Object> syncHashGet(String key)
      获取hashKey对应的所有键值
      参数:
      key - 键
      返回:
      对应的多个键值 IntegerConsts.ZERO

    • hGetAll

      public static Map<String,String> hGetAll(String key, String value)
      获取指定hash键全部值
      参数:
      key - 键
      value - 值
      返回:
      返回结果

    • syncHashSet

      public static boolean syncHashSet(String key, Map<String,Object> map)
      HashSet
      参数:
      key - 键
      map - 对应多个键值
      返回:
      true 成功 false 失败 IntegerConsts.ZERO

    • syncHashSet

      public static boolean syncHashSet(String key, Map<String,Object> map, long time)
      HashSet 并设置时间
      参数:
      key - 键
      map - 对应多个键值
      time - 时间(秒)
      返回:
      true成功 false失败

    • syncGetEntity

      public static <T> T syncGetEntity(String key, Class<T> clazz)
      获取实体
      类型参数:
      T -
      参数:
      key - 主键
      clazz - 实体
      返回:
      返回实体

    • syncEntitySet

      public static <T> boolean syncEntitySet(String key, T t)
      实体写入缓存
      类型参数:
      T - 实体类型
      参数:
      key - 主键
      t - 实体
      返回:
      返回执行结果

    • syncEntitySet

      public static <T> boolean syncEntitySet(String key, T t, long time)
      实体写入缓存
      类型参数:
      T - 实体类型
      参数:
      key - 主键
      t - 实体
      返回:
      返回执行结果

    • syncGetList

      public static <T> List<T> syncGetList(String key, Class<T> clazz)
      获取实体
      类型参数:
      T -
      参数:
      key - 主键
      clazz - 实体
      返回:
      返回实体

    • syncListSet

      public static <T> boolean syncListSet(String key, List<T> list)
      实体写入缓存
      类型参数:
      T - 实体类型
      参数:
      key - 主键
      list - 实体
      返回:
      返回执行结果

    • syncListSet

      public static <T> boolean syncListSet(String key, List<T> list, long time)
      实体写入缓存
      类型参数:
      T - 实体类型
      参数:
      key - 主键
      list - 实体
      返回:
      返回执行结果