Merge remote-tracking branch 'origin/ywx' into wn

gateway/pom.xml

@@ -43,7 +43,21 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-webmvc</artifactId>
         </dependency>
-
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.56</version>
+        </dependency>
+         <!--redis -->
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.9.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
     </dependencies>
     <dependencyManagement>
         <dependencies>

gateway/src/main/java/com/xhkjedu/gateway/advice/GlobalExceptionHandlerAdvice.java

@@ -0,0 +1,58 @@
+package com.xhkjedu.gateway.advice;
+
+import com.google.common.base.Throwables;
+import com.xhkjedu.gateway.exceptions.GatewayException;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.server.ResponseStatusException;
+
+import java.net.ConnectException;
+
+/**
+ * @Description 这个不是SpringMVC统一异常处理（具体说明详见：ExceptionHandlerCore）
+ * @Author: YWX
+ * @Date 2023/11/15 17:52
+ **/
+@Slf4j
+@RestControllerAdvice
+public class GlobalExceptionHandlerAdvice {
+
+    @ExceptionHandler(GatewayException.class)
+    public ResultVo handler(GatewayException e) {
+        return new ResultVo(e.getCode(), e.getMessage());
+    }
+
+    @ExceptionHandler(ResponseStatusException.class)
+    public ResultVo handler(ResponseStatusException e) {
+        return new ResultVo(1, e.getReason());
+    }
+
+    @ExceptionHandler(ConnectException.class)
+    public ResultVo handler(ConnectException e) {
+        log.error(Throwables.getStackTraceAsString(e));
+        return new ResultVo(1, "网络异常,请稍候再试!");
+    }
+
+    @ExceptionHandler(Throwable.class)
+    public ResultVo handler(Throwable e) {
+        log.error(Throwables.getStackTraceAsString(e));
+        return new ResultVo(1, "服务器异常");
+    }
+
+}
+
+@Data
+@AllArgsConstructor
+class ResultVo{
+    private Integer code;// 返回是否成功  0成功 1失败
+    private String msg;// 返回提示信息
+    private Object obj;// 返回对象或者对象列表
+
+    public ResultVo(int code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/config/SpringContextHolder.java

@@ -0,0 +1,68 @@
+package com.xhkjedu.gateway.config;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import java.lang.annotation.Annotation;
+import java.util.Map;
+
+@Component
+public class SpringContextHolder implements ApplicationContextAware {
+
+    private static ApplicationContext applicationContext;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        SpringContextHolder.applicationContext = applicationContext;
+    }
+
+    public static ApplicationContext getApplicationContext() {
+        assertApplicationContext();
+        return applicationContext;
+    }
+
+    /**
+     * 通过实例类型获取实例
+     *
+     * @param requiredType 实例类型
+     * @param <T>          T
+     * @return T
+     */
+    public static <T> T getBean(Class<T> requiredType) {
+        assertApplicationContext();
+        return applicationContext.getBean(requiredType);
+    }
+
+    /**
+     * 通过实例，名称获取实例
+     *
+     * @param beanName 实例名称
+     * @param <T>      T
+     * @return T
+     */
+    @SuppressWarnings("unchecked")
+    public static <T> T getBean(String beanName) {
+        assertApplicationContext();
+        return (T) applicationContext.getBean(beanName);
+    }
+
+    /**
+     * 通过类上的注解获取类
+     *
+     * @param annotation anno
+     * @return map
+     */
+    public static Map<String, Object> getBeansWithAnnotation(Class<? extends Annotation> annotation) {
+        assertApplicationContext();
+        return applicationContext.getBeansWithAnnotation(annotation);
+    }
+
+    private static void assertApplicationContext() {
+        if (SpringContextHolder.applicationContext == null) {
+            throw new RuntimeException("application Context属性为null,请检查是否注入了SpringContextHolder!");
+        }
+    }
+
+}

gateway/src/main/java/com/xhkjedu/gateway/exceptions/GatewayException.java

@@ -0,0 +1,14 @@
+package com.xhkjedu.gateway.exceptions;
+
+import lombok.Getter;
+
+@Getter
+public class GatewayException extends RuntimeException {
+    private Integer code;
+    private String msg;
+
+    public GatewayException(Integer code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/handler/ErrorHandlerConfiguration.java

@@ -0,0 +1,58 @@
+package com.xhkjedu.gateway.handler;
+
+import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.boot.autoconfigure.web.ServerProperties;
+import org.springframework.boot.autoconfigure.web.WebProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.web.reactive.error.ErrorAttributes;
+import org.springframework.boot.web.reactive.error.ErrorWebExceptionHandler;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.core.annotation.Order;
+import org.springframework.http.codec.ServerCodecConfigurer;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.result.view.ViewResolver;
+
+import java.util.Collections;
+import java.util.List;
+
+@Component
+@EnableConfigurationProperties({ServerProperties.class, WebProperties.class})
+public class ErrorHandlerConfiguration {
+
+    private final ServerProperties serverProperties;
+
+    private final ApplicationContext applicationContext;
+
+    private final WebProperties resourceProperties;
+
+    private final List<ViewResolver> viewResolvers;
+
+    private final ServerCodecConfigurer serverCodecConfigurer;
+
+    public ErrorHandlerConfiguration(ServerProperties serverProperties,
+                                     WebProperties resourceProperties,
+                                     ObjectProvider<List<ViewResolver>> viewResolversProvider,
+                                     ServerCodecConfigurer configurer,
+                                     ApplicationContext applicationContext) {
+        this.serverProperties = serverProperties;
+        this.applicationContext = applicationContext;
+        this.resourceProperties = resourceProperties;
+        this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList);
+        this.serverCodecConfigurer = configurer;
+    }
+
+    @Bean
+    @Order
+    public ErrorWebExceptionHandler errorWebExceptionHandler(ErrorAttributes attributes) {
+        GlobalExceptionHandler exceptionHandler = new GlobalExceptionHandler(
+                attributes,
+                this.resourceProperties,
+                this.serverProperties.getError(),
+                this.applicationContext);
+        exceptionHandler.setViewResolvers(this.viewResolvers);
+        exceptionHandler.setMessageWriters(this.serverCodecConfigurer.getWriters());
+        exceptionHandler.setMessageReaders(this.serverCodecConfigurer.getReaders());
+        return exceptionHandler;
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/handler/ExceptionHandlerCore.java

@@ -0,0 +1,156 @@
+package com.xhkjedu.gateway.handler;
+
+import com.google.common.collect.Maps;
+import com.xhkjedu.gateway.config.SpringContextHolder;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.http.HttpStatus;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.*;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.util.*;
+
+/**
+ * @Description 虽然spring webflux支持springMVC注解，
+ *但是，Filter抛出的异常不属于MVC层，所以，处理Filter抛出的异常依旧不能用SpringMVC那一套注解
+ *但是我们可以自己模仿做一套和MVC类似的注解
+ *该处理类使用SpringMVC的注解
+ *让用户可以无感知的像处理MVC层抛出的异常那样处理Filter抛出的异常
+ * @Author: YWX
+ * @Date 2023/11/16 8:56
+ **/
+@Slf4j
+@Component
+public class ExceptionHandlerCore implements ApplicationRunner {
+
+    /**
+     * key是处理异常的类型
+     * value是处理异常的方法
+     */
+    private LinkedHashMap<Class<? extends Throwable>, Node> exceptionHandlerMap;
+
+    /**
+     * 解析类上的注解
+     * 将处理异常的方法注册到map中
+     */
+    private void register(Object exceptionAdvice) {
+        Method[] methods = exceptionAdvice.getClass().getMethods();
+        Arrays.stream(methods).forEach(method -> {
+            ExceptionHandler exceptionHandler = method.getAnnotation(ExceptionHandler.class);
+            if (Objects.isNull(exceptionHandler)) {
+                return;
+            }
+            ResponseStatus responseStatus = method.getAnnotation(ResponseStatus.class);
+            HttpStatus status = null;
+            if (Objects.nonNull(responseStatus)) {
+                status = responseStatus.value();
+            }
+            HttpStatus finalStatus = status;
+            Arrays.asList(exceptionHandler.value()).forEach(a -> exceptionHandlerMap.put(a, new Node(method, exceptionAdvice, finalStatus)));
+        });
+    }
+
+    /**
+     * 根据异常对象获取解决异常的方法
+     *
+     * @param throwable 异常对象
+     * @return handler method
+     */
+    private Node getHandlerExceptionMethodNode(Throwable throwable) {
+        ArrayList<Class<?>> superClass = this.getSuperClass(throwable.getClass());
+        for (Class<?> aClass : superClass) {
+            Node handlerNode = null;
+            if ((handlerNode = exceptionHandlerMap.get(aClass)) != null) {
+                return handlerNode;
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        Map<String, Object> beans = SpringContextHolder.getBeansWithAnnotation(RestControllerAdvice.class);
+        log.info("-------------异常处理对象获取完毕-------------");
+        exceptionHandlerMap = Maps.newLinkedHashMapWithExpectedSize(beans.size());
+        log.info("-------------异常处理容器内存分配完毕-------------");
+        beans.keySet()
+             .stream()
+             .map(beans::get)
+             .forEach(this::register);
+        log.info("-------------异常处理方法注册完毕-------------");
+    }
+
+    /**
+     * 对外暴露的处理异常的方法
+     *
+     * @param throwable 处理的异常
+     * @return 调用异常后的返回值
+     */
+    public HashMap<String, Object> handlerException(Throwable throwable) {
+        Node exceptionMethodNode = this.getHandlerExceptionMethodNode(throwable);
+        if (Objects.isNull(exceptionMethodNode)) {
+            log.error("未定义异常处理方法，处理异常失败,异常处理信息如下：{}", throwable.getMessage());
+            throw new RuntimeException("未定义异常处理方法，处理异常失败");
+        }
+        /**
+         * 本人水平有限。
+         * 现在支持持一个入参类型类{@link Throwable}
+         * 后人可以随意扩展~
+         */
+        Object returnResult = null;
+        try {
+            returnResult = exceptionMethodNode.method.invoke(exceptionMethodNode.thisObj, throwable);
+        } catch (IllegalAccessException | InvocationTargetException e) {
+            e.printStackTrace();
+        }
+        HashMap<String, Object> resultMap = Maps.newHashMapWithExpectedSize(2);
+        resultMap.put("status", exceptionMethodNode.status);
+        resultMap.put("result", returnResult);
+        return resultMap;
+    }
+
+    /**
+     * 用于存放方法和方法所在的实例
+     */
+    private static class Node {
+        Node(Method method, Object thisObj, HttpStatus status) {
+            this.method = method;
+            this.thisObj = thisObj;
+            this.status = status;
+        }
+
+        /**
+         * 状态码
+         */
+        HttpStatus status;
+        /**
+         * 处理异常的方法
+         */
+        Method method;
+        /**
+         * 方法所在的实例
+         */
+        Object thisObj;
+    }
+
+
+    /**
+     * 获取该类的class以及所有父的class
+     *
+     * @param clazz this.class
+     * @return list
+     */
+    public ArrayList<Class<?>> getSuperClass(Class<?> clazz) {
+        ArrayList<Class<?>> classes = new ArrayList<>();
+        classes.add(clazz);
+        Class<?> suCl = clazz.getSuperclass();
+        while (suCl != null) {
+            classes.add(suCl);
+            suCl = suCl.getSuperclass();
+        }
+        return classes;
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/handler/GlobalExceptionHandler.java

@@ -0,0 +1,84 @@
+package com.xhkjedu.gateway.handler;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.web.ErrorProperties;
+import org.springframework.boot.autoconfigure.web.WebProperties;
+import org.springframework.boot.autoconfigure.web.reactive.error.DefaultErrorWebExceptionHandler;
+import org.springframework.boot.web.error.ErrorAttributeOptions;
+import org.springframework.boot.web.reactive.error.ErrorAttributes;
+import org.springframework.context.ApplicationContext;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.BodyInserters;
+import org.springframework.web.reactive.function.server.*;
+import reactor.core.publisher.Mono;
+
+import javax.annotation.Resource;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * @Description 全局异常处理
+ * @Author: YWX
+ * @Date 2023/11/16 8:57
+ **/
+@Slf4j
+public class GlobalExceptionHandler extends DefaultErrorWebExceptionHandler {
+
+    @Resource
+    private ExceptionHandlerCore handlerCore;
+
+
+    public GlobalExceptionHandler(ErrorAttributes errorAttributes, WebProperties webProperties, ErrorProperties errorProperties, ApplicationContext applicationContext) {
+        super(errorAttributes, webProperties.getResources(), errorProperties, applicationContext);
+    }
+
+    /**
+     * 统一处理异常信息
+     */
+    @Override
+    @SuppressWarnings(value = "unchecked")
+    protected Map<String, Object> getErrorAttributes(ServerRequest request, boolean includeStackTrace) {
+        Throwable error = super.getError(request);
+        //调用处理异常的方法，并将对象转换成map
+        return handlerCore.handlerException(error);
+    }
+
+    /**
+     * Extract the error attributes from the current request, to be used to populate error
+     * views or JSON payloads.
+     *
+     * @param request the source request
+     * @param options options to control error attributes
+     * @return the error attributes as a Map
+     */
+    @Override
+    protected Map<String, Object> getErrorAttributes(ServerRequest request, ErrorAttributeOptions options) {
+        Throwable error = super.getError(request);
+        return handlerCore.handlerException(error);
+    }
+
+    @Override
+    protected RouterFunction<ServerResponse> getRoutingFunction(ErrorAttributes errorAttributes) {
+        return RouterFunctions.route(RequestPredicates.all(), this::renderErrorResponse);
+    }
+
+    @Override
+    protected Mono<ServerResponse> renderErrorResponse(ServerRequest request) {
+        boolean includeStackTrace = isIncludeStackTrace(request, MediaType.ALL);
+        Map<String, Object> error = getErrorAttributes(request, includeStackTrace);
+        return ServerResponse
+                .status(getHttpStatus(error))
+                .contentType(MediaType.APPLICATION_JSON_UTF8)
+                .body(BodyInserters.fromObject(error.get("result")));
+    }
+
+    @Override
+    protected int getHttpStatus(Map<String, Object> errorAttributes) {
+        HttpStatus status = (HttpStatus) errorAttributes.get("status");
+        if (Objects.isNull(status)) {
+            return HttpStatus.OK.value();
+        }
+        return status.value();
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/interceptors/DecryptRequestionBodyFilter.java

@@ -1,8 +1,10 @@
 package com.xhkjedu.gateway.interceptors;
 
-import com.xhkjedu.gateway.utils.AES;
+import com.xhkjedu.gateway.exceptions.GatewayException;
+import com.xhkjedu.gateway.utils.*;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.gateway.filter.GatewayFilterChain;
 import org.springframework.cloud.gateway.filter.GlobalFilter;
 import org.springframework.cloud.gateway.filter.factory.rewrite.CachedBodyOutputMessage;
@@ -19,8 +21,7 @@ import org.springframework.util.AntPathMatcher;
 import org.springframework.util.CollectionUtils;
 import org.springframework.web.reactive.function.BodyInserter;
 import org.springframework.web.reactive.function.BodyInserters;
-import org.springframework.web.reactive.function.server.HandlerStrategies;
-import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.*;
 import org.springframework.web.server.ServerWebExchange;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -34,7 +35,11 @@ import java.util.List;
  **/
 @Component
 @Slf4j
-public class DecryptRequestionBodyFilter implements GlobalFilter, Ordered {
+public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilter, Ordered {
+    @Value("${Xh-St}")
+    private String xhSt;
+    @Value("${whitelistAPI}")
+    private String whitelistAPI;
 
     private static String AES_KEY = "XINGHUOLIAOYUAN7";
 
@@ -51,12 +56,28 @@ public class DecryptRequestionBodyFilter implements GlobalFilter, Ordered {
 //        log.info("HttpMethod:{},Url:{}", request.getMethod(), request.getURI().getRawPath());
         List<String> decrypts = headers.get("st");
         String decrypt = isListNotEmpty(decrypts)?decrypts.get(0):"false";
+        response.getHeaders().add("Xh-St", xhSt);
+        response.getHeaders().add("Access-Control-Expose-Headers","Xh-St");
+        Mono<Void> voidMono;
         if (!decrypt.equals("true")) {
-            return chain.filter(exchange);
+            voidMono = chain.filter(exchange);
         }else{
-            return readBody(exchange, chain);
+            voidMono = readBody(exchange, chain);
         }
 
+        String key = ApiUtil.listToStr(headers.get("Token-Key"));
+        String token = ApiUtil.listToStr(headers.get("Token-Value"));
+        if (!ApiUtil.whiteAPI(path, whitelistAPI)) {//非白名单接口验证token
+            String redis_token = get(key);//系统缓存中保存的token
+            if (ApiUtil.isEmpty(token) || !token.equals(redis_token)) {
+                GatewayException throwable = new GatewayException(2, "登录失效了");
+                return Mono.error(throwable);
+            } else {
+                refreshToken(key, redis_token);//刷新token
+            }
+        }
+        return voidMono;
+
 //        //  登录跳过网关验证，检查白名单（配置）最好把不拦截路径放入配置文件，此处通过正则
 //        if(antPathMatcher.match("/**/api/login/auth/**",path)){
 //            return readBody(exchange, chain);

gateway/src/main/java/com/xhkjedu/gateway/utils/ApiUtil.java

@@ -0,0 +1,128 @@
+package com.xhkjedu.gateway.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.CollectionUtils;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @ClassName ApiUtil
+ * Description api工具类
+ * Author WN
+ * Date 2022/2/21 11:08
+ **/
+@Slf4j
+public class ApiUtil {
+
+    /*
+    * @Description 比较当前时间和时间段
+    * @Author WN
+    * @Date 2023/6/15 11:24:59
+    */
+    public static boolean compareCurrDateTime(String starttimeStr,String stoptimeStr) throws Exception{
+        boolean rtn = false;
+        if(isEmpty(starttimeStr) || isEmpty(stoptimeStr)){
+            rtn = false;
+        }else{
+            SimpleDateFormat sdf = new SimpleDateFormat("MM-dd HH:mm");
+
+            Date starttime = sdf.parse(starttimeStr); //开始时间
+            Date stoptime = sdf.parse(stoptimeStr); //结束时间
+
+            Date nowtime = new Date();
+            String times = sdf.format(nowtime);
+            Date currtime = sdf.parse(times);//当前时间
+
+            //当前时间在开始时间之前或者等于开始时间  并且 当前时间在结束时间之后或者等于结束时间
+            if((starttime.before(currtime) || starttime.equals(currtime)) && (stoptime.after(currtime) || stoptime.equals(currtime))){
+                rtn = true;
+            }
+        }
+
+        return rtn;
+    }
+    /**
+     * 字符串是否为空
+     *
+     * @param: @param obj
+     * @param: @return
+     * @author WN
+     */
+    public static boolean isNotEmpty(Object obj) {
+        if (null == obj || "".equals(obj.toString().trim()) || "null".equals(obj.toString().trim())) {
+            return false;
+        } else {
+            return true;
+        }
+    }
+
+    /**
+     * 字符串是否为空
+     *
+     * @param: @param obj
+     * @param: @return
+     * @author zj
+     */
+    public static boolean isEmpty(Object obj) {
+        if (null == obj || "".equals(obj.toString().trim()) || "null".equals(obj.toString().trim())) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    /**
+     * @Description 是否是白名单接口
+     * @Date 2023/11/16 9:02
+     * @Author YWX
+     * @Param [requestURI, whitelistAPI]
+     * @Return boolean
+     **/
+    public static boolean whiteAPI(String requestURI, String whitelistAPI) {
+        boolean rtn = false;
+        if (isEmpty(whitelistAPI)) return rtn;
+
+        String[] apis = whitelistAPI.split(",");
+        for (String api : apis) {
+            if (requestURI.contains(api)) {
+                rtn = true;
+                break;
+            }
+        }
+        return rtn;
+    }
+
+    /**
+     * @Description 判断list是否不为空
+     * @Date 2023/11/16 9:01
+     * @Author YWX
+     * @Param [list]
+     * @Return boolean
+     **/
+    public static boolean isListNotEmpty(List list) {
+        if (CollectionUtils.isEmpty(list)){
+            return false;
+        } else {
+            return true;
+        }
+    }
+
+    /**
+     * @Description list转字符
+     * @Date 2023/11/16 9:01
+     * @Author YWX
+     * @Param [list]
+     * @Return java.lang.String
+     **/
+    public static String listToStr(List<String> list) {
+        String str = "";
+        if (isListNotEmpty(list)) {
+            for (String s : list) {
+                str += s;
+            }
+        }
+        return str;
+    }
+}

gateway/src/main/java/com/xhkjedu/gateway/utils/JedisUtil.java

@@ -0,0 +1,123 @@
+package com.xhkjedu.gateway.utils;
+
+import com.alibaba.fastjson.JSON;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author ywx
+ * @classname JedisUtil
+ * @description Redis工具类
+ * @date 2019/8/2 16:48
+ **/
+@Component
+public class JedisUtil {
+	@Autowired
+	private StringRedisTemplate stringRedisTemplate;
+	private ValueOperations<String, String> valueOperations;
+
+	@PostConstruct
+	public void init(){
+		this.valueOperations = stringRedisTemplate.opsForValue();
+	}
+
+	/**  默认过期时长，单位：秒 */
+	//redis失效时间
+	@Value("${redisdatatime}")
+	private Integer redisdatatime;
+	/**  不设置过期时长 */
+	public final static long NOT_EXPIRE = -1;
+
+	public boolean set(String key, Object value, Integer expire){
+		boolean rtn = false;
+		valueOperations.set(key, toJson(value));
+		if(expire != NOT_EXPIRE){
+			rtn = stringRedisTemplate.expire(key, expire, TimeUnit.SECONDS);
+		}
+		return rtn;
+	}
+
+	public void set(String key, Object value){
+		set(key, value, redisdatatime);
+	}
+
+	public Boolean setObject(String key, Object value, int cacheSeconds) {
+		String val = toJson(value);
+		return set(key,val,cacheSeconds);
+	}
+
+	public <T> T get(String key, Class<T> clazz, long expire) {
+		String value = valueOperations.get(key);
+		if(expire != NOT_EXPIRE){
+			stringRedisTemplate.expire(key, expire, TimeUnit.SECONDS);
+		}
+		return value == null ? null : fromJson(value, clazz);
+	}
+
+	public <T> T get(String key, Class<T> clazz) {
+		return get(key, clazz, NOT_EXPIRE);
+	}
+
+	public String get(String key, long expire) {
+		String value = valueOperations.get(key);
+		if (expire != NOT_EXPIRE) {
+			stringRedisTemplate.expire(key, expire, TimeUnit.SECONDS);
+		}
+		return value;
+	}
+
+	public String get(String key) {
+		try {
+			return get(key, NOT_EXPIRE);
+		} catch (Exception e) {
+			return "0";
+		}
+	}
+
+	//获取剩余有效期
+	public Long getExpire(String key) {
+		return stringRedisTemplate.getExpire(key);
+	}
+
+	//如果token有效期低于10分钟更新有效期
+	public void refreshToken(String key,String value) {
+		Long expire = getExpire(key);
+		if (expire <= 10 * 60) {
+			set(key, value);
+		}
+	}
+
+	public Object getObject(String key, Class<?> clazz) {
+		String value = get(key);
+		return fromJson(value, clazz);
+	}
+
+	public boolean delete(String key) {
+		return stringRedisTemplate.delete(key);
+	}
+
+	/**
+	 * Object转成JSON数据
+	 */
+	private String toJson(Object object){
+		if(object instanceof Integer || object instanceof Long || object instanceof Float ||
+				object instanceof Double || object instanceof Boolean || object instanceof String){
+			return String.valueOf(object);
+		}
+		return JSON.toJSONString(object);
+	}
+
+	/**
+	 * JSON数据，转成Object
+	 */
+	private <T> T fromJson(String json, Class<T> clazz){
+		return JSON.parseObject(json, clazz);
+	}
+
+}

gateway/src/main/resources/application.properties

@@ -66,3 +66,27 @@ logging.level.com.netflix=error
 
 #请求超时时间30s
 rq.overtime = 30000
+
+#接口是否加密
+Xh-St = false
+
+#redis配置
+spring.redis.host=cachetest.xhkjedu.com
+spring.redis.port=6379
+spring.redis.password=xhkjedud07
+#超时时间：单位ms
+spring.redis.timeout=5000
+#设置过期时间10min
+spring.redis.jedis.pool.max-idle=300
+#最大等待时间：单位ms //高版本改为maxWaitMillis
+spring.redis.jedis.pool.max-wait=1000000
+spring.redis.jedis.pool.max-active=60000
+#缓存访问数据有效时长60*60*24*7
+redisdatatime=604800
+
+#白名单接口
+whitelistAPI=user/login,/class_student/stu_class,/user/detail,/status/info,/user/qrg,/user/check_user\
+  ,/user/update_code,/user/update_pwd_byCode,/user/list_usecret,/user/check_usecret,/user/reset_pwd\
+  ,/get_new,/stype/list,/cloud/detail\
+  ,/pdf\
+  ,/section/get_zjr,/csw/add