JdonFramework 开源项目教程

1. 项目介绍

JdonFramework 是一个基于领域驱动设计（Domain-Driven Design, DDD）的发布/订阅（Pub/Sub）领域事件框架。它支持异步编程模型，无需任何消息中间件（如 Apache Kafka 或 RabbitMQ），可以直接将命令传递给领域模型，并监听领域模型中发生的领域事件。JdonFramework 帮助开发者实现一个清晰的六边形架构，将业务逻辑与基础设施分离，适用于构建异步、高并发、高吞吐量的 Java 应用系统。

2. 项目快速启动

2.1 环境准备

• JDK 8 或更高版本
• Maven 3.x

2.2 添加依赖

在项目的 pom.xml 文件中添加 JdonFramework 的依赖：

<dependency>
    <groupId>org.jdon</groupId>
    <artifactId>jdonframework</artifactId>
    <version>6.9</version>
</dependency>

2.3 创建领域模型

创建一个简单的领域模型类 AggregateRootA：

@Model
public class AggregateRootA {
    private int state = 100;

    @OnCommand("CommandtoEventA")
    public Object save(ParameterVO parameterVO) {
        // 更新领域模型的状态
        this.state = parameterVO.getValue() + state;
        return state;
    }
}

2.4 发送命令

使用 @Send 注解发送命令：

@Send("CommandtoEventA")
public void sendCommand(ParameterVO parameterVO) {
    // 发送命令到领域模型
}

2.5 监听事件

使用 @OnEvent 注解监听领域事件：

@OnEvent("EventA")
public void handleEvent(EventA event) {
    // 处理领域事件
}

2.6 运行示例

将上述代码整合到一个简单的应用中，并运行 Maven 打包命令：

mvn package

3. 应用案例和最佳实践

3.1 案例：账户转账

JdonFramework 提供了基于事件溯源（EventSourcing）和 Saga 模式的分布式事务解决方案。以下是一个简单的账户转账案例：

@Model
public class BankAccount {
    private final String id;
    private int balance = 0;
    private Collection<TransferEvent> eventsources = new ArrayList<>();

    @OnCommand("transfer")
    public void transfer(TransferCommand transferCommand) {
        int balance2 = getBalance() + transferCommand.getValue();
        if (balance2 > 1000 || balance2 < 0) {
            aggregatePub.next(transferCommand.createCanceled());
        }
        TransferEvent transferEvent = transferCommand.creatTransferEvent();
        eventsources.add(transferEvent);
        aggregatePub.next(transferEvent);
    }

    @OnCommand("cancel")
    public void cancel(Cancel cancel) {
        int balance2 = getBalance() - cancel.getTransferCommand().getValue();
        if (balance2 > 1000 || balance2 < 0) {
            System.err.println("can not be canceled " + cancel.getTransferCommand().getTransactionId());
        }
        eventsources.add(cancel.getTransferCommand().createCanceled());
    }

    private int project() {
        return eventsources.stream().map(e -> e.getValue()).reduce(this.balance, (a, b) -> a + b);
    }

    public int getBalance() {
        return project();
    }
}

3.2 最佳实践

• 领域驱动设计：使用 JdonFramework 时，应遵循 DDD 的原则，将业务逻辑集中在领域模型中。
• 事件驱动架构：通过事件驱动的方式实现模块间的解耦，提高系统的可扩展性和可维护性。
• 分布式事务：利用 Saga 模式和事件溯源实现分布式事务，确保数据的一致性。

4. 典型生态项目

4.1 JiveJdon

JiveJdon 是一个基于 JdonFramework 实现的复杂 DDD 应用案例，是一个讨论论坛/博客/CMS 平台。它展示了如何使用 JdonFramework 构建一个高并发、高可扩展的 Web 应用。

4.2 LMAX 架构

JdonFramework 借鉴了 LMAX 架构的设计思想，实现了高性能的并发处理能力。LMAX 架构通过事件驱动的模式，实现了每秒处理数百万订单的高吞吐量。

4.3 Apache Kafka

虽然 JdonFramework 本身不依赖于 Apache Kafka，但它可以与 Kafka 结合使用，实现更高级别的消息传递和分布式事务处理。

通过以上内容，您可以快速了解并上手使用 JdonFramework，构建基于领域驱动设计的 Java 应用系统。