Volley不解释了吧, android 官方的一个网络请求库.

源码的地址在:

git@github.com:com314159/VolleyMultiPartRequest.git

上面的是ssh

以下的是http地址

https://github.com/com314159/VolleyMultiPartRequest

是依据

https://github.com/smanikandan14/Volley-demo

这位大神改动而来的, 可是那位大神的代码有bug, 上传文件不成功.

注: 我的demo里面还集成了okhttp, 不须要的同学不用理这个类就可以

实现方法:

1.加入三个jar包,

httpcore-4.3.2.jar

httpclient-4.3.5.jar

httpmime-4.3.5.jar

2.实现MultiPartStack

package com.example.volleytest;

import java.io.File;
import java.io.IOException;
import java.util.Map; import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPatch;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;
import org.apache.http.protocol.HTTP; import com.android.volley.AuthFailureError;
import com.android.volley.Request;
import com.android.volley.Request.Method;
import com.android.volley.toolbox.HurlStack; /**
* @author ZhiCheng Guo
* @version 2014年10月7日 上午11:00:52 这个Stack用于上传文件, 假设没有这个Stack, 则上传文件不成功
*/
public class MultiPartStack extends HurlStack {
@SuppressWarnings("unused")
private static final String TAG = MultiPartStack.class.getSimpleName();
private final static String HEADER_CONTENT_TYPE = "Content-Type"; @Override
public HttpResponse performRequest(Request<? > request,
Map<String, String> additionalHeaders) throws IOException, AuthFailureError { if(!(request instanceof MultiPartRequest)) {
return super.performRequest(request, additionalHeaders);
}
else {
return performMultiPartRequest(request, additionalHeaders);
}
} private static void addHeaders(HttpUriRequest httpRequest, Map<String, String> headers) {
for (String key : headers.keySet()) {
httpRequest.setHeader(key, headers.get(key));
}
} public HttpResponse performMultiPartRequest(Request<? > request,
Map<String, String> additionalHeaders) throws IOException, AuthFailureError {
HttpUriRequest httpRequest = createMultiPartRequest(request, additionalHeaders);
addHeaders(httpRequest, additionalHeaders);
addHeaders(httpRequest, request.getHeaders());
HttpParams httpParams = httpRequest.getParams();
int timeoutMs = request.getTimeoutMs();
// TODO: Reevaluate this connection timeout based on more wide-scale
// data collection and possibly different for wifi vs. 3G.
HttpConnectionParams.setConnectionTimeout(httpParams, 5000);
HttpConnectionParams.setSoTimeout(httpParams, timeoutMs); /* Make a thread safe connection manager for the client */
HttpClient httpClient = new DefaultHttpClient(httpParams); return httpClient.execute(httpRequest);
} static HttpUriRequest createMultiPartRequest(Request<?> request,
Map<String, String> additionalHeaders) throws AuthFailureError {
switch (request.getMethod()) {
case Method.DEPRECATED_GET_OR_POST: {
// This is the deprecated way that needs to be handled for backwards compatibility.
// If the request's post body is null, then the assumption is that the request is
// GET. Otherwise, it is assumed that the request is a POST.
byte[] postBody = request.getBody();
if (postBody != null) {
HttpPost postRequest = new HttpPost(request.getUrl());
if(request.getBodyContentType() != null)
postRequest.addHeader(HEADER_CONTENT_TYPE, request.getBodyContentType());
HttpEntity entity;
entity = new ByteArrayEntity(postBody);
postRequest.setEntity(entity);
return postRequest;
} else {
return new HttpGet(request.getUrl());
}
}
case Method.GET:
return new HttpGet(request.getUrl());
case Method.DELETE:
return new HttpDelete(request.getUrl());
case Method.POST: {
HttpPost postRequest = new HttpPost(request.getUrl());
postRequest.addHeader(HEADER_CONTENT_TYPE, request.getBodyContentType());
setMultiPartBody(postRequest,request);
return postRequest;
}
case Method.PUT: {
HttpPut putRequest = new HttpPut(request.getUrl());
if(request.getBodyContentType() != null)
putRequest.addHeader(HEADER_CONTENT_TYPE, request.getBodyContentType());
setMultiPartBody(putRequest,request);
return putRequest;
}
// Added in source code of Volley libray.
case Method.PATCH: {
HttpPatch patchRequest = new HttpPatch(request.getUrl());
if(request.getBodyContentType() != null)
patchRequest.addHeader(HEADER_CONTENT_TYPE, request.getBodyContentType());
return patchRequest;
}
default:
throw new IllegalStateException("Unknown request method.");
}
} /**
* If Request is MultiPartRequest type, then set MultipartEntity in the
* httpRequest object.
*
* @param httpRequest
* @param request
* @throws AuthFailureError
*/
private static void setMultiPartBody(HttpEntityEnclosingRequestBase httpRequest,
Request<?> request) throws AuthFailureError { // Return if Request is not MultiPartRequest
if (!(request instanceof MultiPartRequest)) {
return;
} // MultipartEntity multipartEntity = new
// MultipartEntity(HttpMultipartMode.BROWSER_COMPATIBLE); MultipartEntityBuilder builder = MultipartEntityBuilder.create(); /* example for setting a HttpMultipartMode */
builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE); // Iterate the fileUploads
Map<String, File> fileUpload = ((MultiPartRequest) request).getFileUploads();
for (Map.Entry<String, File> entry : fileUpload.entrySet()) { builder.addPart(((String) entry.getKey()), new FileBody((File) entry.getValue()));
} ContentType contentType = ContentType.create(HTTP.PLAIN_TEXT_TYPE, HTTP.UTF_8);
// Iterate the stringUploads
Map<String, String> stringUpload = ((MultiPartRequest) request).getStringUploads();
for (Map.Entry<String, String> entry : stringUpload.entrySet()) {
try {
builder.addPart(((String) entry.getKey()),
new StringBody((String) entry.getValue(), contentType));
} catch (Exception e) {
e.printStackTrace();
}
} httpRequest.setEntity(builder.build());
} }

