Eunoia —— 源自希腊语 εὔνοια：美好的思维、善意、心态平和。

Euonia 是一个用于构建企业级 Java 应用的开发框架。它将**面向对象可扩展业务架构（OSBA）与领域驱动设计（DDD）**理念结合起来，为构建健壮、可维护的业务系统提供完整基础设施。该框架基于 Java 17+，可与 Spring Boot 4.x / Spring Framework 7.x 无缝集成。

Euonia 同时提供 .NET 版本，本仓库为 Java 版本。

graph TD
    subgraph "Euonia Java"
        direction TB
        DDD --> Core
        OSBA --> Core
        UoW --> Core
        Pipeline --> Core
        Spring --> Core
        Spring --> UoW
        Spring --> OSBA
        Spring --> Pipeline
        BusAbstract --> Core
        BusCore --> BusAbstract
        BusCore --> Core
        BusCore --> Pipeline
        BusInmemory --> BusAbstract
        BusInmemory --> Core
        BusRabbitmq --> BusAbstract
        BusRabbitmq --> Core
        BusKafka --> BusAbstract
        Sample --> DDD
        Sample --> OSBA
        Sample --> Pipeline
        Sample --> Spring
    end

    style Core fill:#4A90D9,color:#fff
    style DDD fill:#50B86C,color:#fff
    style UoW fill:#1F6FEB,color:#fff
    style OSBA fill:#E8833A,color:#fff
    style Pipeline fill:#E74C3C,color:#fff
    style Spring fill:#2ECC71,color:#fff
    style BusAbstract fill:#F39C12,color:#fff
    style BusCore fill:#E67E22,color:#fff
    style BusInmemory fill:#D35400,color:#fff
    style BusRabbitmq fill:#C0392B,color:#fff
    style BusKafka fill:#8E44AD,color:#fff
    style Sample fill:#9B59B6,color:#fff

基础核心库：提供基类、ID 生成、反射工具、元组、HTTP 异常、安全能力与验证注解。

领域驱动设计抽象：实体、聚合、值对象、领域事件、命令、应用服务、用例与审计支持。

Unit of Work 抽象：定义事务边界、提交/回滚生命周期与一致性的持久化编排。

受 ASP.NET Core 启发的中间件管道框架：统一的 Pipeline<TRequest, TResponse>，支持可链式的行为拼装、委托与依赖注入集成。

关键特性：

• Fluent API：支持通过 .use() 以 lambda、类或 @PipelineBehaviors 自动发现方式拼装行为
• 单一 Pipeline<TRequest, TResponse> 同时覆盖即发即忘（Pipeline<Object, Void>）和类型化请求/响应场景
• 基于委托的组合，采用反向链构建（最内层先执行）
• ServiceProvider 抽象支持独立运行与 Spring 集成
• 全链路异步（CompletionStage）

// 创建一个管道
Pipeline<Object, Void> pipeline = new DefaultPipelineProvider<>(resolver)
    .use((ctx, next) -> next.invoke(ctx).thenRun(() -> System.out.println("Log: done")))
    .use(LoggingBehavior.class);

// 运行
pipeline.runAsync(new MyContext()).toCompletableFuture().join();

消息总线抽象契约层：定义消息信封、上下文、约定、传输策略、注解、抽象传输接口、收件箱/发件箱/死信队列抽象。所有总线模块的扩展基础。依赖 core。

核心契约

收件箱 / 发件箱 / 死信队列（inbox / outbox / dlq）

接收者（Recipient）

契约接口（标记）

注解（十种）

事件体系

异常层次

消息总线运行时编排层：处理器发现、注册、分发、约定实现、策略实现、路由消息与总线 API。依赖 bus-abstract 和 pipeline，将所有抽象契约组合为可用的消息总线引擎。

核心类

约定与策略实现

幂等性 & 管道行为

流式构建器

消息总线三类操作

辅助类型

关键特性：

• 通过 @Subscribe 方法或 Handler<M,R> 接口自动发现处理器
• 单处理器通道支持请求/响应（Unicast / Request）；多处理器通道并行执行（Multicast）
• TransportStrategy 系统映射消息类型到传输方式（Local vs Distributed）
• 与 Pipeline 集成，支持中间件风格的消息处理（日志、验证、转换、幂等）
• 内置 IdempotentHandler + InboxPipelineBehavior 实现消息去重与幂等消费
• 流式构建器 API（bus.publish(msg).withChannel("orders").executeAsync()）

