fastEventbus4cj入门教程5分钟上手仓颉语言第一个发布/订阅事件总线【免费下载链接】fast-eventbus-cj一种发布/订阅事件总线为多线程应用程序中的高吞吐量而优化的强大事件总线。项目地址: https://gitcode.com/Cangjie-TPC/fast-eventbus-cjfastEventbus4cj是一个用仓颉语言编写的发布/订阅Pub/Sub事件总线库专为多线程高吞吐量场景优化支持同步/异步订阅、发布与事件过滤。本教程将带你在 5 分钟内完成第一个仓颉事件总线的搭建从理解概念、配置依赖到跑通订阅-发布-取消订阅的完整流程并了解如何启用异步并行与自定义过滤器。1. 什么是发布/订阅事件总线为什么选 fastEventbus4cj传统组件A直接调用组件B的写法会让模块之间紧紧耦合。事件总线则像一根共享的广播线发布者Publisher只管喊话发出事件订阅者Subscriber只管听收到事件后执行自己的逻辑总线Mbassador负责把事件路由给正确的订阅者发布者和订阅者互不感知。fastEventbus4cj 的核心亮点特性说明适合场景 同步订阅/发布/取消订阅调用即完成逻辑直观简单业务、调试阶段 异步并行处理基于线程池src/executor_service.cj高吞吐、不阻塞主流程 事件过滤器链自定义 Filter 顺序过滤事件按类型/来源筛选事件 COW 无阻塞容器写时加锁、读不阻塞src/copyonwriter_container.cj多线程并发读写2. 环境准备一键安装与编译前置条件已安装仓颉工具链推荐 cjc v1.1.3项目验证版本见 cjpm.toml。克隆仓库Linux / Windows 通用git clone https://link.gitcode.com/i/1f9e12f0b106efdfbdc25a6836e7b3e2进入项目目录后一条命令完成编译cjpm build项目采用 cjpm 包管理包名为mbassador4cj见 cjpm.toml编译产物为动态库可被你的仓颉应用直接引入。3. 5分钟上手同步订阅与发布事件整个流程只有 3 步定义事件 → 订阅 → 发布。3.1 第一步定义事件对象事件是总线的最小执行单元由三个要素组成事件类型名称、订阅者、发布者源码见 src/event.cjvar event: Event Event(IntergerType, IntegerSubscriber(), IntegerPublisher())其中IntegerSubscriber/IntegerPublisher是你实现 Subscriber 与 Publisher 接口的类——订阅者只需实现onEvent(event)方法发布者实现publish(event)方法即可。3.2 第二步创建总线并订阅、发布总线的统一入口是 Mbassador 类var mbassador Mbassador() mbassador.register(event) // 订阅 mbassador.publish(event) // 发布触发订阅者的 onEvent mbassador.unregister(event) // 取消订阅⚠️新手避坑提示发布前必须先订阅否则会抛出MbassadorException如 The current event has not been subscribed, please operate subscription first.异常定义见 src/mbassador_exception.cj。3.3 完整最小示例import mbassador4cj.* main() { var event: Event Event(IntergerType, IntegerSubscriber(), IntegerPublisher()) var mbassador Mbassador() mbassador.register(event) mbassador.publish(event) mbassador.unregister(event) }运行后订阅者的onEvent会被同步调用——你的第一个仓颉发布/订阅事件总线就跑通了 更多可运行的同步示例见 test/LLT/mbassador_test.cj。4. 进阶异步并行发布吞吐量拉满同步方式下发布、订阅都在当前线程串行完成。当事件量大如每秒上千条时可切换到异步模式配置线程池并行度——ExecutorService(subscriberParallel, unsubscriberParallel, publishParallel)将配置注入总线Mbassador(mbconfig)把事件放入LinkedBlockingQueueEvent调用registerAsny/publishAsny。var mbconfig MbassadorConfiguration() mbconfig.setExecutorService(ExecutorService(3, 3, 30)) var mbassador Mbassador(mbconfig) mbassador.publishAsny(mbconfig, eventQueue) // 异步发布线程池与队列由 src/executor_service.cj 和 src/mbassador_configuration.cj 实现配置细节见 src/mbassador_configuration.cj。异步用例可参考 test/LLT/mbassador_test.cj性能基准测试见 test/LLT/mbassdor_performance_test.cj。5. 进阶用过滤器链精准筛事件当事件流混杂多种类型时可用过滤器链按顺序逐级筛选。FilterChain 的设计类似流水线let filterChanin: FilterChain FilterChain() filterChanin.addFilter(EventNameAFilter()) // 只保留 eventA filterChanin.addFilter(PublisherFilter()) // 再按发布者类型过滤 var results: ArrayListEvent filterChanin.filter(events)只需实现 Filter 接口的filter(events)方法即可按任意规则事件名、发布者类型等自定义过滤逻辑。完整可对照的用例见 test/LLT/filter_test.cj。6. 源码地图与扩展阅读仓库结构清晰建议按以下路径深入了解总线入口src/mbassador.cj ——register/publish/unregister及全部异步 API事件模型src/event.cj ——Event与EventManager定义订阅/发布者接口src/subscriber.cj、src/publisher.cjCOW 并发容器src/copyonwriter_container.cj —— 高吞吐的底层支撑官方 API 文档doc/feature_api.md —— 全部接口签名与示例测试目录test/LLT/ 单元测试与 test/HLT/ 高负载测试7. 常见问题速查FAQQ1发布时抛出 MbassadorException先register再publish未订阅就发布会触发该异常这是预期行为。Q2同步和异步怎么选事件量少、要求结果立即可见 → 同步事件量大、允许异步消费、要求高吞吐 → 异步 线程池。Q3版本兼容当前发布版 v0.0.3 基于仓颉 cjc v1.1.3 验证通过版本演进记录见 CHANGELOG.md开源协议为 MIT可自由商用。总结fastEventbus4cj 用极小的 API 面EventMbassador 订阅/发布者接口覆盖了同步/异步订阅发布与事件过滤三大能力是仓颉多线程应用中解耦组件通信的高吞吐事件总线方案。现在就可以克隆仓库跑通本文第 3 节的最小示例开启你的仓颉事件驱动之旅【免费下载链接】fast-eventbus-cj一种发布/订阅事件总线为多线程应用程序中的高吞吐量而优化的强大事件总线。项目地址: https://gitcode.com/Cangjie-TPC/fast-eventbus-cj创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考