flutter開發實戰-log日志存儲zip上傳，發送釘釘機器人消息
當我們需要Apk上傳的時候，我們需要將日志打包并上傳到七牛，上傳之后通過釘釘通知我們日志下載地址。
這里我使用的是loggy來處理日志
一、引入loggy日志格式插件
在工程的pubspec.yaml中引入插件
loggy: ^2.0.2使用loggy，當引入loggy后，可以在main方法中進行初始化
import 'package:loggy/loggy.dart';main() {Loggy.initLoggy();
}之后在需要的地方進行輸入相關日志
import 'package:loggy/loggy.dart';class DoSomeWork {DoSomeWork() {logDebug('This is debug message');logInfo('This is info message');logWarning('This is warning message');logError('This is error message');}
}二、日志存儲到本地
查看loggy源碼看到，日志沒有存儲到本地，在日志的目錄下可以看到printers目錄，LoggyPrinter為printer的抽象類
part of loggy;/// Printer used to show logs, this can be easily swapped or replaced
abstract class LoggyPrinter {const LoggyPrinter();void onLog(LogRecord record);
}當然我們需要通過繼承該類來實現將日志內容寫入到本地文件中，這時候我們定義了一個FilePrinter，實現onLog方法將日志寫入文件中。
- 創建日志File
我們需要指定log日志所在目錄，可以使用path_provider來獲取document、tmp等目錄。
Future<String> createDirectory(String appTAG) async {final Directory directory = await getApplicationDocumentsDirectory();var file = Directory("${directory.path}/$appTAG");try {bool exist = await file.exists();if (exist == false) {await file.create();}} catch (e) {print("createDirectory error");}return file.path;
}創建日志File
Future<void> getDirectoryForLogRecord() async {String currentDay = getCurrentDay();if (currentDay != _currentDate) {final String fileDir = await createDirectory(this.appTAG);file = File('$fileDir/$currentDay.log');_sink = file!.openWrite(mode: overrideExisting ? FileMode.writeOnly : FileMode.writeOnlyAppend,encoding: encoding,);_currentDate = currentDay;}}- 處理日志跨天的情況
每一天的日志對應一個date.log文件，如20240101.log
如果出現正好跨天的情況下，需要生成新的File來處理。這里定義了一個定時器，10分鐘檢測一次，如果日期不一致，則重新創建File
// 定時器void startTimer() {timerDispose();_timer = Timer.periodic(dateCheckDuration!, (timer) {getDirectoryForLogRecord();});}void timerDispose() {_timer?.cancel();_timer = null;}- IOSink寫入文件
寫入文件，我們需要用到IOSink，
寫入的文件file調用openWrite即可獲得IOSink對象。
openWrite方法如下
IOSink openWrite({FileMode mode: FileMode.write, Encoding encoding: utf8});默認情況下寫入是會覆蓋整個文件的，但是可以通過下面的方式來更改寫入模式
IOSink ioSink = logFile.openWrite(mode: FileMode.append);IOSink寫入文件流程如下
var logFile = File('log.txt');
var sink = logFile.openWrite();
sink.write('FILE ACCESSED ${DateTime.now()}\n');
await sink.flush();
await sink.close();通過onLog方法輸入的record
@overridevoid onLog(LogRecord record) async {_sink?.writeln('${record.time} [${record.level.toString().substring(0, 1)}] ${record.loggerName}: ${record.message}');}通過sink將文件保存到文件中。
完整的FilePrinter如下
import 'dart:async';
import 'dart:convert';
import 'dart:io';import 'package:loggy/loggy.dart';
import 'package:path_provider/path_provider.dart';
import 'package:common_utils/common_utils.dart';Future<String?> getDirectory(String appTAG) async {final Directory directory = await getApplicationDocumentsDirectory();var file = Directory("${directory.path}/$appTAG");try {bool exist = await file.exists();if (exist == true) {return file.path;}} catch (e) {print("createDirectory error");}return null;
}Future<String> createDirectory(String appTAG) async {final Directory directory = await getApplicationDocumentsDirectory();var file = Directory("${directory.path}/$appTAG");try {bool exist = await file.exists();if (exist == false) {await file.create();}} catch (e) {print("createDirectory error");}return file.path;
}// 輸出的文本文件, 開啟定時器處理跨天的log存儲問題
class FilePrinter extends LoggyPrinter {final bool overrideExisting;final Encoding encoding;final String appTAG;// 檢查日期時長，可能出現跨天的情況，比如十分鐘檢測一次，Duration? dateCheckDuration;IOSink? _sink;File? file;String? _currentDate;// 定時器Timer? _timer;FilePrinter(this.appTAG, {this.overrideExisting = false,this.encoding = utf8,this.dateCheckDuration = const Duration(minutes: 10),}) {directoryLogRecord(onCallback: () {// 開啟定時器startTimer();});}void directoryLogRecord({required Function onCallback}) {getDirectoryForLogRecord().whenComplete(() {onCallback();});}Future<void> getDirectoryForLogRecord() async {String currentDay = getCurrentDay();if (currentDay != _currentDate) {final String fileDir = await createDirectory(this.appTAG);file = File('$fileDir/$currentDay.log');_sink = file!.openWrite(mode: overrideExisting ? FileMode.writeOnly : FileMode.writeOnlyAppend,encoding: encoding,);_currentDate = currentDay;}}String getCurrentDay() {String currentDate =DateUtil.formatDate(DateTime.now(), format: "yyyyMMdd");return currentDate;}// 文件刪除后重新設置logFuture<void> resetLogFile() async {_currentDate = null;getDirectoryForLogRecord();}@overridevoid onLog(LogRecord record) async {_sink?.writeln('${record.time} [${record.level.toString().substring(0, 1)}] ${record.loggerName}: ${record.message}');}dispose() {timerDispose();}// 定時器void startTimer() {timerDispose();_timer = Timer.periodic(dateCheckDuration!, (timer) {getDirectoryForLogRecord();});}void timerDispose() {_timer?.cancel();_timer = null;}
}// 輸出到ConsolePrinter
class ConsolePrinter extends LoggyPrinter {const ConsolePrinter() : super();@overridevoid onLog(LogRecord record) {print('${record.time} [${record.level.toString().substring(0, 1)}] ${record.loggerName}: ${record.message}');}
}// 多種同時使用的printer
class MultiPrinter extends LoggyPrinter {MultiPrinter({required this.consolePrinter,required this.filePrinter,});final LoggyPrinter consolePrinter;final LoggyPrinter filePrinter;@overridevoid onLog(LogRecord record) {consolePrinter.onLog(record);filePrinter.onLog(record);}
}三、日志log壓縮成zip
將日志log壓縮成zip，打包成zip時候，我們需要用到archive插件
在工程的pubspec.yaml中引入插件
archive: ^3.3.7archive是一個Dart庫，用于對各種存檔和壓縮格式進行編碼和解碼。
該archive使用示例如下
import 'dart:io';
import 'package:archive/archive_io.dart';Future<void> main() async {// Read the Zip file from disk.final bytes = File('test.zip').readAsBytesSync();// Decode the Zip filefinal archive = ZipDecoder().decodeBytes(bytes);// Extract the contents of the Zip archive to disk.for (final file in archive) {final filename = file.name;if (file.isFile) {final data = file.content as List<int>;File('out/$filename')..createSync(recursive: true)..writeAsBytesSync(data);} else {Directory('out/$filename').createSync(recursive: true);}}// Encode the archive as a BZip2 compressed Tar file.final tarData = TarEncoder().encode(archive);final tarBz2 = BZip2Encoder().encode(tarData);// Write the compressed tar file to disk.final fp = File('test.tbz');fp.writeAsBytesSync(tarBz2);// Zip a directory to out.zip using the zipDirectory convenience methodvar encoder = ZipFileEncoder();await encoder.zipDirectoryAsync(Directory('out'), filename: 'out.zip');// Manually create a zip of a directory and individual files.encoder.create('out2.zip');await encoder.addDirectory(Directory('out'));await encoder.addFile(File('test.zip'));encoder.closeSync();
}
壓縮log，我這里創建一個log_archive類
- 首先創建zip目錄
Future<String?> getZipDir() async {final Directory directory = await getApplicationDocumentsDirectory();var file = Directory("${directory.path}/zip");try {bool exist = await file.exists();if (exist == false) {await file.create();}} catch (e) {print("createDirectory error");}return file.path;
}Future<void> setZipPath({String? zipName}) async {if (!(zipName != null && zipName.isNotEmpty)) {String currentTime =DateUtil.formatDate(DateTime.now(), format: "yyyy_MM_dd_HH_mm_ss");zipName = "$currentTime.zip";}if (!zipName.endsWith(".zip")) {zipName = "$zipName.zip";}String? zipDir = await getZipDir();if (zipDir != null && zipDir.isNotEmpty) {String zipPath = "${zipDir}/${zipName}";this.zipPath = zipPath;}}- 創建zip文件
創建zip文件，需要用到ZipFileEncoder，如果有同名的zip文件，則刪除后重新生成新的zip文件
Future<void> createZip() async {if (!(zipPath != null && zipPath!.isNotEmpty)) {return;}bool fileExists = await checkFileExists();if (fileExists == true) {// 文件存在// 刪除后重新創建File file = File(zipPath!);await file.delete();}// zip文件重新生成zipFileEncoder.open(zipPath!);}- 添加File文件
zipFileEncoder生成zip后，添加File問價
Future<void> addFile(File file) async {bool fileExists = await checkFileExists();if (fileExists) {await zipFileEncoder.addFile(file);await close();}}- 最后調用close
zipFileEncoder添加File后，需要結束編碼并關閉
Future<void> close() async {zipFileEncoder.close();}log_archive完整代碼如下
import 'dart:convert';
import 'dart:io';
import 'package:archive/archive.dart';
import 'package:archive/archive_io.dart';
import 'package:common_utils/common_utils.dart';
import 'package:path_provider/path_provider.dart';Future<String?> getZipDir() async {final Directory directory = await getApplicationDocumentsDirectory();var file = Directory("${directory.path}/zip");try {bool exist = await file.exists();if (exist == false) {await file.create();}} catch (e) {print("createDirectory error");}return file.path;
}// archive
class LogArchive {String? zipPath;late ZipFileEncoder zipFileEncoder;LogArchive() {zipFileEncoder = ZipFileEncoder();}Future<void> setZipPath({String? zipName}) async {if (!(zipName != null && zipName.isNotEmpty)) {String currentTime =DateUtil.formatDate(DateTime.now(), format: "yyyy_MM_dd_HH_mm_ss");zipName = "$currentTime.zip";}if (!zipName.endsWith(".zip")) {zipName = "$zipName.zip";}String? zipDir = await getZipDir();if (zipDir != null && zipDir.isNotEmpty) {String zipPath = "${zipDir}/${zipName}";this.zipPath = zipPath;}}Future<void> createZip() async {if (!(zipPath != null && zipPath!.isNotEmpty)) {return;}bool fileExists = await checkFileExists();if (fileExists == true) {// 文件存在// 刪除后重新創建File file = File(zipPath!);await file.delete();}// zip文件重新生成zipFileEncoder.open(zipPath!);}Future<void> addFile(File file) async {bool fileExists = await checkFileExists();if (fileExists) {await zipFileEncoder.addFile(file);await close();}}Future<void> addFiles(List<File> files) async {bool fileExists = await checkFileExists();if (fileExists) {for (File file in files) {await zipFileEncoder.addFile(file);}await close();}}Future<void> close() async {zipFileEncoder.close();}Future<bool> checkFileExists() async {if (!(zipPath != null && zipPath!.isNotEmpty)) {return false;}try {File file = File(zipPath!);bool exist = await file.exists();if (exist == true) {return true;}} catch (e) {print("checkFileExists error");}return false;}// 刪除單個zip文件Future<void> zipDelete(String aZipPath) async {if (aZipPath.isEmpty) {return;}final File file = File(aZipPath);bool exist = await file.exists();if (exist == false) {print("LogArchive 文件不存在");return;}await file.delete();}// 清空zip目錄Future<void> zipClean() async {String? zipDir = await getZipDir();if (zipDir != null && zipDir.isNotEmpty) {var dir = Directory(zipDir);await dir.delete(recursive: true);}}Future<void> readZip(String zipDir) async {if (!(zipPath != null && zipPath!.isNotEmpty)) {return;}// Read the Zip file from disk.final File file = File(zipPath!);bool exist = await file.exists();if (exist == false) {print("LogArchive 文件不存在");return;}try {// InputFileStream only uses a cache buffer memory (4k by default), not the entire filevar stream = InputFileStream(zipPath!);// The archive will have the memory of the compressed archive. ArchiveFile's are decompressed on// demandvar zip = ZipDecoder().decodeBuffer(stream);for (var file in zip.files) {final filename = file.name;if (file.isFile) {final data = file.content as List<int>;final logFile = await File('${zipDir}/out/$filename')..create(recursive: true)..writeAsBytesSync(data);String logContent = await logFile.readAsString(encoding: utf8);print("readZip logContent:${logContent}");} else {await Directory('${zipDir}/out/' + filename).create(recursive: true);}// file.clear() will release the file's compressed memoryfile.clear();}} catch(e) {print("readZip e:${e.toString()}");}}
}四、上傳到七牛
文件上傳的到七牛，需要用到七牛的qiniu_flutter_sdk插件
在工程的pubspec.yaml中引入插件
qiniu_flutter_sdk: ^0.5.0通過使用該插件上傳示例
// 創建 storage 對象storage = Storage();// 創建 Controller 對象putController = PutController();// 使用 storage 的 putFile 對象進行文件上傳storage.putFile(File('./file.txt'), 'TOKEN', PutOptions(controller: putController,))- 七牛token獲取
我這邊使用定義個log_uploader類，由于七牛上傳需要token，token需要從服務端獲取，所以定義個一個抽象類LogTokenFetch
可以實現一個類來實現getToken。
// 定義獲取token接口
abstract class LogTokenFetch {Future<String> getToken();
}// 下面是示例, 請勿使用
class LogTokenFetchImpl implements LogTokenFetch {@overrideFuture<String> getToken() {// TODO: implement getTokenreturn Future.value('');}
}- 文件上傳到七牛
我這邊使用定義個log_uploader類，本質上還是套用qiniu_flutter_sdk插件的實現。
import 'dart:convert';
import 'dart:io';import 'package:qiniu_flutter_sdk/qiniu_flutter_sdk.dart';
import 'package:crypto/crypto.dart';import 'log_token_fetch.dart';// logUploader
class LogUploader {// 創建 storage 對象final Storage storage = Storage();final PutController putController = PutController();LogTokenFetch? tokenFetch;LogUploader(this.tokenFetch) {init();}init() {// 添加狀態監聽putController.addStatusListener((StorageStatus status) {print('LogUploader status：$status');});}Future<String?> uploadFile(File zipFile, {String? customKey}) async {if (tokenFetch != null) {String? token = await tokenFetch!.getToken();if (token != null && token.isNotEmpty) {print("token:${token}");String key = customKey??md5.convert(utf8.encode(zipFile.path)).toString();PutResponse putResponse = await storage.putFile(zipFile, token, options: PutOptions(key: key,controller: putController,));return putResponse.key;} else {return null;}} else {return null;}}
}上傳七牛過程中，可能會出現一下錯誤
StorageError [StorageErrorType.RESPONSE, 403]: {error: limited mimeType: this file type (application/octet-stream) is forbidden to upload}
當然需要確認token是否支持了對應的mimeType類型。
五、發送消息到釘釘機器人
經常會遇到釘釘的機器人消息，我們也可以調用其api實現發送消息。
請查考網址：https://open.dingtalk.com/document/orgapp/custom-robots-send-group-messages
這里使用的是插件dingtalk_bot_sender插件，當然dingtalk_bot_sender源碼也是http請求實現了發送消息到釘釘機器人的API接口。
在工程的pubspec.yaml中引入插件
dingtalk_bot_sender: ^1.2.0發送消息，使用的是DingTalkSender，我們可以發送markdown、url、文本等等
使用示例如下
final sender = DingTalkSender(hookUrl: hookUrl,keyword: keyword,appsecret: appsecret,);await sender.sendText('1');final markdown = '''
markdown內容''';await sender.sendMarkdown(markdown);我這邊發送的是日志鏈接地址
final sender = DingTalkSender(hookUrl: hookUrl,keyword: keyword,appsecret: appsecret,);await sender.sendLink(title: "app日志", text: "下載地址：${url}", messageUrl: url);
到此，flutter開發實戰-log日志存儲zip上傳，發送釘釘機器人消息完成。
六、小結
flutter開發實戰-log日志存儲zip上傳，發送釘釘機器人消息。
學習記錄，每天不停進步。
本文地址：https://brucegwo.blog.csdn.net/article/details/138672565
兩款小游戲
| 戰機長空 | 小繩套牛 |
|---|---|
 |  |
![[ECE] SRAM DRAM](http://pic.xiahunao.cn/[ECE] SRAM DRAM)
)
 帶來的安全風險？)
