🚀 Global Event Bus - 全局事件总线 #

一个高性能、类型安全的 Flutter 全局事件分发系统，用于在应用程序的不同模块之间进行解耦通信。采用观察者模式和流式处理架构，支持事件优先级、批量处理、延迟发送、统计监控等高级功能。

✨ 核心特性 #

🔒 类型安全 #

基于泛型的类型安全事件系统
编译时类型检查，避免运行时错误
自动类型推断，提升开发体验

⚡ 高性能 #

基于 Dart Stream 的高效事件分发
支持批量处理模式，优化高频事件场景
内置事件统计和性能监控

🎯 事件优先级 #

四级优先级系统：critical、high、normal、low
高优先级事件优先处理
适用于不同业务场景的事件分级

📊 完善的日志系统 #

多级别日志配置（debug、info、warning、error、none）
可配置的日志输出格式
支持自定义日志处理器
事件类型和监听器过滤

🔧 灵活的监听方式 #

类型监听：只监听特定类型的事件
一次性监听：监听一次后自动移除
多类型监听：同时监听多种事件类型
延迟发送：支持延迟指定时间后发送事件

📈 统计监控 #

实时事件统计
发送/接收计数
事件类型分布统计
性能监控数据

🏗️ 核心架构 #

┌───────────────────────────────────────┐
│ Global Event Bus                      │
├───────────────────────────────────────┤
│ GlobalEventManager (单例事件管理器)     │
│ ├── 事件发送与分发                      │
│ ├── 监听器管理                         │
│ ├── 批量处理                           │
│ └── 统计监控                           │
├───────────────────────────────────────┤
│ BaseGlobalEvent (事件基类)             │
│ ├── 事件类型标识                        │
│ ├── 时间戳                             │
│ ├── 优先级                             │
│ └── 元数据                             │
├───────────────────────────────────────┤
│ GlobalEvent(泛型事件类)                 │
│ └── 类型安全的数据传递                   │
├───────────────────────────────────────┤
│ GlobalEventLogger (日志系统)           │
│ ├── 多级别日志                         │
│ ├── 可配置输出格式                      │
│ └── 自定义处理器                        │
└───────────────────────────────────────┘

📦 安装 #

在 pubspec.yaml 文件中添加依赖：

dependencies:
  global_event_bus: <latest_version>

然后运行：

flutter pub get

🚀 快速开始 #

1. 导入包 #

import 'package:global_event_bus/global_event_bus.dart';

2. 配置日志（可选） #

void main() {
  // 配置全局事件总线日志
  globalEventBus.configureLogging(
    const GlobalEventLogConfig(
      level: EventLogLevel.debug,
      showEventData: true,
      showEventId: true,
      showListenerInfo: true,
    ),
  );
  
  runApp(MyApp());
}

3. 发送事件 #

// 发送简单事件
sendGlobalEvent<String>(
  type: 'user_message',
  data: 'Hello, World!',
);

// 发送带优先级的事件
sendGlobalEvent<Map<String, dynamic>>(
  type: 'user_login',
  data: {
    'userId': '12345',
    'username': 'john_doe',
    'loginTime': DateTime.now().toIso8601String(),
  },
  priority: EventPriority.high,
);

// 延迟发送事件
sendGlobalEventDelayed<String>(
  type: 'delayed_notification',
  data: '这是一个延迟消息',
  delayMs: 3000, // 3秒后发送
);

4. 监听事件 #

class MyWidget extends StatefulWidget {
  @override
  _MyWidgetState createState() => _MyWidgetState();
}

class _MyWidgetState extends State<MyWidget> {
  late StreamSubscription _subscription;
  
  @override
  void initState() {
    super.initState();
    
    // 监听特定类型的事件
    _subscription = listenGlobalEvent<String>(
      listenerId: 'my_widget_listener',
      onEvent: (event) {
        print('收到事件: ${event.type}, 数据: ${event.data}');
        // 处理事件数据
        setState(() {
          // 更新UI
        });
      },
    );
  }
  
  @override
  void dispose() {
    _subscription.cancel(); // 取消订阅
    super.dispose();
  }
}

📚 详细使用指南 #

事件优先级事件优先级决定了事件的处理顺序，共有四个级别：

enum EventPriority {
  low(0),      // 低优先级 - 日志、统计等后台任务
  normal(1),   // 普通优先级 - 默认级别，一般业务事件
  high(2),     // 高优先级 - 用户交互、UI更新等
  critical(3); // 关键优先级 - 系统级重要事件
}

