android - 使用 Retrofit 库处理带有通知的多个下载-6ren

android - 使用 Retrofit 库处理带有通知的多个下载

转载作者：搜寻专家更新时间：2023-11-01 08:33:38

我正在关注 a tutorial to download files using the Retrofit library .

我的应用程序的用户界面有几个不同的按钮，它们使用上述方法下载不同的文件。问题是当有人在按下第一个按钮后按下另一个按钮时，它会排队并在第一个按钮完成后开始。我希望它立即同时开始。

这是 DownloadService 的代码:

public class DownloadService extends IntentService {

    public DownloadService() {
        super("Download Service");
    }

    private int totalFileSize;
    private NotificationCompat.Builder notificationBuilder;
    private NotificationManager notificationManager;

    @Override
    protected void onHandleIntent(Intent intent) {
        MyApp x = (MyApp)getApplicationContext();
        notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);

        notificationBuilder = new NotificationCompat.Builder(this)
                .setSmallIcon(R.drawable.ic_file_download_deep_orange_a400_18dp)
                .setContentTitle("Downloading")
                .setContentText("Please wait...")
                .setAutoCancel(true);
        notificationManager.notify(x.ID, notificationBuilder.build());
        Log.i("Paras", "onHandleIntent: " + x.filename + x.url);
        initDownload(x.filename,x.url,x.ID);

    }

    private void initDownload(String filename, String url, int id) {

        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://dl.dropboxusercontent.com/")
                .build();

        RequestInterface.RetrofitInterface retrofitInterface = retrofit.create(RequestInterface.RetrofitInterface.class);

        Call<ResponseBody> request = retrofitInterface.downloadFile(url);
        try {

            downloadFile(request.execute().body(),filename,id);

        } catch (IOException e) {

            e.printStackTrace();
            Toast.makeText(getApplicationContext(), e.getMessage(), Toast.LENGTH_SHORT).show();

        }
    }

    private void downloadFile(ResponseBody body, String filename,int id) throws IOException {

        int count;
        byte data[] = new byte[1024 * 4];
        long fileSize = body.contentLength();
        InputStream bis = new BufferedInputStream(body.byteStream(), 1024 * 8);
        File outputFile = new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), filename);
        OutputStream output = new FileOutputStream(outputFile);
        long total = 0;
        long startTime = System.currentTimeMillis();
        int timeCount = 1;

        while ((count = bis.read(data)) != -1) {
            total += count;
            totalFileSize = (int) (fileSize / (Math.pow(1, 2))) / 1000;
            double current = Math.round(total / (Math.pow(1, 2))) / 1000;

            int progress = (int) ((total * 100) / fileSize);

            long currentTime = System.currentTimeMillis() - startTime;

            Download download = new Download();
            download.setTotalFileSize(totalFileSize);

            if (currentTime > 1000 * timeCount) {
                download.setCurrentFileSize((int) current);
                download.setProgress(progress);
                sendNotification(download,id);
                timeCount++;
            }

            output.write(data, 0, count);
        }

        onDownloadComplete(filename,id);
        output.flush();
        output.close();
        bis.close();

    }

    private void sendNotification(Download download, int id) {

        sendIntent(download);
        notificationBuilder.setProgress(100, download.getProgress(), false);
        notificationBuilder.setContentText("Downloading file " + download.getCurrentFileSize() + "/" + totalFileSize + " KB");
        notificationManager.notify(id, notificationBuilder.build());
    }

    private void sendIntent(Download download) {

        Intent intent = new Intent(subject.MESSAGE_PROGRESS);
        intent.putExtra("download", download);
        LocalBroadcastManager.getInstance(DownloadService.this).sendBroadcast(intent);
    }

    private void onDownloadComplete(String filename,int id) {
        try {

            Download download = new Download();
            download.setProgress(100);
            sendIntent(download);

            notificationManager.cancel(id);
            notificationBuilder.setProgress(0, 0, false);
            notificationBuilder.setContentText("Tap to open");
            notificationManager.notify(id, notificationBuilder.build());

            String path1 = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/" + filename;

            File file = new File(path1);
            Uri uri_path = Uri.fromFile(file);
            String mimeType = MimeTypeMap.getSingleton().getMimeTypeFromExtension
                    (MimeTypeMap.getFileExtensionFromUrl(path1));

            Intent intent = new Intent(android.content.Intent.ACTION_VIEW);
            intent.setType(mimeType);
            intent.setDataAndType(uri_path, mimeType);
            PendingIntent pIntent = PendingIntent.getActivity(this, (int) System.currentTimeMillis(), intent, 0);
            String string = filename;
            notificationBuilder
                    .setContentIntent(pIntent)
                    .setAutoCancel(true)
                    .setContentTitle(string + " Downloaded");
            Log.i("Paras", "onDownloadComplete: " + string);
            notificationManager.notify(id, notificationBuilder.build());
        } catch (Exception ex) {

        }
    }

    @Override
    public void onTaskRemoved(Intent rootIntent) {

    }
}

