【重生之我在学Android】WorkManager （章一）

相关文章

【重生之我在学Android原生】ContentProvider(Java)
【重生之我在学Android原生】Media3
【重生之我在学Android】WorkManager （章一）

前言

官方文档
在这里插入图片描述
官方推荐 - 前台服务、后台服务都可以使用WorkManger来实现
在这里插入图片描述

案例

语言：JAVA

实现要求

一步步实现一个图片压缩APP

创建项目

在这里插入图片描述

添加WorkManager依赖

参考文章
在这里插入图片描述
添加到builder.gradle, sync一下
在这里插入图片描述

    val workVersion = "2.9.0"
    implementation("androidx.work:work-runtime:$workVersion")

接收share来的图片数据

在这里插入图片描述
要实现这种效果，需要在AndroidManifest.xml声明标签，过滤intent
在这里插入图片描述

<intent-filter>
                <action android:name="android.intent.action.SEND" />
                <category android:name="android.intent.category.DEFAULT" />
                <data android:mimeType="image/*" />
            </intent-filter>

将Activity改为singleTop

运行APP。打开手机相册，分享一张图片，会重新使用这个Activity
在这里插入图片描述

android:launchMode="singleTop"

在onNewIntent接收数据

在这里插入图片描述

定义Worker

你需要做什么事情，你就定义一个Worker，指派它做事，做什么事，就在dowork里定义
dowork有三个返回，见图
在这里插入图片描述

传入Uri到Worker

参考这里
在这里插入图片描述
通过inputdata传入
在这里插入图片描述
在这里插入图片描述

Uri -> Bitmap

在这里插入图片描述
若有爆红位置
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

压缩图片直到图片的大小不超过XKB

传入图片的大小阀值
在这里插入图片描述
不断循环压缩，一直到图片的大小不超过20KB
在这里插入图片描述

生成文件

在这里插入图片描述
在这里插入图片描述

返回图片地址数据

构建Data，传值回去
在这里插入图片描述

监听Worker结果

在获取到WorkManager这个实例后
通过getWorkInfoByIdLiveData方法来监听workerrequest状态及结果返回
在这里插入图片描述

显示结果

在布局中，加入一张图片
在这里插入图片描述
在这里插入图片描述

Android版本 兼容问题

兼容低版本的Android系统
在这里插入图片描述
inputStream.readAllBytes() 需要在API 33之后使用
所以需要更改写法，来使低版本的Android系统使用
在这里插入图片描述

bytes = new byte[inputStream.available()];
             inputStream.read(bytes);

运行项目

请添加图片描述

完整代码

// ImageCompressionWorker
package com.test.imagecompressionworkerapplication;

import android.content.Context;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.net.Uri;
import android.os.Build;
import android.util.Log;

import androidx.annotation.NonNull;
import androidx.annotation.RequiresApi;
import androidx.work.Data;
import androidx.work.Worker;
import androidx.work.WorkerParameters;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;

public class ImageCompressionWorker extends Worker {
    private final String TAG = "worker - log";
    public static final String KEY_CONTENT_URI = "KEY_CONTENT_URI";
    public static final String KEY_COMPRESSION_THRESHOLD = "KEY_COMPRESSION_THRESHOLD";
    public static final String KEY_RESULT_PATH = "KEY_RESULT_PATH";
    private final WorkerParameters workerParameters;
    private final Context appContext;

