spring 统一再处理接口返回的json数据

import java.lang.reflect.Constructor; import java.util.ArrayList; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.MethodParameter; import org.springframework.http.MediaType; import org.springframework.http.server.ServerHttpRequest; import org.springframework.http.server.ServerHttpResponse; import org.springframework.web.bind.annotation.ControllerAdvice; import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; import com.ssss.annotation.NeedEditResponseBody; import com.ssss.entity.JsonResultUtil; @ControllerAdvice public class MyResponseBodyAdvice implements ResponseBodyAdvice{ protected Logger logger = LoggerFactory.getLogger(this.getClass()); @Override public Object beforeBodyWrite(Object returnValue, MethodParameter arg1, MediaType arg2, Class arg3, ServerHttpRequest arg4, ServerHttpResponse arg5) { if(returnValue instanceof JsonResultUtil) { try { JsonResultUtil msg=(JsonResultUtil) returnValue; if(msg.get("data") instanceof ArrayList) { logger.info("MyResponseBodyAdvice getTypeName-->" + msg.get("data").getClass().getTypeName()); String data = new Gson().toJson(msg.get("data")); if(data.contains("http://znx.****.com")) { Gson gson1=new Gson(); logger.info("msg.get(\"data\").getClass().getTypeName()-->" + msg.get("data").getClass().getTypeName()); List list= gson1.fromJson(data.replaceAll("http://znx.****.com", "http://znxcdn.****.com"), new TypeToken<List>() {}.getType()); msg.put("data", list); } }else if(msg.containsKey("data") && msg.get("data") != null) { logger.info("MyResponseBodyAdvice getTypeName-->" + msg.get("data").getClass().getTypeName()); String data = new Gson().toJson(msg.get("data")); String className = msg.get("data").getClass().getTypeName(); Class pClass=Class.forName(className); //构造器 Constructor c= pClass.getConstructor(); //通过构造器实例化 Object obj = c.newInstance(); if(data.contains("http://znx.*****.com")) { Gson gson1=new Gson(); logger.info("msg.get(\"data\").getClass().getTypeName()-->" + msg.get("data").getClass().getTypeName()); obj = gson1.fromJson(data.replaceAll("http://znx.****.com", "http://znxcdn.****.com"), obj.getClass()); msg.put("data", obj); } } }catch(Exception e) { e.printStackTrace(); logger.info("MyResponseBodyAdvice 出错-->" + e.getMessage()); } } logger.info("MyResponseBodyAdvice-->" + new Gson().toJson(returnValue)); //统一修改返回值/响应体 //返回修改后的值 return returnValue; } @Override public boolean supports(MethodParameter arg0, Class arg1) { NeedEditResponseBody anno = arg0.getMethod().getAnnotation(NeedEditResponseBody.class); logger.info("NeedEditResponseBody --->" + anno); if(anno != null) { //只有方法上有NeedEditResponseBody，才会对json数据进行再处理，将资源改为cdn资源 return true; } return false; } }