Загрузить файл на AWS S3, используя залп запроса PUT (в Android) - PullRequest
1 голос
/ 22 января 2020

Я пытаюсь загрузить файл в Amazon s3, используя запрос PUT из моего приложения android. У меня есть ссылка с сервера с закрытым ключом, отображаемым в том же виде.

При попытке загрузить файл из POSTMAN он работает при загрузке с использованием двоичного параметра и типа содержимого application / octet-stream или application / x- www-form-urlencoded (пробовал с обоими) в заголовке, но если вы загружаете одно и то же изображение с использованием данных формы, оно не работает.

В моем приложении android я пробовал запрос JsonObject, используя залп, в котором я получаю.

Json Исключение для организации

Пожалуйста, найдите мой запрос ниже

     JsonObjectRequest jsonObjReq = new JsonObjectRequest(Request.Method.PUT,
                url, new JSONObject(parameters),
                new Response.Listener<JSONObject>() {

                    @Override
                    public void onResponse(JSONObject response) {
                        if (listener != null) {
                            Log.e("Response", response + "");

                            listener.onResult(response + "", responseCode);
                            if (showDialog == true) {
                                try {
                                    mOverlayDialog.dismiss();
                                } catch (Exception e) {
//                                    Crashlytics.logException(e);
                                }

                                try {
                                    materialDialog.dismiss(); // To hide the progress bar
                                } catch (Exception e) {
//                                    Crashlytics.logException(e);
                                }

                            }
                        }
                    }
                }, new Response.ErrorListener() {

            @Override
            public void onErrorResponse(VolleyError error) {

                if (listener != null) {
                            try {
                                if(error.networkResponse!=null && error.networkResponse.data!=null) {
                                    String responseBody = new String(error.networkResponse.data, "utf-8");
                                    if (!responseBody.equalsIgnoreCase("")) {
                                        JSONObject data = new JSONObject(responseBody);

                                        listener.onResult(data + "", responseCode);
                                        //listener.onResult(error.toString(), WebAPIConstants.VOLLEY_ERROR);
                                        Log.e("ERROR", error.toString() + "");
                                    } else {

                                        listener.onResult("", responseCode);
                                    }

                                }
                                else
                                    listener.onResult("", responseCode);
                            } catch (JSONException e) {
                            } catch (UnsupportedEncodingException errorr) {
                            } catch (Exception e) {
                                Crashlytics.logException(e);
                            }
                        }
                        if (showDialog == true) {
                            try {
                                mOverlayDialog.dismiss();
                            } catch (Exception e) {
//                                    Crashlytics.logException(e);
                            }

                            try {
                                materialDialog.dismiss(); // To hide the progress bar
                            } catch (Exception e) {
//                                    Crashlytics.logException(e);
                            }

                        }
                        try {

                            if (error instanceof TimeoutError) {
                                AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.timeout_error_title), mContext.getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                    @Override
                                    public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                    }
                                });

                            } else if (error instanceof NoConnectionError) {
                                if (CheckInternetConnection.haveNetworkConnection(mContext)) {

                                    AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.timeout_error_title), mContext.getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                        @Override
                                        public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                        }
                                    });

                                } else {


                                    AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.no_internet_title), mContext.getResources().getString(R.string.no_internet_message), new MaterialDialog.SingleButtonCallback() {
                                        @Override
                                        public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                        }
                                    });


                                }

                            }


                        } catch (Exception e) {

                            Crashlytics.logException(e);
                        }

            }

(отправил изображение в байт-коде), при использовании строки запросить загрузку изображения, но с размером 1 КБ, но без открытия на сервере (отправил изображение в байт-коде).

