Praktische Übung: Beispiel für den Aufruf einer HTTP-Schnittstelle mit Java

Anfrage initiieren:

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;

import org.apache.http.util.TextUtils;

import com.alibaba.fastjson.JSONObject;

import cn.com.doone.tx.cloud.tool.common.util.Md5Util;

import java.util.Collection;
import java.util.Date;

public class IntfMain {

	//post请求方法
	 public static String post(String strURL, String params) {  
	        System.out.println(strURL);  
	        System.out.println(params); 
	        String result = "";
	        BufferedReader reader = null;
	        
	        StringBuilder sb = new StringBuilder();
	        BufferedReader in = null;
	        try {  
	            URL url = new URL(strURL);// 创建连接  
	            HttpURLConnection connection = (HttpURLConnection) url.openConnection();  
	            connection.setDoOutput(true);  
	            connection.setDoInput(true);  
	            connection.setUseCaches(false);  
	            connection.setInstanceFollowRedirects(true);  
	            connection.setRequestMethod("POST"); // 设置请求方式  
	            connection.setRequestProperty("Accept", "application/json"); // 设置接收数据的格式  
	            connection.setRequestProperty("Content-Type", "application/json"); // 设置发送数据的格式  
	            connection.connect();  
	            if (params != null && !TextUtils.isEmpty(params)) {
	                byte[] writebytes = params.getBytes();
	                // 设置文件长度
	             //   connection.setRequestProperty("Content-Length", String.valueOf(writebytes.length));
	                OutputStream outwritestream = connection.getOutputStream();
	                outwritestream.write(params.getBytes());
	                outwritestream.flush();
	                outwritestream.close();
	            }
	            int responseCode = connection.getResponseCode();  
		    	InputStream inputStream = null;  

		    	
	            if (responseCode == 200) {  
		    		inputStream = new BufferedInputStream(connection.getInputStream());  
	            } else {  
		    		inputStream = new BufferedInputStream(connection.getErrorStream());  
		    	} 
	            
	            in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
				String line;
				while ((line = in.readLine()) != null) {
					result+=line;
				}
	        } catch (Exception e) {
	            e.printStackTrace();
	        } finally {
	            if (reader != null) {
	                try {
	                    reader.close();
	                } catch (IOException e) {
	                    e.printStackTrace();
	                }
	            }
	        }
	        return result;
	    }
	  
	  
	  
	  