然后我阅读了有关 IntentService 和 Service 类的内容。 Service 类是否允许同时下载？我试过这样的事情:

public class DownloadService extends Service {

    public DownloadService() {
        super();
    }

    private Looper mServiceLooper;
    private ServiceHandler mServiceHandler;

    private final class ServiceHandler extends Handler {
        public ServiceHandler(Looper looper) {
            super(looper);
        }

        @Override
        public void handleMessage(Message msg) {
            MyApp x = (MyApp)getApplicationContext();
            notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);

            notificationBuilder = new NotificationCompat.Builder(getBaseContext())
                    .setSmallIcon(R.drawable.ic_file_download_deep_orange_a400_18dp)
                    .setContentTitle("Downloading")
                    .setContentText("Please wait...")
                    .setAutoCancel(true);
            notificationManager.notify(x.ID, notificationBuilder.build());
            Log.i("Paras", "onHandleIntent: " + x.filename + x.url);
            initDownload(x.filename,x.url,x.ID);
        }
    }

    @Override
    public void onCreate() {
        // Start up the thread running the service.  Note that we create a
        // separate thread because the service normally runs in the process's
        // main thread, which we don't want to block.  We also make it
        // background priority so CPU-intensive work will not disrupt our UI.
        HandlerThread thread = new HandlerThread("ServiceStartArguments", Process.THREAD_PRIORITY_BACKGROUND);
        thread.start();

        // Get the HandlerThread's Looper and use it for our Handler
        mServiceLooper = thread.getLooper();
        mServiceHandler = new ServiceHandler(mServiceLooper);
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {

        // For each start request, send a message to start a job and deliver the
        // start ID so we know which request we're stopping when we finish the job
        MyApp x = (MyApp)getApplicationContext();
        Message msg = mServiceHandler.obtainMessage();
        msg.arg1 = startId;
        msg.obj= intent.putExtra("ID",x.ID);
        mServiceHandler.sendMessage(msg);

        // If we get killed, after returning from here, restart
        return START_STICKY;
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    private int totalFileSize;
    private NotificationCompat.Builder notificationBuilder;
    private NotificationManager notificationManager;

    private void initDownload(String filename, String url, int id) {

        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://dl.dropboxusercontent.com/")
                .build();

        RequestInterface.RetrofitInterface retrofitInterface = retrofit.create(RequestInterface.RetrofitInterface.class);

        Call<ResponseBody> request = retrofitInterface.downloadFile(url);
        try {

            downloadFile(request.execute().body(),filename,id);

        } catch (IOException e) {

            e.printStackTrace();
            Toast.makeText(getApplicationContext(), e.getMessage(), Toast.LENGTH_SHORT).show();

        }
    }

    private void downloadFile(ResponseBody body, String filename,int id) throws IOException {

        int count;
        byte data[] = new byte[1024 * 4];
        long fileSize = body.contentLength();
        InputStream bis = new BufferedInputStream(body.byteStream(), 1024 * 8);
        File outputFile = new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), filename);
        OutputStream output = new FileOutputStream(outputFile);
        long total = 0;
        long startTime = System.currentTimeMillis();
        int timeCount = 1;

        while ((count = bis.read(data)) != -1) {
            total += count;
            totalFileSize = (int) (fileSize / (Math.pow(1, 2))) / 1000;
            double current = Math.round(total / (Math.pow(1, 2))) / 1000;

            int progress = (int) ((total * 100) / fileSize);

            long currentTime = System.currentTimeMillis() - startTime;

            Download download = new Download();
            download.setTotalFileSize(totalFileSize);

            if (currentTime > 1000 * timeCount) {
                download.setCurrentFileSize((int) current);
                download.setProgress(progress);
                sendNotification(download,id);
                timeCount++;
            }

            output.write(data, 0, count);
        }

        onDownloadComplete(filename,id);
        output.flush();
        output.close();
        bis.close();

    }

    private void sendNotification(Download download, int id) {

        sendIntent(download);
        notificationBuilder.setProgress(100, download.getProgress(), false);
        notificationBuilder.setContentText("Downloading file " + download.getCurrentFileSize() + "/" + totalFileSize + " KB");
        notificationManager.notify(id, notificationBuilder.build());
    }

    private void sendIntent(Download download) {

        Intent intent = new Intent(subject.MESSAGE_PROGRESS);
        intent.putExtra("download", download);
        LocalBroadcastManager.getInstance(DownloadService.this).sendBroadcast(intent);
    }

    private void onDownloadComplete(String filename,int id) {
        try {

            Download download = new Download();
            download.setProgress(100);
            sendIntent(download);

            notificationManager.cancel(id);
            notificationBuilder.setProgress(0, 0, false);
            notificationBuilder.setContentText("Tap to open");
            notificationManager.notify(id, notificationBuilder.build());

            String path1 = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/" + filename;

            File file = new File(path1);
            Uri uri_path = Uri.fromFile(file);
            String mimeType = MimeTypeMap.getSingleton().getMimeTypeFromExtension
                    (MimeTypeMap.getFileExtensionFromUrl(path1));

            Intent intent = new Intent(android.content.Intent.ACTION_VIEW);
            intent.setType(mimeType);
            intent.setDataAndType(uri_path, mimeType);
            PendingIntent pIntent = PendingIntent.getActivity(this, (int) System.currentTimeMillis(), intent, 0);
            String string = filename;
            notificationBuilder
                    .setContentIntent(pIntent)
                    .setAutoCancel(true)
                    .setContentTitle(string + " Downloaded");
            Log.i("Paras", "onDownloadComplete: " + string);
            notificationManager.notify(id, notificationBuilder.build());
        } catch (Exception ex) {

        }
    }

    @Override
    public void onTaskRemoved(Intent rootIntent) {

    }
}

