使用接口模拟调运其他平台数据并返回

凯特-呼丽华

案例描述

在平台A上利用接口模拟调运平台B中功能数据

实现思路

• 确定平台B的功能数据正常，获取指定用户token、功能编码、数据ID（只需要一条数据的时候），组成url
• 在平台A写接口，利用HttpClientUtil工具类的doPost()方法进行解析并获取数据
• 在平台A上写个测试按钮，调运接口进行测试
  
  

操作步骤

1. 确定平台B的url

//定义api，一般情况下这个api的url是第三方提供

1. String  id = "5qZUoTMjp3LsbO8E4y2";
   
2. String apiurl = "http://example.jepaas.com/je/getInfoById"+"?pkValue="+id+"&authorization=6Dy0QDIS7IRuVXzqmYh&tableCode=JE_DEMO_XMINFO";

复制代码

2. 在平台A写接口，利用HttpClientUtil工具类的doPost()方法进行解析并获取数据

3. 在平台A上写个测试按钮，调运接口进行测试

相关代码

1 、HttpClientUtil代码

1. package com.project.demo.controller;
   
2. import java.io.IOException;
   
3. import java.net.URI;
   
4. import java.util.ArrayList;
   
5. import java.util.List;
   
6. import java.util.Map;
   
7. 
   
8. import org.apache.http.NameValuePair;
   
9. import org.apache.http.client.entity.UrlEncodedFormEntity;
   
10. import org.apache.http.client.methods.CloseableHttpResponse;
    
11. import org.apache.http.client.methods.HttpGet;
    
12. import org.apache.http.client.methods.HttpPost;
    
13. import org.apache.http.client.utils.URIBuilder;
    
14. import org.apache.http.entity.ContentType;
    
15. import org.apache.http.entity.StringEntity;
    
16. import org.apache.http.impl.client.CloseableHttpClient;
    
17. import org.apache.http.impl.client.HttpClients;
    
18. import org.apache.http.message.BasicNameValuePair;
    
19. import org.apache.http.util.EntityUtils;
    
20. 
    
21. public class HttpClientUtilTest {
    
22. 
    
23.     /**
    
24.      * 带参数的get请求
    
25.      * @param url
    
26.      * @param param
    
27.      * @return String
    
28.      */
    
29.     public static String doGet(String url, Map<String, String> param) {
    
30.         // 创建Httpclient对象
    
31.         CloseableHttpClient httpclient = HttpClients.createDefault();
    
32. 
    
33.         String resultString = "";
    
34.         CloseableHttpResponse response = null;
    
35.         try {
    
36.             // 创建uri
    
37.             URIBuilder builder = new URIBuilder(url);
    
38.             if (param != null) {
    
39.                 for (String key : param.keySet()) {
    
40.                     builder.addParameter(key, param.get(key));
    
41.                 }
    
42.             }
    
43.             URI uri = builder.build();
    
44.             // 创建http GET请求
    
45.             HttpGet httpGet = new HttpGet(uri);
    
46.             // 执行请求
    
47.             response = httpclient.execute(httpGet);
    
48.             // 判断返回状态是否为200
    
49.             if (response.getStatusLine().getStatusCode() == 200) {
    
50.                 resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
    
51.             }
    
52.         } catch (Exception e) {
    
53.             e.printStackTrace();
    
54.         } finally {
    
55.             try {
    
56.                 if (response != null) {
    
57.                     response.close();
    
58.                 }
    
59.                 httpclient.close();
    
60.             } catch (IOException e) {
    
61.                 e.printStackTrace();
    
62.             }
    
63.         }
    
64.         return resultString;
    
65.     }
    
66. 
    
67.     /**
    
68.      * 不带参数的get请求
    
69.      * @param url
    
70.      * @return String
    
71.      */
    
72.     public static String doGet(String url) {
    
73.         return doGet(url, null);
    
74.     }
    
75. 
    
76.     /**
    
77.      * 带参数的post请求
    
78.      * @param url
    
79.      * @param param
    
80.      * @return String
    
81.      */
    
82.     public static String doPost(String url, Map<String, String> param) {
    
83.         // 创建Httpclient对象
    
84.         CloseableHttpClient httpClient = HttpClients.createDefault();
    
85.         CloseableHttpResponse response = null;
    
86.         String resultString = "";
    
87.         try {
    
88.             // 创建Http Post请求
    
89.             HttpPost httpPost = new HttpPost(url);
    
90.             // 创建参数列表
    
91.             if (param != null) {
    
92.                 List<NameValuePair> paramList = new ArrayList<>();
    
93.                 for (String key : param.keySet()) {
    
94.                     paramList.add(new BasicNameValuePair(key, param.get(key)));
    
95.                 }
    
96.                 // 模拟表单
    
97.                 UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
    
98.                 httpPost.setEntity(entity);
    
99.             }
    
100.             // 执行http请求
     
101.             response = httpClient.execute(httpPost);
     
102.             resultString = EntityUtils.toString(response.getEntity(), "utf-8");
     
103.         } catch (Exception e) {
     
104.             e.printStackTrace();
     
105.         } finally {
     
106.             try {
     
107.                 response.close();
     
108.             } catch (IOException e) {
     
109.                 e.printStackTrace();
     
110.             }
     
111.         }
     
112.         return resultString;
     
113.     }
     
114. 
     
115.     /**
     
116.      * 不带参数的post请求
     
117.      * @param url
     
118.      * @return String
     
119.      */
     
120.     public static String doPost(String url) {
     
121.         return doPost(url, null);
     
122.     }
     
123. 
     
124.     /**
     
125.      * 传送json类型的post请求
     
126.      * @param url
     
127.      * @param json
     
128.      * @return String
     
129.      */
     
130.     public static String doPostJson(String url, String json) {
     
131.         // 创建Httpclient对象
     
132.         CloseableHttpClient httpClient = HttpClients.createDefault();
     
133.         CloseableHttpResponse response = null;
     
134.         String resultString = "";
     
135.         try {
     
136.             // 创建Http Post请求
     
137.             HttpPost httpPost = new HttpPost(url);
     
138.             // 创建请求内容
     
139.             StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
     
140.             httpPost.setEntity(entity);
     
141.             // 执行http请求
     
142.             response = httpClient.execute(httpPost);
     
143.             resultString = EntityUtils.toString(response.getEntity(), "utf-8");
     
144.         } catch (Exception e) {
     
145.             e.printStackTrace();
     
146.         } finally {
     
147.             try {
     
148.                 response.close();
     
149.             } catch (IOException e) {
     
150.                 e.printStackTrace();
     
151.             }
     
152.         }
     
153.         return resultString;
     
154.     }
     
155. }