	public static void main(String[] args) {
		//String url = "http://localhost:28001/intf/send";
		String url = "http://###:##/gdctsWeb/intf/send";
		
		long createTime = new Date().getTime();
		long reqTime = new Date().getTime();
		
		String bodyStr="{\"creator\":\"4\",\"operator\":\"4\",\"operateType\":\"ADD\",\"channelCode\":\"V7\",\"synId\":\"556445\",\"name\":\"計算機团体345\",\"password\":\"345123\",\"registerTime\":\"2018-07-0121:00:00\",\"account\":\"account041\",\"custType\":\"2\",\"bindNumber\":\"15055556666\",\"groupContact\":[{\"contactName\":\"团体联系人\",\"contactNumber\":\"155555555\",\"email\":\"2222@qq.com\",\"occupation\":\"leader\",\"qq\":\"313131\",\"remark\":\"联系人备注\"}],\"groupInfoEvt\":[{\"address\":\"团体地址\",\"areaCode\":\"111\",\"busiArea\":\"222\",\"cityCode\":\"322\",\"custIndustry\":\"行业\",\"groupNature\":\"性质\",\"groupSize\":\"大\",\"name\":\"某团体客户\",\"provinceCode\":\"1111\",\"registeredCapital\":\"资本\",\"remark\":\"备注\",\"zipCode\":\"350000\"}],\"members\":[{\"name\":\"名称\",\"contactNumber\":\"111444\",\"cerType\":\"1\",\"cerNo\":\"6874268552552\",\"sex\":\"1\",\"age\":\"10\"}],\"resource\":\"介绍\"}";
		

		JSONObject paramJson = new JSONObject(true);
		JSONObject body = new JSONObject(true);
		body=JSONObject.parseObject(bodyStr);
		
		JSONObject head = new JSONObject(true);
		String intfCode = "CRM_CUSTGROUP004";
		String sysSecret="GRD01";
		String sysCode="V7";
		
		String signOri=sysCode+intfCode+sysSecret+reqTime;
		Collection<Object> values = body.values();
		for (Object v : values) {
			signOri=signOri+v.toString();
		}
		//System.out.println(signOri);
		String sign = Md5Util.MD5(signOri);
		
		String headStr="{\"sysCode\":\""+sysCode+"\",\"intfCode\":\""+intfCode+"\",\"reqTime\":\""+reqTime+"\",\"sign\":\""+sign+"\"}";
		head=JSONObject.parseObject(headStr);
		
		paramJson.put("head", head);
		paramJson.put("body", body);

		try {
			String json = paramJson.toJSONString();
			String postWithJSON = post(url, json);
			System.out.println(postWithJSON);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

Empfänger:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URLDecoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.jsp.tagext.TryCatchFinally;

import org.apache.http.protocol.HTTP;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.alibaba.fastjson.JSONObject;

import cn.com.doone.tx.cloud.system.service.IntfConfigService;
import cn.com.doone.tx.cloud.system.utils.JsonUtils;
import cn.com.doone.tx.cloud.system.utils.ServerHeaderSyn;
import cn.com.doone.tx.cloud.system.utils.ServerRespSyn;
import cn.com.doone.tx.cloud.system.evt.RequestJsonEvt;
import cn.com.doone.tx.cloud.system.service.IntfConfigLogService;
import cn.com.doone.tx.cloud.tool.common.invoke.ServerResp;
import cn.com.doone.tx.cloud.tool.common.util.Md5Util;
import cn.com.doone.tx.cloud.tool.web.base.BaseController;
//v7系统同步接口
@Controller
@EnableAutoConfiguration
@RequestMapping("/intf")
public class IntfConfigController extends BaseController {

	@Autowired
	IntfConfigService intfConfigService;

	@Autowired
	IntfConfigLogService intfConfigLogService;

	@RequestMapping("send")
	@ResponseBody
	public ServerRespSyn<Object> send(HttpServletRequest request) throws IOException {
		ServerRespSyn<Object> respV7 = new ServerRespSyn<>();
		ServerHeaderSyn respV7Header = new ServerHeaderSyn();
		ServerResp<Object> respLogAdd  = new ServerResp<>();
		ServerResp<Object> resp = new ServerResp<>();
		HashMap<String, Object> pram = new HashMap<String, Object>();
		
		
			// 读取请求内容
			BufferedReader br = new BufferedReader(new InputStreamReader(request.getInputStream()));
			String line = null;
			StringBuilder sb = new StringBuilder();
			while ((line = br.readLine()) != null) {
				sb.append(line);
			}
			// 将资料解码
			String reqBody = sb.toString();
			String str = URLDecoder.decode(reqBody, HTTP.UTF_8);
			RequestJsonEvt jsonEvt = JsonUtils.fromJson(str, RequestJsonEvt.class);
			Map<String, Object> head = jsonEvt.getHead();
			Map<String, Object> body = jsonEvt.getBody();
			String sysSecret="GRD01";
			String signMy =head.get("sysCode").toString()+head.get("intfCode").toString()+ sysSecret +head.get("reqTime").toString();
			String sign =  head.get("sign").toString();
			for (Object m: body.values()) {
				signMy=signMy+ JsonUtils.toJson(m);
			}
			try {
			ServerResp<Object> respConfigList = intfConfigService.getIntfConfigList(pram);
			List<LinkedHashMap<String, Object>> list = (List<LinkedHashMap<String, Object>>) respConfigList.getBody();
			
			if (Md5Util.MD5(signMy).equals(sign)) {
				for (LinkedHashMap<String, Object> linkedHashMap : list) {
					if (head.get("intfCode").equals(linkedHashMap.get("intfCode"))){
						HashMap<String, Object> pramLog = new HashMap<String, Object>();
						HashMap<String, Object> pramLog1 = new HashMap<String, Object>();
						LinkedHashMap<String, Object> mapLog = new LinkedHashMap<>();
						try {
							pramLog.put("callSystemCode", "V7");
							pramLog.put("intfSystemCode", "CRM");
							pramLog.put("intfUrl",linkedHashMap.get("intfUrl"));
							pramLog.put("intfName",linkedHashMap.get("intfName"));
							pramLog.put("intfCode", linkedHashMap.get("intfCode"));
							pramLog.put("intfParamsIn",str );
							pramLog.put("creator", 4);
							pramLog.put("operator",4);
							respLogAdd = intfConfigLogService.addLog(pramLog);
							mapLog = (LinkedHashMap<String, Object>) respLogAdd.getBody();
							
							resp = intfConfigService.doSend(body, linkedHashMap.get("intfUrl").toString());
							if(resp.isSuccess()) {
								pramLog1.put("id", mapLog.get("id"));
								pramLog1.put("resDesc", "调用成功");
								pramLog1.put("status", resp.getHead().getRespCode());
								pramLog1.put("intfParamsOut",JsonUtils.toJson(resp));
								
								SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); 
								String resTime =  formatter.format(new Date());
								respV7Header.setResTime(resTime);
								respV7Header.setRespCode(0);
								respV7Header.setSign(sign);
								respV7Header.setRespMsg(resp.getHead().getRespMsg());
								respV7.setHead(respV7Header);
								respV7.setBody(resp.getBody());
							}else {
								pramLog1.put("id", mapLog.get("id"));
								pramLog1.put("resDesc", resp.getHead().getRespMsg());
								pramLog1.put("status", resp.getHead().getRespCode());
								pramLog1.put("intfParamsOut",JsonUtils.toJson(resp));
								
								SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); 
								String resTime =  formatter.format(new Date());
								respV7Header.setResTime(resTime);
								respV7Header.setRespCode(1);
								respV7Header.setSign(sign);
								respV7Header.setRespMsg(resp.getHead().getRespMsg());
								respV7.setHead(respV7Header);
								respV7.setBody(resp.getBody());
								
							} 
						
						} catch (Exception e) {
							pramLog1.put("id", mapLog.get("id"));
							pramLog1.put("resDesc", "调用失败");
							pramLog1.put("status", "-1");
							pramLog1.put("intfParamsOut",e.getMessage());
							
							SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); 
							String resTime =  formatter.format(new Date());
							respV7Header.setResTime(resTime);
							respV7Header.setRespCode(1);
							respV7Header.setSign(sign);
							respV7Header.setRespMsg(resp.getHead().getRespMsg());
							respV7.setHead(respV7Header);
							respV7.setBody(e.getMessage());
							
						}finally {
							intfConfigLogService.editLog(pramLog1);
						}
					}
				}
				 
			}else {
				SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); 
				String resTime =  formatter.format(new Date());
				respV7Header.setResTime(resTime);
				respV7Header.setRespCode(1);
				respV7Header.setSign(sign);
				respV7Header.setRespMsg("调用失败");
				respV7.setHead(respV7Header);
				respV7.setBody("安全验签不一致");
			}
			

		} catch (Exception e) {
			e.printStackTrace();
			SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); 
			String resTime =  formatter.format(new Date());
			respV7Header.setResTime(resTime);
			respV7Header.setRespCode(1);
			respV7Header.setSign(sign);
			respV7Header.setRespMsg("调用失败");
			respV7.setHead(respV7Header);
			respV7.setBody(e.getMessage());
		}
		return respV7;
	}
}

Verwandte Empfehlungen:

Ich möchte ein Beispiel dafür erstellen, wie PHP den Java-Webservice aufruft Schnittstelle.

Beispiel für einen direkten Aufruf von Python-Skript durch Java

Das obige ist der detaillierte Inhalt vonPraktische Übung: Beispiel für den Aufruf einer HTTP-Schnittstelle mit Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!