但是没有用。任何线索我应该做什么？如果需要，我准备好提供更多详细信息。

编辑 1: DownloadService 在函数“startDownload”上运行，该函数由各种按钮执行。正如您在第二个代码中看到的，类扩展服务。有一个线程处理所有这些按钮点击。如果您查看评论，建议我对所有这些点击使用服务和不同的线程。现在我如何以编程方式创建这么多线程。有将近 40 个按钮使用了 DownloadService。

最佳答案

感谢@Lxu，我让它工作了。所以IntentService的意思是一次做一个任务，不能同时做多个任务。我们应该改用 Service。它允许同时执行多个任务。我们可以在 Service 中创建多个线程，它们将同时执行。通过将 onCreate() 的所有代码放到 onStartCommand() 中，我的问题得到了解决。当服务第一次被调用时，onCreate()被调用，之后无论调用多少次都不再调用。在每次服务调用时，都会执行 onStartCommand()，每次都会创建新线程。就是这样。

完整代码如下:

public class DownloadService extends Service {

    public DownloadService() {
        super();
    }
    private Looper mServiceLooper;
    private ServiceHandler mServiceHandler;

    int id1;
    int id2;
    private final class ServiceHandler extends Handler {
        public ServiceHandler(Looper looper) {
            super(looper);
        }
        @Override
        public void handleMessage(Message msg) {
            MyApp x = (MyApp)getApplicationContext();
            notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);