    public ImageCompressionWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
        appContext = context;
        workerParameters = workerParams;
    }

    @NonNull
    @Override
    public Result doWork() {
        Data inputData = workerParameters.getInputData();
        String uriStr = inputData.getString(KEY_CONTENT_URI);
        long size = inputData.getLong(KEY_COMPRESSION_THRESHOLD, 0L);

        assert uriStr != null;
        Uri uri = Uri.parse(uriStr);
        byte[] bytes;
        try {
            InputStream inputStream = appContext.getContentResolver().openInputStream(uri);
            assert inputStream != null;
//            byte[] bytes_ = inputStream.readAllBytes();
             bytes = new byte[inputStream.available()];
             inputStream.read(bytes);

            Bitmap bitmap = BitmapFactory.decodeByteArray(bytes, 0, bytes.length);
            inputStream.close();

            int quality = 100;
            byte[] byteArray;
            do {
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                bitmap.compress(Bitmap.CompressFormat.JPEG, quality, byteArrayOutputStream);
                byteArray = byteArrayOutputStream.toByteArray();
                quality -= Math.round(quality * 0.1);
            } while (byteArray.length > size && quality > 5);

            File file = new File(appContext.getCacheDir(), workerParameters.getId() + ".jpg");
            FileOutputStream fileOutputStream = new FileOutputStream(file);
            fileOutputStream.write(byteArray);
            fileOutputStream.close();
            String absolutePath = file.getAbsolutePath();

            Data outputData = new Data.Builder()
                    .putString(KEY_RESULT_PATH, absolutePath)
                    .build();
            return Result.success(outputData);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}

// MainActivity.java
package com.test.imagecompressionworkerapplication;

import androidx.appcompat.app.AppCompatActivity;
import androidx.lifecycle.Observer;
import androidx.work.Data;
import androidx.work.OneTimeWorkRequest;
import androidx.work.OutOfQuotaPolicy;
import androidx.work.WorkInfo;
import androidx.work.WorkManager;

import android.content.Intent;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.net.Uri;
import android.os.Bundle;
import android.util.Log;
import android.widget.ImageView;

import java.util.UUID;

public class MainActivity extends AppCompatActivity {
    private final String TAG = "mainActivity - log";
    private WorkManager workManager;
    private ImageView sharedImage;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        workManager = WorkManager.getInstance(this);
        bindView();
    }

    @Override
    protected void onNewIntent(Intent intent) {
        super.onNewIntent(intent);
        Uri uri;
        if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.TIRAMISU) {
            uri = intent.getParcelableExtra(Intent.EXTRA_STREAM, Uri.class);
        } else {
            uri = intent.getParcelableExtra(Intent.EXTRA_STREAM);
        }
        assert uri != null;
        long size = 1024 * 20L;
        Data inputData = new Data.Builder()
                .putString(ImageCompressionWorker.KEY_CONTENT_URI, uri.toString())
                .putLong(ImageCompressionWorker.KEY_COMPRESSION_THRESHOLD, size)
                .build();
        OneTimeWorkRequest oneTimeWorkRequest = new OneTimeWorkRequest.Builder(ImageCompressionWorker.class)
                .setInputData(inputData)
//                .setExpedited(OutOfQuotaPolicy.RUN_AS_NON_EXPEDITED_WORK_REQUEST)
                .build();
        workManager.enqueue(oneTimeWorkRequest);

        UUID id = oneTimeWorkRequest.getId();
        workManager.getWorkInfoByIdLiveData(id).observe(this, workInfo -> {
            if (workInfo.getState() == WorkInfo.State.SUCCEEDED) {
                Data outputData = workInfo.getOutputData();
                String filePath = outputData.getString(ImageCompressionWorker.KEY_RESULT_PATH);
                Bitmap bitmap = BitmapFactory.decodeFile(filePath);
                sharedImage.setImageBitmap(bitmap);
            }
        });
    }

    private void bindView() {
        sharedImage = findViewById(R.id.sharedImage);
    }
}

更多内容

这一节，有些流水账，看看就好
可以直接看官方文档吧
官方文档

执行加急工作

在这里插入图片描述
在这里插入图片描述

配额策略

在这里插入图片描述

加急工作 + CoroutineWorker + 通知

加急工作需要配合通知使用，否则会报错
将之前的继承Worker改为CoroutineWorker
重写方法getForegroundInfo
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

    @Nullable
    @Override
    public Object getForegroundInfo(@NonNull Continuation<? super ForegroundInfo> $completion) {
        return new ForegroundInfo(NOTIFICATION_ID, createNotification());
    }

    private Notification createNotification() {
        String CHANNEL_ID = "compressor_channel_id";
        String CHANNEL_NAME = "压缩图片通知通道";
        String NOTIFICATION_TITLE = "你有一个程序在压缩图片";
        int importance = NotificationManager.IMPORTANCE_HIGH;
        NotificationChannel notificationChannel;
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            notificationChannel = new NotificationChannel(CHANNEL_ID, CHANNEL_NAME, importance);
            NotificationManager notificationManager = getSystemService(appContext, NotificationManager.class);
            assert notificationManager != null;
            notificationManager.createNotificationChannel(notificationChannel);
        }
        String NOTIFICATION_TEXT = "压缩中...";
        Intent intent = new Intent(appContext, ImageCompressionWorker.class);
        PendingIntent pendingIntent = PendingIntent.getActivity(appContext, 0, intent, PendingIntent.FLAG_IMMUTABLE);
        return new NotificationCompat.Builder(appContext, CHANNEL_ID)
                .setContentTitle(NOTIFICATION_TITLE)
                .setContentText(NOTIFICATION_TEXT)
                .setSmallIcon(R.drawable.ic_launcher_background)
                .setContentIntent(pendingIntent)
                .build();
    }

