使用排球上傳視頻

Question

在我的應用程序中，用戶應該能夠將他們的視頻從手機上傳到遠程服務器。我不想使用像this這樣的方法，我必須處理所有事情以及其他許多缺點。是否有可能爲此目的使用排球？如果是，請解釋如何或提及教程。

Answer 1

你可以使用下面的代碼片段對任何使用 抽樣的多部分請求。

import com.android.volley.AuthFailureError; 
import com.android.volley.NetworkResponse; 
import com.android.volley.ParseError; 
import com.android.volley.Request; 
import com.android.volley.Response; 
import com.android.volley.VolleyError; 
import com.android.volley.VolleyLog; 
import com.android.volley.toolbox.HttpHeaderParser; 

import org.apache.http.HttpEntity; 
import org.apache.http.entity.mime.HttpMultipartMode; 
import org.apache.http.entity.mime.MultipartEntityBuilder; 
import org.apache.http.entity.mime.content.FileBody; 
import org.json.JSONException; 
import org.json.JSONObject; 

import java.io.ByteArrayOutputStream; 
import java.io.File; 
import java.io.IOException; 
import java.io.UnsupportedEncodingException; 
import java.util.Map; 

public class TestMultiPartRequestextends Request<JSONObject> { 

// private MultipartEntity entity = new MultipartEntity(); 

    MultipartEntityBuilder entity = MultipartEntityBuilder.create(); 
    HttpEntity httpentity; 
    private static final String FILE_PART_NAME = "import_file"; 

    private final Response.Listener<JSONObject> mListener; 
    private final Response.ErrorListener mErrorListener; 
    private final File mFilePart; 
    private final Map<String, String> mStringPart; 

    public TestMultiPartRequest(String url, Response.ErrorListener errorListener, 
           Response.Listener<JSONObject> listener, File file, 
           Map<String, String> mStringPart) { 
     super(Method.POST, url, errorListener); 
     this.mErrorListener = errorListener; 
     mListener = listener; 
     mFilePart = file; 
     this.mStringPart = mStringPart; 
     entity.setMode(HttpMultipartMode.BROWSER_COMPATIBLE); 
     buildMultipartEntity(); 
    } 

    public void addStringBody(String param, String value) { 
     mStringPart.put(param, value); 
    } 

    private void buildMultipartEntity() { 
     entity.addPart(FILE_PART_NAME, new FileBody(mFilePart)); 
     for (Map.Entry<String, String> entry : mStringPart.entrySet()) { 
      entity.addTextBody(entry.getKey(), entry.getValue()); 
     } 
    } 

    @Override 
    public String getBodyContentType() { 
     return httpentity.getContentType().getValue(); 
    } 

    @Override 
    public byte[] getBody() throws AuthFailureError { 
     ByteArrayOutputStream bos = new ByteArrayOutputStream(); 
     try { 
      httpentity = entity.build(); 
      httpentity.writeTo(bos); 
     } catch (IOException e) { 
      VolleyLog.e("IOException writing to ByteArrayOutputStream"); 
     } 
     return bos.toByteArray(); 
    } 

    @Override 
    protected Response<JSONObject> parseNetworkResponse(NetworkResponse response) { 
     try { 
      String jsonString = new String(response.data, HttpHeaderParser.parseCharset(response.headers)); 
      return Response.success(new JSONObject(jsonString), HttpHeaderParser.parseCacheHeaders(response)); 
     } catch (UnsupportedEncodingException e) { 
      return Response.error(new ParseError(e)); 
     } catch (JSONException je) { 
      return Response.error(new ParseError(je)); 
     } 
    } 

    @Override 
    public void deliverError(VolleyError error) { 
     mErrorListener.onErrorResponse(error); 
    } 

    @Override 
    protected void deliverResponse(JSONObject response) { 
     mListener.onResponse(response); 
    } 
} 

使用

TestMultiPartRequest multiPartRequest = new TestMultiPartRequest (URL, new Response.ErrorListener() { 
      @Override 
      public void onErrorResponse(VolleyError error) { 
       //Error response 
      } 
     }, new Response.Listener<JSONObject>() { 
      @Override 
      public void onResponse(JSONObject response) { 
       //Response 
      } 
     }, new File(fPath), params); 

     multiPartRequest.setRetryPolicy(new DefaultRetryPolicy(5 * 1000, 0, 
       DefaultRetryPolicy.DEFAULT_BACKOFF_MULT)); 
     TestVolleyHelper.getInstance(getApplicationContext()).addToRequestQueue(multiPartRequest); 

TestVolleyHelper

import android.content.Context; 
import android.text.TextUtils; 

import com.android.volley.Request; 
import com.android.volley.RequestQueue; 
import com.android.volley.toolbox.Volley; 


public class TestVolleyHelper { 

    private static final String TAG = TestVolleyHelper.class 
      .getSimpleName(); 

    private RequestQueue mRequestQueue; 
    private static TestVolleyHelper mInstance; 

    public TestVolleyHelper(Context context) { 
     if (mRequestQueue == null) { 
      mRequestQueue = Volley.newRequestQueue(context); 
     } 
    } 

    public static synchronized TestVolleyHelper getInstance(Context context) { 
     if (mInstance == null) { 
      mInstance = new TestVolleyHelper(context); 
     } 
     return mInstance; 
    } 

    public RequestQueue getRequestQueue() { 
     return mRequestQueue; 
    } 

    public <T> void addToRequestQueue(Request<T> req, String tag) { 
     // set the default tag if tag is empty 
     req.setTag(TextUtils.isEmpty(tag) ? TAG : tag); 
     getRequestQueue().add(req); 
    } 

    public <T> void addToRequestQueue(Request<T> req) { 
     req.setTag(TAG); 
     getRequestQueue().add(req); 
    } 

    public void cancelPendingRequests(Object tag) { 
     if (mRequestQueue != null) { 
      mRequestQueue.cancelAll(tag); 
     } 
    } 
} 

看看this是一個沒有使用HttpEntity的例子。

而且不要使用HttpEntity。它在Android-M中完全刪除，因爲它最近已被棄用。