HttpURLConnection 傳送 檔案和字串資訊
阿新 • • 發佈:2019-02-19
直接上程式碼
/**
* 通過拼接的方式構造請求內容,實現引數傳輸以及檔案傳輸*
* @param actionUrl 訪問的伺服器URL
* @param params 普通引數
* @param files 檔案引數
* @return
* @throws IOException
*/
public static void post(String actionUrl, Map<String, String> params, Map<String, File> files) throws IOException
{
String BOUNDARY = java.util.UUID.randomUUID().toString();
String PREFIX = "--", LINEND = "\r\n";
String MULTIPART_FROM_DATA = "multipart/form-data";
String CHARSET = "UTF-8";
URL uri = new URL(actionUrl);
HttpURLConnection conn = (HttpURLConnection) uri.openConnection();
conn.setReadTimeout(5 * 1000); // 快取的最長時間
conn.setDoInput(true);// 允許輸入
conn.setDoOutput(true);// 允許輸出
conn.setUseCaches(false); // 不允許使用快取
conn.setRequestMethod("POST");
conn.setRequestProperty("connection", "keep-alive");
conn.setRequestProperty("Charsert", "UTF-8");
conn.setRequestProperty("Content-Type", MULTIPART_FROM_DATA + ";boundary=" + BOUNDARY);
// 首先組拼文字型別的引數
StringBuilder sb = new StringBuilder();
for (Map.Entry<String, String> entry : params.entrySet())
{
sb.append(PREFIX);
sb.append(BOUNDARY);
sb.append(LINEND);
sb.append("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"" + LINEND);
sb.append("Content-Type: text/plain; charset=" + CHARSET + LINEND);
sb.append("Content-Transfer-Encoding: 8bit" + LINEND);
sb.append(LINEND);
sb.append(entry.getValue());
sb.append(LINEND);
}
DataOutputStream outStream = new DataOutputStream(conn.getOutputStream());
outStream.write(sb.toString().getBytes());
InputStream in = null;
// 傳送檔案資料
if (files != null)
{
for (Map.Entry<String, File> file : files.entrySet())
{
StringBuilder sb1 = new StringBuilder();
sb1.append(PREFIX);
sb1.append(BOUNDARY);
sb1.append(LINEND);
// name是post中傳參的鍵 filename是檔案的名稱
sb1.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + file.getKey() + "\"" + LINEND);
sb1.append("Content-Type: application/octet-stream; charset=" + CHARSET + LINEND);
sb1.append(LINEND);
outStream.write(sb1.toString().getBytes());
InputStream is = new FileInputStream(file.getValue());
byte[] buffer = new byte[1024];
int len = 0;
while ((len = is.read(buffer)) != -1)
{
outStream.write(buffer, 0, len);
}
is.close();
outStream.write(LINEND.getBytes());
}
// 請求結束標誌
byte[] end_data = (PREFIX + BOUNDARY + PREFIX + LINEND).getBytes();
outStream.write(end_data);
outStream.flush();
// 得到響應碼
int res = conn.getResponseCode();
if (res == 200)
{
in = conn.getInputStream();
int ch;
StringBuilder sb2 = new StringBuilder();
while ((ch = in.read()) != -1)
{
sb2.append((char) ch);
}
}
outStream.close();
conn.disconnect();
}
// return in.toString();
}
以資料流的形式傳參
public static String postFile(String actionUrl, Map<String, String> params, Map<String, byte[]> files)
throws Exception
{
StringBuilder sb2 = null;
String BOUNDARY = java.util.UUID.randomUUID().toString();
String PREFIX = "--", LINEND = "\r\n";
String MULTIPART_FROM_DATA = "multipart/form-data";
String CHARSET = "UTF-8";
URL uri = new URL(actionUrl);
HttpURLConnection conn = (HttpURLConnection) uri.openConnection();
conn.setReadTimeout(6 * 1000); // 快取的最長時間
conn.setDoInput(true);// 允許輸入
conn.setDoOutput(true);// 允許輸出
conn.setUseCaches(false); // 不允許使用快取
conn.setRequestMethod("POST");
conn.setRequestProperty("connection", "keep-alive");
conn.setRequestProperty("Charsert", "UTF-8");
conn.setRequestProperty("Content-Type", MULTIPART_FROM_DATA + ";boundary=" + BOUNDARY);
// 首先組拼文字型別的引數
StringBuilder sb = new StringBuilder();
for (Map.Entry<String, String> entry : params.entrySet())
{
sb.append(PREFIX);
sb.append(BOUNDARY);
sb.append(LINEND);
sb.append("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"" + LINEND);
sb.append("Content-Type: text/plain; charset=" + CHARSET + LINEND);
sb.append("Content-Transfer-Encoding: 8bit" + LINEND);
sb.append(LINEND);
sb.append(entry.getValue());
sb.append(LINEND);
}
DataOutputStream outStream = new DataOutputStream(conn.getOutputStream());
outStream.write(sb.toString().getBytes());
InputStream in = null;
// 傳送檔案資料
if (files != null)
{
for (Map.Entry<String, byte[]> file : files.entrySet())
{
StringBuilder sb1 = new StringBuilder();
sb1.append(PREFIX);
sb1.append(BOUNDARY);
sb1.append(LINEND);
sb1.append("Content-Disposition: form-data; name=\"pic\"; filename=\"" + file.getKey() + "\"" + LINEND);
sb1.append("Content-Type: application/octet-stream; charset=" + CHARSET + LINEND);
sb1.append(LINEND);
outStream.write(sb1.toString().getBytes());
// InputStream is = new FileInputStream(file.getValue());
// byte[] buffer = new byte[1024];
// int len = 0;
// while ((len = is.read(buffer)) != -1)
// {
// outStream.write(buffer, 0, len);
// }
// is.close();
outStream.write(file.getValue());
outStream.write(LINEND.getBytes());
}
// 請求結束標誌
byte[] end_data = (PREFIX + BOUNDARY + PREFIX + LINEND).getBytes();
outStream.write(end_data);
outStream.flush();
// 得到響應碼
int res = conn.getResponseCode();
if (res == 200)
{
in = conn.getInputStream();
int ch;
sb2 = new StringBuilder();
while ((ch = in.read()) != -1)
{
sb2.append((char) ch);
}
System.out.println(sb2.toString());
}
outStream.close();
conn.disconnect();
// 解析伺服器返回來的資料
return ParseJson.getEditMadIconResult(sb2.toString());
}
else
{
return "Update icon Fail";
}
// return in.toString();
}
專案改進
public static HttpURLConnection getCon(String url) {
try {
URL uri = new URL(url);
HttpURLConnection conn = (HttpURLConnection) uri.openConnection();
conn.setConnectTimeout(CONNECTTIMEOUT);
conn.setReadTimeout(READTIMEOUT);
conn.setDoOutput(true);
conn.setDoInput(true);
conn.setUseCaches(false);
conn.setRequestMethod("POST");
conn.setRequestProperty("Connection", "Keep-Alive");
conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows; U; Windows NT 6.1; zh-CN; rv:1.9.2.6)");
conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=---------------------------");
return conn;
} catch (MalformedURLException e) {
System.out.println("請求超時");
BaseAction.LOGGER.error(e);
} catch (IOException e) {
}
return null;
}
public static String sendPost(String url, File file, Map<String, Object> params, String filename1) {
String res = "";
ByteArrayOutputStream ret = null;
// boundary就是request頭和上傳檔案內容的分隔符
String boundary = "---------------------------";
DataInputStream in = null;
BufferedReader reader = null;
FileInputStream fileInputStream = null;
try {
String rn = "\r\n";
HttpURLConnection conn = getCon(url);
OutputStream out = new DataOutputStream(conn.getOutputStream());
// text
if (params != null) {
StringBuilder strBuf = new StringBuilder();
Iterator<Map.Entry<String, Object>> iter = params.entrySet().iterator();
while (iter.hasNext()) {
Map.Entry<String, Object> entry = iter.next();
String inputName = entry.getKey();
Object inputValue = entry.getValue();
if (null == inputValue) {
continue;
}
strBuf.append(rn).append("--").append(boundary).append(rn);
strBuf.append("Content-Disposition: form-data; name=\"" + inputName + "\"" + rn + rn);
strBuf.append(inputValue);
}
out.write(strBuf.toString().getBytes());
}
// file
if (file != null) {
StringBuilder strBuf = new StringBuilder();
strBuf.append(rn).append("--").append(boundary).append(rn);
strBuf.append("Content-Disposition: form-data; name=\"pic\"; filename=\"" + filename1 + "\"" + rn);
strBuf.append("Content-Type:application/octet-stream " + rn + rn);
out.write(strBuf.toString().getBytes());
fileInputStream = new FileInputStream(file);
in = new DataInputStream(fileInputStream);
int bytes;
byte[] bufferOut = new byte[MAX];
while ((bytes = in.read(bufferOut)) != -1) {
out.write(bufferOut, 0, bytes);
}
in.close();
fileInputStream.close();
}
byte[] endData = ("\r\n--" + boundary + "--\r\n").getBytes();
out.write(endData);
out.flush();
out.close();
// *******************************************
// 讀取返回資料
/*
* StringBuilder strBuf = new StringBuilder(); reader = new
* BufferedReader( new InputStreamReader(conn.getInputStream()));
* String line; while ((line = reader.readLine()) != null) {
* strBuf.append(line).append("\n"); } res = strBuf.toString();
* System.out.println(" 返回:" + res); //System.out.println(" 返回:" +
* DESUtil.decrypt(res)); reader.close();
*/
// ****newread*****************************************
InputStream input = conn.getInputStream();
// 位元組陣列
byte[] bcache = new byte[2048];
int readSize = 0;// 每次讀取的位元組長度
ret = new ByteArrayOutputStream();
try {
// 一次性讀取2048位元組
while ((readSize = input.read(bcache)) > 0) {
ret.write(bcache, 0, readSize);
}
} catch (IOException e1) {
BaseAction.LOGGER.error(e1);
} finally {
try {
// 輸入流關閉
input.close();
} catch (IOException e) {
}
}
System.out.println(" 返回:" + ret.toString());
// *****newreadend
// ***************************************************************
conn.disconnect();
} catch (IOException e) {
} finally {
try {
if (in != null) {
in.close();
}
if (reader != null) {
reader.close();
}
if (fileInputStream != null) {
fileInputStream.close();
}
} catch (IOException e) {
BaseAction.LOGGER.error(e);
}
}
return ret.toString();
}