// 使用示例
sendGlobalEvent(
  type: 'emergency_logout',
  data: 'Session expired',
  priority: EventPriority.critical,
);

批量处理模式在高频事件场景下，启用批量模式可以显著提升性能：

// 启用批量模式，每50毫秒处理一批事件
globalEventBus.manager.setBatchMode(true, intervalMs: 50);

// 发送大量事件
for (int i = 0; i < 1000; i++) {
  sendGlobalEvent<int>(
    type: 'batch_event',
    data: i,
  );
}

// 关闭批量模式
globalEventBus.manager.setBatchMode(false);

多种监听方式一次性监听

// 只监听一次，收到事件后自动移除监听器
globalEventBus.manager.addOnceListener<String>(
  listenerId: 'splash_page',
  onEvent: (event) {
    print('应用初始化完成');
    // 跳转到主页面
  },
);

多类型监听

// 同时监听多种事件类型
listenGlobalEvent(
  listenerId: 'notification_handler',
  eventTypes: ['user_login', 'user_logout', 'message_received'],
  onEvent: (event) {
    switch (event.type) {
      case 'user_login':
        handleUserLogin(event);
        break;
      case 'user_logout':
        handleUserLogout(event);
        break;
      case 'message_received':
        handleMessage(event);
        break;
    }
  },
);

条件监听

// 带条件的事件监听
listenGlobalEvent<Map<String, dynamic>>(
  listenerId: 'admin_listener',
  onEvent: (event) {
    // 只处理管理员相关的事件
    if (event.data['userRole'] == 'admin') {
      handleAdminEvent(event);
    }
  },
);

日志配置预设配置


// 开发环境 - 详细日志
enableDebugLogging();

// 生产环境 - 只记录错误
enableProductionLogging();

// 关闭所有日志
disableLogging();

自定义配置

// 详细的自定义日志配置
configureGlobalEventLogging(GlobalEventLogConfig(
  level: EventLogLevel.info,           // 日志级别
  enabled: true,                       // 启用日志
  showTimestamp: true,                 // 显示时间戳
  showEventId: false,                  // 不显示事件ID
  showPriority: true,                  // 显示优先级
  showEventData: false,                // 不显示事件数据（生产环境推荐）
  showListenerInfo: true,              // 显示监听器信息
  logPrefix: '[MyApp-Events]',         // 自定义日志前缀
  eventTypeFilter: ['user_action', 'api_call'], // 只记录特定类型的事件
  customLogger: (message) {            // 自定义日志处理器
    // 可以将日志写入文件或发送到服务器
    print('Custom: $message');
  },
));

性能监控

// 获取事件统计信息
final stats = globalEventBus.manager.stats;

print('总发送事件数: ${stats.totalEventsSent}');
print('总接收事件数: ${stats.totalEventsReceived}');
print('最后事件时间: ${stats.lastEventTime}');

// 查看各类型事件的发送次数
stats.eventTypeCount.forEach((type, count) {
  print('事件类型 $type: $count 次');
});

批量发送事件

// 批量发送多个事件
final events = [
  GlobalEvent<String>(type: 'event1', data: 'data1'),
  GlobalEvent<int>(type: 'event2', data: 42),
  GlobalEvent<bool>(type: 'event3', data: true),
];

sendGlobalEventBatch(events);

🎯 实际应用场景

用户状态管理

// 用户登录
sendGlobalEvent<UserInfo>(
  type: 'user_login',
  data: UserInfo(id: '123', name: 'John', email: 'john@example.com'),
  priority: EventPriority.high,
);

// 监听用户状态变化, 并在登录后立即更新用户界面
listenGlobalEvent<UserInfo>(
  listenerId: 'user_profile_page',
  onEvent: (event) {
    // 更新用户界面
    updateUserProfile(event.data);
  },
  // 如果其他地方没有 [UserInfo] 的监听, 则不需要传`eventTypes`参数
  // eventTypes: ['user_login'],
);

购物车管理

// 添加商品到购物车
sendGlobalEvent<CartItem>(
  type: 'cart_add_item',
  data: CartItem(
    productId: 'p001',
    productName: 'iPhone 15',
    price: 999.99,
    quantity: 1,
  ),
);

// 监听购物车变化
listenGlobalEvent<CartItem>(
  listenerId: 'cart_badge',
  eventTypes: ['cart_add_item', 'cart_remove_item', 'cart_update_quantity'],
  onEvent: (event) {
    // 更新购物车徽章
    updateCartBadge();
  },
);

网络状态监控

// 网络状态变化
sendGlobalEvent<bool>(
  type: 'network_status_changed',
  data: isConnected,
  priority: EventPriority.critical,
);

