事件总线
事件总线提供了一种强大的发布-订阅机制，允许您的 blocklet 内部的不同组件，甚至不同 blocklet 之间（在同一个 ABT Node 实例内）以解耦的方式相互通信。这对于广播系统范围的状态变化或事件非常理想，而无需组件之间有直接的依赖关系。
虽然通知服务旨在向用户发送有针对性的消息，但事件总线专为内部、组件到组件的通信而设计。
工作原理#
事件总线促进了异步通信流程：
- 发布者组件发送一个带有特定名称和负载的事件。
- Blocklet SDK 将此事件发送到在 ABT Node 中运行的中央事件总线服务。
- 然后，事件总线服务将此事件广播到所有正在监听该事件类型的订阅者组件。
此过程在下图中进行了可视化：
API 参考#
publish#
向事件总线发布一个事件，使其对所有已订阅的监听器可用。这是一个异步操作。
参数#
name
string
required
事件的名称，例如 user.created 或 order.shipped。
event
object
required
包含事件详细信息的对象。
3 subfields
示例#
发布用户创建事件
import eventbus from '@blocklet/sdk/service/eventbus';
async function createUser(userData) {
// ... 在数据库中创建用户的逻辑
const newUser = { id: 'user_123', name: 'John Doe' };
try {
await eventbus.publish('user.created', {
data: {
object_type: 'User',
object_id: newUser.id,
object: newUser,
source_system: 'admin_panel',
},
});
console.log('用户创建事件发布成功。');
} catch (error) {
console.error('发布事件失败：', error);
}
return newUser;
}subscribe#
注册一个回调函数，每当从事件总线接收到事件时执行。请注意，组件不会接收到它自己发布的事件。
参数#
cb
(event: TEvent) => void
required
一个回调函数，当接收到事件时，将使用事件对象调用该函数。
事件对象结构 (TEvent)#
回调函数接收一个参数：事件对象。该对象具有基于 CloudEvents 规范的标准化结构。
id
string
required
事件实例的唯一标识符。
source
string
required
发布事件的组件的 DID。
type
string
required
事件的名称（例如 user.created）。
time
string
required
事件创建时的 ISO 8601 时间戳。
spec_version
string
required
CloudEvents 规范版本，例如 '1.0.0'。
object_type
string
事件数据中主要对象的类型（例如 User）。
object_id
string
事件数据中主要对象的 ID。
data
object
required
事件的详细负载。
3 subfields
示例#
订阅事件
import eventbus from '@blocklet/sdk/service/eventbus';
const handleEvent = (event) => {
console.log(`接收到类型为 ${event.type} 的事件`);
console.log('事件详情：', event);
if (event.type === 'user.created') {
console.log(`创建了一个新用户，ID 为：${event.object_id}`);
// 更新 UI 或执行其他操作
}
};
eventbus.subscribe(handleEvent);
console.log('正在监听来自事件总线的事件...');unsubscribe#
移除先前注册的事件监听器。在组件卸载或不再需要监听事件时调用此函数至关重要，以防止内存泄漏。
参数#
cb
(event: TEvent) => void
required
传递给 subscribe 的完全相同的回调函数引用。
示例#
要正确取消订阅，您必须保留对原始回调函数的引用。
完整的订阅生命周期
import eventbus from '@blocklet/sdk/service/eventbus';
// 1. 定义处理函数
const onUserEvent = (event) => {
console.log(`接收到用户事件：${event.type}`);
};
// 2. 订阅事件总线
eventbus.subscribe(onUserEvent);
console.log('已订阅用户事件。');
// ... 在应用程序生命周期的后期（例如，组件卸载时）
// 3. 使用相同的函数引用取消订阅
eventbus.unsubscribe(onUserEvent);
console.log('已取消订阅用户事件。');