在現(xiàn)在的網(wǎng)絡開發(fā)中,上傳圖片類的需求實在是太普通不過了,但是對于怎么樣做到上傳圖片,對于剛開始建立項目的時候,還是有點不知所措的。也許有幸,我們做的項目是之前已經(jīng)有人寫過類似的用例了,那么我們只需要依葫蘆畫瓢就行了。
好好了解下圖片上傳(文件上傳)的方式,對于認知的提升還是有好處的。而且說不定哪天你就有個這樣的需求呢,這里是一條龍上傳。
本文就一個從app到php層,再到java層的流程,演譯下整個上傳圖片的流程吧。
一、app端獲取用戶選擇的圖片,轉(zhuǎn)化為輸入流,上傳至php前端接口:
package com.dia.ration;import java.io.DataOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStream;import java.net.HttpURLConnection;import java.net.MalformedURLException;import java.net.URL;import java.util.HashMap;import java.util.Map;import java.util.UUID;/** * 上傳文件到服務器類 */public class UploadUtil { private static final String TAG = "uploadFile"; private static final int TIME_OUT = 10 * 1000; // 超時時間 private static final String CHARSET = "utf-8"; // 設置編碼 /** * Android上傳文件到服務端 * * @param file 需要上傳的文件 * @param RequestURL 請求的rul * @return 返回響應的內(nèi)容 */ public static String uploadFile(File file, String RequestURL) { String result = null; String BOUNDARY = UUID.randomUUID().toString(); // 邊界標識 隨機生成 String PREFIX = "--", LINE_END = "\r\n"; String CONTENT_TYPE = "multipart/form-data"; // 內(nèi)容類型 try { URL url = new URL(RequestURL); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setReadTimeout(TIME_OUT); conn.setConnectTimeout(TIME_OUT); conn.setDoInput(true); // 允許輸入流 conn.setDoOutput(true); // 允許輸出流 conn.setUseCaches(false); // 不允許使用緩存 conn.setRequestMethod("POST"); // 請求方式 conn.setRequestProperty("Charset", CHARSET); // 設置編碼 conn.setRequestProperty("connection", "keep-alive"); conn.setRequestProperty("Content-Type", CONTENT_TYPE + ";boundary=" + BOUNDARY); if (file != null) { DataOutputStream dos = new DataOutputStream(conn.getOutputStream()); StringBuffer sb = new StringBuffer(); sb.append(PREFIX); sb.append(BOUNDARY); sb.append(LINE_END); /** * 這里重點注意: name里面的值為服務端需要key 只有這個key 才可以得到對應的文件 * filename是文件的名字,包含后綴名的 比如:abc.png */ sb.append("Content-Disposition: form-data; name=\"uploadfile\"; filename=\"" + file.getName() + "\"" + LINE_END); sb.append("Content-Type: application/octet-stream; charset=" + CHARSET + LINE_END); sb.append(LINE_END); dos.write(sb.toString().getBytes()); InputStream is = new FileInputStream(file); byte[] bytes = new byte[1024]; int len = 0; while ((len = is.read(bytes)) != -1) { dos.write(bytes, 0, len); } is.close(); dos.write(LINE_END.getBytes()); byte[] end_data = (PREFIX + BOUNDARY + PREFIX + LINE_END).getBytes(); dos.write(end_data); dos.flush(); InputStream input = conn.getInputStream(); StringBuffer sb1 = new StringBuffer(); int ss; while ((ss = input.read()) != -1) { sb1.append((char) ss); } result = sb1.toString(); } } catch (MalformedURLException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return result; } /** * 通過拼接的方式構造請求內(nèi)容,實現(xiàn)參數(shù)傳輸以及文件傳輸 * * @param url Service net address * @param params text content * @param files pictures * @return String result of Service response * @throws IOException */ public static String post(String url, Map<String, String> params, Map<String, File> files) throws IOException { String BOUNDARY = UUID.randomUUID().toString(); String PREFIX = "--", LINEND = "\r\n"; String MULTIPART_FROM_DATA = "multipart/form-data"; String CHARSET = "UTF-8"; URL uri = new URL(url); HttpURLConnection conn = (HttpURLConnection) uri.openConnection(); conn.setReadTimeout(10 * 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); // 首先組拼文本類型的參數(shù) 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()); // 發(fā)送文件數(shù)據(jù) if (files != null) for (Map.Entry<String, File> file : files.entrySet()) { StringBuilder sb1 = new StringBuilder(); sb1.append(PREFIX); sb1.append(BOUNDARY); sb1.append(LINEND); sb1.append("Content-Disposition: form-data; name=\"uploadfile\"; filename=\"" + file.getValue().getName() + "\"" + 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(); InputStream in = conn.getInputStream(); StringBuilder sb2 = new StringBuilder(); if (res == 200) { int ch; while ((ch = in.read()) != -1) { sb2.append((char) ch); } } outStream.close(); conn.disconnect(); return sb2.toString(); } // 測試 public static void main(String[] args) throws IOException { String requestURL = "sss"; final Map<String, String> params = new HashMap<String, String>(); params.put("send_userId", String.valueOf(1)); params.put("send_email", "ss@ss.com"); final Map<String, File> files = new HashMap<String, File>(); files.put("uploadfile", new File("/var/data/de.jpg")); final String result = UploadUtil.post(requestURL, params, files); System.out.println("result is: " + result); } }
二、php服務端接收文件,臨時保存并繼續(xù)上傳至java后端:
1. 接收文件類
<?php namespace App\Controller;use Action\RestAction;use Api\UploadApi;class UserController extends RestAction { /** * 用戶頭像上傳 */ public function set_avatar_post($code) { $uploadApi = new UploadApi(); $res = $uploadApi->uploads('avatar'); $filename = $res['data']; $result = $uploadApi->uploadAvatar($code, $filename); @unlink($filename); //刪除圖片 if (!$result['status']) { $this->response($result); } $avatar = A("Personal", "Api")->getAvatar($code); $this->response($avatar); } }
2. 上傳類
<?php namespace Api\Action;class UploadApi { public function __construct() { //... } public function curlGet($url, $param = array(), $timeout = 30, $ajaxResponseImmediately = true) { $opts = array( CURLOPT_TIMEOUT => $timeout, CURLOPT_RETURNTRANSFER => 1, CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYHOST => false, CURLOPT_HTTPHEADER => $header ); switch (strtoupper($method)) { // case 'POST': // $opts[CURLOPT_URL] = $url; // $opts[CURLOPT_POST] = 1; // $opts[CURLOPT_POSTFIELDS] = $param; // break; http://www.cnblogs.com/yougewe/p/7095884.html