复制代码代码如下:
paquete org.ssi.util;
importar java.io.IOException;
importar java.util.ArrayList;
importar java.util.List;
importar net.sf.json.JSONArray;
importar org.apache.commons.lang.exception.ExceptionUtils;
importar org.apache.commons.logging.Log;
importar org.apache.commons.logging.LogFactory;
importar org.apache.http.HttpResponse;
importar org.apache.http.HttpStatus;
importar org.apache.http.NameValuePair;
importar org.apache.http.client.HttpClient;
importar org.apache.http.client.entity.UrlEncodedFormEntity;
importar org.apache.http.client.methods.HttpPost;
importar org.apache.http.impl.client.DefaultHttpClient;
importar org.apache.http.message.BasicNameValuePair;
importar org.apache.http.protocol.HTTP;
importar org.apache.http.util.EntityUtils;
clase pública APIHttpClient {
//接口地址
Cadena privada apiURL = "";
Registrador de registro privado = LogFactory.getLog(this.getClass());
Patrón de cadena final estático privado = "aaaa-MM-dd HH:mm:ss:SSS";
HttpClient privado httpClient = nulo;
método privado HttpPost = nulo;
tiempo de inicio largo privado = 0L;
tiempo de finalización largo privado = 0L;
estado de int privado = 0;
/**
* 接口地址
* URL @param
*/
APIHttpClient público (URL de cadena) {
si (url! = nulo)
{
this.apiURL = URL;
}
si (apiURL! = nulo)
{
httpClient = nuevo DefaultHttpClient();
método = nuevo HttpPost(apiURL);
}
}
/**
* 调用 API
* @param parámetros
* @devolver
*/
publicación de cadena pública (parámetros de cadena)
{
Cuerpo de cadena = nulo;
logger.info("parámetros:" + parámetros);
if(método!= nulo y parámetros!= nulo &&!"".equals(parameters.trim()))
{
JSONArray jsonObject = JSONArray.fromObject(parámetros);
logger.info("json:" + jsonObject.toString());
intentar{
Lista<NameValuePair> params=new ArrayList<NameValuePair>();
//建立一个NameValuePair数组，用于存储欲传送的参数
params.add(new BasicNameValuePair("datos",parámetros));
//添加参数
método.setEntity(new UrlEncodedFormEntity(params,HTTP.UTF_8));
horaInicio = System.currentTimeMillis();
//设置编码
HttpResponse respuesta=httpClient.execute(método);
horafinal = System.currentTimeMillis();
int statusCode = respuesta.getStatusLine().getStatusCode();
logger.info("código de estado:" + código de estado);
logger.info("调用API 花费时间(单位：毫秒)：" + (endTime - startTime));
if(código de estado! = HttpStatus.SC_OK){
logger.error("Método fallido:"+response.getStatusLine());
estado = 1;
}
//Leer el cuerpo de la respuesta
cuerpo=EntityUtils.toString(response.getEntity());
}catch(IOException e){
//发生网络异常
logger.error("¡Se produjo una excepción!/n"+ExceptionUtils.getFullStackTrace(e));
//网络错误
estado = 3;
}
finalmente{
logger.info("调用接口状态：" + estado);
}
}
cuerpo de retorno;
}
/**
* 0.成功 1.执行方法失败 2.协议错误 3.网络错误
* @devolver el estado
*/
público int getStatus() {
estado de devolución;
}
/**
* @param status el estado a establecer
*/
setStatus público vacío (estado int) {
this.status = estado;
}
/**
* @return the startTime
*/
público largo getStartTime() {
devolver hora de inicio;
}
/**
* @return the endTime
*/
público largo getEndTime() {
devolver hora final;
}
}