DamiBus v1.0 发布给单体多模块解耦作为一名长期在单体应用和多模块架构中摸爬滚打的程序员你一定遇到过这样的问题模块A想通知模块B做些事情结果代码里全是硬编码的依赖、回调地狱或者不得不引入重量级的消息队列。今天要介绍的DamiBus就是专为这种场景设计的轻量级解耦方案——它没有中间件、没有网络开销却能让你的模块间通信像订阅杂志一样轻松。## 什么是 DamiBus为什么需要它DamiBus 是一个基于“事件总线”思想的轻量级框架专为单体应用或多模块项目设计。它的核心理念是模块之间不直接调用对方的方法而是通过“事件”和“监听器”进行通信。想象一下你的应用就像一个大型商场-模块A比如订单模块想通知模块B比如库存模块“有用户下单了请扣减库存”- 传统做法是订单模块直接调用库存模块的reduceStock()方法——这会让两个模块耦合在一起- DamiBus 的做法是订单模块发送一个“order.created”事件库存模块监听这个事件然后执行自己的逻辑这样做的最大好处是模块之间完全解耦。你可以随时替换、升级或移除某个模块只要事件接口不变其他模块完全不受影响。## DamiBus 的核心概念DamiBus 的工作流程非常简单只有三个角色1.事件Event模块间传递的消息载体通常是一个对象或字符串2.事件总线EventBus负责管理事件的发送和监听就像邮局3.监听器Listener订阅特定事件的模块事件发生时自动执行引入 DamiBus 后你的项目结构会变成这样┌─────────────┐ ┌──────────────┐ ┌─────────────┐│ 模块A │ │ 事件总线 │ │ 模块B ││ (发送事件) │ ──▶ │ (分发事件) │ ──▶ │ (监听事件) │└─────────────┘ └──────────────┘ └─────────────┘## 快速上手第一个 DamiBus 示例### 步骤1添加依赖在 Maven 项目中只需添加一行依赖xmldependency groupIdcom.damibus/groupId artifactIddamibus-core/artifactId version1.0.0/version/dependency### 步骤2定义事件事件可以是任何对象建议使用类名清晰的POJOjava// 订单创建事件public class OrderCreatedEvent { private String orderId; private String userId; private double amount; // 构造函数、getter/setter 省略}### 步骤3发送事件在订单模块中创建订单后发送事件javaimport com.damibus.EventBus;import com.damibus.EventBusFactory;public class OrderService { private EventBus eventBus EventBusFactory.getDefault(); public void createOrder(Order order) { // 1. 创建订单业务逻辑 System.out.println(订单已创建: order.getId()); // 2. 发送事件 OrderCreatedEvent event new OrderCreatedEvent(); event.setOrderId(order.getId()); event.setUserId(order.getUserId()); event.setAmount(order.getAmount()); // 发送事件所有监听者都会收到 eventBus.post(event); }}### 步骤4监听事件在库存模块中监听订单创建事件javaimport com.damibus.EventBus;import com.damibus.EventBusFactory;import com.damibus.Subscribe;public class InventoryModule { // 在构造函数中注册监听器 public InventoryModule() { EventBus eventBus EventBusFactory.getDefault(); // 注册当前实例的事件方法 eventBus.register(this); } // 监听订单创建事件 Subscribe public void onOrderCreated(OrderCreatedEvent event) { System.out.println(库存模块收到事件: 订单 event.getOrderId() 已创建金额 event.getAmount()); // 执行扣减库存的逻辑 reduceStock(event.getOrderId()); } private void reduceStock(String orderId) { // 实际库存扣减逻辑 System.out.println(库存已扣减订单ID: orderId); }}## 实际应用多模块解耦的完整示例让我们看一个更真实的场景假设你的单体应用包含三个模块——订单模块、通知模块、日志模块。当用户下单后需要1. 通知模块发送邮件2. 日志模块记录操作传统做法需要订单模块直接调用这两个模块的方法现在用 DamiBus 可以完全解耦。### 1. 定义事件类java// 事件类订单创建事件public class OrderCreatedEvent { private String orderId; private String userId; private String email; private double amount; public OrderCreatedEvent(String orderId, String userId, String email, double amount) { this.orderId orderId; this.userId userId; this.email email; this.amount amount; } // getter方法... public String getOrderId() { return orderId; } public String getUserId() { return userId; } public String getEmail() { return email; } public double getAmount() { return amount; }}### 2. 订单模块发送事件javaimport com.damibus.EventBus;import com.damibus.EventBusFactory;public class OrderModule { private EventBus eventBus; public OrderModule() { this.eventBus EventBusFactory.getDefault(); } public void createOrder(String userId, String email, double amount) { // 生成订单ID String orderId ORD System.currentTimeMillis(); System.out.println([订单模块] 订单创建成功: orderId); // 发送事件 OrderCreatedEvent event new OrderCreatedEvent(orderId, userId, email, amount); eventBus.post(event); }}### 3. 通知模块监听事件javaimport com.damibus.EventBus;import com.damibus.EventBusFactory;import com.damibus.Subscribe;public class NotificationModule { public NotificationModule() { EventBus eventBus EventBusFactory.getDefault(); eventBus.register(this); } Subscribe public void sendOrderConfirmationEmail(OrderCreatedEvent event) { System.out.println([通知模块] 正在发送确认邮件至: event.getEmail()); // 模拟发送邮件 System.out.println( - 邮件内容: 订单 event.getOrderId() 已创建金额 event.getAmount() 元); }}### 4. 日志模块监听事件javaimport com.damibus.EventBus;import com.damibus.EventBusFactory;import com.damibus.Subscribe;public class LogModule { public LogModule() { EventBus eventBus EventBusFactory.getDefault(); eventBus.register(this); } Subscribe public void logOrderCreation(OrderCreatedEvent event) { System.out.println([日志模块] 记录日志: 用户 event.getUserId() 创建了订单 event.getOrderId()); // 实际写入日志文件或数据库 }}### 5. 主程序运行javapublic class MainApp { public static void main(String[] args) { // 初始化各模块模块间没有直接依赖 OrderModule orderModule new OrderModule(); NotificationModule notifModule new NotificationModule(); LogModule logModule new LogModule(); // 下单测试 orderModule.createOrder(user123, userexample.com, 299.99); }}运行结果[订单模块] 订单创建成功: ORD1690000000000[通知模块] 正在发送确认邮件至: userexample.com - 邮件内容: 订单 ORD1690000000000 已创建金额 299.99元[日志模块] 记录日志: 用户 user123 创建了订单 ORD1690000000000注意订单模块完全不知道通知模块和日志模块的存在它只是“发了个事件”。这种设计让模块替换变得极其简单——比如想换成短信通知只需修改通知模块的代码订单模块完全不需要改动。## DamiBus 的高级特性除了基础的事件发送与监听DamiBus 还提供了一些实用功能### 1. 异步处理异步事件默认情况下事件是同步处理的监听器按顺序执行。如果需要异步处理可以使用异步事件java// 发送异步事件eventBus.postAsync(event); // 监听器会在独立线程中执行### 2. 事件优先级如果多个监听器需要按特定顺序执行可以设置优先级javaSubscribe(priority 1) // 数值越小优先级越高public void firstListener(OrderCreatedEvent event) { System.out.println(我会首先执行);}Subscribe(priority 2)public void secondListener(OrderCreatedEvent event) { System.out.println(我第二个执行);}### 3. 过滤事件支持按条件过滤只有满足条件的事件才会触发监听器javaSubscribepublic void handleLargeOrder(OrderCreatedEvent event) { if (event.getAmount() 1000) { System.out.println(大额订单处理: event.getOrderId()); }}## 为什么选择 DamiBus 而不是 Spring Event 或其他方案很多人会问Spring 框架也有事件机制为什么还要用 DamiBus这里有几点区别| 特性 | DamiBus | Spring Event | 传统消息队列 ||------|---------|--------------|--------------||依赖| 无任何框架依赖 | 必须依赖 Spring | 需要 RabbitMQ/Kafka 等中间件 ||性能| 极低开销纯内存调用 | 稍高依赖 IoC 容器 | 高网络序列化开销 ||使用场景| 单体/多模块解耦 | Spring 生态 | 分布式系统 ||学习曲线| 10分钟上手 | 需要 Spring 基础 | 较复杂 |如果你的项目已经用了 Spring当然可以用 Spring Event。但 DamiBus 的优势在于不绑定任何框架可以在纯 Java 项目、Android 项目、甚至非 Spring 的 Web 项目中使用。## 常见问题与最佳实践### Q事件应该放在哪个模块A建议放在一个公共的“事件定义模块”中或者放在“发送方”模块中监听方依赖这个模块。### Q事件太多怎么办A可以用命名空间区分比如order.created、user.updated。DamiBus 支持按事件类型过滤。### Q需要持久化事件吗A通常不需要因为 DamiBus 是内存中的事件总线。如果需要持久化请考虑消息队列。### 最佳实践总结-事件命名清晰使用动词名词格式如order.created、payment.completed-事件对象不可变避免监听器修改事件内容-监听器保持单一职责一个监听器只做一件事-异步处理耗时操作如发邮件、写日志等## 总结DamiBus 是一个轻量级、零依赖的事件总线框架专为解决单体应用或多模块项目中的模块间解耦问题而设计。通过将模块间的直接调用替换为事件驱动通信你的代码将变得更灵活、更易维护、更易测试。它的核心价值在于让模块只关心自己该做的事而不是关心其他模块在做什么。当你需要添加新功能时只需新增一个监听器当你需要移除某个模块时只需删除对应的监听器——完全不需要修改其他模块的代码。如果你正在为单体应用的模块耦合问题烦恼不妨试试 DamiBus。它可能不会像微服务那样高大上但对于大多数中小型项目来说是最简单、最有效的解耦方案。现在就动手在你的项目中引入 DamiBus 吧你会惊讶于代码变得多么清爽—DamiBus v1.0 已发布欢迎访问 GitHub 仓库获取更多信息https://github.com/damibus