欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  Java

实战演练java 调用http接口 post 例子

程序员文章站 2022-03-25 08:12:19
...
发起请求：
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();
		}
	}
}

接收方：

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;
	}
}

相关推荐：

想做一上PHP调用java webservice接口的例子，但是.

java直接调用python脚本的例子

以上就是实战演练java 调用http接口 post 例子的详细内容，更多请关注其它相关文章！

相关标签： java 调用http

上一篇： Ifram框架自适应内容的高度（代码简单易懂ie7,8,9,火狐，谷歌都测试通过）

下一篇： JS上传组件FileUpload自定义模板的使用方法_javascript技巧

推荐阅读