[关闭]
@liruiyi962464 2024-08-05T18:51:16.000000Z 字数 8758 阅读 52

后端通过POST互相调用 参考文档

代码

HttpClientUtils 工具类

  1. package org.jeecg.modules.untils;
  3. import com.fasterxml.jackson.databind.ObjectMapper;
  4. import org.apache.http.HttpResponse;
  5. import org.apache.http.NameValuePair;
  6. import org.apache.http.client.HttpClient;
  7. import org.apache.http.client.config.RequestConfig;
  8. import org.apache.http.client.entity.UrlEncodedFormEntity;
  9. import org.apache.http.client.methods.HttpGet;
  10. import org.apache.http.client.methods.HttpPost;
  11. import org.apache.http.entity.StringEntity;
  12. import org.apache.http.impl.client.CloseableHttpClient;
  13. import org.apache.http.impl.client.HttpClientBuilder;
  14. import org.apache.http.impl.client.HttpClients;
  15. import org.apache.http.message.BasicHeader;
  16. import org.apache.http.message.BasicNameValuePair;
  17. import org.apache.http.util.EntityUtils;
  18. import org.apache.logging.log4j.LogManager;
  19. import org.apache.logging.log4j.Logger;
  21. import java.io.IOException;
  22. import java.net.URI;
  23. import java.net.URISyntaxException;
  24. import java.util.ArrayList;
  25. import java.util.Map;
  26. import java.util.Set;
  28. public class HttpClientUtils {
  29.     private static final Logger logger = LogManager.getLogger(HttpClientUtils.class);
  32.     /**
  33.      * 封装POST请求（Map入参）
  34.      *
  35.      * @param url 请求的路径
  36.      * @param map 请求的参数
  37.      * @return
  38.      * @throws IOException
  39.      */
  40.     public static String post(String url, Map map) throws IOException {
  41. //        1、创建HttpClient对象
  42.         CloseableHttpClient httpClient = HttpClients.createDefault();
  43. //        2、创建请求方式的实例
  44.         HttpPost httpPost = new HttpPost();
  45.         //httpPost.addHeader(new BasicHeader("Content-Type", "application/json"));
  46.         //httpPost.addHeader(new BasicHeader("Authorization", "Bearer your_access_token_here"));
  48.         try {
  49.             httpPost.setURI(new URI(url));
  50.         } catch (URISyntaxException e) {
  51.             e.printStackTrace();
  52.         }
  53. //        3、添加请求参数(设置请求和传输超时时间)
  54.         RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(60000).setConnectTimeout(60000).build();
  55.         httpPost.setConfig(requestConfig);
  57.         ArrayList<NameValuePair> list = new ArrayList<>();
  58.         Set<Map.Entry> entrySet = map.entrySet();
  59.         for (Map.Entry entry : entrySet) {
  60.             String key = entry.getKey().toString();
  61.             String value = entry.getValue().toString();
  62.             list.add(new BasicNameValuePair(key, value));
  63.         }
  65.         //System.out.println("canshu:"+list.toString());
  66.         httpPost.setEntity(new UrlEncodedFormEntity(list, org.apache.http.protocol.HTTP.UTF_8));
  68.         System.out.println(httpPost.getEntity().toString());;
  69. //        4、发送Http请求
  70.         HttpResponse response = httpClient.execute(httpPost);
  71. //        5、获取返回的内容
  72.         String result = null;
  73.         int statusCode = response.getStatusLine().getStatusCode();
  74.         if (200 == statusCode) {
  75.             result = EntityUtils.toString(response.getEntity());
  76.         } else {
  77.             logger.info("请求第三方接口出现错误，状态码为:{}", statusCode);
  78.             return null;
  79.         }
  80. //        6、释放资源
  81.         httpPost.abort();
  82.         httpClient.getConnectionManager().shutdown();
  83.         return result;
  84.     }
  86.     /**
  87.      * 封装POST请求（String入参）
  88.      *
  89.      * @param url  请求的路径
  90.      * @param data String类型数据
  91.      * @return
  92.      * @throws IOException
  93.      */
  94.     public static String post(String url, String data) throws IOException {
  95. //        1、创建HttpClient对象
  96.         HttpClient httpClient = HttpClientBuilder.create().build();
  97. //        2、创建请求方式的实例
  98.         HttpPost httpPost = new HttpPost(url);
  99. //        3、添加请求参数(设置请求和传输超时时间)
  100.         RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(60000).setConnectTimeout(60000).build();
  101.         httpPost.setConfig(requestConfig);
  102.         httpPost.setHeader("Accept", "application/json");
  103.         httpPost.setHeader("Content-Type", "application/json");
  104. //        设置请求参数
  105.         httpPost.setEntity(new StringEntity(data, "UTF-8"));
  106. //        4、发送Http请求
  107.         HttpResponse response = httpClient.execute(httpPost);
  108. //        5、获取返回的内容
  109.         String result = null;
  110.         int statusCode = response.getStatusLine().getStatusCode();
  111.         if (200 == statusCode) {
  112.             result = EntityUtils.toString(response.getEntity());
  113.         } else {
  114.             logger.info("请求第三方接口出现错误，状态码为:{}", statusCode);
  115.             return null;
  116.         }
  117. //        6、释放资源
  118.         httpPost.abort();
  119.         httpClient.getConnectionManager().shutdown();
  120.         return result;
  121.     }
  123.     /**
  124.      * 封装GET请求
  125.      *
  126.      * @param url
  127.      * @return
  128.      * @throws IOException
  129.      */
  130.     public static String get(String url) throws IOException {
  131. //        1、创建HttpClient对象
  132.         HttpClient httpClient = HttpClientBuilder.create().build();
  133. //        2、创建请求方式的实例
  134.         HttpGet httpGet = new HttpGet(url);
  135. //        3、添加请求参数(设置请求和传输超时时间)
  136.         RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(60000).setConnectTimeout(60000).build();
  137.         httpGet.setConfig(requestConfig);
  138. //        4、发送Http请求
  139.         HttpResponse response = httpClient.execute(httpGet);
  140. //        5、获取返回的内容
  141.         String result = null;
  142.         int statusCode = response.getStatusLine().getStatusCode();
  143.         if (200 == statusCode) {
  144.             result = EntityUtils.toString(response.getEntity());
  145.         } else {
  146.             logger.info("请求第三方接口出现错误，状态码为:{}", statusCode);
  147.             return null;
  148.         }
  149. //        6、释放资源
  150.         httpGet.abort();
  151.         httpClient.getConnectionManager().shutdown();
  152.         return result;
  153.     }
  156.     /**
  157.      * 封装POST请求（Map入参）--lry
  158.      *
  159.      * @param url 请求的路径
  160.      * @param map 请求的参数
  161.      * @return
  162.      * @throws IOException
  163.      */
  164.     public static String postJSon(String url, Map map) throws IOException {
  165. //        1、创建HttpClient对象
  166.         CloseableHttpClient httpClient = HttpClients.createDefault();
  167. //        2、创建请求方式的实例
  168.         HttpPost httpPost = new HttpPost();
  169.         httpPost.addHeader(new BasicHeader("Content-Type", "application/json"));
  170.         //httpPost.addHeader(new BasicHeader("Authorization", "Bearer your_access_token_here"));
  172.         try {
  173.             httpPost.setURI(new URI(url));
  174.         } catch (URISyntaxException e) {
  175.             e.printStackTrace();
  176.         }
  177. //        3、添加请求参数(设置请求和传输超时时间)
  178.         RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(60000).setConnectTimeout(60000).build();
  179.         httpPost.setConfig(requestConfig);
  180.         ObjectMapper mapper = new ObjectMapper(); // 创建 ObjectMapper 对象，用于 JSON 序列化和反序列化
  181. // 序列化对象为 JSON 字符串
  182.         String jsonString = mapper.writeValueAsString(map);
  183.         StringEntity entity = new StringEntity(jsonString, "UTF-8");
  184.         httpPost.setEntity(entity);
  185. //        4、发送Http请求
  186.         HttpResponse response = httpClient.execute(httpPost);
  187. //        5、获取返回的内容
  188.         String result = null;
  189.         int statusCode = response.getStatusLine().getStatusCode();
  190.         if (200 == statusCode) {
  191.             result = EntityUtils.toString(response.getEntity());
  192.         } else {
  193.             logger.info("请求第三方接口出现错误，状态码为:{}", statusCode);
  194.             return null;
  195.         }
  196. //        6、释放资源
  197.         httpPost.abort();
  198.         httpClient.getConnectionManager().shutdown();
  199.         return result;
  200.     }
  201. }