// 全局网络状态监听
listenGlobalEvent<bool>(
  listenerId: 'global_network_monitor',
  onEvent: (event) {
    if (event.data) {
      showSnackBar('网络已连接');
    } else {
      showSnackBar('网络已断开');
    }
  },
  eventTypes: ['network_status_changed'],
);

主题切换

// 切换主题
sendGlobalEvent<ThemeMode>(
  type: 'theme_changed',
  data: ThemeMode.dark,
);

// 监听主题变化
listenGlobalEvent<ThemeMode>(
  listenerId: 'main_app',
  onEvent: (event) {
    // 更新应用主题
    updateAppTheme(event.data);
  },
  eventTypes: ['theme_changed'],
);

🔧 高级功能事件拦截器

// 添加事件拦截器（即将推出）
globalEventBus.manager.addInterceptor((event) {
  // 在事件发送前进行处理
  if (event.type.startsWith('sensitive_')) {
    // 敏感事件需要权限检查
    if (!hasPermission()) {
      return null; // 阻止事件发送
    }
  }
  return event; // 允许事件发送
});

事件持久化

// 启用事件持久化（即将推出）
globalEventBus.manager.enablePersistence(
  storage: SharedPreferencesStorage(),
  eventTypes: ['user_preferences', 'app_settings'],
);

🧪 测试支持

// 在测试中使用
void main() {
  group('Global Event Bus Tests', () {
    setUp(() {
      // 重置事件总线状态
      globalEventBus.manager.reset();
    });

    test('should send and receive events', () async {
      String? receivedData;

      // 设置监听器
      final subscription = listenGlobalEvent<String>(
        listenerId: 'test_listener',
        onEvent: (event) {
          receivedData = event.data;
        },
      );

      // 发送事件
      sendGlobalEvent<String>(
        type: 'test_event',
        data: 'test_data',
      );

      // 等待事件处理
      await Future.delayed(Duration(milliseconds: 10));

      // 验证结果
      expect(receivedData, equals('test_data'));

      // 清理
      subscription.cancel();
    });
  });
}

📊 性能建议

合理使用事件优先级系统关键事件使用 critical 优先级用户交互事件使用 high 优先级一般业务事件使用 normal 优先级日志统计事件使用 low 优先级
高频事件优化对于高频事件（如滚动、动画），启用批量处理模式合理设置批量处理间隔时间避免在事件处理中执行耗时操作
内存管理及时取消不需要的事件监听器在 Widget dispose 时取消订阅避免创建过多的监听器
日志配置生产环境关闭详细日志使用事件类型过滤减少日志量考虑使用自定义日志处理器 🤝 贡献指南我们欢迎所有形式的贡献！请查看 CONTRIBUTING.md 了解详细信息。

开发环境设置

# 克隆仓库
git clone https://github.com/pei-duo/global_event_bus.git
# 进入项目目录
cd global_event_bus
# 安装依赖
flutter pub get
# 运行示例
cd exampleflutter run
# 运行测试
flutter test

📄 许可证本项目采用 MIT 许可证。

🔗 相关链接

global_event_bus 0.0.1
global_event_bus: ^0.0.1 copied to clipboard

Metadata

🚀 Global Event Bus - 全局事件总线 #

✨ 核心特性 #

🔒 类型安全 #

⚡ 高性能 #

🎯 事件优先级 #

📊 完善的日志系统 #

🔧 灵活的监听方式 #

📈 统计监控 #

🏗️ 核心架构 #

📦 安装 #

🚀 快速开始 #

1. 导入包 #

2. 配置日志（可选） #

3. 发送事件 #

4. 监听事件 #

📚 详细使用指南 #

← Metadata

Publisher

Weekly Downloads

Metadata

License

Dependencies

More

global_event_bus 0.0.1 global_event_bus: ^0.0.1 copied to clipboard

Metadata

🚀 Global Event Bus - 全局事件总线 #

✨ 核心特性 #

🔒 类型安全 #

⚡ 高性能 #

🎯 事件优先级 #

📊 完善的日志系统 #

🔧 灵活的监听方式 #

📈 统计监控 #

🏗️ 核心架构 #

📦 安装 #

🚀 快速开始 #

1. 导入包 #

2. 配置日志（可选） #

3. 发送事件 #

4. 监听事件 #

📚 详细使用指南 #

← Metadata

Publisher

Weekly Downloads

Metadata

License

Dependencies

More

global_event_bus 0.0.1
global_event_bus: ^0.0.1 copied to clipboard