Ionic中Cordova FirebaseX插件通知自动清除实现报错求助

你遇到的InterruptedException错误，本质是因为TimeUnit.SECONDS.sleep()属于检查型异常，Java要求必须显式捕获或者在方法签名里声明抛出。但更关键的是：直接在onMessageReceived里调用sleep会阻塞当前消息处理线程，严重影响Firebase消息处理性能，甚至可能触发应用无响应（ANR），这种做法绝对不可取。

下面给你两种安全且正确的实现方案，解决定时清除通知的需求：

方案一：使用Android Handler（推荐，适合轻量定时任务） #

Handler是Android原生的延迟任务工具，依赖主线程消息队列，不会阻塞当前业务线程。

步骤1：确保导入正确的类 #

在FirebasePlugin.java顶部添加以下导入：

import android.os.Handler;
import android.os.Looper;
import android.content.Context;
import android.app.NotificationManager;

步骤2：修改onMessageReceived方法 #

替换你原来的sleep代码，改用postDelayed实现延迟清除：

private void onMessageReceived(final CallbackContext callbackContext) {
    FirebasePlugin.notificationCallbackContext = callbackContext;
    if (FirebasePlugin.notificationStack != null) {
        for (Bundle bundle : FirebasePlugin.notificationStack) {
            FirebasePlugin.sendMessage(bundle, applicationContext);
        }
        FirebasePlugin.notificationStack.clear();
    }

    // 延迟60秒执行清除操作（单位：毫秒）
    new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
        @Override
        public void run() {
            // 用Cordova线程池执行系统服务操作，避免阻塞主线程
            cordova.getThreadPool().execute(new Runnable() {
                public void run() {
                    try {
                        NotificationManager nm = (NotificationManager) applicationContext.getSystemService(Context.NOTIFICATION_SERVICE);
                        nm.cancelAll(); // 清除所有通知
                        // 注意：callbackContext是当前消息的回调，一分钟后可能已失效，建议不要调用success()
                    } catch (Exception e) {
                        handleExceptionWithContext(e, callbackContext);
                    }
                }
            });
        }
    }, 60 * 1000);
}

方案二：使用ScheduledExecutorService（适合复杂定时场景） #

如果需要更灵活的定时任务管理（比如批量任务、重复任务），可以用Java的ScheduledExecutorService。

步骤1：声明全局调度器 #

在FirebasePlugin类中添加全局变量：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

// 单线程调度器，避免多线程冲突
private static ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

步骤2：修改onMessageReceived方法 #

private void onMessageReceived(final CallbackContext callbackContext) {
    FirebasePlugin.notificationCallbackContext = callbackContext;
    if (FirebasePlugin.notificationStack != null) {
        for (Bundle bundle : FirebasePlugin.notificationStack) {
            FirebasePlugin.sendMessage(bundle, applicationContext);
        }
        FirebasePlugin.notificationStack.clear();
    }

    // 延迟60秒执行清除任务
    scheduler.schedule(new Runnable() {
        @Override
        public void run() {
            try {
                NotificationManager nm = (NotificationManager) applicationContext.getSystemService(Context.NOTIFICATION_SERVICE);
                nm.cancelAll();
            } catch (Exception e) {
                handleExceptionWithContext(e, callbackContext);
            }
        }
    }, 60, TimeUnit.SECONDS);
}

步骤3：避免内存泄漏 #

在插件销毁时关闭调度器，添加以下方法：

@Override
public void onDestroy() {
    super.onDestroy();
    if (scheduler != null && !scheduler.isShutdown()) {
        scheduler.shutdown();
    }
}

额外注意事项 #

1. 清除单个通知而非全部：如果不想清除所有通知，只清除当前收到的这条，可以在sendMessage方法中获取通知的ID（FirebaseX会自动生成），存储后用nm.cancel(notificationId)替代nm.cancelAll()。
2. 进程存活问题：如果应用在后台被系统杀死，上述两种方案的延迟任务都会失效。如果需要进程被杀后仍能执行，需要结合AlarmManager或WorkManager实现，但复杂度会更高。
3. 回调有效性：callbackContext是当前消息的回调实例，一分钟后大概率已失效，不要在延迟任务中调用callbackContext.success()，避免出现错误。

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