企业官网建设流程全解析

fastEventbus4cj入门教程：5分钟上手仓颉语言第一个发布/订阅事件总线

【免费下载链接】fast-eventbus-cj一种发布/订阅事件总线，为多线程应用程序中的高吞吐量而优化的强大事件总线。项目地址: https://gitcode.com/Cangjie-TPC/fast-eventbus-cj

fastEventbus4cj是一个用仓颉语言编写的发布/订阅（Pub/Sub）事件总线库，专为多线程高吞吐量场景优化，支持同步/异步订阅、发布与事件过滤。本教程将带你在 5 分钟内完成第一个仓颉事件总线的搭建：从理解概念、配置依赖，到跑通订阅-发布-取消订阅的完整流程，并了解如何启用异步并行与自定义过滤器。

1. 什么是发布/订阅事件总线？为什么选 fastEventbus4cj？

传统"组件A直接调用组件B"的写法会让模块之间紧紧耦合。事件总线则像一根共享的广播线：

• 发布者（Publisher）：只管"喊话"，发出事件；
• 订阅者（Subscriber）：只管"听"，收到事件后执行自己的逻辑；
• 总线（Mbassador）：负责把事件路由给正确的订阅者，发布者和订阅者互不感知。

fastEventbus4cj 的核心亮点：

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.cj）：

var 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. 进阶：异步并行发布，吞吐量拉满

同步方式下，发布、订阅都在当前线程串行完成。当事件量大（如每秒上千条）时，可切换到异步模式：

1. 配置线程池并行度——ExecutorService(subscriberParallel, unsubscriberParallel, publishParallel)；
2. 将配置注入总线：Mbassador(mbconfig)；
3. 把事件放入LinkedBlockingQueue<Event>，调用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: ArrayList<Event> = 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.cj
• COW 并发容器：src/copyonwriter_container.cj —— 高吞吐的底层支撑
• 官方 API 文档：doc/feature_api.md —— 全部接口签名与示例
• 测试目录：test/LLT/ 单元测试与 test/HLT/ 高负载测试

7. 常见问题速查（FAQ）

Q1：发布时抛出 MbassadorException？先register再publish；未订阅就发布会触发该异常，这是预期行为。

Q2：同步和异步怎么选？事件量少、要求结果立即可见 → 同步；事件量大、允许异步消费、要求高吞吐 → 异步 + 线程池。

Q3：版本兼容？当前发布版 v0.0.3 基于仓颉 cjc v1.1.3 验证通过（版本演进记录见 CHANGELOG.md），开源协议为 MIT，可自由商用。

🎯总结：fastEventbus4cj 用极小的 API 面（Event+Mbassador+ 订阅/发布者接口）覆盖了同步/异步订阅发布与事件过滤三大能力，是仓颉多线程应用中解耦组件通信的高吞吐事件总线方案。现在就可以克隆仓库，跑通本文第 3 节的最小示例，开启你的仓颉事件驱动之旅！

【免费下载链接】fast-eventbus-cj一种发布/订阅事件总线，为多线程应用程序中的高吞吐量而优化的强大事件总线。项目地址: https://gitcode.com/Cangjie-TPC/fast-eventbus-cj