            notificationBuilder = new NotificationCompat.Builder(getApplicationContext())
                    .setSmallIcon(R.drawable.ic_file_download_deep_orange_a400_18dp)
                    .setContentTitle("Downloading")
                    .setContentText("Please wait...")
                    .setAutoCancel(true);
            notificationManager.notify(x.ID, notificationBuilder.build());
            Log.i("Paras", "onHandleIntent: " + x.filename + x.url + "  " + x.ID);
            initDownload(x.filename,x.url,x.ID);
        }
    }
    @Override
    public void onCreate() {
        // Get the HandlerThread's Looper and use it for our Handler
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        // For each start request, send a message to start a job and deliver the
        // start ID so we know which request we're stopping when we finish the job
        HandlerThread thread = new HandlerThread("ServiceStartArguments", Process.THREAD_PRIORITY_BACKGROUND);
        thread.start();
        mServiceLooper = thread.getLooper();
        mServiceHandler = new ServiceHandler(mServiceLooper);
        MyApp x = (MyApp)getApplicationContext();
        Message msg = mServiceHandler.obtainMessage();
        msg.arg1 = startId;
        mServiceHandler.sendMessage(msg);


        // If we get killed, after returning from here, restart
        return START_STICKY;
    }
    @Nullable
    @Override
    public IBinder onBind(Intent intent) {

        return null;
    }

    private int totalFileSize;
    private NotificationCompat.Builder notificationBuilder;
    private NotificationManager notificationManager;

    private void initDownload(String filename, String url, int id) {

        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://dl.dropboxusercontent.com/")
                .build();

        RequestInterface.RetrofitInterface retrofitInterface = retrofit.create(RequestInterface.RetrofitInterface.class);

        Call<ResponseBody> request = retrofitInterface.downloadFile(url);
        try {

            downloadFile(request.execute().body(),filename,id);

        } catch (IOException e) {

            e.printStackTrace();
            Toast.makeText(getApplicationContext(), e.getMessage(), Toast.LENGTH_SHORT).show();

        }
    }

    private void downloadFile(ResponseBody body, String filename,int id) throws IOException {

        int count;
        byte data[] = new byte[1024 * 4];
        long fileSize = body.contentLength();
        InputStream bis = new BufferedInputStream(body.byteStream(), 1024 * 8);
        File outputFile = new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), filename);
        OutputStream output = new FileOutputStream(outputFile);
        long total = 0;
        long startTime = System.currentTimeMillis();
        int timeCount = 1;
        while ((count = bis.read(data)) != -1) {

            total += count;
            totalFileSize = (int) (fileSize / (Math.pow(1, 2))) / 1000;
            double current = Math.round(total / (Math.pow(1, 2))) / 1000;

            int progress = (int) ((total * 100) / fileSize);

            long currentTime = System.currentTimeMillis() - startTime;

            Download download = new Download();
            download.setTotalFileSize(totalFileSize);

            if (currentTime > 1000 * timeCount) {

                download.setCurrentFileSize((int) current);
                download.setProgress(progress);
                sendNotification(download,id);
                timeCount++;
            }

            output.write(data, 0, count);
        }
        onDownloadComplete(filename,id);
        output.flush();
        output.close();
        bis.close();

    }

    private void sendNotification(Download download, int id) {

        sendIntent(download,id);
        notificationBuilder.setProgress(100, download.getProgress(), false)
                            .setContentTitle("Downloading");
        notificationBuilder.setContentText("Downloading file " + download.getCurrentFileSize() + "/" + totalFileSize + " KB");
        notificationManager.notify(id, notificationBuilder.build());
    }

    private void sendIntent(Download download, int id) {

        Intent intent = new Intent(subject.MESSAGE_PROGRESS);
        intent.putExtra("download", download);
        LocalBroadcastManager.getInstance(DownloadService.this).sendBroadcast(intent);
    }

    private void onDownloadComplete(String filename,int id) {
        try {

            Download download = new Download();
            download.setProgress(100);
            sendIntent(download,id);

            notificationManager.cancel(id);
            notificationBuilder.setProgress(0, 0, false);
            notificationBuilder.setContentText("Tap to open");
            notificationManager.notify(id, notificationBuilder.build());

            String path1 = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/" + filename;

            File file = new File(path1);
            Uri uri_path = Uri.fromFile(file);
            String mimeType = MimeTypeMap.getSingleton().getMimeTypeFromExtension
                    (MimeTypeMap.getFileExtensionFromUrl(path1));

            Intent intent = new Intent(android.content.Intent.ACTION_VIEW);
            intent.setType(mimeType);
            intent.setDataAndType(uri_path, mimeType);
            PendingIntent pIntent = PendingIntent.getActivity(this,(int) System.currentTimeMillis(), intent, 0);
            String string = filename;
            notificationBuilder
                    .setContentIntent(pIntent)
                    .setAutoCancel(true)
                    .setContentTitle(string + " Downloaded");
            Log.i("Paras", "onDownloadComplete: " + string);
            notificationManager.notify(id, notificationBuilder.build());
        }catch (Exception ex){

        }
    }
    @Override
    public void onTaskRemoved(Intent rootIntent) {

    }
}

关于android - 使用 Retrofit 库处理带有通知的多个下载，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38549633/

文章推荐： android - Html.fromHtml 或 Spannable，哪个最好？

文章推荐： MySQL 将多个日期时间值映射到相同的 unix 纪元时间

文章推荐： php - 运行多个 PHP MySQL 查询