方案一 使用工具类原方法 封装POST请求（Map入参）

java1 调用

  1.     //推送数据给文件传输系统  2024-8-1 muzi
  2.     private void  pushDataForWenJian(YwTicketBasic ywTicketBasic){
  3.         //一个为接口配置内的路径，，，倒是目前开发阶段，先随意
  4.         YwInterfaceConfig ywInterfaceConfig = new YwInterfaceConfig();
  5.         //String url = ywInterfaceConfig.getInterfacePath();
  6.         String url = "http://192.168.10.97:8085/jeecg-boot/weld/zctWeld/zuiwaiceng";
  7.         try {
  8.             Date nowdate = new Date();
  9.             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  10.             Map<String,Object> map = new HashMap<>();
  11.             map.put("tokenPush","123456");
  12.             ObjectMapper mapper = new ObjectMapper();
  13.             String jsonString = mapper.writeValueAsString(ywTicketBasic);
  14.             map.put("ywTicketBasic",jsonString);
  15.             map.put("timePush",sdf.format(nowdate));
  16.             String reponseparam = HttpClientUtils.post(url,map);
  17.             //不需要对数据就行处理
  18.             com.alibaba.fastjson.JSONObject parseObject = com.alibaba.fastjson.JSONObject.parseObject(reponseparam.toString());
  19.             //把相关参数分解出来并存储，在接口日志中，记录调用内容
  20.             Date responsedate = new Date();
  21.             System.out.println("返回的内容："+parseObject.toString());
  22.             //存储接口记录
  23.             //ywInterfaceRecordService.addByPublic(reponseparam,parseObject,nowdate,responsedate,ywInterfaceConfig.getId());
  25.         } catch (IOException e) {
  26.             log.error("错误信息：文件传输系统推送数据报错",e);
  27.             //e.printStackTrace();
  28.         }
  29.     }

