// 構(gòu)建報(bào)文
JSONObject rootJson = new JSONObject();
// 賦值
rootJson.put("unique_code", qniqueCode);
JSONObject dataJson = null;
JSONArray dataList = new JSONArray();
for (TransferFundResult rfr : rfrResultList) {
    for (Map.Entry<SubjectEnum, TransferFundItem> entry : rfr.entrySet()) {
        entry.getValue();
        // receive_number ★收款會員號
        dataJson = new JSONObject();
        dataJson.put("receive_number", rfr.getTransferMainbodyOrgMemberId());
        // pay_type ★付款類別
        dataJson.put("pay_type", rftValId.get(entry.getKey().getValue()) + "");
        // amount 金額
        dataJson.put("amount", entry.getValue().getAmount().toString() + "");
        // group_state ★支付狀態(tài)
        dataJson.put("group_state", entry.getValue().getAllocationResult().getValue() + "");
        // group_error_info ★錯(cuò)誤信息
        dataJson.put("group_error_info", entry.getValue().getResult());
                dataList.add(dataJson);
    }
}
rootJson.put("data_list", dataList);
/***************************************************
     * @Description 使用http協(xié)議發(fā)送字節(jié)流消息
     * @Date 2019-10-22 10:13
     * @param hostIp    遠(yuǎn)程主機(jī)IP地址
     * @param port      遠(yuǎn)程主機(jī)端口
     * @param path      遠(yuǎn)程主機(jī)服務(wù)路徑
     * @param method    提交方式
     * @param sendBytes 發(fā)送的字節(jié)
     * @return
     * @throws IOException byte[]
 ***************************************************/
public static byte[] sendHttpBytesMessage(String hostIp, int port, String path, String method, byte[] sendBytes)
            throws IOException {
        BufferedInputStream bis=null;
        BufferedOutputStream bos=null;
        String urlStr = "http://" + hostIp + ":" + port + "/" + path;
        URL url = new URL(urlStr);
        HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
        httpURLConnection.setRequestProperty("Accept-Charset", "utf-8");
        httpURLConnection.setRequestProperty("Content-Type", "text/xml");
        httpURLConnection.setRequestMethod(method.toUpperCase());
        httpURLConnection.setDoInput(true);
        httpURLConnection.setDoOutput(true);
        httpURLConnection.setUseCaches(false);

        bos = new BufferedOutputStream(httpURLConnection.getOutputStream());
        bos.write(sendBytes);
        bos.flush();
        bos.close();
        bis = new BufferedInputStream(httpURLConnection.getInputStream());
        int responseCode = httpURLConnection.getResponseCode();
        byte[] temp = new byte[4096];
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        int len = 0;
        if (responseCode == httpURLConnection.HTTP_OK) {
            while ((len = bis.read(temp)) > 0) {
                baos.write(temp, 0, len);
            }
        } else {
            System.out.println("請求響應(yīng)返回碼=" + responseCode);
        }

        return baos.toByteArray();
}
// 接收響應(yīng)
        byte[] response = null;
        try {
            response = ConmunicationUtil.sendHttpBytesMessage("192.168.1.1", 8080, "lpapiLYPH0006.action",
                    "post", reqMsg.getBytes("utf-8"));
        } catch (UnsupportedEncodingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("response =>> " + new String(response, "utf-8"));

// 對端接收解析
// 以流的方式獲取請求報(bào)文內(nèi)容
        String reqMsg = null;
        System.out.println("contentLength =" + this.request.getContentLength());
        byte[] tempContentBytes = new byte[4096];
        int len = 0;
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        boolean flag = true;
        try {
            BufferedInputStream bis = new BufferedInputStream(this.request.getInputStream());
            while ((len = bis.read(tempContentBytes)) >= 0) {

                System.out.println("tempContentBytes=" + Arrays.toString(tempContentBytes));
                baos.write(tempContentBytes, 0, len);
            }
            reqMsg = baos.toString("utf-8");
            log.debug("接受的請求字節(jié)碼=" + Arrays.toString(baos.toByteArray()));
        } catch (UnsupportedEncodingException e1) {
            e1.printStackTrace();
            flag = false;
            responseMsg = settlementResult.getFailedMesageTemplate(999, "字符編碼處理異常-" + e1.getMessage());
            log.error("請求報(bào)文處理異常", e1);
        } catch (IOException e1) {
            e1.printStackTrace();
            flag = false;
            responseMsg = settlementResult.getFailedMesageTemplate(999, "I/O處理異常-" + e1.getMessage());
            log.error("請求報(bào)文處理異常", e1);
        } finally {
            if (!flag) {
                this.sendResponseMessage(responseMsg, "UTF-8");
            }
        }
JSONObject json = null;
// 流轉(zhuǎn)換JSON
json = JSONObject.fromObject(reqMsg);
// JsonPath取值
String logisticMemberCode = JsonPath.read(json, "$.transit_code");
JSONArray dayList = JsonPath.read(json, "$.data_list");
for (int i = 0; i < dayList.size(); i++) {
  JSONObject job = dayList.getJSONObject(i);
  payType = Integer.parseInt((String) JsonPath.read(job, "$.pay_type"));
}