一、接口参数的获取：
1.参数通过Excel读取，并将结果写入Excel中
package org.fanqi.operateExcel; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.TreeMap; import org.apache.poi.xssf.usermodel.XSSFCell; import org.apache.poi.xssf.usermodel.XSSFSheet; import org.apache.poi.xssf.usermodel.XSSFWorkbook; public class OperateExcelUtil { /* * 读取Excel数据 */ public List<Map<String, Object>> readExcel(String filename) { FileInputStream in; XSSFWorkbook workbook = null; try { in = new FileInputStream(filename); workbook = new XSSFWorkbook(in); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } //获取第一张表 XSSFSheet sheet = workbook.getSheetAt(0); List<Map<String, Object>> listCanshu = new ArrayList<Map<String, Object>>(); for(int i=1;i<=sheet.getLastRowNum();i++){ Map<String, Object> map = new TreeMap<String, Object>(); String cell0 = sheet.getRow(i).getCell(0).getStringCellValue(); String cell1 = sheet.getRow(i).getCell(1).getStringCellValue(); //利用map保存参数 map.put("canshu1", cell0); map.put("canshu2", cell1); listCanshu.add(map); } return listCanshu; } /* * 测试结果写入原Excel * result为测试结果（Pass or Failed） */ public void writeExcel(String filename,List<String> resultList,int resultRow) { XSSFWorkbook workbook = null; FileInputStream in = null; try { in = new FileInputStream(filename); workbook = new XSSFWorkbook(in); } catch (IOException e) { e.printStackTrace(); } XSSFSheet sheet = workbook.getSheetAt(0); int rowSum = sheet.getLastRowNum(); XSSFCell cell = null; for(int i=1;i<=rowSum;i++){ cell = sheet.getRow(i).getCell(resultRow); cell.setCellValue(resultList.get(i-1)); } try { workbook.write(new FileOutputStream(filename)); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } /*创建Excel文件 * public void createExcel() { XSSFWorkbook x = new XSSFWorkbook(); XSSFFont font1 = x.createFont(); font1.setFontHeightInPoints((short) 15); font1.setFontName("Pristina"); font1.setColor(IndexedColors.GREEN.index); //font1.setColor(HSSFColor.YELLOW.index); XSSFCellStyle style = x.createCellStyle(); style.setFont(font1); XSSFSheet sheet = x.createSheet(); XSSFRow row0 = sheet.createRow(0); row0.createCell(0).setCellValue("姓名"); row0.getCell(0).setCellStyle(style); row0.createCell(1).setCellValue("性别"); row0.getCell(1).setCellStyle(style); row0.createCell(2).setCellValue("年龄"); row0.getCell(2).setCellStyle(style); row0.createCell(3).setCellValue("职位"); row0.getCell(3).setCellStyle(style); row0.createCell(4).setCellValue("工作年限"); row0.getCell(4).setCellStyle(style); User u = new User(); u.setName("郭大侠"); u.setSex("男"); u.setAge("30"); u.setJob("Java开发"); u.setExperience("2"); User u1 = new User(); u1.setName("陶大婶"); u1.setSex("男"); u1.setAge("28"); u1.setJob("Java开发"); u1.setExperience("3"); ArrayList<User> arrayList = new ArrayList<User>(); arrayList.add(u); arrayList.add(u1); for(int i=1; i<3; i++){ XSSFRow row = sheet.createRow(i); row.createCell(0).setCellValue(arrayList.get(i-1).getName()); row.createCell(1).setCellValue(arrayList.get(i-1).getSex()); row.createCell(2).setCellValue(arrayList.get(i-1).getAge()); row.createCell(3).setCellValue(arrayList.get(i-1).getJob()); row.createCell(4).setCellValue(arrayList.get(i-1).getExperience()); } try { x.write(new FileOutputStream("E:\test.xlsx")); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } } */ public static void main(String[] args) { OperateExcelUtil op = new OperateExcelUtil(); List<String> resultList = new ArrayList<String>(); resultList.add("Failed"); resultList.add("Pass"); op.writeExcel("E:\test.xlsx", resultList, 3); } }
可能需要加验签：sign(MD5)验签
/** * MD5工具类（许总监） * */ public class MD5Util { /** * Md5. * * @param value * the value * @return the string */ public static String md5(String value) { return DigestUtils.md5Hex(value); } public static String md5New(String value) { try { MessageDigest md = MessageDigest.getInstance("md5"); byte[] e = md.digest(value.getBytes()); return toHex(e); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); return value; } } /** * To hex. * * @param bytes * the bytes * @return the string */ private static String toHex(byte bytes[]) { StringBuilder hs = new StringBuilder(); String stmp = ""; for (int n = 0; n < bytes.length; n++) { stmp = Integer.toHexString(bytes[n] & 0xff); if (stmp.length() == 1) hs.append("0").append(stmp); else hs.append(stmp); } return hs.toString(); } }
二、请求报文的组装：
1.组装为JSON格式
package org.fanqi.operateJSONUtil; import java.util.List; import java.util.Map; import org.json.JSONArray; import org.json.JSONObject; public class BuildJSON { /* * 组装成JSON形式 */ public JSONObject buildJSON(Map mapParameters) { JSONObject json = new JSONObject(mapParameters); return json; } /* * 组装成JSON形式 */ public JSONObject buildJSONByString(String str) { return new JSONObject(str); } /* * 组装成JSON形式 * @parameter list<map> */ public JSONArray buildsJSON(List<Map> listCanshu) { JSONArray jArray = new JSONArray(); for(int i=0;i<listCanshu.size();i++ ){ JSONObject json = new JSONObject(listCanshu.get(i)); jArray.put(json); } return jArray; } }
三、请求方法：方式get、post、Hessian
1.get请求方式
/* * get请求方式 * @author:fanqi */ public static String httpGetMethod(String url,Map<Object,Object> map) { DefaultHttpClient httpClient = new DefaultHttpClient(); Object value; Object urlInfo = ""; for(Object key : map.keySet()){ value = map.get(key); urlInfo += key+"="+value+"&"; } urlInfo = urlInfo.toString().substring(0, urlInfo.toString().length()-1); url = url + "?" + urlInfo.toString(); HttpGet httpGet = new HttpGet(url); HttpResponse httpResponse = null; try { httpResponse = httpClient.execute(httpGet); StringBuilder sb = new StringBuilder(); InputStream inputStream = httpResponse.getEntity().getContent(); BufferedReader br = new BufferedReader(new InputStreamReader(inputStream,"GBK")); String temp = ""; while((temp = br.readLine()) != null){ sb.append(temp + " "); } return sb.toString(); } catch (IllegalStateException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; }
2.Post请求方式PostMethod（根据httpclient.jar包的版本不同，用到的方法有差异）
/* * author:fanqi */ public String HttpClientPostMethod(String url,Map map) { DefaultHttpClient httpClient = new DefaultHttpClient(); HttpPost httpPost = new HttpPost(url); InputStream responseStream = null; //参数形式为JSON格式 JSONObject parameter = new JSONObject(map); try { StringEntity entity = new StringEntity(parameter.toString());//解决中文乱码问题可以加参数"utf-8" entity.setContentEncoding("UTF-8"); entity.setContentType("application/json"); httpPost.setEntity(entity); HttpResponse httpResponse = httpClient.execute(httpPost); if(httpResponse.getStatusLine().getStatusCode() == 200){ HttpEntity httpEntity = httpResponse.getEntity(); responseStream = httpEntity.getContent(); BufferedReader br = new BufferedReader(new InputStreamReader(responseStream)); StringBuilder sb = new StringBuilder(); String temp = ""; while((temp = br.readLine()) != null){ String str = new String(temp.getBytes(), "UTF-8"); sb.append(str + " "); } return sb.toString(); } } catch (IOException e) { e.printStackTrace(); } return null; }
------------------------------------------------------------------------------------------------------------------------------------------------------------------------
/* * author:xu zong jian */ public static String HttpClientPostMethod(String url,String sign,Map<String,String> map){ try { log.info("HttpClientPostMethod -- url:{}",url); HttpClient client = new HttpClient(); PostMethod postMethod = new PostMethod(url); NameValuePair[] data = new NameValuePair[map.keySet().size()]; Iterator it = map.entrySet().iterator(); int i = 0; while (it.hasNext()) { Map.Entry entry = (Entry) it.next(); Object key = entry.getKey(); Object value = entry.getValue(); data[i] = new NameValuePair(key.toString(), value.toString()); i++; } postMethod.setRequestBody(data); client.executeMethod(postMethod); log.info("HttpClientPostMethod -- status:{} ",postMethod.getStatusCode()); if (postMethod.getStatusCode() == HttpStatus.SC_OK) { return postMethod.getResponseBodyAsString(); } } catch (Exception e) { log.error("HttpClientPostMethod error", e); } log.info("HttpClientPostMethod return null"); return null; }
3.Hessian请求：
Hessian是基于Binary –RPC（二进制远程过程调用协议）进行通讯。
Hessian就是把Java对象转变成字节序列，然后通过Http传输到目标服务器上（主机），主机收到这个字节序列后，按照一定的协议标准进行反序列，提交给对应的服务处理。处理完成以后以同样的方式返回数据。
需要：Hessian.jar、 所测接口的API包、请求地址
/* * url为请求地址，包含端口号 * Response为接口请求返回对象 * ServerClient为接口中定义的请求客户端类 */ public Response executes(String url) { HessianProxyFactory hpf = new HessianProxyFactory(); ServerClient ServerClient = null; try { ServerClient = (ServerClient) hpf.create(ServerClient.class, url); } catch (MalformedURLException e) { e.printStackTrace(); } response = ServerClient.TxnSyncAudit(SyncAuditRequestBo); return response; }
四、返回报文的解析：
1.返回JSON格式的报文
package org.fanqi.operateJSONUtil; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import org.json.JSONObject; public class AnalysisJSON { /* * 解析JSON报文,JSON中不嵌套JSON */ public Map analysisJSON1(String responseResult) { //去掉{} responseResult = responseResult.substring(1, responseResult.length()-1); String[] strs = responseResult.split(","); @SuppressWarnings("rawtypes") Map<String, Object> map = new HashMap<String, Object>(); for(int i=0;i<strs.length;i++){ String[] str = strs[i].split(":"); map.put(str[0], str[1]); } return map; } /* * 解析JSON报文,JSON中不嵌套JSON */ public Map analysisJSON2(String responseResult) { JSONObject json = new JSONObject(responseResult); Iterator<String> it = json.keys(); HashMap<String, Object> map = new HashMap<String, Object>(); while(it.hasNext()){ String key = it.next(); Object value = json.getString(key); map.put(key, value); } return map; } /* * 解析JSON报文,JSON中含有JSON数组 */ public Map analysisJSONs(String responseResult) { JSONObject json = new JSONObject(responseResult); Iterator<String> it = json.keys(); HashMap<String, Object> map = new HashMap<String, Object>(); while(it.hasNext()){ String key = it.next(); Object value = json.getJSONArray(key); map.put(key, value); } return map; } }