团队

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/support/aop/TokenAop.java

@@ -13,12 +13,10 @@ import org.aspectj.lang.annotation.Pointcut;
 import org.aspectj.lang.reflect.MethodSignature;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.context.annotation.ComponentScan;
 import org.springframework.stereotype.Component;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 
-import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import java.lang.reflect.Method;

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/UserBussinessController.java

@@ -3,6 +3,10 @@ package com.github.wxiaoqi.security.admin.rest;
 import com.github.wxiaoqi.security.admin.biz.UserBusinessBiz;
 import com.github.wxiaoqi.security.admin.bo.UserTeamMemberBo;
 import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
+import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
+import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil;
+import com.github.wxiaoqi.security.auth.common.util.jwt.IJWTInfo;
+import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -11,6 +15,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.servlet.http.HttpServletRequest;
+
 /**
  * @author libin
  * @version 1.0
@@ -21,12 +27,24 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/team")
 public class UserBussinessController {
 
+    @Autowired
+   private UserAuthUtil userAuthUtil;
+
+    @Autowired
+    private UserAuthConfig userAuthConfig;
+
      @Autowired
     private UserBusinessBiz businessBiz;
 
      @GetMapping("/teams")
-     public ObjectRestResponse<PageDataVO<UserTeamMemberBo>> findTeamPage(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, AppUserDTO appUserDTO){
-         PageDataVO<UserTeamMemberBo> teamMemberBoPageDataVO = businessBiz.findTeamMemberPageByUserId(appUserDTO.getUserid(), pageNo, pageSize);
+     public ObjectRestResponse<PageDataVO<UserTeamMemberBo>> findTeamPage(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, HttpServletRequest request){
+         try {
+             IJWTInfo infoFromToken = userAuthUtil.getInfoFromToken(userAuthConfig.getToken(request));
+             PageDataVO<UserTeamMemberBo> teamMemberBoPageDataVO = businessBiz.findTeamMemberPageByUserId(Integer.valueOf(infoFromToken.getId()), pageNo, pageSize);
              return ObjectRestResponse.succ(teamMemberBoPageDataVO);
+         } catch (Exception e) {
+           throw new BaseException(e);
+         }
+
      }
 }

xx-common/xx-common-demo/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>xx-common</artifactId>
+        <groupId>com.xxfc</groupId>
+        <version>2.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>xx-common-demo</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.xxfc.platform</groupId>
+            <artifactId>xx-common-platform-component</artifactId>
+            <version>2.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+</project>
\ No newline at end of file

xx-common/xx-common-demo/src/main/java/com/xxfc/platform/demo/DemoApplication.java

+package com.xxfc.platform.demo;
+
+
+public class DemoApplication {
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/annotaion/LoginUser.java

+package com.xxfc.platform.common.annotaion;
+
+import java.lang.annotation.*;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description 
+ * @data 2019/7/8 15:26
+ */
+@Target(ElementType.PARAMETER)
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface LoginUser {
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/annotaion/NoRepeatSubmit.java

+package com.xxfc.platform.common.annotaion;
+
+import com.xxfc.platform.common.util.RedisLock;
+
+import java.lang.annotation.*;
+/**
+ * @author libin
+ * @version 1.0
+ * @description 
+ * @data 2019/7/8 15:26
+ */
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface NoRepeatSubmit {
+     long timeout() default 10;
+     String pre() default "";
+     RedisLock.ExpireTimeUnitEnum exptunit() default RedisLock.ExpireTimeUnitEnum.EXPIRETIME;
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/annotaion/RateLimit.java

+package com.xxfc.platform.common.annotaion;
+
+import java.lang.annotation.*;
+
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface RateLimit {
+
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/aop/NoRepeatSubmitAop.java

+package com.xxfc.platform.common.aop;
+
+import com.xxfc.platform.common.annotaion.NoRepeatSubmit;
+import com.xxfc.platform.common.msg.ApiResult;
+import com.xxfc.platform.common.msg.PageApiResult;
+import com.xxfc.platform.common.util.RedisLock;
+import lombok.extern.slf4j.Slf4j;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Pointcut;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/8 21:04
+ */
+@Aspect
+@Component
+@Slf4j
+public class NoRepeatSubmitAop {
+
+    @Value("${auth.user.token-header:Authorization}")
+    private String tokenHeader;
+
+    private static final String NO_REPEAT_SUBMIT_PREKEY = "no:submit";
+
+    @Autowired
+    private RedisLock redisLock;
+
+    @Pointcut("@annotation(noRepeatSubmit)")
+    public void noRepeateSubmitExpress(NoRepeatSubmit noRepeatSubmit) {}
+
+    @Around("noRepeateSubmitExpress(noRepeatSubmit)")
+    public Object noRepeateSubmitAround(ProceedingJoinPoint proceedingJoinPoint, NoRepeatSubmit noRepeatSubmit) {
+        ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+        HttpServletRequest request = servletRequestAttributes.getRequest();
+        String uri = request.getRequestURI();
+        String token = request.getHeader(tokenHeader);
+
+        String lockKey = String.format("%s%s:%s:%s", StringUtils.isEmpty(noRepeatSubmit.pre()) ? "" : noRepeatSubmit.pre() + ":", NO_REPEAT_SUBMIT_PREKEY, token, uri);
+        boolean tryLock = redisLock.tryLock(lockKey, uri, noRepeatSubmit.exptunit(), noRepeatSubmit.timeout());
+
+        Object result = null;
+        if (tryLock) {
+            log.info("tryLock success, key=【{}】,接口地址:uri=【{}】", lockKey, uri);
+            try {
+                result = proceedingJoinPoint.proceed();
+            } catch (Throwable throwable) {
+                throwable.printStackTrace();
+            } finally {
+                redisLock.releaseLock(lockKey, uri);
+                log.info("releassLock success,key=【{}】,接口地址：uri=【{}】", lockKey, uri);
+            }
+            return result;
+        } else {
+            log.info("tryLock fail key=【{}】", lockKey);
+            return ApiResult.fail(100001, "获取锁失败");
+        }
+    }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/aop/ValidParamAop.java

+package com.xxfc.platform.common.aop;
+
+import cn.hutool.core.util.ArrayUtil;
+import com.github.wxiaoqi.security.common.annotation.BeanValid;
+import com.github.wxiaoqi.security.common.annotation.SimpleValid;
+import com.xxfc.platform.common.msg.ApiResult;
+import lombok.Data;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+
+import javax.validation.ConstraintViolation;
+import javax.validation.Validator;
+import javax.validation.executable.ExecutableValidator;
+import java.lang.reflect.Method;
+import java.lang.reflect.Parameter;
+import java.util.Objects;
+import java.util.Set;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description  切面验证
+ * @data 2019/6/13 13:46
+ */
+@Aspect
+@Data
+public class ValidParamAop {
+
+     /**
+      * 复合类型验证器
+      */
+     private Validator validator;
+
+     /**
+      * 简单类型验证器
+      */
+     private ExecutableValidator executableValidator;
+
+     @Pointcut("execution(* com.xxfc.platform..rest..*(..))")
+     public void validatorExpress(){}
+
+     @Around("validatorExpress()")
+     public Object validatorAround(ProceedingJoinPoint proceedingJoinPoint)throws Throwable{
+
+          //获取方法的所有参数
+          Object[] args = proceedingJoinPoint.getArgs();
+          if (ArrayUtil.isEmpty(args)){
+                //没有参数，不用验证
+               return  proceedingJoinPoint.proceed();
+          }
+
+          MethodSignature methodSignature = (MethodSignature) proceedingJoinPoint.getSignature();
+          Method currentMethod = methodSignature.getMethod();
+          Parameter[] parameters = currentMethod.getParameters();
+
+           boolean hashSimpleValid = false;
+
+          int argLength = args.length;
+          for (int i =0;i<argLength;i++){
+               BeanValid beanValidAnnotation = parameters[i].getDeclaredAnnotation(BeanValid.class);
+               if (Objects.nonNull(beanValidAnnotation)){
+                    if (args[i].getClass().isArray()){
+                          Object[] arrayArg =(Object[])args[i];
+                          for (Object item:arrayArg){
+                               Set<ConstraintViolation<Object>> validateResult = this.validator.validate(item, beanValidAnnotation.value());
+                               if (!validateResult.isEmpty()){
+                                    String message = validateResult.iterator().next().getMessage();
+                                    return ApiResult.fail(400,message);
+                               }
+                          }
+                    }else {
+                         Set<ConstraintViolation<Object>> validateResult = this.validator.validate(args[i], beanValidAnnotation.value());
+                         if (!validateResult.isEmpty()){
+                              String message = validateResult.iterator().next().getMessage();
+                              return ApiResult.fail(400,message);
+                         }
+                    }
+                    continue;
+               }
+               if (!hashSimpleValid){
+                    SimpleValid  simpleValidAnnotation = parameters[i].getDeclaredAnnotation(SimpleValid.class);
+                    if (Objects.nonNull(simpleValidAnnotation)){
+                         hashSimpleValid = true;
+                    }
+               }
+          }
+          if (hashSimpleValid){
+               Object target = proceedingJoinPoint.getTarget();
+               Set<ConstraintViolation<Object>> validResult = this.executableValidator.validateParameters(target, currentMethod, args);
+               if(!validResult.isEmpty()){
+                    String message = validResult.iterator().next().getMessage();
+                    return ApiResult.fail(400,message);
+               }
+
+          }
+          return proceedingJoinPoint.proceed();
+     }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/config/ValidatorConfig.java

+package com.xxfc.platform.common.config;
+
+import com.github.wxiaoqi.security.common.support.aop.ValidParamAop;
+import org.hibernate.validator.HibernateValidator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.validation.Validation;
+import javax.validation.Validator;
+import javax.validation.ValidatorFactory;
+import javax.validation.executable.ExecutableValidator;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description 验证器validator
+ * @data 2019/6/13 13:48
+ */
+@Configuration
+public class ValidatorConfig {
+
+    /**
+     * 复合类型所用的验证器
+     * @return Validator
+     */
+    @Bean
+    public Validator validator(){
+        // .failFast( true ) 为设置快速错误模式，默认为false
+        ValidatorFactory validatorFactory = Validation.byProvider( HibernateValidator.class )
+                .configure()
+                .failFast( true )
+                .buildValidatorFactory();
+        return validatorFactory.getValidator();
+    }
+
+    /**
+     * 简单类型所用的验证器
+     * @return ExecutableValidator
+     */
+    @Bean
+    public ExecutableValidator executableValidator() {
+        return validator().forExecutables();
+    }
+
+    /**
+     * 装配验证器切面
+     * @param validator Bean验证器
+     * @param executableValidator 简单类型验证器
+     * @return ValidParamAop
+     */
+    @Bean
+    public ValidParamAop validAop(Validator validator, ExecutableValidator executableValidator) {
+        ValidParamAop validParamAop = new ValidParamAop();
+        validParamAop.setValidator(validator);
+        validParamAop.setExecutableValidator(executableValidator);
+        return validParamAop;
+    }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/config/WebMvcConfig.java

+package com.xxfc.platform.common.config;
+
+import com.xxfc.platform.common.resover.LoginUserParamResolver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.method.support.HandlerMethodArgumentResolver;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import java.util.List;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/9 17:29
+ */
+@Configuration
+public class WebMvcConfig implements WebMvcConfigurer {
+
+    @Autowired
+    private LoginUserParamResolver loginUserParamResolver;
+
+    @Override
+    public void addArgumentResolvers(List<HandlerMethodArgumentResolver> resolvers) {
+        resolvers.add(loginUserParamResolver);
+    }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/msg/ApiResult.java

+package com.xxfc.platform.common.msg;
+
+import lombok.Data;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/9 16:55
+ */
+@Data
+public class ApiResult<T> extends BaseApiResult<T> {
+
+    private ApiResult(long code, String msg, T data, boolean successResponse, String requestId) {
+      super(code,msg,data,successResponse,requestId);
+    }
+
+    public static <T> ApiResult<T> ok() {
+        return new ApiResult(200, "ok", "ok", true, "0");
+    }
+
+    public static <T> ApiResult<T> ok(T data) {
+        return new ApiResult(200, "ok", data, true, "0");
+    }
+
+    public static <T> ApiResult<T> ok(T data, String requestId) {
+        return new ApiResult(200, "ok", data, true, requestId);
+    }
+
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/msg/BaseApiResult.java

+package com.xxfc.platform.common.msg;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/9 17:55
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class BaseApiResult<T> implements Serializable {
+    private static final long serialVersionUID = 1L;
+    protected long code;
+    protected String msg;
+    protected T data;
+    protected boolean successResponse;
+    protected String requestId;
+
+    public static <T> BaseApiResult<T> fail() {
+        return new BaseApiResult(400, "fail", "fail", false, "0");
+    }
+    public static <T> BaseApiResult<T> fail(String msg) {
+        return new BaseApiResult(400, msg, "fail", false, "0");
+    }
+    public static <T> BaseApiResult<T> fail(long code, String msg) {
+        return new BaseApiResult(code, msg, "fail", false, "0");
+    }
+
+
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/msg/PageApiResult.java

+package com.xxfc.platform.common.msg;
+
+import lombok.Data;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/9 17:45
+ */
+@Data
+public class PageApiResult<T> extends BaseApiResult<T> {
+
+    private PageInfo pageInfo;
+
+    private PageApiResult(long code, String msg, T data, boolean successResponse, String requestId, PageInfo pageInfo) {
+        super(code, msg, data, successResponse, requestId);
+        this.pageInfo = pageInfo;
+    }
+
+    public static <T> PageApiResult<T> ok() {
+        return new PageApiResult(200, "ok", "ok", true, "0", PageInfo.createEmptyPageInfo());
+    }
+
+    public static <T> PageApiResult<T> ok(T data, PageInfo pageInfo) {
+        return new PageApiResult(200, "ok", data, true, "0", pageInfo);
+    }
+
+    public static <T> PageApiResult<T> ok(T data, PageInfo pageInfo, String requestId) {
+        return new PageApiResult(200, "ok", data, true, requestId, pageInfo);
+    }
+
+    @Data
+    static class PageInfo {
+        private Integer page;
+        private Integer pageSize;
+        private Integer total;
+
+        private PageInfo(){}
+        private PageInfo(Integer page, Integer pageSize, Integer total) {
+            this.page = page;
+            this.pageSize = pageSize;
+            this.total = total;
+        }
+
+        public static PageInfo createEmptyPageInfo() {
+            return new PageInfo();
+        }
+        public static PageInfo createPageInfo(Integer page, Integer pageSize, Integer total) {
+             return new PageInfo(page,pageSize,total);
+        }
+    }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/resover/LoginUserParamResolver.java

+package com.xxfc.platform.common.resover;
+
+import com.github.wxiaoqi.security.admin.feign.UserFeign;
+import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
+import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
+import com.xxfc.platform.common.annotaion.LoginUser;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.MethodParameter;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.support.WebDataBinderFactory;
+import org.springframework.web.context.request.NativeWebRequest;
+import org.springframework.web.method.support.HandlerMethodArgumentResolver;
+import org.springframework.web.method.support.ModelAndViewContainer;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/8 20:17
+ */
+@Component
+public class LoginUserParamResolver implements HandlerMethodArgumentResolver {
+
+    @Value("${auth.user.token-header:Authorization}")
+    private String tokenHeader;
+
+    @Autowired
+     private UserFeign userFeign;
+
+    @Override
+    public boolean supportsParameter(MethodParameter parameter) {
+        return parameter.hasParameterAnnotation(LoginUser.class);
+    }
+
+    @Override
+    public Object resolveArgument(MethodParameter parameter, ModelAndViewContainer mavContainer, NativeWebRequest webRequest, WebDataBinderFactory binderFactory) throws Exception {
+        HttpServletRequest request = webRequest.getNativeRequest(HttpServletRequest.class);
+        String token = request.getHeader(tokenHeader);
+        Class<?> parameterType = parameter.getParameterType();
+        if (AppUserDTO.class.equals(parameterType)){
+            return  userFeign.userDetailByToken(token).getData();
+        }
+        if (UserDTO.class.equals(parameterType)){
+          return  userFeign.userinfoByToken(token).getData();
+        }
+        return null;
+    }
+}

xx-common/xx-common-platform-component/src/main/java/com/xxfc/platform/common/util/RedisLock.java

+package com.xxfc.platform.common.util;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisCallback;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+import redis.clients.jedis.Jedis;
+
+import java.util.Collections;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/8 21:02
+ */
+@Component
+public class RedisLock {
+    private static final Long RELEASE_SUCCESS = 1L;
+    private static final String LOCK_SUCCESS = "OK";
+    private static final String SET_IF_NOT_EXIST = "NX";
+
+    /**
+     * if get(key) == value return del(key)
+     */
+    private static final String RELEASE_LOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
+
+    @Autowired
+    private StringRedisTemplate redisTemplate;
+
+    /**
+     * 该加锁方法仅针对单实例 Redis 可实现分布式加锁
+     * 对于 Redis 集群则无法使用
+     * <p>
+     * 支持重复，线程安全
+     *
+     * @param lockKey  加锁键
+     * @param clientId 加锁客户端唯一标识(采用UUID)
+     * @param seconds  锁过期时间
+     * @return
+     */
+    public boolean tryLock(String lockKey, String clientId, ExpireTimeUnitEnum expireTimeEnum,long seconds) {
+        return redisTemplate.execute((RedisCallback<Boolean>) redisConnection -> {
+            Jedis jedis = (Jedis) redisConnection.getNativeConnection();
+            String result = jedis.set(lockKey, clientId, SET_IF_NOT_EXIST, expireTimeEnum.getUnit(), seconds);
+            if (LOCK_SUCCESS.equals(result)) {
+                return true;
+            }
+            return false;
+        });
+    }
+
+    /**
+     * 与 tryLock 相对应，用作释放锁
+     *
+     * @param lockKey
+     * @param clientId
+     * @return
+     */
+    public boolean releaseLock(String lockKey, String clientId) {
+        return redisTemplate.execute((RedisCallback<Boolean>) redisConnection -> {
+            Jedis jedis = (Jedis) redisConnection.getNativeConnection();
+            Object result = jedis.eval(RELEASE_LOCK_SCRIPT, Collections.singletonList(lockKey),
+                    Collections.singletonList(clientId));
+            if (RELEASE_SUCCESS.equals(result)) {
+                return true;
+            }
+            return false;
+        });
+    }
+    public enum ExpireTimeUnitEnum {
+        /**
+         * 当前设置 过期时间单位, EX = seconds; PX = milliseconds
+         */
+         EXPIRETIME("EX"),
+        PXPIRETIME("PX");
+
+        ExpireTimeUnitEnum(String unit) {
+            this.unit = unit;
+        }
+
+        String unit;
+
+        public String getUnit() {
+            return unit;
+        }
+
+        public void setUnit(String unit) {
+            this.unit = unit;
+        }
+    }
+}