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方式

客户端的测试结果如下：

服务端的测试结果如下：