项目初始化

datax-common/datax-common-redis/src/main/java/cn/datax/common/redis/annotation/RedisCacheAop.java

+package cn.datax.common.redis.annotation;
+
+import java.lang.annotation.*;
+
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface RedisCacheAop {
+
+    // 缓存名
+    String cacheName() default "";
+    // 过期时间(秒) time要大于0 如果time小于等于0 将设置无限期
+    long expire() default -1;
+    // 缓存反序列化获取的对象
+    Class clazz() default Object.class;
+    // 序列化后的对象是否是数组 比如 List<Object>
+    boolean isArray() default false;
+}

datax-common/datax-common-redis/src/main/java/cn/datax/common/redis/aspectj/RedisCacheAspect.java

+package cn.datax.common.redis.aspectj;
+
+import cn.datax.common.redis.annotation.RedisCacheAop;
+import com.fasterxml.jackson.databind.JavaType;
+import com.fasterxml.jackson.databind.ObjectMapper;
+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.aspectj.lang.reflect.MethodSignature;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import java.lang.reflect.Method;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+@Aspect
+@Slf4j
+public class RedisCacheAspect {
+
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+    @Autowired
+    private ObjectMapper objectMapper;
+
+    /**
+     * 分隔符 生成key 格式为 类全类名|方法名|参数所属类全类名
+     */
+    private static final String DELIMITER = ":";
+
+    /**
+     * Service层切点 使用到了我们定义的 RedisCacheAspect 作为切点表达式。
+     * 而且我们可以看出此表达式基于 annotation。
+     * 并且用于内建属性为查询的方法之上
+     */
+    @Pointcut("@annotation(cn.datax.common.redis.annotation.RedisCacheAop)")
+    public void redisCacheAspect() {
+    }
+
+    /**
+     * Around 手动控制调用核心业务逻辑，以及调用前和调用后的处理,
+     * <p>
+     * 注意：当核心业务抛异常后，立即退出，转向AfterAdvice 执行完AfterAdvice，再转到ThrowingAdvice
+     */
+    @Around(value = "redisCacheAspect()")
+    public Object aroundAdvice(ProceedingJoinPoint joinPoint) throws Throwable {
+        // 得到类名、方法名和参数
+        String clazzName = joinPoint.getTarget().getClass().getName();
+        String methodName = joinPoint.getSignature().getName();
+        Object[] args = joinPoint.getArgs();
+
+        // 根据类名、方法名和参数生成Key
+        log.info("key参数: " + clazzName + "." + methodName);
+        String key = getKey(clazzName, methodName, args);
+        log.info("生成key: " + key);
+
+        // 得到被代理的方法
+        Method method = ((MethodSignature) joinPoint.getSignature()).getMethod();
+
+        String cacheName = method.getAnnotation(RedisCacheAop.class).cacheName();
+
+        long expire = method.getAnnotation(RedisCacheAop.class).expire();
+
+        Class objectType = method.getAnnotation(RedisCacheAop.class).clazz();
+
+        boolean isArray = method.getAnnotation(RedisCacheAop.class).isArray();
+
+        // 检查Redis中是否有缓存
+        String value = (String) redisTemplate.opsForValue().get(key + DELIMITER + cacheName);
+
+        // result是方法的最终返回结果
+        Object result = null;
+        try {
+            if (null == value) {
+                log.info("缓存未命中");
+                // 调用数据库查询方法
+                result = joinPoint.proceed(args);
+                // 结果放入缓存
+                if (expire > 0) {
+                    redisTemplate.opsForValue().set(key + DELIMITER + cacheName, objectMapper.writeValueAsString(result), expire, TimeUnit.SECONDS);
+                } else {
+                    redisTemplate.opsForValue().set(key + DELIMITER + cacheName, objectMapper.writeValueAsString(result));
+                }
+            } else {
+                /**
+                 * 可以直接针对mapper进行缓存，如果mapper查询返回的List<Objec> 需要isArray 为true 否则转换异常
+                 */
+                if (isArray){
+                    JavaType javaType = objectMapper.getTypeFactory().constructCollectionType(List.class, objectType);
+                    return objectMapper.readValue(value, javaType);
+                }else {
+                    return objectMapper.readValue(value, objectType);
+                }
+            }
+        } catch (Throwable e) {
+            log.error("程序异常", e.getMessage());
+            throw e;
+        }
+        return result;
+    }
+
+    /**
+     * 根据类名、方法名和参数生成Key
+     * @param clazzName
+     * @param methodName
+     * @param args
+     * @return key格式：全类名:方法名:参数类型
+     */
+    private String getKey(String clazzName, String methodName, Object[] args) {
+        StringBuilder key = new StringBuilder(clazzName);
+        key.append(DELIMITER);
+        key.append(methodName);
+        key.append(DELIMITER);
+        key.append(Arrays.stream(args).map(x -> x.toString()).collect(Collectors.joining(DELIMITER)));
+        return key.toString();
+    }
+}