通知

在这里插入图片描述
在Android 12 之前的版本运行，会有通知显示；
通知需要申请权限

<uses-permission android:name="android.permission.POST_NOTIFICATIONS"/>

在这里插入图片描述

private static final String[] PERMISSION_REQUIRED = new String[]{
            Manifest.permission.POST_NOTIFICATIONS
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        workManager = WorkManager.getInstance(this);
        bindView();
        if (!checkAllPermissions()) {
            requestPermissions(PERMISSION_REQUIRED, REQUEST_CODE);
        }
    }

    private boolean checkAllPermissions() {
        for (String permission : PERMISSION_REQUIRED) {
            int permissionCheck = ContextCompat.checkSelfPermission(this, permission);
            if (permissionCheck == PackageManager.PERMISSION_DENIED) {
                return false;
            }
        }
        return true;
    }

运行项目

压缩过程很快，压缩完成之后，通知关闭了
请添加图片描述

调度定期工作

每间隔一小时的最后15分钟工作一次
在这里插入图片描述
为了方便测试，这里使用15分钟一次

WorkRequest uploadRequest = new PeriodicWorkRequest
                .Builder(PeriodicUploadLogWorker.class, 15, TimeUnit.MINUTES, 15, TimeUnit.MINUTES)
                .build();
        WorkManager workManager = WorkManager.getInstance(this);
        workManager.enqueue(uploadRequest);

public class PeriodicUploadLogWorker extends Worker {
    private final String TAG = "periodic_upload_log";

    public PeriodicUploadLogWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
    }

    @NonNull
    @Override
    public Result doWork() {
        uploadLog();
        return Result.success();
    }

    private void uploadLog() {
        Log.i(TAG, String.valueOf(System.currentTimeMillis()));
    }
}

在这里插入图片描述

工作约束

将工作延迟到满足最佳条件时运行
在这里插入图片描述
在这里插入图片描述

延迟工作

在这里插入图片描述

重试和退避政策

在这里插入图片描述
在这里插入图片描述

标记工作

在这里插入图片描述
在这里插入图片描述

分配输入数据

setInputData 传入数据
getInputData 获取数据
在这里插入图片描述
在这里插入图片描述

唯一工作

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

查询工作

按id、name、tag查询
在这里插入图片描述
WorkQuery
在这里插入图片描述

取消工作

在这里插入图片描述

链接工作

将每个Worker链接起来，按顺序执行。
在这里插入图片描述

还可以定义合并器
在这里插入图片描述
默认合并器，变量名一致的，值采用最新的覆盖前者
在这里插入图片描述
在这里插入图片描述
第二种，会保留返回的结果，会合并相同变量名到一个数组中
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

长时间运行worker

观察Worker的中间进度

更新工作

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/631087.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Leetcode---1.两数之和 （详解加哈希表解释和使用）

Leetcode---1.两数之和 （详解加哈希表解释和使用）

