Android update notification progress from service using Volley plus or OkHttp

Question

I need your help! I am trying to update the progress bar in the status bar of a callback file upload procedure. I tried two and both network lib when calling the update progress bar interface cause the system to freeze. I understand this to mean that basically callback procedure works in the main thread no matter what I run them in service. How do I properly call the update progress bar, so as not to cause the system UI to freeze?

Note: if i update notification in main thread (Activity) all work fine! Both examples are working, and the server receives the file as expected.

OkHTTP code in service

mUBuilder.setContentTitle("Upload image")
    .setContentText("")
    .setAutoCancel(false)
    .setContentIntent(PendingIntent.getActivity(getApplicationContext(), 0, notificationIntent, PendingIntent.FLAG_UPDATE_CURRENT))
    .setSmallIcon(R.drawable.ic_launcher);
try {
    final File file = new File(IMAGE_PATH);
    final long totalSize = file.length();
    RequestBody requestBody = new MultipartBody.Builder()
        .addPart(Headers.of("Content-Disposition", "form-data; name=\"image\"; filename=\"" + file.getName() + "\""),
            new CountingFileRequestBody(file, "image/*", new CountingFileRequestBody.ProgressListener() {
            @Override
                                public void transferred(long num) {
                                    final float progress = (num / (float) totalSize) * 100;
                                    Log.d(TAG, "OUT THREAD: " + progress); //see in logs
                                    new Thread(
                                            new Runnable() {
                                                @Override
                                                public void run() {
                                                    Log.d(TAG, "IN THREAD: " + progress); //not visible in the logs
                                                    mUBuilder.setProgress(100,(int) progress, false);
                                                    mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mUBuilder.build());
                                                }
                                            }
                                    );
                                }
                            }))
                    .build();

            Request request = new Request.Builder()
                    .url("http://posttestserver.com/post.php?dir=123")
                    .post(requestBody)
                    .build();

            client.newCall(request).enqueue(new Callback() {
                @Override public void onFailure(Call call, IOException e) {
                    e.printStackTrace();
                }

                @Override public void onResponse(Call call, Response response) throws IOException {
                    if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

                    Headers responseHeaders = response.headers();
                    for (int i = 0, size = responseHeaders.size(); i < size; i++) {
                        System.out.println(responseHeaders.name(i) + ": " + responseHeaders.value(i));
                    }
                    mUBuilder.setContentTitle("Upload complete!");
                    mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mUBuilder.build());
                    System.out.println(response.body().string());
                }
            });
        }catch(Exception e){
            e.printStackTrace();
        }

CountingFileRequestBody.java from this https://stackoverflow.com/a/26376724/2127124

Volley Plus code

mNotifyManager = (NotificationManager) getApplicationContext().getSystemService(Context.NOTIFICATION_SERVICE);
        notificationIntent = new Intent(getApplicationContext(), NMainActivity.class);
        final NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(getApplicationContext());
        mBuilder.setContentTitle("Upload image")
                .setContentText("")
                .setAutoCancel(false)
                .setContentIntent(PendingIntent.getActivity(getApplicationContext(), 0, notificationIntent, PendingIntent.FLAG_UPDATE_CURRENT))
                .setSmallIcon(R.drawable.ic_launcher);
        SimpleMultiPartRequest jsonRequest = new SimpleMultiPartRequest(Request.Method.POST, "http://posttestserver.com/post.php?dir=123",
                new Response.Listener<String>() {
                    @Override
                    public void onResponse(String response) {
                        Log.i(getClass().getName(), response);
                        mBuilder.setContentText("Upload image complete!");
                        mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mBuilder.build());
                    }
                }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error) {
                Log.e(getClass().getName(), error.toString());
            }
        }) {

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

        };
        jsonRequest.addFile("images", (IMAGE_PATH);
        jsonRequest.setFixedStreamingMode(true);
        jsonRequest.setShouldCache(false);
        jsonRequest.setShouldRetryServerErrors(true);
        jsonRequest.setOnProgressListener(new Response.ProgressListener() {
            @Override
            public void onProgress(long transferredBytes, long totalSize) {
                final int percentage = (int) ((transferredBytes / ((float) totalSize)) * 100);
                mBuilder.setProgress(100, percentage, false);
                mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mBuilder.build());
//freeze system UI
            }
        });
        mRequestQueue = Volley.newRequestQueue(getApplicationContext());
        mRequestQueue.add(jsonRequest);
        mRequestQueue.start();

score 0 · Accepted Answer · edited May 23 '17 at 11:48

I found a simple solution to this problem!

Original here https://stackoverflow.com/a/23107289/2127124

Slightly fix the code for OkHTTP:

@Override
public void transferred(final int progress) {
    handler.post(new Runnable() {
        @Override
        public void run() {
            mUBuilder.setProgress(100, progress, true);
            mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mUBuilder.build());
        }
    });
}

CountingFileRequestBody.java

