跳过网络,从内存中取图片

This commit is contained in:
‘593378212@qq.com’ 2024-03-19 16:24:51 +08:00
parent ca53509ebc
commit d674f6c409
1 changed files with 115 additions and 11 deletions

View File

@ -41,6 +41,9 @@ import common from '@ohos.app.ability.common'
import HashMap from '@ohos.util.HashMap'
import LinkedList from '@ohos.util.LinkedList'
import { MemoryLruCache } from '../cache/MemoryLruCache'
import { BusinessError } from '@ohos.base'
import { IParseImage } from './interface/IParseImage'
import { ParseImageUtil } from './utils/ParseImageUtil'
export class ImageKnife {
static readonly SEPARATOR: string = '/'
@ -70,15 +73,16 @@ export class ImageKnife {
defaultLifeCycle: IDrawLifeCycle | undefined = undefined;
// 开发者可配置全局缓存
engineKeyImpl: EngineKeyInterface;
private mParseImageUtil: IParseImage<PixelMap>;
private constructor() {
this.mParseImageUtil = new ParseImageUtil();
this.runningMaps = new EasyLinkedHashMap();
this.pendingMaps = new EasyLinkedHashMap();
this.pausedMaps = new EasyLinkedHashMap();
// 构造方法传入size 为保存文件个数
this.memoryCache = new MemoryLruCache(100,100*1024*1024);
this.memoryCache = new MemoryLruCache(100, 100 * 1024 * 1024);
// 创建disk缓存 传入的size 为多少比特 比如20KB 传入20*1024
this.diskMemoryCache = DiskLruCache.create(ImageKnifeGlobal.getInstance().getHapContext());
@ -99,6 +103,7 @@ export class ImageKnife {
}
//全局设置请求头调用方法
addHeader(key: string, value: Object) {
this.headerMap.set(key, value);
@ -184,11 +189,11 @@ export class ImageKnife {
// 设置缓存张数,缓存大小,单位字节
public setLruCacheSize(size: number,memory:number) {
public setLruCacheSize(size: number, memory: number) {
if (this.memoryCache.map.size() <= 0) {
this.memoryCache = new MemoryLruCache(size,memory);
this.memoryCache = new MemoryLruCache(size, memory);
} else {
let newLruCache = new MemoryLruCache(size,memory);
let newLruCache = new MemoryLruCache(size, memory);
this.memoryCache.foreachLruCache((value: ImageKnifeData, key: string, map: Object) => {
newLruCache.put(key, value);
})
@ -214,6 +219,106 @@ export class ImageKnife {
// }
}
public isUrlExist(url: string): Promise<PixelMap> {
return new Promise((resolve, reject) => {
let request1 = new RequestOption();
request1.loadSrc = url;
let request = this.loadResourcesCaches(request1);
let loadComplete = (ImageKnifeData: ImageKnifeData) => {
let pixelMap: PixelMap | undefined;
pixelMap = ImageKnifeData?.drawPixelMap?.imagePixelMap;
resolve(pixelMap as PixelMap);
}
let loadError = (err ?: BusinessError | string) => {
reject(undefined);
}
this.loadMemoryCacheAndDiskFrom(request, loadComplete, loadError);
})
}
loadMemoryCacheAndDiskFrom(request: RequestOption, onComplate: (ImageKnifeData: ImageKnifeData) => void | PromiseLike<ImageKnifeData>, onError: (err?: BusinessError | string) => void) {
let cache = this.memoryCache.get(request.generateCacheKey);
if (cache == null || typeof cache == 'undefined') {
let cached = this.diskMemoryCache.get(request.generateDataKey);
if (cached == null) {
//4.加载磁盘缓存 原图
cached = this.diskMemoryCache.get(request.generateResourceKey);
}
if (cached != null) {
//5.磁盘有数据解析错误返回onError
let success = (value: PixelMap) => {
let imageKnifeData = ImageKnifeData.createImagePixelMap(ImageKnifeType.PIXELMAP, value);
this.memoryCache.put(request.generateCacheKey, imageKnifeData);
onComplate(imageKnifeData);
}
this.mParseImageUtil.parseImage(cached, success, onError)
} else {
//6.磁盘无数据返回onError
onError("网络缓存and磁盘缓存无数据")
}
} else {
//需要清理状态
cache.waitSaveDisk = false;
//2.网络缓存有数据,返回
onComplate(cache);
}
}
loadResourcesCaches(request: RequestOption) {
let factories: EngineKeyInterface;
let cacheKey: string;
let transferKey: string;
let dataKey: string;
if (this.engineKeyImpl) {
factories = this.engineKeyImpl;
} else {
factories = new EngineKeyFactories();
}
// 生成内存缓存key 内存 变换后磁盘
let loadKey = '';
if (typeof request.loadSrc == 'string') {
loadKey = request.loadSrc;
} else {
loadKey = JSON.stringify(request.loadSrc);
}
let size = JSON.stringify(request.size);
let transformed = '';
if (request && request.transformations) {
for (let i = 0; i < request.transformations.length; i++) {
if (i == request.transformations.length - 1) {
transformed += request.transformations[i].getName() + "";
} else {
transformed += request.transformations[i].getName() + ",";
}
}
}
let dontAnimateFlag = request.dontAnimateFlag;
let signature = request.signature;
cacheKey = factories.generateMemoryCacheKey(loadKey, size, transformed, dontAnimateFlag, signature);
// 生成磁盘缓存变换后数据key 变换后数据保存在磁盘
transferKey = factories.generateTransformedDiskCacheKey(loadKey, size, transformed, dontAnimateFlag, signature);
// 生成磁盘缓存源数据key 原始数据保存在磁盘
dataKey = factories.generateOriginalDiskCacheKey(loadKey, signature);
request.generateCacheKey = cacheKey;
request.generateResourceKey = transferKey;
request.generateDataKey = dataKey;
return request;
}
// 预加载 resource资源一级缓存string资源实现二级缓存
preload(request: RequestOption): void {
// 每个request 公共信息补充
@ -308,6 +413,7 @@ export class ImageKnife {
return this.parseSource(request);
}
loadResources(request: RequestOption) {
let factories: EngineKeyInterface;
let cacheKey: string;
@ -344,13 +450,13 @@ export class ImageKnife {
let signature = request.signature;
cacheKey = factories.generateMemoryCacheKey(loadKey,size,transformed,dontAnimateFlag,signature);
cacheKey = factories.generateMemoryCacheKey(loadKey, size, transformed, dontAnimateFlag, signature);
// 生成磁盘缓存变换后数据key 变换后数据保存在磁盘
transferKey = factories.generateTransformedDiskCacheKey(loadKey,size,transformed,dontAnimateFlag,signature);
transferKey = factories.generateTransformedDiskCacheKey(loadKey, size, transformed, dontAnimateFlag, signature);
// 生成磁盘缓存源数据key 原始数据保存在磁盘
dataKey = factories.generateOriginalDiskCacheKey(loadKey,signature);
dataKey = factories.generateOriginalDiskCacheKey(loadKey, signature);
request.generateCacheKey = cacheKey;
request.generateResourceKey = transferKey;
@ -375,8 +481,6 @@ export class ImageKnife {
private keyEqualPendingToRun(nextPending: RequestOption) {
this.pendingMaps.remove(nextPending.uuid)
this.runningMaps.put(nextPending.uuid, nextPending);
@ -428,7 +532,7 @@ export class ImageKnife {
}
if (hasEqualRunning) {
if(tailNode != null && tailNode.value != null) {
if (tailNode != null && tailNode.value != null) {
this.keyEqualPendingToRun(tailNode.value);
}
} else {