java2 接收参数

  1.      @PostMapping(value = "/zuiwaiceng")
  2.      public Result<?> abutmentInterface(HttpServletRequest request, HttpServletResponse response){
  3.          try {
  4.              System.out.println(request);
  5.              // 接收参数
  6.              String timePush = request.getParameter("timePush");
  7.              String tokenPush = request.getParameter("tokenPush");
  8.              String ywTicketBasic = request.getParameter("ywTicketBasic");
  9.              // 序列化成对象
  10.              Gson gson = new Gson();
  11.              YwTicketBasic yw = gson.fromJson(ywTicketBasic, YwTicketBasic.class);
  12.              System.out.println(yw);
  13.              System.out.println(timePush);
  14.              System.out.println(tokenPush);
  15.              System.out.println(ywTicketBasic);
  16.          }catch (Exception e){
  17.              e.printStackTrace();
  18.          }finally {
  19.              return Result.OK("成功");
  20.          }
  21.      }

方案二 封装POST请求（Map入参）--lry

java1 调用

  1.     //推送数据给文件传输系统  2024-8-1 muzi
  2.     private void  pushDataForWenJian(YwTicketBasic ywTicketBasic){
  3.         //一个为接口配置内的路径，，，倒是目前开发阶段，先随意
  4.         YwInterfaceConfig ywInterfaceConfig = new YwInterfaceConfig();
  5.         //String url = ywInterfaceConfig.getInterfacePath();
  6.         String url = "http://192.168.10.103:8083/jeecg-boot/interface/record/abutmentInterface";
  7.         try {
  8.             Date nowdate = new Date();
  9.             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  10.             Map<String,Object> map = new HashMap<>();
  11.             map.put("tokenPush","123456");
  12.             ObjectMapper mapper = new ObjectMapper();
  13.             String jsonString = mapper.writeValueAsString(ywTicketBasic);
  14.             map.put("ywTicketBasic",jsonString);
  15.             map.put("timePush",sdf.format(nowdate));
  16.             String reponseparam = HttpClientUtils.postJSon(url,map);
  17.             //不需要对数据就行处理
  18.             com.alibaba.fastjson.JSONObject parseObject = com.alibaba.fastjson.JSONObject.parseObject(reponseparam.toString());
  19.             //把相关参数分解出来并存储，在接口日志中，记录调用内容
  20.             Date responsedate = new Date();
  21.             System.out.println("返回的内容："+parseObject.toString());
  22.             //存储接口记录
  23.             //ywInterfaceRecordService.addByPublic(reponseparam,parseObject,nowdate,responsedate,ywInterfaceConfig.getId());
  25.         } catch (IOException e) {
  26.             log.error("错误信息：文件传输系统推送数据报错",e);
  27.             //e.printStackTrace();
  28.         }
  29.     }

java2 接收参数 使用map接收

  1. @Override
  2.     public Result<?> abutmentInterface(Map<String, Object> data, HttpServletRequest req, HttpServletResponse resp) {
  3.         try {
  4.             //获取传递过来参数
  5.             String timePush =(String) data.get("timePush");
  6.             String tokenPush =(String) data.get("tokenPush");
  7.             String ywTicketBasic = (String) data.get("ywTicketBasic");
  9.             //json转换成java对象
  10.             Gson gson = new Gson();
  11.             ZcTicket zcTicket = gson.fromJson(ywTicketBasic, ZcTicket.class);
  13.         }catch (Exception e){
  14.             return null；
  15.         }
  17.     }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注