您的位置:首页 > 理论基础 > 计算机网络

Apache并发请求数及其TCP连接状态

2015-07-28 12:34 495 查看
package cn.wemart.httppost;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import net.sf.json.JSONObject;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.dom4j.DocumentException;

public class ExecuteGet {

/**
* 组装请求参数
* @param keyVlaueList
*/
public static Map<String ,String> setPostPara(String[][] keyVlaueList) throws DocumentException{
Map<String ,String> map = new HashMap<String ,String>();
for(int i = 0;i<keyVlaueList.length;i++)
{
map.put(keyVlaueList[i][0],keyVlaueList[i][1]);
}
return map;
}

/**
* 获取接口返回字符串
* @param url
* @throws DocumentException
* @throws URISyntaxException
*/
public static String getGetMethodResponse(String url,String[][] keyVlaueList) {
String xmlStr =null;
String Str;
try {

//把键值对转换成JSON格式串
Map<String, String> postMap;
postMap = setPostPara(keyVlaueList);
JSONObject object = JSONObject.fromObject(postMap);

List<NameValuePair> postPara = new ArrayList<NameValuePair>();
postPara.add(new BasicNameValuePair("para",object.toString()));
System.out.println("+++++para="+object.toString()+"+++++");

//发送转码过的字符串,发送
CloseableHttpClient httpclient = HttpClients.createDefault();
HttpGet httpget = new HttpGet(url);
String sendstr = EntityUtils.toString(new UrlEncodedFormEntity(postPara,HTTP.UTF_8));
httpget.setURI(new URI(httpget.getURI().toString() + "?" + sendstr));
CloseableHttpResponse response = httpclient.execute(httpget);

//处理response的中文编码
BufferedReader reader = new BufferedReader(new InputStreamReader(response.getEntity().getContent(),"UTF-8"));
StringBuffer sb = new StringBuffer();
while ((Str = reader.readLine()) != null) {
sb.append(Str).append("\n");
}
xmlStr = sb.toString();

} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (URISyntaxException e) {
e.printStackTrace();
} catch (DocumentException e) {
e.printStackTrace();
}
return xmlStr;
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: