Java:使用HttpClient進行POST和GET請求以及文件下載
來源：程序員人生 發布時間：2015-03-06 08:43:48 閱讀次數：2866次
1.HttpClient
大家可以先看1下HttpClient的介紹，這篇博文寫的還算不錯：http://blog.csdn.net/wangpeng047/article/details/19624529
固然，詳細的文檔，你可以去官方網站查看和下載：http://hc.apache.org/httpclient⑶.x/
2.本博客簡單介紹1下POST和GET和文件下載的利用。
代碼以下：
package net.mobctrl;
import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
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.util.EntityUtils;
/**
* @web http://www.mobctrl.net
* @author Zheng Haibo
* @Description: 文件下載 POST GET
*/
public class HttpClientUtils {
/**
* 最大線程池
*/
public static final int THREAD_POOL_SIZE = 5;
public interface HttpClientDownLoadProgress {
public void onProgress(int progress);
}
private static HttpClientUtils httpClientDownload;
private ExecutorService downloadExcutorService;
private HttpClientUtils() {
downloadExcutorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE);
}
public static HttpClientUtils getInstance() {
if (httpClientDownload == null) {
httpClientDownload = new HttpClientUtils();
}
return httpClientDownload;
}
/**
* 下載文件
*
* @param url
* @param filePath
*/
public void download(final String url, final String filePath) {
downloadExcutorService.execute(new Runnable() {
@Override
public void run() {
httpDownloadFile(url, filePath, null,null);
}
});
}
/**
* 下載文件
*
* @param url
* @param filePath
* @param progress
* 進度回調
*/
public void download(final String url, final String filePath,
final HttpClientDownLoadProgress progress) {
downloadExcutorService.execute(new Runnable() {
@Override
public void run() {
httpDownloadFile(url, filePath, progress,null);
}
});
}
/**
* 下載文件
*
* @param url
* @param filePath
*/
private void httpDownloadFile(String url, String filePath,
HttpClientDownLoadProgress progress, Map<String, String> headMap) {
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpGet httpGet = new HttpGet(url);
setGetHead(httpGet, headMap);
CloseableHttpResponse response1 = httpclient.execute(httpGet);
try {
System.out.println(response1.getStatusLine());
HttpEntity httpEntity = response1.getEntity();
long contentLength = httpEntity.getContentLength();
InputStream is = httpEntity.getContent();
// 根據InputStream 下載文件
ByteArrayOutputStream output = new ByteArrayOutputStream();
byte[] buffer = new byte[4096];
int r = 0;
long totalRead = 0;
while ((r = is.read(buffer)) > 0) {
output.write(buffer, 0, r);
totalRead += r;
if (progress != null) {// 回調進度
progress.onProgress((int) (totalRead * 100 / contentLength));
}
}
FileOutputStream fos = new FileOutputStream(filePath);
output.writeTo(fos);
output.flush();
output.close();
fos.close();
EntityUtils.consume(httpEntity);
} finally {
response1.close();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
httpclient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* get要求
*
* @param url
* @return
*/
public String httpGet(String url) {
return httpGet(url, null);
}
/**
* http get要求
*
* @param url
* @return
*/
public String httpGet(String url, Map<String, String> headMap) {
String responseContent = null;
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpGet httpGet = new HttpGet(url);
CloseableHttpResponse response1 = httpclient.execute(httpGet);
setGetHead(httpGet, headMap);
try {
System.out.println(response1.getStatusLine());
HttpEntity entity = response1.getEntity();
InputStream is = entity.getContent();
StringBuffer strBuf = new StringBuffer();
byte[] buffer = new byte[4096];
int r = 0;
while ((r = is.read(buffer)) > 0) {
strBuf.append(new String(buffer, 0, r, "UTF⑻"));
}
responseContent = strBuf.toString();
System.out.println("debug:" + responseContent);
EntityUtils.consume(entity);
} finally {
response1.close();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
httpclient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return responseContent;
}
public String httpPost(String url, Map<String, String> paramsMap) {
return httpPost(url, paramsMap, null);
}
/**
* http的post要求
*
* @param url
* @param paramsMap
* @return
*/
public String httpPost(String url, Map<String, String> paramsMap,
Map<String, String> headMap) {
String responseContent = null;
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpPost httpPost = new HttpPost(url);
setPostHead(httpPost, headMap);
setPostParams(httpPost, paramsMap);
CloseableHttpResponse response = httpclient.execute(httpPost);
try {
System.out.println(response.getStatusLine());
HttpEntity entity = response.getEntity();
InputStream is = entity.getContent();
StringBuffer strBuf = new StringBuffer();
byte[] buffer = new byte[4096];
int r = 0;
while ((r = is.read(buffer)) > 0) {
strBuf.append(new String(buffer, 0, r, "UTF⑻"));
}
responseContent = strBuf.toString();
EntityUtils.consume(entity);
} finally {
response.close();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
httpclient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
System.out.println("responseContent = " + responseContent);
return responseContent;
}
/**
* 設置POST的參數
*
* @param httpPost
* @param paramsMap
* @throws Exception
*/
private void setPostParams(HttpPost httpPost, Map<String, String> paramsMap)
throws Exception {
if (paramsMap != null && paramsMap.size() > 0) {
List<NameValuePair> nvps = new ArrayList<NameValuePair>();
Set<String> keySet = paramsMap.keySet();
for (String key : keySet) {
nvps.add(new BasicNameValuePair(key, paramsMap.get(key)));
}
httpPost.setEntity(new UrlEncodedFormEntity(nvps));
}
}
/**
* 設置http的HEAD
*
* @param httpPost
* @param headMap
*/
private void setPostHead(HttpPost httpPost, Map<String, String> headMap) {
if (headMap != null && headMap.size() > 0) {
Set<String> keySet = headMap.keySet();
for (String key : keySet) {
httpPost.addHeader(key, headMap.get(key));
}
}
}
/**
* 設置http的HEAD
*
* @param httpGet
* @param headMap
*/
private void setGetHead(HttpGet httpGet, Map<String, String> headMap) {
if (headMap != null && headMap.size() > 0) {
Set<String> keySet = headMap.keySet();
for (String key : keySet) {
httpGet.addHeader(key, headMap.get(key));
}
}
}
}
我們可使用以下代碼進行測試：
import java.util.HashMap;
import java.util.Map;
import net.mobctrl.HttpClientUtils;
import net.mobctrl.HttpClientUtils.HttpClientDownLoadProgress;
/**
* @date 2015年1月14日 下午1:49:50
* @author Zheng Haibo
* @Description: 測試
*/
public class Main {
public static void main(String[] args) {
/**
* 測試下載文件 異步下載
*/
HttpClientUtils.getInstance().download(
"http://newbbs.qiniudn.com/phone.png", "test.png",
new HttpClientDownLoadProgress() {
@Override
public void onProgress(int progress) {
System.out.println("download progress = " + progress);
}
});
// POST 同步方法
Map<String, String> params = new HashMap<String, String>();
params.put("username", "admin");
params.put("password", "admin");
HttpClientUtils.getInstance().httpPost(
"http://localhost:8080/sshmysql/register", params);
// GET 同步方法
HttpClientUtils.getInstance().httpGet(
"http://wthrcdn.etouch.cn/weather_mini?city=北京");
}
}
運行結果為：
HTTP/1.1 200 OK
responseContent = {"id":"⑵","msg":"添加失敗!用戶名已存在！"}
HTTP/1.1 200 OK
debug:{"desc":"OK","status":1000,"data":{"wendu":"⑴","ganmao":"天氣轉涼，空氣濕度較大，較易產生感冒，體質較弱的朋友請注意適當防護。","forecast":[{"fengxiang":"無延續風向","fengli":"微風級","high":"高溫 2℃","type":"小雪","low":"低溫 ⑸℃","date":"14日星期3"},{"fengxiang":"無延續風向","fengli":"微風級","high":"高溫 3℃","type":"霾","low":"低溫 ⑶℃","date":"15日星期4"},{"fengxiang":"北風","fengli":"4⑸級","high":"高溫 5℃","type":"晴","low":"低溫 ⑹℃","date":"16日星期5"},{"fengxiang":"無延續風向","fengli":"微風級","high":"高溫 4℃","type":"多云","low":"低溫 ⑸℃","date":"17日星期6"},{"fengxiang":"無延續風向","fengli":"微風級","high":"高溫 6℃","type":"多云","low":"低溫 ⑷℃","date":"18日星期天"}],"yesterday":{"fl":"微風","fx":"無延續風向","high":"高溫 4℃","type":"霾","low":"低溫 ⑷℃","date":"13日星期2"},"aqi":"309","city":"北京"}}
HTTP/1.1 200 OK
download progress = 2
download progress = 6
download progress = 8
download progress = 10
download progress = 12
download progress = 15
download progress = 17
download progress = 20
download progress = 22
download progress = 27
download progress = 29
download progress = 31
download progress = 33
download progress = 36
download progress = 38
download progress = 40
download progress = 45
download progress = 47
download progress = 49
download progress = 51
download progress = 54
download progress = 56
download progress = 58
download progress = 60
download progress = 62
download progress = 69
download progress = 75
download progress = 81
download progress = 87
download progress = 89
download progress = 91
download progress = 93
download progress = 96
download progress = 100
下載進程有進度回調。
相干的libs包，可以在以下鏈接中下載：http://download.csdn.net/detail/nuptboyzhb/8362801
上述代碼，既可以在J2SE,J2EE中使用，也能夠在Android中使用，在android中使用時，需要相干的權限。
未經允許不得用于商業目的
生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈
