Android端使用retrofit上传多张图片，后端使用Php接收图片

Android端使用retrofit上传多张图片，后端使用Php接收图片(前后端代码都有)

1.先列出Android端使用的library：

dependencies {
...
compile 'com.jakewharton:butterknife:7.0.1'
compile 'com.squareup:otto:1.3.5'
compile 'cn.finalteam:galleryfinal:1.4.8.4'
compile 'com.squareup.retrofit:retrofit:1.9.0'
compile 'com.squareup.okhttp:okhttp-urlconnection:2.0.0'
compile 'com.squareup.okhttp:okhttp:2.0.0'
compile 'com.github.bumptech.glide:glide:3.6.1'
compile 'com.jcodecraeer:xrecyclerview:1.2.6'
compile 'com.baoyz.actionsheet:library:1.1.5'
compile 'com.nostra13.universalimageloader:universal-image-loader:1.9.5'
compile 'io.reactivex:rxjava:1.0.6'
compile 'io.reactivex:rxandroid:0.23.0'
compile files('libs/fastjson-1.2.7.jar')
}

Android端代码：

uploadFile(@Part("uploadfile") TypedFile file);

//  上传多张图片
@POST("/UploadFileDemo/android_upload_file/uploads.php")
Observable uploadFiles(@Body MultipartTypedOutput multipartTypedOutput);
}

" data-snippet-id="ext.381f609497f3e3ce769170a047e23726" data-snippet-saved="false" data-csrftoken="5rTceeqO-EeYMIt8hHcXv_ywCwmXHI3eBLhA" data-codota-status="done">[code]public interface ApiService {
//  上传一个文件/图片
@Multipart
@POST("/UploadFileDemo/android_upload_file/upload.php")
Observable<Response> uploadFile(@Part("uploadfile") TypedFile file);

//  上传多张图片
@POST("/UploadFileDemo/android_upload_file/uploads.php")
Observable<Response> uploadFiles(@Body MultipartTypedOutput multipartTypedOutput);
}

pendingAndOngoing = mExecutorService.shutdownNow();
}

static class MyCookieManager extends CookieManager {
@Override
public void put(URI uri, Map> stringListMap) throws IOException {
super.put(uri, stringListMap);
if (stringListMap != null && stringListMap.get("Set-Cookie") != null)
for (String string : stringListMap.get("Set-Cookie")) {
String cookieValue = string.substring(0, string.indexOf("\"; ") + 1);
if (string.contains("A2=\"")) {
//保存到应用
}
if (string.contains("PB3_SESSION=\"")) {
////保存到应用
}
}
}
}

static class ApiHeaders implements RequestInterceptor {
@Override
public void intercept(RequestFacade request) {
request.addHeader("User-Agent", "Mozilla/5.0 (Linux; U; Android 4.1.1; zh-cn; HTC One X - 4.1.1 - API 16 - 720x1280 Build/JRO03S) AppleWebKit/534.30 (KHTML, like Gecko) Version/4.0 Mobile Safari/534.30");
request.addHeader("Accept", "*/*");
request.addHeader("Accept-Language", "zh-cn,zh");
}
}

}" data-snippet-id="ext.bf26c06794bbd034d14ac8d69614d8b1" data-snippet-saved="false" data-csrftoken="x9E0HcdR-WnC77IwV5Hz6M1Jg-P_3bCGhZBk" data-codota-status="done">[code]public class Client {

public static String API_URL = Constant.API_URL;

public static ExecutorService mExecutorService;

private static ApiService instance;

public static ApiService getServiceClient() {
if (instance == null) {
synchronized (Client.class) {
if (instance == null) {
OkHttpClient okHttpClient = new OkHttpClient();
okHttpClient.setCookieHandler(new MyCookieManager());
okHttpClient.setReadTimeout(100, TimeUnit.SECONDS);
okHttpClient.setConnectTimeout(100, TimeUnit.SECONDS);

RestAdapter.Builder restAdapter = new RestAdapter.Builder();

restAdapter.setRequestInterceptor(new ApiHeaders());
restAdapter.setEndpoint(API_URL);
restAdapter.setClient(new OkClient(okHttpClient));
restAdapter.setLogLevel(RestAdapter.LogLevel.FULL);

mExecutorService = Executors.newCachedThreadPool();
instance = restAdapter.build().create(ApiService.class);
}
}
}
return instance;
}

public static void stopAll() {
List<Runnable> pendingAndOngoing = mExecutorService.shutdownNow();
}

static class MyCookieManager extends CookieManager {
@Override
public void put(URI uri, Map<String, List<String>> stringListMap) throws IOException {
super.put(uri, stringListMap);
if (stringListMap != null && stringListMap.get("Set-Cookie") != null)
for (String string : stringListMap.get("Set-Cookie")) {
String cookieValue = string.substring(0, string.indexOf("\"; ") + 1);
if (string.contains("A2=\"")) {
//保存到应用
}
if (string.contains("PB3_SESSION=\"")) {
////保存到应用
}
}
}
}