Строковый запрос

     StringRequest stringRequest=new StringRequest(Request.Method.PUT, url, new Response.Listener<String>() {

            @Override
            public void onResponse(String response) {


                if (listener != null) {

                            Log.e("Response", response + "");


                            if (showDialog == true) {
                                try {
                                    mOverlayDialog.dismiss();
                                } catch (Exception e) {
//                                    Crashlytics.logException(e);
                                }

                                try {
                                    materialDialog.dismiss(); // To hide the progress bar
                                } catch (Exception e) {
//                                    Crashlytics.logException(e);
                                }

                            }
                        }
            }

        }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error) {
                if (listener != null) {
                            try {
                                if(error.networkResponse!=null && error.networkResponse.data!=null) {
                                    String responseBody = new String(error.networkResponse.data, "utf-8");
                                    if (!responseBody.equalsIgnoreCase("")) {
                                        JSONObject data = new JSONObject(responseBody);

                                        listener.onResult(data + "", responseCode);
                                        //listener.onResult(error.toString(), WebAPIConstants.VOLLEY_ERROR);
                                        Log.e("ERROR", error.toString() + "");
                                    } else {

                                        listener.onResult("", responseCode);
                                    }

                                }
                                else
                                    listener.onResult("", responseCode);
                            } catch (JSONException e) {
                            } catch (UnsupportedEncodingException errorr) {
                            } catch (Exception e) {
                                Crashlytics.logException(e);
                            }
                        }
                        if (showDialog == true) {
                            try {
                                mOverlayDialog.dismiss();
                            } catch (Exception e) {
//                                    Crashlytics.logException(e);
                            }

                            try {
                                materialDialog.dismiss(); // To hide the progress bar
                            } catch (Exception e) {
//                                    Crashlytics.logException(e);
                            }

                        }
                        try {

                            if (error instanceof TimeoutError) {
                                AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.timeout_error_title), mContext.getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                    @Override
                                    public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                    }
                                });

                            } else if (error instanceof NoConnectionError) {
                                if (CheckInternetConnection.haveNetworkConnection(mContext)) {

                                    AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.timeout_error_title), mContext.getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                        @Override
                                        public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                        }
                                    });

                                } else {


                                    AlertDialogManager.showAlertDialog(mContext, mContext.getResources().getString(R.string.no_internet_title), mContext.getResources().getString(R.string.no_internet_message), new MaterialDialog.SingleButtonCallback() {
                                        @Override
                                        public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                        }
                                    });


                                }

                            }


                        } catch (Exception e) {

                            Crashlytics.logException(e);
                        }
                }

        })
        {
            @Override
            protected Response<String> parseNetworkResponse(NetworkResponse response) {
                if (listener!=null) {

                    listener.onResult(mStatusCode + "", responseCode);
                }

                 mStatusCode = response.statusCode;

                return super.parseNetworkResponse(response);


            }



            @Override
            protected Map<String, String> getParams() throws AuthFailureError {
                return parameters;
            }



            @Override
            public Map<String, String> getHeaders() throws AuthFailureError {
                HashMap<String, String> headers = new HashMap<String, String>();
                headers.put("Content-Type", "application/octet-stream");
                return headers;
            }



        };

        stringRequest.setRetryPolicy(new DefaultRetryPolicy(120000,
                DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
                DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));

        try {

            stringRequest.setShouldCache(false);
            queue.getCache().clear();
            queue.add(stringRequest);


        } catch (Exception e) {

            Crashlytics.logException(e);
        }

Также пробовал многокомпонентный запрос, но получал ошибки, такие как ошибка аутентификации et c.

Многокомпонентный запрос, где docUrl - тот же URL, что и в почтальоне

Зависимость добавлена ​​для запроса ниже:

группа компиляции: 'org. apache .httpcomponents ', name:' httpclient- android ', версия:' 4.3.5.1 'compile (' org. apache .httpcomponents: httpmime: 4.3 ') {исключить модуль: "httpclient"}

MultipartRequest AWS класс

