发起请求：
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免费学习笔记（深入）”；