public class CountingFileRequestBody extends RequestBody {
    ...
    int latestPercentDone, percentDone;
    ...
    @Override
    public void writeTo(BufferedSink sink) throws IOException {
        ...
        while ((read = source.read(sink.buffer(), SEGMENT_SIZE)) != -1) {
            total += read;
            sink.flush();
            latestPercentDone = (int) ((total / (float) file.length()) * 100);
            if (percentDone != latestPercentDone) {
                percentDone = latestPercentDone;
                this.listener.transferred(percentDone);
            }
        }
    }
    public interface ProgressListener {
        void transferred(int num);
    }
}

Volley Plus code:

jsonRequest.setOnProgressListener(new Response.ProgressListener() {
            int latestPercentDone, percentDone;
            @Override
            public void onProgress(long transferredBytes, long totalSize) {
                latestPercentDone = (int) ((transferredBytes / (float) totalSize) * 100);
                if (percentDone != latestPercentDone) {
                    percentDone = latestPercentDone;
                    mUBuilder.setProgress(100, percentDone, false);
                    mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mUBuilder.build());
                }
            }
        });

Also you can use this code:

final File file = new File(event.getPath().getPath());
final long totalSize = file.length();

new AsyncTask<Void, Integer, String>() {
    @Override
    protected void onProgressUpdate(Integer... values) {
        mUBuilder.setProgress(100, values[0], false);
        mNotifyManager.notify(AppSettings.SEND_DATA_NOTIF, mUBuilder.build());
    }

    @Override
    protected String doInBackground(Void... voids) {
        try{
            final File file = new File(event.getPath().getPath());
            final long totalSize = file.length();

            HttpClient client = new DefaultHttpClient();
            HttpPost post = new HttpPost("http://posttestserver.com/post.php?dir=123");
            MultipartEntityBuilder builder = MultipartEntityBuilder.create();
            builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);

            FileBody fb = new FileBody(file);

            builder.addPart("file", fb);
            final HttpEntity yourEntity = builder.build();
            class ProgressiveEntity implements HttpEntity {
                @Override
                public void consumeContent() throws IOException {
                    yourEntity.consumeContent();
                }

                @Override
                public InputStream getContent() throws IOException,
                        IllegalStateException {
                    return yourEntity.getContent();
                }

                @Override
                public Header getContentEncoding() {
                    return yourEntity.getContentEncoding();
                }

                @Override
                public long getContentLength() {
                    return yourEntity.getContentLength();
                }

                @Override
                public Header getContentType() {
                    return yourEntity.getContentType();
                }

                @Override
                public boolean isChunked() {
                    return yourEntity.isChunked();
                }

                @Override
                public boolean isRepeatable() {
                    return yourEntity.isRepeatable();
                }

                @Override
                public boolean isStreaming() {
                    return yourEntity.isStreaming();
                } 

                @Override
                public void writeTo(OutputStream outstream) throws IOException {

                    class ProxyOutputStream extends FilterOutputStream {
                        public ProxyOutputStream(OutputStream proxy) {
                            super(proxy);
                        }

                        public void write(int idx) throws IOException {
                            out.write(idx);
                        }

                        public void write(byte[] bts) throws IOException {
                            out.write(bts);
                        }

                        public void write(byte[] bts, int st, int end) throws IOException {
                            out.write(bts, st, end);
                        }

                        public void flush() throws IOException {
                            out.flush();
                        }

                        public void close() throws IOException {
                            out.close();
                        }
                    } 

                    class ProgressiveOutputStream extends ProxyOutputStream {
                        long totalSent;
                        int latestPercentDone, percentDone;

                        public ProgressiveOutputStream(OutputStream proxy) {
                            super(proxy);
                            totalSent = 0;
                        }

                        public void write(byte[] bts, int st, int end) throws IOException {

                            totalSent += end;
                            latestPercentDone = (int) ((totalSent / (float) totalSize) * 100);
                            if (percentDone != latestPercentDone) {
                                percentDone = latestPercentDone;
                                publishProgress(percentDone);
                            }

                            out.write(bts, st, end);
                        }
                    }

                    yourEntity.writeTo(new ProgressiveOutputStream(outstream));
                }
            }

            ProgressiveEntity myEntity = new ProgressiveEntity();

            post.setEntity(myEntity);
            HttpResponse response = client.execute(post);
            Log.d(TAG, response.toString());

        }catch(Exception e){
            e.printStackTrace();
        }
        return null;
    }

}.execute();

Don't forget add if you use last sample code:

android {
    useLibrary 'org.apache.http.legacy'
}
dependencies {
    ...
    compile('org.apache.httpcomponents:httpcore:+') {
        exclude module: "httpclient"
    }
    compile('org.apache.httpcomponents:httpmime:4.3.6') {
        exclude module: "httpclient"
    }
    ...
}

Tested on Android 6.0.1.

Android update notification progress from service using Volley plus or OkHttp

1 Answers1