spring aop实现接口参数变更前后对比和日志记录

package com.congge.utils; import okhttp3.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; import java.util.Iterator; import java.util.Map; @Component public class OkHttpUtils { private static final Logger logger = LoggerFactory.getLogger(OkHttpUtils.class); @Autowired private OkHttpClient okHttpClient; /** * @param url 请求的url * @param paramMap 请求的参数，在浏览器？后面的数据，没有可以传null * @return */ public String get(String url, Map<String, Object> paramMap) { paramCheck(url, paramMap); String resBody = ""; StringBuffer sb = new StringBuffer(url); boolean firstFlag = true; Iterator iterator = paramMap.entrySet().iterator(); while (iterator.hasNext()) { Map.Entry entry = (Map.Entry<String, String>) iterator.next(); if (firstFlag) { sb.append("?" + entry.getKey() + "=" + entry.getValue()); firstFlag = false; } else { sb.append("&" + entry.getKey() + "=" + entry.getValue()); } } Request request = new Request.Builder() .url(sb.toString()) .build(); Response response = null; try { response = okHttpClient.newCall(request).execute(); int status = response.code(); if(200 !=status){ throw new RuntimeException("调用失败"); } if (response.isSuccessful()) { return response.body().string(); } } catch (Exception e) { logger.error("okhttp3 put error >> ex = {}", e.getMessage()); } finally { if (response != null) { response.close(); } } return resBody; } private void paramCheck(String url, Map<String, Object> paramMap) { if(StringUtils.isEmpty(url)){ throw new RuntimeException("url不能为空"); } if(null == paramMap || paramMap.isEmpty()){ throw new RuntimeException("参数不能为空"); } } /** * post请求 * @param url * @param json * @return * @throws Exception */ public String post(String url, String json) throws Exception { RequestBody body = RequestBody.create(json, MediaType.get("application/json")); Request request = new Request.Builder() .url(url) .post(body) .build(); Response response = okHttpClient.newCall(request).execute(); return response.body().string(); } /** * post * * @param url 请求的url * @param params post form 提交的参数 * @return */ public String post(String url, Map<String, Object> params) { paramCheck(url, params); String responseBody = ""; FormBody.Builder builder = new FormBody.Builder(); //添加参数 if (params != null && params.keySet().size() > 0) { for (String key : params.keySet()) { builder.add(key, params.get(key).toString()); } } Request request = new Request.Builder() .url(url) .post(builder.build()) .addHeader("Content-Type", "application/json") .build(); Response response = null; try { response = okHttpClient.newCall(request).execute(); int status = response.code(); if(200 !=status){ throw new RuntimeException("调用失败"); } if (response.isSuccessful()) { return response.body().string(); } } catch (Exception e) { logger.error("okhttp3 post error >> ex = {}", e.getMessage()); } finally { if (response != null) { response.close(); } } return responseBody; } /** * @param url 请求的url * @param paramMap 请求的参数，在浏览器？后面的数据，没有可以传null * @return */ public String getForHeader(String url, Map<String, Object> paramMap) { paramCheck(url,paramMap); String responseBody = ""; StringBuffer sb = new StringBuffer(url); boolean firstFlag = true; Iterator iterator = paramMap.entrySet().iterator(); while (iterator.hasNext()) { Map.Entry entry = (Map.Entry<String, String>) iterator.next(); if (firstFlag) { sb.append("?" + entry.getKey() + "=" + entry.getValue()); firstFlag = false; } else { sb.append("&" + entry.getKey() + "=" + entry.getValue()); } } Request request = new Request.Builder() .addHeader("key", "value") .url(sb.toString()) .build(); Response response = null; try { response = okHttpClient.newCall(request).execute(); int status = response.code(); if(200 !=status){ throw new RuntimeException("调用失败"); } if (response.isSuccessful()) { return response.body().string(); } } catch (Exception e) { logger.error("okhttp3 put error >> ex = {}", e.getMessage()); } finally { if (response != null) { response.close(); } } return responseBody; } /** * Post请求发送JSON数据....{"name":"zhangsan","pwd":"123456"} * 参数一：请求Url * 参数二：请求的JSON * 参数三：请求回调 */ public String postJsonParams(String url, String jsonParams) { String responseBody = ""; RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), jsonParams); Request request = new Request.Builder() .url(url) .post(requestBody) .build(); Response response = null; try { response = okHttpClient.newCall(request).execute(); int status = response.code(); if(200 !=status){ throw new RuntimeException("调用失败"); } if (response.isSuccessful()) { return response.body().string(); } } catch (Exception e) { logger.error("okhttp3 post error >> ex = {}", e.getMessage()); } finally { if (response != null) { response.close(); } } return responseBody; } /** * Post请求发送xml数据.... * 参数一：请求Url * 参数二：请求的xmlString * 参数三：请求回调 */ public String postXmlParams(String url, String xml) { String responseBody = ""; RequestBody requestBody = RequestBody.create(MediaType.parse("application/xml; charset=utf-8"), xml); Request request = new Request.Builder() .url(url) .post(requestBody) .build(); Response response = null; try { response = okHttpClient.newCall(request).execute(); int status = response.code(); if(200 !=status){ throw new RuntimeException("调用失败"); } if (response.isSuccessful()) { return respo