进程内内存传输适配器 — 完整的 Transport 实现。提供无需外部中间件的纯内存消息分发，适用于开发测试、单进程集成及超低延迟场景。依赖 bus-abstract 和 core。

核心类

信使引擎（Messenger）

映射规则： Unicast → InMemoryUnicastRecipient → StrongMessenger；Multicast → InMemoryMulticastRecipient → WeakMessenger；Request → InMemoryRequestRecipient → StrongMessenger。

RabbitMQ 传输适配器 — 完整的 Transport 实现。通过 RabbitMQ 代理提供分布式消息分发，支持队列、交换器、路由键映射与基于 Failsafe 的重试策略。依赖 bus-abstract、core 和 com.rabbitmq:amqp-client:5.31.0。

核心类

映射规则： Unicast → RabbitMqQueueConsumer；Multicast → RabbitMqTopicSubscriber；Request → RabbitMqRequestExecutor。

Kafka 传输适配器 — 完整的 Transport 实现。通过 Apache Kafka 代理提供分布式消息分发，支持主题、消费者组与基于 Failsafe 的重试策略。依赖 bus-abstract、core 和 org.apache.kafka:kafka-clients。

核心类

映射规则： Unicast → KafkaQueueConsumer；Multicast → KafkaTopicSubscriber；Request → KafkaRequestExecutor。

Spring 集成模块。通过 ApplicationContext 与 ServiceProvider 建立桥接，为 Pipeline 及其它 Euonia 组件提供无缝依赖注入。

关键特性：

• 为 Pipeline 与其它 Euonia 组件提供 Spring DI 能力
• 自动注入 Spring 管理的 Bean 到 Pipeline 委托/行为
• 提供带自动装配的反射构建兜底能力
• 极简接入：@Import(ServiceProviderConfiguration.class) 或组件扫描

面向对象可扩展业务架构：提供富业务对象模型，支持规则校验、属性变更追踪、状态管理与反射驱动工厂。

BusinessObject<B>          — 核心：规则、上下文、属性管理
    └── ObservableObject<T>  — 状态跟踪：NEW / CHANGED / DELETED
        ├── EditableObject<T>  — 支持异步规则校验与保存
        ├── ReadOnlyObject<T>  — 带权限控制的只读对象
        └── ExecutableObject<T> — 模板化执行对象

protected void addRules() {
    getRules().addRule(new LambdaRule<>(age, (a, ctx) -> a != null && a >= 18, "Must be 18+"));
}

sample 模块演示了 Euonia 与 Spring Boot 4.1 的完整集成，包含 CQRS 命令查询职责分离与消息总线：

<!-- 核心工具 -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>core</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- Pipeline 中间件 -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>pipeline</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- Spring 集成 -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>spring</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 业务对象（OSBA） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>osba</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 领域驱动设计（DDD） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>domain-driven-design</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 消息总线（抽象层） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>bus-abstract</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 消息总线（核心运行时） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>bus-core</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 消息总线（内存传输） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>bus-inmemory</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 消息总线（RabbitMQ 传输） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>bus-rabbitmq</artifactId>
    <version>10.0.0</version>
</dependency>

<!-- 消息总线（Kafka 传输） -->
<dependency>
    <groupId>com.euonia</groupId>
    <artifactId>bus-kafka</artifactId>
    <version>10.0.0</version>
</dependency>

// 定义业务对象
@Component @Scope("prototype")
public class Order extends EditableObject<Order> {
    private final PropertyInfo<String> productName = registerProperty(String.class, "productName");

    @FactoryCreate
    protected void create(String productName) {
        super.create();
        setProductName(productName);
        setId(ObjectId.snowflake().getValue(Long.class));
    }

    @Override
    protected void addRules() {
        getRules().addRule(new RequiredRule(productName));
    }
}

// 使用工厂
@Autowired
private ObjectFactory factory;

var order = factory.create(Order.class, "Widget");
order.save(false);

# 构建全部模块
mvn clean install

# 运行示例应用
cd sample
mvn spring-boot:run

# 发布到 Maven 中央仓库
mvn clean deploy -DskipTests -P release 2>&1 | tee release.log

• GitHub: https://github.com/euonia-project/euonia-java
• .NET 版本: https://github.com/euonia-project/euonia-dotnet

感谢 JetBrains 通过其 开源免费许可证计划 提供 全家桶产品支持。