import java.io.BufferedReader
import java.io.IOException
import java.io.InputStream
import java.io.InputStreamReader
import java.io.StringWriter
import java.io.UnsupportedEncodingException
import java.util.ArrayList
import java.util.List
import java.util.Map
import org.apache.http.Header
import org.apache.http.HttpHost
import org.apache.http.HttpResponse
import org.apache.http.HttpStatus
import org.apache.http.HttpVersion
import org.apache.http.ParseException
import org.apache.http.client.ClientProtocolException
import org.apache.http.client.HttpClient
import org.apache.http.client.entity.UrlEncodedFormEntity
import org.apache.http.client.methods.HttpGet
import org.apache.http.client.methods.HttpPost
import org.apache.http.client.params.CookiePolicy
import org.apache.http.client.params.HttpClientParams
import org.apache.http.conn.params.ConnRoutePNames
import org.apache.http.impl.client.DefaultHttpClient
import org.apache.http.message.BasicNameValuePair
import org.apache.http.params.BasicHttpParams
import org.apache.http.params.HttpConnectionParams
import org.apache.http.params.HttpParams
import org.apache.http.params.HttpProtocolParams
import org.apache.http.protocol.HTTP
//import bsh.ParseException
import com.google.gson.Gson
/**
* TODO
* @Version 1.0
*/
public class HttpClients {
/** UTF-8 */
private static final String UTF_8 = "UTF-8"
/** 日志记录tag */
private static final String TAG = "HttpClients"
/** 用户host */
private static String proxyHost = ""
/** 用户端口 */
private static int proxyPort = 80
/** 是否使用用户端口 */
private static boolean useProxy = false
/** 连接超时 */
private static final int TIMEOUT_CONNECTION = 60000
/** 读取超时 */
private static final int TIMEOUT_SOCKET = 60000
/** 重试3次 */
private static final int RETRY_TIME = 3
/**
* @param url
* @param requestData
* @return
*/
public String doHtmlPost(HttpClient httpClient,HttpPost httpPost )
{
String responseBody = null
int statusCode = -1
try {
HttpResponse httpResponse = httpClient.execute(httpPost)
Header lastHeader = httpResponse.getLastHeader("Set-Cookie")
if(null != lastHeader)
{
httpPost.setHeader("cookie", lastHeader.getValue())
}
statusCode = httpResponse.getStatusLine().getStatusCode()
if (statusCode != HttpStatus.SC_OK) {
System.out.println("HTTP" + " " + "HttpMethod failed: " + httpResponse.getStatusLine())
}
InputStream is = httpResponse.getEntity().getContent()
responseBody = getStreamAsString(is, HTTP.UTF_8)
} catch (Exception e) {
e.printStackTrace()
} finally {
// httpClient.getConnectionManager().shutdown()
// httpClient = null
}
return responseBody
}
/**
*
* 发起网络请求
*
* @param url
* URL
* @param requestData
* requestData
* @return INPUTSTREAM
* @throws AppException
*/
public static String doPost(String url, String requestData) throws Exception {
String responseBody = null
HttpPost httpPost = null
HttpClient httpClient = null
int statusCode = -1
int time = 0
do {
try {
httpPost = new HttpPost(url)
httpClient = getHttpClient()
// 设置HTTP POST请求参数必须用NameValuePair对象
List<BasicNameValuePair> params = new ArrayList<BasicNameValuePair>()
params.add(new BasicNameValuePair("param", requestData))
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(params, HTTP.UTF_8)
// 设置HTTP POST请求参数
httpPost.setEntity(entity)
HttpResponse httpResponse = httpClient.execute(httpPost)
statusCode = httpResponse.getStatusLine().getStatusCode()
if (statusCode != HttpStatus.SC_OK) {
System.out.println("HTTP" + " " + "HttpMethod failed: " + httpResponse.getStatusLine())
}
InputStream is = httpResponse.getEntity().getContent()
responseBody = getStreamAsString(is, HTTP.UTF_8)
break
} catch (UnsupportedEncodingException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生致命的异常，可能是协议不对或者返回的内容有问题
e.printStackTrace()
} catch (ClientProtocolException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生致命的异常，可能是协议不对或者返回的内容有问题
e.printStackTrace()
} catch (IOException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生网络异常
e.printStackTrace()
} catch (Exception e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生网络异常
e.printStackTrace()
} finally {
httpClient.getConnectionManager().shutdown()
httpClient = null
}
} while (time < RETRY_TIME)
return responseBody
}
/**
*
* 将InputStream 转化为String
*
* @param stream
* inputstream
* @param charset
* 字符集
* @return
* @throws IOException
*/
private static String getStreamAsString(InputStream stream, String charset) throws IOException {
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(stream, charset), 8192)
StringWriter writer = new StringWriter()
char[] chars = new char[8192]
int count = 0
while ((count = reader.read(chars)) > 0) {
writer.write(chars, 0, count)
}
return writer.toString()
} finally {
if (stream != null) {
stream.close()
}
}
}
/**
* 得到httpClient
*
* @return
*/
public HttpClient getHttpClient1() {
final HttpParams httpParams = new BasicHttpParams()
if (useProxy) {
HttpHost proxy = new HttpHost(proxyHost, proxyPort, "http")
httpParams.setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy)
}
HttpConnectionParams.setConnectionTimeout(httpParams, TIMEOUT_CONNECTION)
HttpConnectionParams.setSoTimeout(httpParams, TIMEOUT_SOCKET)
HttpClientParams.setRedirecting(httpParams, true)
final String userAgent = "Mozilla/5.0 (Windows U Windows NT 6.1 zh-CN rv:1.9.2.14) Gecko/20110218 Firefox/3.6.14"
HttpProtocolParams.setUserAgent(httpParams, userAgent)
HttpProtocolParams.setVersion(httpParams, HttpVersion.HTTP_1_1)
HttpClientParams.setCookiePolicy(httpParams, CookiePolicy.RFC_2109)
HttpProtocolParams.setUseExpectContinue(httpParams, false)
HttpClient client = new DefaultHttpClient(httpParams)
return client
}
/**
*
* 得到httpClient
*
* @return
*/
private static HttpClient getHttpClient() {
final HttpParams httpParams = new BasicHttpParams()
if (useProxy) {
HttpHost proxy = new HttpHost(proxyHost, proxyPort, "http")
httpParams.setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy)
}
HttpConnectionParams.setConnectionTimeout(httpParams, TIMEOUT_CONNECTION)
HttpConnectionParams.setSoTimeout(httpParams, TIMEOUT_SOCKET)
HttpClientParams.setRedirecting(httpParams, true)
final String userAgent = "Mozilla/5.0 (Windows U Windows NT 6.1 zh-CN rv:1.9.2.14) Gecko/20110218 Firefox/3.6.14"
HttpProtocolParams.setUserAgent(httpParams, userAgent)
HttpProtocolParams.setVersion(httpParams, HttpVersion.HTTP_1_1)
HttpClientParams.setCookiePolicy(httpParams, CookiePolicy.BROWSER_COMPATIBILITY)
HttpProtocolParams.setUseExpectContinue(httpParams, false)
HttpClient client = new DefaultHttpClient(httpParams)
return client
}
/**
* 打印返回内容
* @param response
* @throws ParseException
* @throws IOException
*/
public static void showResponse(String str) throws Exception {
Gson gson = new Gson()
Map<String, Object> map = (Map<String, Object>) gson.fromJson(str, Object.class)
String value = (String) map.get("data")
//String decodeValue = Des3Request.decode(value)
//System.out.println(decodeValue)
//logger.debug(decodeValue)
}
/**
*
* 发起网络请求
*
* @param url
* URL
* @param requestData
* requestData
* @return INPUTSTREAM
* @throws AppException
*/
public static String doGet(String url) throws Exception {
String responseBody = null
HttpGet httpGet = null
HttpClient httpClient = null
int statusCode = -1
int time = 0
do {
try {
httpGet = new HttpGet(url)
httpClient = getHttpClient()
HttpResponse httpResponse = httpClient.execute(httpGet)
statusCode = httpResponse.getStatusLine().getStatusCode()
if (statusCode != HttpStatus.SC_OK) {
System.out.println("HTTP" + " " + "HttpMethod failed: " + httpResponse.getStatusLine())
}
InputStream is = httpResponse.getEntity().getContent()
responseBody = getStreamAsString(is, HTTP.UTF_8)
break
} catch (UnsupportedEncodingException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生致命的异常，可能是协议不对或者返回的内容有问题
e.printStackTrace()
} catch (ClientProtocolException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生致命的异常，可能是协议不对或者返回的内容有问题
e.printStackTrace()
} catch (IOException e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生网络异常
e.printStackTrace()
} catch (Exception e) {
time++
if (time < RETRY_TIME) {
try {
Thread.sleep(1000)
} catch (InterruptedException e1) {
}
continue
}
// 发生网络异常
e.printStackTrace()
} finally {
httpClient.getConnectionManager().shutdown()
httpClient = null
}
} while (time < RETRY_TIME)
return responseBody
}
}
HttpClient方式发送请求或则以流的方式。两种实现方式不同，怎么使用看个人喜好，不过在项目开发过程中，使用流的方式部署在预发机linux机器上会出现发送请求返回null的情况，但是本地windows却正常访问，而且，换另外一台预发机也能正常获取数据，目前还没有研究出个所以然，get是从服务器上获取数据，post是向服务器传送数据，get是把参数数据队列加到提交表单的ACTION属性所指的URL中，值和表单内各个字段一一对应，在URL中可以看到，post是通过HTTPpost机制，将表单内各个字段与其内容放置在HTML HEADER内一起传送到ACTION属性所指的URL地址。