文章目录 题目 [两数之和](https://leetcode.cn/problems/two-sum/)方法一&#xff1a;暴力枚举代码方法二&#xff1a;哈希表代码 哈希表哈希表的基本概念哈希函数&#xff08;Hash Function&#xff09;&#xff1a;冲突&#xff08;Collision&#xff09;&#xff1a;链地址…
阅读更多...
Linux查看进程命令ps和top

Linux查看进程命令ps和top

Linux 是一种自由和开放源代码的操作系统&#xff0c;它的使用在全球范围内非常广泛。在 Linux 中&#xff0c;进程是操作系统中最重要的组成部分之一&#xff0c;它代表了正在运行的程序。了解如何查看正在运行的进程是非常重要的&#xff0c;因为它可以帮助你了解系统的运行状…
阅读更多...
Qwen学习笔记4：Qwen 7B模型调用天气API实现天气的实时查询

Qwen学习笔记4：Qwen 7B模型调用天气API实现天气的实时查询

前言 在学习Qwen模型的函数调用功能后&#xff0c;进一步尝试利用本地的Qwen模型访问OpenWeather API来获取实时的天气情况。 参考代码来源于视频教程&#xff1a; 简单粗暴&#xff0c;轻松配置Qwen模型查询实时数据功能_哔哩哔哩_bilibili 说明 该代码运行前&#xff0c…
阅读更多...
基于51单片机的AD/DA转换的串口通信proteus仿真（附源码）

基于51单片机的AD/DA转换的串口通信proteus仿真（附源码）

文章目录 一、前言二、PCF85911.介绍2.原理图3.引脚介绍 三、仿真图1.未仿真时2.仿真时 四、仿真程序main.cIIC.c 五、总结 一、前言 AT89C52是一款经典的8051系列单片机&#xff0c;它通常不包含内置的模数转换器&#xff08;ADC&#xff09;或数字模拟转换器&#xff08;DAC…
阅读更多...
「Python绘图」绘制奥运五环

「Python绘图」绘制奥运五环

python 绘制奥运五环 一、预期结果 二、核心代码 import turtle print("开始绘制奥运五环")# 创建Turtle对象 pen turtle.Turtle() pen.shape("turtle") pen.pensize(8)print("绘制蓝色圆") pen.up() pen.goto(50-170,0) pen.down() pen.color…
阅读更多...
进程信号 signal

进程信号 signal

文章目录 信号基础信号的产生OS中的时间 信号的保存sigset_tsigprocmasksigpending 信号的捕捉用户态和内核态sigactionvolatile SIGCHLD 信号基础 生活中的信号 你在网上买了很多件商品&#xff0c;再等待不同商品快递的到来。但即便快递没有到来&#xff0c;你也知道快递来临…
阅读更多...
HNU-算法设计与分析-作业5

HNU-算法设计与分析-作业5

第五次作业【回溯算法】 文章目录 第五次作业【回溯算法】<1> 算法分析题5-3 回溯法重写0-1背包<2> 算法分析题5-5 旅行商问题&#xff08;剪枝&#xff09;<3> 算法实现题5-2 最小长度电路板排列问题<4> 算法实现题5-7 n色方柱问题<5> 算法实现…
阅读更多...
[论文阅读]FINE-TUNE THE PRETRAINED ATST MODEL FOR SOUND EVENT DETECTION

[论文阅读]FINE-TUNE THE PRETRAINED ATST MODEL FOR SOUND EVENT DETECTION

摘要 本研究提出了一种微调预训练模型ATST&#xff08;音频师生转换模型&#xff09;的方法&#xff0c;用于声音事件检测&#xff08;SED&#xff09;。通过引入ATST-Frame模型&#xff0c;该方法在DCASE挑战任务4数据集上取得了新的SOTA结果&#xff0c;有效解决了预训练模型…
阅读更多...
Leetcode - 130双周赛

Leetcode - 130双周赛

目录 一&#xff0c;3142. 判断矩阵是否满足条件 二&#xff0c;3143. 正方形中的最多点数 三&#xff0c;3144. 分割字符频率相等的最少子字符串 四&#xff0c;3145. 大数组元素的乘积 一&#xff0c;3142. 判断矩阵是否满足条件 本题题意&#xff0c;满足每一列的数全部…
阅读更多...
LLama3大模型本地部署 仅需6步完成对话模型本地安装部署。附送可视化ui安装、自定义模型目录，修改模型保存地址，第三方微调模型、中文模型下载地址

LLama3大模型本地部署 仅需6步完成对话模型本地安装部署。附送可视化ui安装、自定义模型目录，修改模型保存地址，第三方微调模型、中文模型下载地址

本篇分为三部分 一&#xff1a;6步完成llama3大模型本地部署 二&#xff1a;8步完成llama3可视化对话界面安装 三&#xff1a;重设模型文件路径 四&#xff1a;微调模型、中文模型下载资源分享 一、LLama3 大模型本地部署安装 首先去mata官网下载ollama客户端 Ollama 选择合适…
阅读更多...
Linux操作系统最著名的两大系列Red Hat和Debian

Linux操作系统最著名的两大系列Red Hat和Debian

Linux操作系统可以根据其背后的项目或社区分为不同的系列&#xff0c;其中最著名的两大系列是Red Hat系列和Debian系列。 1.著名的两大系列是Red Hat和Debian Red Hat系列&#xff1a; Red Hat Enterprise Linux (RHEL)&#xff1a;这是Red Hat公司推出的企业级操作系统&#…
阅读更多...
计算机网络-路由策略与路由控制一

计算机网络-路由策略与路由控制一

到目前为止我们学习了路由与交换基础&#xff0c;路由协议有静态、RIP、OSPF、IS-IS等&#xff0c;但是根据实际组网需求&#xff0c;往往需要实施一些路由策略对路由信息进行过滤、属性设置等操作&#xff0c;通过对路由的控制&#xff0c;可以影响数据流量转发。 因此我们开始…
阅读更多...
Vitis HLS 学习笔记--资源绑定-使用URAM（1）

Vitis HLS 学习笔记--资源绑定-使用URAM（1）

目录 1. 简介 2. 代码分析 2.1 存储器代码 2.2 Implementation报告 2.3 存储器类型指定 2.4 存储器初始化 3. 总结 1. 简介 在博文《Vitis HLS 学习笔记--资源绑定-使用URAM-CSDN博客》中&#xff0c;介绍了如何在Vitis HLS环境下设计一个简易的存储器模型。 通过以下…
阅读更多...
Skywalking配置traceId

Skywalking配置traceId

1.引言 1.1 SkyWalking概述 SkyWalking是一个开源的分布式系统观测平台&#xff0c;旨在解决微服务和云原生架构中常见的性能监控和故障排除问题。自2015年由Apache基金会孵化以来&#xff0c;SkyWalking已经成为全球范围内广泛使用的APM&#xff08;应用性能管理&#xff09…
阅读更多...
Selenium 自动化 —— 高级交互（click、sendKeys、submit、clear、select）

Selenium 自动化 —— 高级交互（click、sendKeys、submit、clear、select）

更多关于Selenium的知识请访问CSND论坛“兰亭序咖啡”的专栏&#xff1a;专栏《Selenium 从入门到精通》 ​​ 1. 前言 这是我的《Selenium从入门到精通》专栏的第11篇文章&#xff0c;前面花了很多时间在元素的定位上。不管是爬虫和自动化&#xff0c;找到元素后&#xff0c…
阅读更多...
jvisualvm安装Visual GC插件

jvisualvm安装Visual GC插件

给jdk自带的jvisualvm安装Visual GC插件&#xff0c;遇到We’re sorry the java.net site has closed&#xff08;我们很抱歉java.net网站已经关闭&#xff09; 1、找到新的更新地址 visualvm新访问地址&#xff1a;https://visualvm.github.io/index.html 进入“Plugins”&am…
阅读更多...
【介绍下Python多线程，什么是Python多线程】

【介绍下Python多线程，什么是Python多线程】

&#x1f308;个人主页: 程序员不想敲代码啊 &#x1f3c6;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家 &#x1f44d;点赞⭐评论⭐收藏 &#x1f91d;希望本文对您有所裨益&#xff0c;如有不足之处&#xff0c;欢迎在评论区提出指正&#xff0c;让我们共…
阅读更多...
一个可自动生成行排号的excel VBA小工具

一个可自动生成行排号的excel VBA小工具

如下图&#xff0c;点击“生成行排号”按钮即可生成想要的行排号 基本用法如下&#xff1a; 1、设置顺序排列的行排号&#xff08;每排的行号一致&#xff0c;行的方向排序方向也一致&#xff09; 2、设置顺序排列的行排号&#xff08;行号从小到大排列&#xff0c;而不受排的…
阅读更多...
UEC++学习（十五）创建、查找、加入会话

UEC++学习（十五）创建、查找、加入会话

创建会话 基于上篇配置steam在线子系统之后&#xff0c;在Character.h中声明一个会话创建完成时的委托以及回调函数。 #include "Interfaces/OnlineSessionInterface.h"public://指向在线会话界面的指针,将会话接口存储在里面TSharedPtr<class IOnlineSession, ES…
阅读更多...
电脑缺失api-ms-win-crt-runtime-l1-1-0.dll文件的几种修复方法

电脑缺失api-ms-win-crt-runtime-l1-1-0.dll文件的几种修复方法

当您在使用电脑过程中遇到程序启动失败&#xff0c;提示缺少“api-ms-win-crt-runtime-l1-1-0.dll”文件时&#xff0c;不必过于焦虑&#xff0c;此问题通常与Windows系统的Visual C Redistributable组件未正确安装或损坏有关。小编将介绍5种修复电脑缺失api-ms-win-crt-runtim…
阅读更多...
最新文章

Copyright @ 2022~2023