android - 当应用程序不在前台时，如何使用 Firebase Cloud Messaging(通知)在 Android 中获取 Heads Up 通知？
我有一个应用程序应该在应用程序处于前台和后台(不在历史记录中)时显示提醒通知。在前景情况下，我通过以下方法实现了这一点。 PendingIntent pendingIntent = PendingI
WPF 通知
如何为我的 WPF 应用程序创建通知，例如浏览器上的通知，它们通过浏览器顶部的“工具栏”显示消息或通过在右下角向上/向下滑动的弹出窗口显示“MSN”样式通知屏幕。也许在应用程序中心淡入/淡出的面板可以
HTML5 通知
关闭。这个问题是opinion-based .它目前不接受答案。想要改进这个问题？更新问题，以便 editing this post 可以用事实和引用来回答它. 关闭 9 年前。 Improve
Redis 通知
我正在使用 Redis 作为分布式缓存。我有不同的应用程序，它们只听特定的键。例如:App1 听 App1.*App2 监听 App2.* 等等。我的应用程序使用以下模式接收通知:App1:“ ke
新镜像版本的 Docker 通知
我正在尝试构建一个基于官方节点 docker 镜像的 docker 镜像，我想知道是否有某种方法可以在推送新版本的官方节点镜像时自动重建镜像。这样我的图像就不会基于过时的基础图像。也许有类似 rss
notifications - Nextcloud 通知
我在一个项目中工作，我需要在添加或修改文件时在数据库中记录文件信息，以便它们保持同步。这些文件应该存储在 Nextcloud 服务器中，那么 Nextcloud 是否有办法通知这些更改(例如 webh
Laravel 通知 - 通过用户指定
通知类中的方法via 如何根据用户的偏好动态变化，一个用户可能想通过电子邮件接收，而另一个用户则不想 public function via($notifiable) { return ['d
Laravel 通知 - 延迟电子邮件发送并在条件满足时取消
我有一个应用程序，我正在发送推送通知，如果用户登录到应用程序，这很好 - 但是，如果他们没有/如果他们没有在 X 分钟内阅读通知，我想给他们发送一封电子邮件. 我要解决的方法是使用 Laravel N
关于提交评论的 Django 通知
我正在使用 Django 的 contrib.comments 并想了解以下内容。是否有任何实用程序或应用程序可以插入到某个应用程序中，当对某个项目发表评论时向您发送通知？我并没有真正使用过那么多
首次启动应用程序时 iPhone 通知
我希望用户在启动应用程序之前接受协议(protocol)。所以在 appDelegate.m 中我有以下内容: - (BOOL)application:(UIApplication *)applica
移除元素时的 angularJS 通知
我正在创建一个新指令，我想知道如何在 angular 从 DOM 中删除元素时收到通知。我的目标是在删除元素时添加 jquery 动画。最佳答案如果您尝试对元素的移除进行动画处理，则需要在移除元
iphone - UIScrollView 通知
我正在编写一个应用程序，其工作方式与Apple的Weather.app非常相似:底部有一个UIPageControl，屏幕中间有一个UIScrollView。在我的代码中，我实现了 - (void)s
iPhone notification_post 通知
如何查明 iPhone 注册了哪些通知？例如: notify_post("com.apple.springboard/Prefs"); 最佳答案虽然这个问题的答案已经得到确认，但由于 @Nate
cocoa 通知，如何观察事件？
我的 Cocoa 应用程序中有一个 TextField。该文本字段有时会被填充，有时会为空。我希望当字段为空时按钮被禁用。现在，每当我对 Core Data 执行某些操作时，我都会检查该字段，Tex
文件更新时的 Delphi 通知
我的应用程序在其数据库中包含文档。用户可以打开文档，在这种情况下，文档将保存到临时文件夹并在用户计算机上打开。我希望在这些临时文件之一发生更改时收到通知，并让用户将更改后的文档保存回数据库。在 D
javascript - 轮询新消息警报/通知
我目前正在开发一个网络应用程序，它不断对 php 进行 ajax 调用(轮询)，以从数据库中提取新的“任务”，有点像 gmail/facebook 检查新电子邮件和消息的方式。当前的 JavaScri
angular - Electron 通知
我正在尝试让通知适用于我使用 Angular 5 和 Electron 制作的 Electron 应用程序。到目前为止，我的 index.html 文件中有以下代码: function doNo
系统为后台音频应用程序提供的 iOS 通知
我有一个录音/播放应用程序。它在后台运行。当它进入后台时，如果任何其他音频应用程序打开或开始使用音频资源，我想适本地处理我的应用程序。 iOS 提供了一种发送此类通知的方法，如在 ipod 播放器中看
javascript - Chrome 通知
关闭。这个问题需要多问focused 。目前不接受答案。想要改进此问题吗？更新问题，使其仅关注一个问题 editing this post . 已关闭 4 年前。 Improve this ques
提交某些文件的 SVN 通知
是否有 Subversion 的工具可以在对某些文件提交更改时自动通知我？最佳答案您可以创建一个 post-commit hook script “ Hook ”提交。在钩子(Hook)脚本中，

搜寻专家

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

android - 使用 Retrofit 库处理带有通知的多个下载