Android接收通知时运行无头Dart/Flutter回调及后台引擎创建方案

核心思路 #

WorkManager的Worker默认运行在后台线程，而FlutterEngine必须在主线程初始化，所以第一步是切换到主线程执行引擎创建逻辑；之后通过MethodChannel或Dart入口参数将通知数据传递给Flutter侧，处理完成后及时销毁引擎避免资源浪费。

1. Android端Worker实现（Kotlin示例） #

在自定义Worker中，通过Handler切换到主线程初始化FlutterEngine，并传递通知数据：

import android.content.Context
import android.os.Handler
import android.os.Looper
import androidx.work.Worker
import androidx.work.WorkerParameters
import io.flutter.embedding.engine.FlutterEngine
import io.flutter.embedding.engine.FlutterEngineCache
import io.flutter.embedding.engine.dart.DartExecutor
import io.flutter.plugin.common.MethodChannel

class NotificationProcessingWorker(context: Context, params: WorkerParameters) : Worker(context, params) {
    private val CHANNEL_NAME = "com.your.app/notification_handler"
    private val ENGINE_ID = "notification_engine"

    override fun doWork(): Result {
        // 从WorkManager参数中获取通知数据
        val notificationData = inputData.getString("notification_data") ?: return Result.failure()

        // 切换到主线程初始化FlutterEngine
        Handler(Looper.getMainLooper()).post {
            val flutterEngine = FlutterEngine(applicationContext)
            
            // 缓存引擎（可选，用于复用）
            FlutterEngineCache.getInstance().put(ENGINE_ID, flutterEngine)

            // 初始化Dart入口，传递启动参数
            val dartEntrypoint = DartExecutor.DartEntrypoint.createDefault()
            flutterEngine.dartExecutor.executeDartEntrypoint(dartEntrypoint, listOf(notificationData))

            // 通过MethodChannel动态传递通知数据
            val channel = MethodChannel(flutterEngine.dartExecutor.binaryMessenger, CHANNEL_NAME)
            channel.invokeMethod("processNotification", notificationData)

            // 监听Flutter侧处理完成信号，销毁引擎
            channel.setMethodCallHandler { call, result ->
                if (call.method == "processingComplete") {
                    flutterEngine.destroy()
                    FlutterEngineCache.getInstance().remove(ENGINE_ID)
                    result.success(null)
                }
            }
        }

        return Result.success()
    }
}

2. Flutter侧处理逻辑 #

在Flutter的main函数中，同时处理启动参数和MethodChannel传递的数据：

import 'package:flutter/services.dart';

void main(List<String> args) {
  // 处理启动时直接传递的通知参数
  if (args.isNotEmpty) {
    _processNotification(args.first);
  }

  runApp(const MyApp());

  // 初始化MethodChannel监听动态传递的数据
  const channel = MethodChannel('com.your.app/notification_handler');
  channel.setMethodCallHandler((call) async {
    if (call.method == 'processNotification') {
      final data = call.arguments as String;
      await _processNotification(data);
      // 通知Android侧处理完成，触发引擎销毁
      channel.invokeMethod('processingComplete');
    }
  });
}

Future<void> _processNotification(String data) async {
  // 这里编写你的通知处理逻辑：解析数据、触发业务操作、本地存储等
  print('处理通知数据: $data');
}

关键注意事项 #

• 资源释放：FlutterEngine内存占用较高，处理完逻辑后必须调用destroy()销毁，避免内存泄漏。
• 任务时间限制：WorkManager单次任务执行时间有限（通常10分钟内），确保通知处理逻辑为轻量级操作。
• 引擎复用：若后台任务频繁触发，可使用FlutterEngineGroup创建共享引擎实例，减少初始化开销。
• 权限配置：确保AndroidManifest中配置WorkManager权限，以及通知监听相关权限（如POST_NOTIFICATIONS、ACCESS_NOTIFICATION_POLICY）。

内容的提问来源于stack exchange，提问作者Dmytro Popov