3. 实现MultiPartRequest, 这个接口是为了方便扩展

package com.example.volleytest;

import java.io.File;
import java.util.Map; /**
* @author ZhiCheng Guo
* @version 2014年10月7日 上午11:04:36
*/
public interface MultiPartRequest { public void addFileUpload(String param,File file); public void addStringUpload(String param,String content); public Map<String,File> getFileUploads(); public Map<String,String> getStringUploads();
}
/**
* Copyright 2013 Mani Selvaraj
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/ package com.example.volleytest; import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.Map; import com.android.volley.NetworkResponse;
import com.android.volley.Request;
import com.android.volley.Response;
import com.android.volley.Response.ErrorListener;
import com.android.volley.Response.Listener;
import com.android.volley.toolbox.HttpHeaderParser; /**
* MultipartRequest - To handle the large file uploads.
* Extended from JSONRequest. You might want to change to StringRequest based on your response type.
* @author Mani Selvaraj
*
*/
public class MultiPartStringRequest extends Request<String> implements MultiPartRequest{ private final Listener<String> mListener;
/* To hold the parameter name and the File to upload */
private Map<String,File> fileUploads = new HashMap<String,File>(); /* To hold the parameter name and the string content to upload */
private Map<String,String> stringUploads = new HashMap<String,String>(); /**
* Creates a new request with the given method.
*
* @param method the request {@link Method} to use
* @param url URL to fetch the string at
* @param listener Listener to receive the String response
* @param errorListener Error listener, or null to ignore errors
*/
public MultiPartStringRequest(int method, String url, Listener<String> listener,
ErrorListener errorListener) {
super(method, url, errorListener);
mListener = listener;
} public void addFileUpload(String param,File file) {
fileUploads.put(param,file);
} public void addStringUpload(String param,String content) {
stringUploads.put(param,content);
} /**
* 要上传的文件
*/
public Map<String,File> getFileUploads() {
return fileUploads;
} /**
* 要上传的參数
*/
public Map<String,String> getStringUploads() {
return stringUploads;
} @Override
protected Response<String> parseNetworkResponse(NetworkResponse response) {
String parsed;
try {
parsed = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
} catch (UnsupportedEncodingException e) {
parsed = new String(response.data);
}
return Response.success(parsed, HttpHeaderParser.parseCacheHeaders(response));
} @Override
protected void deliverResponse(String response) {
if(mListener != null) {
mListener.onResponse(response);
}
} /**
* 空表示不上传
*/
public String getBodyContentType() {
return null;
}
}

3.用法和volley原生的request的用法是一样的, 仅仅是要使用新的Stack, 如以下的是put的方法的用法. 假设是post, 就改动成post方法就能够了

        RequestQueue mSingleQueue = Volley.newRequestQueue(this, new MultiPartStack());

    MultiPartStringRequest multiPartRequest = new MultiPartStringRequest(
Request.Method.PUT, url, responseListener, errorListener) { @Override
public Map<String, File> getFileUploads() {
return files;
} @Override
public Map<String, String> getStringUploads() {
return params;
} }; mSingeQueue.add(multiPartRequest)

最新文章

  1. Maven提高篇系列之(四)——使用Profile
  2. 最近win7更新后出现第二次打开IDE(delphi2007)的时候提示无法打开&quot;EditorLineEnds.ttr&quot;这个文件
  3. Mysql 的MYISAM引擎拷贝出现异常——Incorrect information in file &#39;xxx.frm&#39;
  4. 常见算法:C语言求最小公倍数和最大公约数三种算法
  5. MFC窗口程序显示命令行输出窗口的方法
  6. LCT学习笔记
  7. class, classloder, dex 详解
  8. 动态计算rem的js代码
  9. Material使用11 核心模块和共享模块、 如何使用@angular/material
  10. leetcode — subsets
  11. 微信小程序开发之搞懂flex布局5——cross axis
  12. ABAP 文件选择框
  13. 时间序列(六): 炙手可热的RNN: LSTM
  14. sql server 2012 复制数据库向导出现TransferDatabasesUsingSMOTransfer()异常
  15. Javascript 函数及其执行环境和作用域
  16. IOS 与 PHP 通信加密,使用AES 128 CBC no padding
  17. 【3】JVM-OutOfMemory异常重现
  18. findmaven的英文版本号上线了
  19. 随手记——数据结构可视化(graphviz)
  20. jar读取外部和内部配置文件的问题

热门文章

  1. Android Studio自动化快速实现Parcelable接口序列化
  2. Spring中与Spring相关的注解
  3. Node.js的http模块理解
  4. 谷歌地图聚合点使用(GoogleMaps MarkerCluster)
  5. SSL协议的握手过程(摘录)
  6. 【js】js数组置空的三种方式
  7. express.Router创建模块化路由
  8. Oracle 11gR2 RAC连接时ORA-12545错误
  9. 解决Hue/hiveserver2报错:java.io.IOException: Job status not available
  10. cpu个数、核数、线程数、Java多线程关系的理解