static class ApiHeaders implements RequestInterceptor {
@Override
public void intercept(RequestFacade request) {
request.addHeader("User-Agent", "Mozilla/5.0 (Linux; U; Android 4.1.1; zh-cn; HTC One X - 4.1.1 - API 16 - 720x1280 Build/JRO03S) AppleWebKit/534.30 (KHTML, like Gecko) Version/4.0 Mobile Safari/534.30");
request.addHeader("Accept", "*/*");
request.addHeader("Accept-Language", "zh-cn,zh");
}
}

}

上传关键代码：

paths) {
MultipartTypedOutput multipartTypedOutput = new MultipartTypedOutput();
for (String imgPath : paths){
//注意“uploadfile[]”一定要带“[]”,表明上传的是数组，也就是多张图片,不能写“uploadfile”
multipartTypedOutput.addPart("uploadfile[]", new TypedFile("", new File(imgPath)));
}
mApi.uploadFiles(multipartTypedOutput)
.subscribeOn(Schedulers.computation())
.subscribe(response -> handleUploadFile(response), error -> handleFailure(error));
}

private void handleUploadFile(Response response) {

System.out.println(response.getUrl());
try {
InputStream in = response.getBody().in();
String responseString = inputStream2String(in);
Log.i("AAA", responseString);
//解析json数据

//otto事件传递
mBus.post(responseString);

} catch (IOException e) {
e.printStackTrace();
}

}

//接收事件代码
@Subscribe //需要注解@Subscribe ,表明在这个函数接收数据
public void uploadFileResponse(String response) {
Message msg = JSON.parseObject(response, Message.class);
List imgUrls = msg.getImgUrls();
if (msg.getCode() == 1) {
if (choosePhotoListAdapter == null) {
choosePhotoListAdapter = new ChoosePhotoListAdapter(this, null, imgUrls);
lvPhotoShow.setAdapter(choosePhotoListAdapter);
}
choosePhotoListAdapter.notifyDataSetChanged();
}
}" data-snippet-id="ext.df6a504b292dde3ba02b42145f649a52" data-snippet-saved="false" data-csrftoken="6lwFsVfj-x-1zcl6vqXWV-Jh_fICkD1VyOjw" data-codota-status="done">[code]//使用MultipartTypedOutput类来上传多张图片
public void uploadFiles(List<String> paths) {
MultipartTypedOutput multipartTypedOutput = new MultipartTypedOutput();
for (String imgPath : paths){
//注意“uploadfile[]”一定要带“[]”,表明上传的是数组，也就是多张图片,不能写“uploadfile”
multipartTypedOutput.addPart("uploadfile[]", new TypedFile("", new File(imgPath)));
}
mApi.uploadFiles(multipartTypedOutput)
.subscribeOn(Schedulers.computation())
.subscribe(response -> handleUploadFile(response), error -> handleFailure(error));
}

private void handleUploadFile(Response response) {

System.out.println(response.getUrl());
try {
InputStream in = response.getBody().in();
String responseString = inputStream2String(in);
Log.i("AAA", responseString);
//解析json数据

//otto事件传递
mBus.post(responseString);

} catch (IOException e) {
e.printStackTrace();
}

}

//接收事件代码
@Subscribe //需要注解@Subscribe ,表明在这个函数接收数据
public void uploadFileResponse(String response) {
Message msg = JSON.parseObject(response, Message.class);
List<String> imgUrls = msg.getImgUrls();
if (msg.getCode() == 1) {
if (choosePhotoListAdapter == null) {
choosePhotoListAdapter = new ChoosePhotoListAdapter(this, null, imgUrls);
lvPhotoShow.setAdapter(choosePhotoListAdapter);
}
choosePhotoListAdapter.notifyDataSetChanged();
}
}

Php端代码：

//初学php，写的比较简单，不太健壮，像图片是否已经上传过，都没有判断，大家自己补充啊^_^

<?php
/**
* Created by PhpStorm.
* User: zhangyipeng
* Date: 16/2/18
* Time: 下午3:48
*/

$base_path = "./upload_file/"; //接收文件目录
$imgs = array();  //定义一个数组存放上传图片的路径
$isSave = false;
if (!file_exists($base_path)) {
mkdir($base_path);
}

foreach ($_FILES["uploadfile"]["error"] as $key => $error) {
if ($error == UPLOAD_ERR_OK) {
$tmp_name = $_FILES["uploadfile"]["tmp_name"][$key];
$name = $_FILES["uploadfile"]["name"][$key];
$uploadfile = $base_path . $name;
$isSave = move_uploaded_file($tmp_name, $uploadfile);
if ($isSave){
$imgs[]=$uploadfile;
}
}
}

if ($isSave) {
$array = array("code" => "1", "message" =>"上传图片成功"
, "imgUrls" => $imgs);
echo json_encode($array);
} else {
$array = array("code" => "0", "message" => "上传图片失败," . $_FILES ['uploadfile'] ['error']
, "imgUrls" => $imgs);
echo json_encode($array);
}

其实上传成功的关键是part需要带uploadfile[] ,【 multipartTypedOutput.addPart(“uploadfile[]”, new TypedFile(“”, new File(imgPath)));】

我在这个地方失败了几十次，无意中看见html网页批量上传的name属性中带[]了（），我就试了试，果然成功了。

资源下载