HarmonyOS鸿蒙Next中emitter事件跨UIAbility收不到？单进程多Ability下的事件订阅生命周期踩坑

背景知识：

emitter 核心底层机制

1. emitter 分进程隔离，每个 UIAbility 是独立 ArkUI 运行上下文，默认 emitter 属于当前 Ability 实例内局部事件总线，不同 Ability（MainAbility / FloatAbility）的 emitter 实例完全隔离；A 实例 emit，B 实例 on 永远收不到，这是问题 1 收不到事件的根本原因。
2. 监听生命周期绑定 Ability 实例，emitter.on() 注册的监听句柄挂载在当前 Ability 上下文；MainAbility 被系统回收销毁后，旧实例所有监听自动销毁；新拉起的 MainAbility 虽然重新注册 on，但如果你复用旧句柄、未清理残留监听、或注册时机滞后，会出现监听失效无报错
3. 生命周期时序错位，
   • FloatAbility 点击按钮 → emit() 立即发事件
   • MainAbility aboutToAppear 是页面渲染阶段才注册监听
   • 事件发送时机 早于监听注册完成，事件无订阅者直接丢弃，第二次点击时监听已就绪才能正常接收

问题解决：

步骤 1：新建全局独立事件总线（全局单例，跨 Ability 共享）

新建 common/GlobalEventBus.ets，全局唯一实例

type EventCallback = (...args: any[]) => void;

class GlobalEventBus {
  // 存储事件名 - 回调数组
  private eventMap: Map<string, EventCallback[]> = new Map();

  // 订阅事件
  on(eventName: string, cb: EventCallback) {
    if (!this.eventMap.has(eventName)) {
      this.eventMap.set(eventName, []);
    }
    const cbs = this.eventMap.get(eventName)!;
    // 去重，防止重复注册多个相同回调
    if (!cbs.includes(cb)) {
      cbs.push(cb);
    }
  }

  // 取消订阅（销毁Ability必须调用，防止内存泄漏）
  off(eventName: string, cb: EventCallback) {
    if (!this.eventMap.has(eventName)) return;
    const cbs = this.eventMap.get(eventName)!;
    const idx = cbs.indexOf(cb);
    if (idx > -1) cbs.splice(idx, 1);
  }

  // 发送事件，支持透传参数
  emit(eventName: string, ...params: any[]) {
    if (!this.eventMap.has(eventName)) return;
    const cbs = this.eventMap.get(eventName)!;
    cbs.forEach(cb => {
      cb(...params);
    });
  }

  // 清空全部事件（可选）
  clear() {
    this.eventMap.clear();
  }
}

// 全局单例，全应用唯一总线
export const eventBus = new GlobalEventBus();

步骤 2：FloatAbility（悬浮窗）发送事件（替换原 emitter.emit）

import { eventBus } from '../common/GlobalEventBus';

// 悬浮窗按钮点击事件
function onRefreshMainClick() {
  // 发送全局事件，携带参数（如刷新标识、商品ID等）
  eventBus.emit("refresh_main_data", { needReload: true });
}

步骤 3：MainAbility 正确订阅 + 销毁监听

1. 监听注册放在 onCreate（因为Ability 生命周期，早于页面渲染 aboutToAppear，解决首条消息丢失）；
2. onDestroy 必须执行 off 取消订阅，避免重建后多回调叠加、失效；
3. 保存回调引用，用于卸载时解绑。

import UIAbility from '@ohos.app.ability.UIAbility';
import hilog from '@ohos.hilog';
import { eventBus } from '../common/GlobalEventBus';

export default class MainAbility extends UIAbility {
  // 保存回调引用，用于销毁时解绑
  private refreshCb: Function | null = null;

  onCreate(want, launchParam) {
    hilog.info(0x0001, "Main", "MainAbility onCreate，提前注册全局事件");
    // 1. 在Ability创建最早时机注册监听，解决首条事件丢失
    this.refreshCb = (payload) => {
      hilog.info(0x0001, "Main", "收到悬浮窗刷新指令", payload);
      // 执行主界面刷新逻辑
      this.refreshPageData(payload);
    };
    eventBus.on("refresh_main_data", this.refreshCb);
  }

  refreshPageData(payload) {
    // 主页面刷新数据逻辑
  }

  onDestroy() {
    // 2. Ability被系统回收销毁，解绑事件，解决重建监听失效问题
    if (this.refreshCb) {
      eventBus.off("refresh_main_data", this.refreshCb);
      this.refreshCb = null;
    }
  }
}

步骤 4：页面内配合刷新（如果刷新逻辑写在页面 ets）

如果刷新 UI 逻辑在 Entry 页面而非 Ability，用 AppStorage 传递标记触发页面更新：

// MainAbility onCreate
this.refreshCb = (payload) => {
  AppStorage.SetOrCreate<boolean>("needRefresh", true);
};

// 主页面
@StorageLink("needRefresh") needRefresh: boolean = false;

aboutToAppear() {
  if (this.needRefresh) {
    this.loadData();
    AppStorage.SetOrCreate("needRefresh", false);
  }
}