HttpClient 发送 POST 请求

API 说明

HttpClientBuilder用于创建CloseableHttpClient实例。
在 HttpClient 新的版本中， AbstractHttpClient、 AutoRetryHttpClient、 DefaultHttpClient等都被弃用了，使用HttpClientBuilder代替。

Client 代码

package com.bilfinance.core.service.impl;

import java.io.IOException;
import java.io.UnsupportedEncodingException;

import net.sf.json.JSONObject;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.ParseException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.EntityBuilder;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import com.achievo.framework.exception.FrameworkException;
import com.bilfinance.core.model.AsParam;
import com.bilfinance.core.model.AsResult;
import com.bilfinance.core.service.IAsHttpInterficeService;

@Service
public class AsHttpInterficeService implements IAsHttpInterficeService {

    private static Logger logger = LoggerFactory.getLogger(AsHttpInterficeService.class);


    @Override
    public AsResult doAsHttpMethod(AsParam asParam) throws FrameworkException {
        //请求内容
        String content = JSONObject.fromObject((Object)asParam).toString();
        logger.debug("AsParam = "+content);
        byte[] byte_content = null;
        try {
            byte_content = content.getBytes("UTF-8");
        } catch (UnsupportedEncodingException e2) {
            throw new FrameworkException("请求参数字符集编码异常：Charset=UTF-8");
        }

        //建立连接
        String urlstr = "http://localhost:7070/bqjrcar/WeiXinServlet";
        logger.debug("URL = "+urlstr);
        CloseableHttpClient client = HttpClientBuilder.create().build();
        HttpPost post = new HttpPost(urlstr);
        post.setConfig(RequestConfig.DEFAULT);
        EntityBuilder enbu = EntityBuilder.create().setContentType(ContentType.APPLICATION_JSON).setContentEncoding("UTF-8").setBinary(byte_content);
        HttpEntity rqEntity = enbu.build();
        post.setEntity(rqEntity);

        //执行请求
        HttpResponse httprs = null;
        try {
            httprs = client.execute(post);
        } catch (IOException e) {
            throw new FrameworkException("请求失败。meg="+e.getMessage(),e);
        }
        HttpEntity rsEntity = httprs.getEntity();
        logger.debug("StatusLine = "+httprs.getStatusLine());

        //返回结果
        AsResult result = null;
        if(httprs.getStatusLine().getStatusCode() != 200)
            throw new FrameworkException("安硕系统异常，StatusLine="+httprs.getStatusLine());
        if(rsEntity==null) 
            throw new FrameworkException("安硕保存返回空");
        try {
            String text = EntityUtils.toString(rsEntity, "UTF-8");
            logger.debug("AsResult = "+text);
            result = (AsResult)JSONObject.toBean(JSONObject.fromObject(text), AsResult.class);
        } catch (ParseException | IOException e) {
            throw new FrameworkException("安硕返回字符集编码异常：Charset=UTF-8");
        }

        //关闭连接
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return result;
    }


}

Servlet 代码

package com.weixinservlet;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.amarsoft.are.ARE;

import net.sf.json.JSONObject;

public class WeiXinServlet extends HttpServlet{

    private static final long serialVersionUID = -3501685878733962236L;


    @Override
    protected void service(HttpServletRequest rq, HttpServletResponse rs) throws ServletException, IOException {
        AsParam param = getPostParameter(rq);
        AsResult result = new AsResult();

        //合同保存
        if(AsParam.method_saveBC.equals(param.getMethod())){
            try {
                result = new WeiXinSaveCreditInfo().saveCreditInfo(param);
                result.setStatus(AsResult.status_success);
            } catch (Exception e) {
                result.setStatus(AsResult.status_failed);
                result.setMessage(e.getMessage());
            }
        }else {
            result.setStatus(AsResult.status_failed);
            result.setMessage("方法名称不正确，method="+param.getMethod());
        }

        //设置 Response
        rs.setContentType("text/html; charset=utf-8");
        rs.setCharacterEncoding("UTF-8");
        String asResult = JSONObject.fromObject(result).toString();
        ARE.getLog().debug("AsResult = "+asResult);
        rs.getWriter().println(asResult);
    }


    /**
     * 获取request参数
     */
    private AsParam getPostParameter(HttpServletRequest request){
        StringBuffer sb = new StringBuffer();
        try {
            InputStream in = request.getInputStream();
            BufferedReader breader = new BufferedReader(new InputStreamReader(in,"UTF-8"));
            String strTem;
            while((strTem=breader.readLine())!=null)
                sb.append(strTem); 
            breader.close();

            ARE.getLog().debug("AsParam = "+sb.toString());
            JSONObject datas = JSONObject.fromObject(sb.toString());
            AsParam bean = (AsParam)JSONObject.toBean(datas, AsParam.class);
            return bean;
        } catch (Exception e) {
            throw new RuntimeException("参数JSON格式错误！request="+sb.toString(),e);
        }
    }
}

AsParam.java

package com.weixinservlet;

import java.io.Serializable;
import java.util.HashMap;

public class AsParam implements Serializable{

    private static final long serialVersionUID = 1063546577762134098L;
    public static final String method_saveBC = "SaveCreditInfo"; 
    private String method;
    private String message;
    private HashMap<String, Object> data;
    public String getMethod() {
        return method;
    }
    public void setMethod(String method) {
        this.method = method;
    }
    public HashMap<String, Object> getData() {
        return data;
    }
    public void setData(HashMap<String, Object> data) {
        this.data = data;
    }
    public String getMessage() {
        return message;
    }
    public void setMessage(String message) {
        this.message = message;
    }

}

AsResult.java

package com.weixinservlet;

import java.io.Serializable;
import java.util.HashMap;

public class AsResult implements Serializable{

    private static final long serialVersionUID = -6044201397210634459L;
    public static final String status_success = "SUCCESS";
    public static final String status_failed = "FAILED";

    private String status;
    private String message;
    private HashMap<String, Object> data;

    public String getStatus() {
        return status;
    }
    public void setStatus(String status) {
        this.status = status;
    }
    public String getMessage() {
        return message;
    }
    public void setMessage(String message) {
        this.message = message;
    }
    public HashMap<String, Object> getData() {
        return data;
    }
    public void setData(HashMap<String, Object> data) {
        this.data = data;
    }

}