datax-common/datax-common-redis/src/main/resources/META-INF/spring.factories

 org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
   cn.datax.common.redis.config.RedisConfig,\
-  cn.datax.common.redis.config.RedissonConfig
+  cn.datax.common.redis.config.RedissonConfig,\
+  cn.datax.common.redis.aspectj.RedisCacheAspect

datax-modules/data-market-service-parent/data-market-service-api-mapping/pom.xml

@@ -84,6 +84,11 @@
             <artifactId>datax-common-rabbitmq</artifactId>
             <version>2.0.0</version>
         </dependency>
+        <dependency>
+            <groupId>com.thoughtworks.xstream</groupId>
+            <artifactId>xstream</artifactId>
+            <version>${xstream.vsersion}</version>
+        </dependency>
     </dependencies>
 
     <build>

datax-modules/data-market-service-parent/data-market-service-api-mapping/src/main/java/cn/datax/service/data/market/api/mapping/handler/RequestHandler.java

@@ -6,11 +6,14 @@ import cn.datax.common.database.core.PageResult;
 import cn.datax.common.utils.ThrowableUtil;
 import cn.datax.service.data.market.api.dto.ApiLogDto;
 import cn.datax.service.data.market.api.entity.DataApiEntity;
+import cn.datax.service.data.market.api.enums.ResType;
 import cn.datax.service.data.market.api.mapping.service.ApiLogService;
 import cn.datax.service.data.market.api.mapping.service.impl.ApiMappingEngine;
 import cn.datax.service.data.market.api.mapping.utils.ThreadUtil;
 import cn.hutool.core.map.MapUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.thoughtworks.xstream.XStream;
+import com.thoughtworks.xstream.io.xml.StaxDriver;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -83,7 +86,13 @@ public class RequestHandler {
             requestInterceptor.postHandle(request, response, api, params, value);
             ThreadUtil.getInstance().get().setCallerSize(value.getData().size());
             ThreadUtil.getInstance().get().setTime(System.currentTimeMillis() - start);
-            return R.ok().setData(value);
+            R r = R.ok().setData(value);
+            if (ResType.XML.getDesc().equals(api.getResType())) {
+                XStream xstream = new XStream(new StaxDriver());
+                xstream.alias("R", R.class);
+                return xstream.toXML(r);
+            }
+            return r;
         } catch (Exception e) {
             log.error("全局异常信息ex={}, StackTrace={}", e.getMessage(), ThrowableUtil.getStackTrace(e));
             ThreadUtil.getInstance().get().setStatus(DataConstant.EnableState.DISABLE.getKey());

datax-modules/data-market-service-parent/data-market-service-api/src/main/java/cn/datax/service/data/market/api/enums/ResType.java

@@ -2,7 +2,8 @@ package cn.datax.service.data.market.api.enums;
 
 public enum ResType {
 
-    JSON("JSON");
+    JSON("JSON"),
+    XML("XML");
 
     private String desc;
 

pom.xml

@@ -57,6 +57,7 @@
     <jasperreports.version>6.12.2</jasperreports.version>
     <mybatis-spring.version>2.1.2</mybatis-spring.version>
     <bitwalker.version>1.21</bitwalker.version>
+    <xstream.vsersion>1.4.12</xstream.vsersion>
   </properties>
 
   <modules>