1. 程式人生 > >HttpURLConnection 傳送 檔案和字串資訊

HttpURLConnection 傳送 檔案和字串資訊

直接上程式碼

/**

     * 通過拼接的方式構造請求內容,實現引數傳輸以及檔案傳輸
     * 
     * @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();
	
    }