• JAVA反射机制实现调用类的方法

    NmsMonitorDrillController

    1. package com.nrxt.nms.mon.ms.controller;
    2.  
    3. import com.nrxt.nms.mon.ms.service.impl.NmsMonitorDrillService;
    4. import com.nrxt.nms.mon.ms.utils.ByteArrayUtil;
    5. import org.apache.log4j.Logger;
    6. import org.springframework.stereotype.Controller;
    7. import org.springframework.web.bind.annotation.RequestBody;
    8. import org.springframework.web.bind.annotation.RequestMapping;
    9. import org.springframework.web.bind.annotation.RequestMethod;
    10. import org.springframework.web.bind.annotation.ResponseBody;
    11. import javax.annotation.Resource;
    12. import javax.servlet.http.HttpServletRequest;
    13. import javax.servlet.http.HttpServletResponse;
    14. import java.io.IOException;
    15.  
    16. @Controller
    17. @RequestMapping(value = "/monitor/interface")
    18. public class NmsMonitorDrillController {
    19.  
    20.     @Resource
    21.     NmsMonitorDrillService nmsMonitorDrillService;
    22.  
    23.     private static final Logger logger = Logger.getLogger(NmsMonitorDrillController.class);
    24.  
    25.     @ResponseBody
    26.     @RequestMapping(value = "/queryByDrillReceive", method = RequestMethod.POST)
    27.     public byte[] queryByDrillReceive(HttpServletRequest request, HttpServletResponse response) {
    28.         String param;
    29.         try {
    30.             param = ByteArrayUtil.inputStreamToObject(request.getInputStream(), logger).toString();
    31.             if (param == null) {
    32.                 return null;
    33.             }
    34.         } catch (IOException e) {
    35.             e.printStackTrace();
    36.             return null;
    37.         }
    38.  
    39.         String responseStr = nmsMonitorDrillService.queryByDrillReceive(param);
    40.         return ByteArrayUtil.objectToByteArray(responseStr, logger);
    41.     }
    42.  
    43.     
    44.     @ResponseBody
    45.     @RequestMapping(value = "/queryByDrillSend", method = RequestMethod.POST)
    46.     public String queryByDrillSend(HttpServletRequest request, @RequestBody String param) {
    47.         return nmsMonitorDrillService.queryByDrillSend(param);
    48.     }
    49. }

    NmsMonitorDrillService

    1. package com.nrxt.nms.mon.ms.service.impl;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.nrxt.nms.mon.ms.dao.NmsAppConfDao;
    5. import com.nrxt.nms.mon.ms.utils.ByteArrayUtil;
    6. import com.nrxt.nms.mon.ms.utils.DrillUtils;
    7. import org.apache.commons.lang.StringUtils;
    8. import org.apache.log4j.Logger;
    9. import org.springframework.beans.factory.annotation.Autowired;
    10. import org.springframework.context.ApplicationContext;
    11. import org.springframework.stereotype.Service;
    12. import org.springframework.web.client.RestTemplate;
    13. import javax.annotation.Resource;
    14. import javax.servlet.http.HttpServletResponse;
    15. import java.lang.reflect.InvocationTargetException;
    16. import java.lang.reflect.Method;
    17.  
    18. @Service
    19. public class NmsMonitorDrillService {
    20.     @Resource
    21.     NmsAppConfDao nmsAppConfDao;
    22.  
    23.     @Autowired
    24.     private RestTemplate restTemplate;
    25.  
    26.     @Autowired
    27.     private ApplicationContext applicationContext;
    28.  
    29.     private static final Logger logger = Logger.getLogger(NmsMonitorDrillService.class);
    30.  
    31.     public String queryByDrillSend(String param) {
    32.         JSONObject requestParam = JSONObject.parseObject(param);
    33.         JSONObject requestHead = requestParam.getJSONObject("head");
    34.         String bgId = requestHead.getString("bgId");
    35.         if (StringUtils.isEmpty(bgId)) {
    36.             return "bgId can not be null";
    37.         }
    38.         String corpCode = requestHead.getString("corpCode");
    39.         if (StringUtils.isEmpty(corpCode)) {
    40.             return "corpCode can not be null";
    41.         }
    42. 		String drillUrl = "http://127.0.0.1:30098/monitor/interface/queryByDrillReceive";
    43.         drillUrl = nmsAppConfDao.queryBgPathByBgCode(corpCode);
    44.  
    45.         byte[] compressedDatas = ByteArrayUtil.objectToByteArray(param, logger);
    46.  
    47.         String uploadResult = DrillUtils.tryUpload(compressedDatas, drillUrl,restTemplate ,logger).toString();
    48.  
    49.         return uploadResult;
    50.     }
    51.  
    52.     public String queryByDrillReceive(String param){
    53.         JSONObject requestParam = JSONObject.parseObject(param);
    54.         JSONObject requestHead = requestParam.getJSONObject("head");
    55.  
    56.         String result = null;
    57.         // 获取类的全路径以及名称
    58.         String className = requestHead.get("className").toString();
    59.         if(!className.contains(".")){
    60.             className = "com.nrxt.nms.mon.ms.controller." + className;
    61.         }
    62.         // 获取方法名
    63.         String functionName = requestHead.get("functionName").toString();
    64.         try {
    65.             Object classBean = applicationContext.getBean(Class.forName(className));
    66.             // 获取class文件
    67.             Class clazz = classBean.getClass();
    68.             // 获取该类所需求的方法
    69.             Method method = clazz.getMethod(functionName, HttpServletResponse.class,String.class);
    70.  
    71.             result = method.invoke(classBean,null,param).toString();
    72.         } catch (NoSuchMethodException e) {
    73.             e.printStackTrace();
    74.         } catch (IllegalAccessException e) {
    75.             e.printStackTrace();
    76.         } catch (InvocationTargetException e) {
    77.             e.printStackTrace();
    78.         } catch (ClassNotFoundException e) {
    79.             e.printStackTrace();
    80.         }
    81.  
    82.         return result;
    83.     }
    84. }

    DrillUtils

    1. package com.nrxt.nms.mon.ms.utils;
    2.  
    3. import com.xxl.job.core.log.XxlJobLogger;
    4. import org.apache.log4j.Logger;
    5. import org.springframework.http.HttpEntity;
    6. import org.springframework.http.HttpHeaders;
    7. import org.springframework.http.HttpMethod;
    8. import org.springframework.http.ResponseEntity;
    9. import org.springframework.web.client.RestTemplate;
    10.  
    11. public class DrillUtils {
    12.     public static Object tryUpload(byte[] compressedDatas, String url, RestTemplate restTemplate, Logger logger) {
    13.         Object result = null;
    14.         HttpHeaders headers = new HttpHeaders();
    15.         headers.add("Content-Type", "application/json");
    16.         headers.add("Content-Encoding", "gzip");
    17.         headers.add("Accept", "application/json");
    18.         HttpEntity<byte[]> entity = new HttpEntity(compressedDatas, headers);
    19.  
    20.         ResponseEntity<byte[]> exchange;
    21.         for (int i = 0; i < 3; i++) {//重连3次
    22.             exchange = postByteMsg(url, restTemplate,entity);
    23.             if (exchange != null) {
    24.                 byte[] returnResult = exchange.getBody();
    25.                 if (returnResult != null) {
    26.                     return com.nrxt.nms.mon.ms.utils.ByteArrayUtil.byteArrayToObject(exchange.getBody(), logger);
    27.                 }
    28.                 break;
    29.             } else {
    30.                 XxlJobLogger.log("尝试第" + (i + 1) + "次发送");
    31.             }
    32.         }
    33.         return result;
    34.     }
    35.  
    36.     private static ResponseEntity<byte[]> postByteMsg(String url, RestTemplate restTemplate, HttpEntity<byte[]> entity) {
    37.         try {
    38.             return restTemplate.exchange(url, HttpMethod.POST, entity, byte[].class);
    39.         } catch (Exception e) {
    40.             XxlJobLogger.log("发送错误:");
    41.             XxlJobLogger.log(e);
    42.             return null;
    43.         }
    44.     }
    45. }

    ByteArrayUtil

    1. package com.nrxt.nms.mon.ms.utils;
    2.  
    3. import org.apache.commons.codec.binary.Base64;
    4. import org.apache.log4j.Logger;
    5. import javax.servlet.ServletInputStream;
    6. import java.io.*;
    7. import java.util.HashMap;
    8. import java.util.Map;
    9. import java.util.zip.GZIPInputStream;
    10. import java.util.zip.GZIPOutputStream;
    11.  
    12. public class ByteArrayUtil {
    13.  
    14. 	/**
    15. 	 * Object转为byte[]
    16. 	 * 
    17. 	 * @param obj
    18. 	 * @return
    19. 	 * @throws IOException
    20. 	 */
    21. 	public static byte[] objectToByteArray(Object obj, Logger logger) {
    22. 		byte[] bytes = null;
    23. 		ByteArrayOutputStream byteArrayOutputStream = null;
    24. 		GZIPOutputStream gzipOutputStream = null;
    25. 		ObjectOutputStream objectOutputSream = null;
    26. 		byteArrayOutputStream = new ByteArrayOutputStream();
    27. 		try {
    28. 			gzipOutputStream = new GZIPOutputStream(byteArrayOutputStream);
    29. 			objectOutputSream = new ObjectOutputStream(gzipOutputStream);
    30. 			objectOutputSream.writeObject(obj);
    31. 			objectOutputSream.flush();
    32. 			objectOutputSream.close();
    33. 			objectOutputSream = null;
    34. 			gzipOutputStream.close();
    35. 			gzipOutputStream = null;
    36. 			bytes = byteArrayOutputStream.toByteArray();
    37. 			byteArrayOutputStream.close();
    38. 			byteArrayOutputStream = null;
    39. 		} catch (IOException e) {
    40. 			e.printStackTrace();
    41. 			if (logger != null)
    42. 				logger.error("消息序列化+压缩失败", e);
    43. 		} finally {
    44. 			if (objectOutputSream != null) {
    45. 				try {
    46. 					objectOutputSream.close();
    47. 				} catch (IOException e) {
    48.  
    49. 				}
    50. 			}
    51. 			if (gzipOutputStream != null) {
    52. 				try {
    53. 					gzipOutputStream.close();
    54. 				} catch (IOException e) {
    55.  
    56. 				}
    57. 			}
    58. 			if (byteArrayOutputStream != null) {
    59. 				try {
    60. 					byteArrayOutputStream.close();
    61. 				} catch (IOException e) {
    62.  
    63. 				}
    64. 			}
    65. 		}
    66. 		return bytes;
    67. 	}
    68.  
    69. 	/**
    70. 	 * byte[]转为Object
    71. 	 * 
    72. 	 * @param bytes
    73. 	 * @return
    74. 	 * @throws IOException
    75. 	 * @throws ClassNotFoundException
    76. 	 */
    77. 	public static Object byteArrayToObject(byte[] bytes, Logger logger) {
    78. 		Object obj = null;
    79. 		ByteArrayInputStream inputStream = null;
    80. 		GZIPInputStream gzin = null;
    81. 		ObjectInputStream objInt = null;
    82. 		try {
    83. 			inputStream = new ByteArrayInputStream(bytes);
    84. 			gzin = new GZIPInputStream(inputStream);
    85. 			objInt = new ObjectInputStream(gzin);
    86. 			obj = objInt.readObject();
    87. 		} catch (IOException | ClassNotFoundException e) {
    88. 			e.printStackTrace();
    89. 			if (logger != null)
    90. 				logger.error("消息解压缩+反序列化失败", e);
    91. 		} finally {
    92. 			if (objInt != null)
    93. 				try {
    94. 					objInt.close();
    95. 				} catch (IOException e) {
    96.  
    97. 				}
    98. 			if (gzin != null)
    99. 				try {
    100. 					gzin.close();
    101. 				} catch (IOException e) {
    102.  
    103. 				}
    104. 			if (inputStream != null)
    105. 				try {
    106. 					inputStream.close();
    107. 				} catch (IOException e) {
    108.  
    109. 				}
    110. 		}
    111. 		return obj;
    112. 	}
    113.  
    114. 	public static Object inputStreamToObject(ServletInputStream inputStream, Logger logger) {
    115. 		Object obj = null;
    116. 		GZIPInputStream gzin = null;
    117. 		ObjectInputStream objInt = null;
    118. 		try {
    119. 			gzin = new GZIPInputStream(inputStream);
    120. 			objInt = new ObjectInputStream(gzin);
    121. 			obj = objInt.readObject();
    122. 		} catch (IOException | ClassNotFoundException e) {
    123. 			e.printStackTrace();
    124. 			if (logger != null)
    125. 				logger.error("消息解压缩+反序列化失败", e);
    126. 		} finally {
    127. 			if (objInt != null)
    128. 				try {
    129. 					objInt.close();
    130. 				} catch (IOException e) {
    131.  
    132. 				}
    133. 			if (gzin != null)
    134. 				try {
    135. 					gzin.close();
    136. 				} catch (IOException e) {
    137.  
    138. 				}
    139. 			if (inputStream != null)
    140. 				try {
    141. 					inputStream.close();
    142. 				} catch (IOException e) {
    143.  
    144. 				}
    145. 		}
    146. 		return obj;
    147. 	}
    148. }

  • 相关阅读:
    ubuntu 18.04 安装jdk
    MATLAB算法实战应用案例精讲-【数模应用】理想解法（TOPSIS）（附MATLAB和Python代码）
    docker介绍、安装及卸载
    docker镜像配置mysql、redis
    Spring_IOC
    stable diffusion学习笔记【2023-10-2】
    TiDB 集群故障诊断
    Qt学习26 布局管理综合实例
    去外地旅游遇到的问题和心得
    半同态加密(Partially Homomorphic Encryption, PHE)
  • 原文地址：https://blog.csdn.net/qq_41482600/article/details/134328045