пакет spice.mudra.csp_cred;

    import com.android.volley.AuthFailureError;
    import com.android.volley.NetworkResponse;
    import com.android.volley.Request;
    import com.android.volley.Response;
    import com.android.volley.VolleyLog;

    import org.apache.http.entity.mime.MultipartEntity;
    import org.apache.http.entity.mime.content.FileBody;
    import org.apache.http.entity.mime.content.StringBody;

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

    public class MultipartRequestAWS extends Request<String> {
    private MultipartEntity entity = new MultipartEntity();

        private static final String FILE_PART_NAME = "file";
        private static final String STRING_PART_NAME = "text";

        private final Response.Listener<String> mListener;
        private final File mFilePart;
        private final String mStringPart;



        public MultipartRequestAWS(String url, Response.Listener<String> listener, Response.ErrorListener errorListener,File file, String stringPart) {
            super(Method.POST, url, errorListener);

            mListener = listener;
            mFilePart = file;
            mStringPart = stringPart;
            buildMultipartEntity();
        }

        private void buildMultipartEntity()
        {
            entity.addPart(FILE_PART_NAME, new FileBody(mFilePart));
            try
            {
                entity.addPart(STRING_PART_NAME, new StringBody(mStringPart));
            }
            catch (UnsupportedEncodingException e)
            {
                VolleyLog.e("UnsupportedEncodingException");
            }
        }

        @Override
        public String getBodyContentType()
        {
            return "application/octet-stream";
        }

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

        @Override
        protected Response<String> parseNetworkResponse(NetworkResponse response)
        {
            return Response.success("Uploaded", getCacheEntry());
        }

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

**** Многочастный запрос ****

MultipartRequestAWS request = new MultipartRequestAWS(docUrl, new Response.Listener<String>() {
                    @Override
                    public void onResponse(String response) {
                        Log.e("Responce", "" + response);

                    }
                }, new Response.ErrorListener() {
                    @Override
                    public void onErrorResponse(VolleyError error) {
                        Log.e("Responce", "" + error);
                    }
                }, outputFile, imageArray.toString()
                );


                request.setRetryPolicy(new DefaultRetryPolicy(300000,
                        DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
                        DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));
                //adding request to request queue
    //            if(!Constants.IS_PRODUCTION) {
                Volley.newRequestQueue(this).add(request);
    //            }else{
    //                Volley.newRequestQueue(getActivity(), new OKHttpStack(new URL(request.getUrl()).getHost())).add(request);
    //
    //                // Volley.newRequestQueue(getActivity(), new HurlStack(null, newSslSocketFactory())).add(request);
    //            }

Прочие многочастные запросы

    private final String boundary = "apiclient-" + System.currentTimeMillis();
        private final String mimeType = "multipart/form-data;boundary=" + boundary;

//multipartBody is byte code of image to be uploaded

        MultipartRequest request = new MultipartRequest(url, null, mimeType, multipartBody, new Response.Listener<NetworkResponse>() {
                    @Override
                    public void onResponse(NetworkResponse response) {

                        try {
                            mOverlayDialogAsync.dismiss();
                        } catch (Exception e) {
                            Crashlytics.logException(e);
                        }

                        try {
                            materialDialogAsync.dismiss(); // To hide the progress bar
                        } catch (Exception e) {
                            Crashlytics.logException(e);
                        }







                }
            }, new Response.ErrorListener() {
                @Override
                public void onErrorResponse(VolleyError error) {

                    try {
                        mOverlayDialogAsync.dismiss();
                    } catch (Exception e) {
                        Crashlytics.logException(e);
                    }

                    try {
                        materialDialogAsync.dismiss(); // To hide the progress bar
                    } catch (Exception e) {
                        Crashlytics.logException(e);
                    }


                    try {
                        // getting json string form the response obtained from server
                        String jsonString = new String(error.toString());

                        Log.e("response multipart", jsonString);

                    } catch (Exception e) {
                        Crashlytics.logException(e);
                    }


                    try {


                        //Network errors handling

                        if (error instanceof TimeoutError) {
                            AlertDialogManager.showAlertDialog(CustomDialogNetworkRequest.this, getResources().getString(R.string.timeout_error_title), getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                @Override
                                public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                }
                            });

                        } else if (error instanceof NoConnectionError) {
                            if (spice.mudra.utils.CheckInternetConnection.haveNetworkConnection(AddYourProffDetails.this)) {

                                AlertDialogManager.showAlertDialog(AddYourProffDetails.this, getResources().getString(R.string.timeout_error_title), getResources().getString(R.string.timeout_error_string), new MaterialDialog.SingleButtonCallback() {
                                    @Override
                                    public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                    }
                                });

                            } else {


                                AlertDialogManager.showAlertDialog(AddYourProffDetails.this, getResources().getString(R.string.no_internet_title), getResources().getString(R.string.no_internet_message), new MaterialDialog.SingleButtonCallback() {
                                    @Override
                                    public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                    }
                                });


                            }

                        } else {

                            AlertDialogManager.showAlertDialog(AddYourProffDetails.this, "", "Something went wrong. Please try again.", new MaterialDialog.SingleButtonCallback() {
                                @Override
                                public void onClick(@NonNull MaterialDialog dialog, @NonNull DialogAction which) {
                                }
                            });


                        }


                    } catch (Exception e) {

                        Crashlytics.logException(e);
                    }


                }
            });

            //setting timeout to multipart request
            request.setRetryPolicy(new DefaultRetryPolicy(300000,
                    DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
                    DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));


            //adding request to request queue


                Log.i("++++++++++", "Request body: " + new String(request.getBody()));
                Volley.newRequestQueue(CustomDialogNetworkRequest.this).add(request);

        } catch (Exception e) {
            Crashlytics.logException(e);
        }
        }

Пожалуйста, помогите с тем же.

Пожалуйста, найдите скриншот POSTMAN для справки. Это также имеет тип URL, который я использую.

enter image description here

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...