get/post發送HTTP請求3

本節摘要:采用httpclient插件的post方式發送二進制數據流到http服務端

說明，本節在我之前的一篇博客get/post方式調用http接口的基礎上來介紹，本節的代碼和之前的這篇博客放在同一個工程目錄的同一個包下。

1.背景介紹

最近項目中發布了一個HTTP服務，HTTP服務端采用二進制流來接收數據，

與其他系統的同事聯調的時候，總是出現一些問題，現把這些問題列出來，並在代碼中得到了解決。

（1）請求的中文，服務器端接收到后為亂碼

（2）客戶端接收到服務器端的響應報文后，中文為亂碼

（3）請求的報文中沒有設置字符集，服務器報空指針異常

（4）客戶端發送請求后，服務器端接收到的二進制數據的長度為0，報NegativeArraySizeExceptio異常

（5）服務端接收到客戶端的報文后里面全是百分號以及英文字母（不用說，你懂的。）

之前介紹過采用JDK自帶的java.net.HttpURLConnection(見博客get/post發送HTTP請求2)可以解決這個問題，但是項目中發現客戶端很多同事都是采用的httpclient插件，那咱這次就用httpclient插件來發送post請求，並解決以上問題。服務端接收代碼以及輸出代碼不能改，那么我們只能想千方設百計的去修改完善我們客戶端的代碼。

 

2.代碼如下：

之前的博客get/post方式調用http接口，這個直接采用發送字符串的形式，也沒有解決中文問題，

廢話咱就不多說了，直接上代碼

(1)修改web.xml配置文件,增加以下幾行

    <!-- 模擬HTTP的調用，寫的一個只處理POST請求的http服務 -->
    <servlet>
        <servlet-name>PostHttpServer</servlet-name>
        <servlet-class>httpcall.PostHttpServer</servlet-class>
    </servlet>

    <servlet-mapping>
        <servlet-name>PostHttpServer</servlet-name>
        <url-pattern>/postHttpServer</url-pattern>
    </servlet-mapping>

servlet的配置，很easy

（2）HTTP服務器端的代碼

package httpcall;

import java.io.IOException;
import java.io.InputStream;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * 
 *Module:          PostHttpServer.java
 *Description:    模擬的一個Http服務,處理客戶端的post請求
 *Company:       
 *Author:           pantp
 *Date:              May 5, 2012
 */
public class PostHttpServer extends HttpServlet {

    private static final long serialVersionUID = 1L;

    /*
     * 代碼邏輯分以下三部分:
     * 1.獲得請求報文
     * 2.根據請求報文的信息去做業務邏輯，然后封裝返回報文
     * 3.輸出相應報文
     */
    protected void doPost(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {
        String inJson = null;// 保存HTTP客戶端請求報文
        String outJson = null;// 保存HTTP服務端輸出報文

        // 獲得輸人報文然后打印出來
        inJson = getInJson(request);
        System.out
                .println("\nauthor<pantp>===========服務端日志----POST方式接收HTTP請求,HTTP服務端收到的請求報文如下:==========\n");
        System.out.println(inJson);
        System.out
                .println("\nauthor<pantp>=================================================================\n");

        // 以下代碼部分獲得請求報文,然后去做校驗,轉換以及其他的調用其他的業務邏輯等,這里就不管它
        // ........................................................................

        // 下面部分是輸出部分的處理
        outJson = "{\"Response\": {\"code\": \"0\",\"message\": \"成功\",\"data\": \"12345\"}}";// 輸出不部分也以JSON格式的字符串輸出,這里我就寫死

        response.setContentType("application/json; charset=UTF-8");
        response.getWriter().print(outJson);
    }
    
    // 獲得請求的報文,並作簡單的校驗
    public String getInJson(HttpServletRequest request) throws IOException {

        byte buffer[] = new byte[64 * 1024];
        InputStream in = request.getInputStream();// 獲取輸入流對象

        int len = in.read(buffer);
        // 必須對數組長度進行判斷，否則在new byte[len]會報NegativeArraySizeException異常
        if (len < 0) {
            throw new IOException("請求報文為空");
        }

        String encode = request.getCharacterEncoding();// 獲取請求頭編碼
        // 必須對編碼進行校驗,否則在new String(data, encode);會報空指針異常
        if (null == encode || encode.trim().length() < 0) {
            throw new IOException("請求報文未指明請求編碼");
        }

        byte data[] = new byte[len];
        
        // 把buffer數組的值復制到data數組
        System.arraycopy(buffer, 0, data, 0, len);
        
        // 通過使用指定的 charset 解碼指定的 byte 數組，構造一個新的 String
        String inJson = new String(data, encode);

        return inJson;
    }

    // 不提供get的處理方式
    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {    
    }
}

 

（3）HTTP客戶端的代碼

package httpcall;

import java.io.IOException;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.methods.ByteArrayRequestEntity;
import org.apache.commons.httpclient.methods.EntityEnclosingMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;

/**
 * 
 *Module:          PostHttpClient.java
 *Description:     采用httpclient插件的post方式發送流二進制流數據到HTTP服務端
 *Company:       
 *Author:           pantp
 *Date:              May 5, 2012
 */
public class PostHttpClient {

    /**
     * 發送post請求,客戶端采用二進制流發送,服務端采用二進制流介紹
     * @param json  入參的json格式的報文
     * @param url    http服務器的地址
     * @return  返回響應信息
     */
    public static String postHttpReq(String json,String url) {
        HttpClient httpClient = new HttpClient();
        
        byte b[] = json.getBytes();//把字符串轉換為二進制數據
        RequestEntity requestEntity = new ByteArrayRequestEntity(b);

        EntityEnclosingMethod postMethod = new PostMethod();
        postMethod.setRequestEntity(requestEntity);// 設置數據
        postMethod.setPath(url);// 設置服務的url
        postMethod.setRequestHeader("Content-Type", "text/html;charset=GBK");// 設置請求頭編碼

        // 設置連接超時
        httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(
                5 * 1000);
        // 設置讀取超時
        httpClient.getHttpConnectionManager().getParams().setSoTimeout(20 * 1000);

        String responseMsg = "";
        int statusCode = 0;
        try {
            statusCode = httpClient.executeMethod(postMethod);// 發送請求
            responseMsg = postMethod.getResponseBodyAsString();// 獲取返回值
        } catch (HttpException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            postMethod.releaseConnection();// 釋放連接
        }

        if (statusCode != HttpStatus.SC_OK) {
            System.out.println("HTTP服務異常" + statusCode);
        }
        return responseMsg;
    }
    
    //POST方式發送HTTP請求
    public static void main(String[] args) {
        String json = "{\"PubInfo\": {\"clinet\": \"10.70.128.132\",\"company\": \"月月鳥0820\"},\"Request\": {\"strBillId\": \"18221075148\",\"strCcsOpId\": \"1234\"}}";
        String url = "http://localhost:8080/UpDown/postHttpServer";
        String outPackage = null;
        outPackage = postHttpReq(json, url);
        System.out.println("客戶端日志----POST方式調用HTTP,請求報文為:" + json);
        System.out
                .println("\nauthor<pantp>===========客戶端日志----POST方式調用HTTP服務,HTTP服務端響應報文如下:=============\n");

        System.out.println(outPackage);

        System.out
                .println("\nauthor<pantp>================================================================\n");
    }

}

3.測試結果

部署項目，啟動tomc，運行客戶端代碼中的main方式

客戶端的測試結果如下：

服務端的測試結果如下：