Java
Euonia Bus-InMemory 模块 API 文档
概述¶
Euonia 消息总线的进程内传输适配器。基于 bus-abstract 的抽象契约，提供无外部中间件的纯内存消息传递实现，适用于开发测试、单进程集成以及需要超低延迟的场景。
- Maven 坐标:
com.euonia:bus-inmemory - Java 模块名:
com.euonia.bus - 依赖:
com.euonia:core,com.euonia:pipeline,com.euonia:bus-abstract,com.euonia:bus-core
导出包¶
com.euonia.bus¶
进程内传输的核心实现类。
| 类 | 类型 | 说明 |
|---|---|---|
| InMemoryTransport | class | Transport 接口的进程内实现 |
| InMemoryBusOptions | class | 进程内总线配置选项 |
| InMemoryRecipient | abstract class | 接收者基类，实现消息处理流水线 |
| InMemoryUnicastRecipient | class | 单播接收者（Executor） |
| InMemoryMulticastRecipient | class | 多播接收者（Subscriber） |
| InMemoryRequestRecipient | class | 请求-响应接收者（Executor） |
| InMemoryRecipientRegistrar | class | 接收者注册映射器 |
| InMemoryMessageDispatcher | class | 消息分发器（单例） |
| InMemoryDeadLetterQueue | class | 死信队列（单例，CopyOnWriteArrayList） |
| MessagePack | class | 传输信封包装 |
com.euonia.bus.messenger¶
内部消息分发子系统。
| 类 | 类型 | 说明 |
|---|---|---|
| Messenger | interface | 信使契约：register/send/unregister/cleanup/reset |
| StrongReferenceMessenger | class | 强引用信使（Unicast/Request） |
| WeakReferenceMessenger | class | 弱引用信使（Multicast，GC 友好） |
| Recipient | @FunctionalInterface | 泛型消息接收者 |
| MessageHandler | @FunctionalInterface | 类型化处理器 |
| MessageHandlerDispatcher | abstract class | 处理器分发器 |
| EquatableType | class | 不可变 (message, token) 复合键 |
| MessengerReferenceType | enum | STRONG / WEAK |
依赖¶
com.euonia:core(compile)com.euonia:pipeline(compile)com.euonia:bus-abstract(compile)com.euonia:bus-core(compile)
作者¶
- damon (zhaorong@outlook.com)