// An highlighted block

public synchronized static byte[] CustomPostMethodPost(String url, String charset, Map header,

Map data, String body) throws Exception {

byte[] result = null;

CustomPostMethod postMethod = new CustomPostMethod(url);

try {

HttpClient client = getClient(charset);

if (header != null && !header.isEmpty()) {

Set headers = header.keySet();

for (String key : headers) {

postMethod.setRequestHeader(key, header.get(key));

}

}

if (data != null && !data.isEmpty()) {

Set keys = data.keySet();

NameValuePair[] ps = new NameValuePair[keys.size()];

int index = 0;

for (String k : keys) {

ps[index++] = new NameValuePair(k, data.get(k));

}

postMethod.setRequestBody(ps);

}

postMethod.setQueryString(body);

int statusCode = client.executeMethod(postMethod);

Header[] _map = postMethod.getResponseHeaders();

Map map = new HashMap();

for (Header h : _map) {

map.put(h.getName(), h.getValue());

}

if (statusCode == 200) {

result = postMethod.getResponseBody();

return result;

} else if (statusCode == 302) {

result = postMethod.getResponseBody();

return result;

}

postMethod.abort();

throw new java.net.ConnectException("请求错误,status code is[" + statusCode + "]");

} catch (Exception e) {

postMethod.abort();

throw e;

} finally {

postMethod.releaseConnection();

}

}

private static HttpClient getClient(String charset) {

HttpClient client = new HttpClient(connectionManager);

HttpConnectionManagerParams params = client.getHttpConnectionManager().getParams();

params.setConnectionTimeout(30000);

params.setSoTimeout(30000);

params.setDefaultMaxConnectionsPerHost(500);

params.setMaxTotalConnections(1500);

params.setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler());

HttpClientParams hcp = client.getParams();

hcp.setParameter("http.connection.timeout", 20 * 1000L);

hcp.setParameter("http.connection-manager.timeout", 20 * 1000L);

hcp.setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, charset);

hcp.setAuthenticationPreemptive(true);

return client;

}

public class CustomPostMethod extends

org.apache.commons.httpclient.methods.PostMethod{

public CustomPostMethod(String url){

super(url);

}

public String getResponseBodyAsString() throws IOException {

GZIPInputStream gzin;

if (getResponseBody() != null || getResponseStream() != null) {

if (getResponseHeader("Content-Encoding") != null

&& getResponseHeader("Content-Encoding").getValue()

.toLowerCase().indexOf("gzip") > -1) {

// For GZip response

InputStream is = getResponseBodyAsStream();

gzin = new GZIPInputStream(is);

InputStreamReader isr = new InputStreamReader(gzin,

getResponseCharSet());

java.io.BufferedReader br = new java.io.BufferedReader(isr);

StringBuffer sb = new StringBuffer();

String tempbf;

while ((tempbf = br.readLine()) != null) {

sb.append(tempbf);

sb.append("\r\n");

}

isr.close();

gzin.close();

return sb.toString();

} else {

// For deflate response

return super.getResponseBodyAsString();

}

} else {

return null;

}

}

}