复制代码

2、接口代码

1. package com.project.demo.controller;
   
2. 
   
3. import com.je.core.base.MethodArgument;
   
4. import com.je.core.result.BaseRespResult;
   
5. import org.springframework.stereotype.Controller;
   
6. import org.springframework.web.bind.annotation.RequestMapping;
   
7. import org.springframework.web.bind.annotation.RequestMethod;
   
8. import org.springframework.web.bind.annotation.ResponseBody;
   
9. 
   
10. 
    
11. @Controller
    
12. @RequestMapping(value = "/je/demo/test")
    
13. public class TestDemoController {
    
14.     @RequestMapping(value = "/testUrl", method = RequestMethod.POST, produces = "application/json; charset=utf-8")
    
15.     @ResponseBody
    
16.     public BaseRespResult testUrl(MethodArgument param){
    
17.         //定义api，一般情况下这个api的url是第三方提供
    
18.         String  id = "5qZUoTMjp3LsbO8E4y2";
    
19.         String apiurl = "http://example.jepaas.com/je/getInfoById"+"?pkValue="+id+"&authorization=6Dy0QDIS7IRuVXzqmYh&tableCode=JE_DEMO_XMINFO";
    
20.         String result="";
    
21.         try {
    
22.             result = HttpClientUtilTest.doPost(apiurl);
    
23.         } catch (Exception e) {
    
24.             e.printStackTrace();
    
25.         }
    
26.         return  BaseRespResult.successResult(result);
    
27.     }
    
28. }

复制代码

平台调试

1、在某个功能上写个按钮,进行Ajax调运测试

2、调运代码

1. function(btn,event,eOpts){
   
2. var obj = JE.ajax({
   
3.        url:'/je/demo/test/testUrl',
   
4.        text:false,//返回字符串,如果不配置,返回对象
   
5.        params:{}
   
6.     });
   
7.     if(obj.success){
   
8.         console.log(obj);
   
9.         JE.alert(obj.obj);
   
10.     }else{
    
11.         JE.alert('失败,请联系管理员');
    
12.     }
    
13. }

复制代码

3、后台断点调试