DDD在Java中的实战：聚合根、值对象与领域事件实现

夜晨

发布时间：2025-09-03 20:59:01

645人浏览过

来源于php中文网

原创

聚合根、值对象与领域事件是DDD核心要素。选择聚合根需基于业务不变性约束，确保事务边界清晰，如电商中订单为聚合根，订单项依附其存在；值对象如货币、地址应不可变且以值判等，提升代码健壮性；领域事件用于解耦模块，如订单创建后发布事件，库存服务订阅并扣减库存。避免过度设计、贫血模型及过大事务边界，采用充血模型和限界上下文划分，逐步重构现有项目，结合Spring Data、Axon等工具提升效率。

ddd在java中的实战：聚合根、值对象与领域事件实现

DDD（领域驱动设计）在Java中的实战，核心在于将业务逻辑清晰地映射到代码中。聚合根作为业务一致性的边界，值对象负责描述领域特征，领域事件则用于解耦不同领域模块。理解并正确应用这三者，是成功实施DDD的关键。

聚合根、值对象与领域事件的具体实现

如何选择合适的聚合根？

选择聚合根是DDD中最关键的决策之一。聚合根是实体，但并非所有实体都是聚合根。选择聚合根的关键在于识别业务上的不变性约束。例如，在一个电商系统中，订单（Order）可能是一个聚合根，因为它涉及到商品、价格、数量等多个方面的业务规则，需要保证这些数据的一致性。而订单项（OrderItem）则可能不是聚合根，它通常依赖于订单而存在。

选择聚合根时，需要考虑以下几点：

立即学习“Java免费学习笔记（深入）”；

业务完整性： 聚合根应该包含所有需要一起改变的数据。
事务边界： 聚合根定义了事务的边界，对聚合根的修改应该在一个事务内完成。
减少依赖： 尽量减少聚合根之间的依赖，可以通过领域事件来解耦。

一个常见的错误是将所有实体都作为聚合根，导致系统过于复杂，事务边界过大，性能下降。另一个错误是忽略了业务上的不变性约束，导致数据不一致。

举个例子，假设我们有一个博客系统。文章（Article）可能是一个聚合根，因为它包含了标题、内容、作者、评论等信息。评论（Comment）可能不是聚合根，它依附于文章而存在。如果我们需要对评论进行审核，那么可以通过在文章聚合根上添加一个审核方法来实现，而不是将评论作为一个独立的聚合根。

// Article 聚合根
public class Article {
    private Long id;
    private String title;
    private String content;
    private Author author;
    private List comments;

    public void addComment(Comment comment) {
        // 添加评论的业务逻辑
        this.comments.add(comment);
    }

    public void approveComment(Long commentId) {
        // 审核评论的业务逻辑
        Comment comment = this.comments.stream()
                .filter(c -> c.getId().equals(commentId))
                .findFirst()
                .orElseThrow(() -> new IllegalArgumentException("Comment not found"));
        comment.approve();
    }
}

// Comment 值对象 (或者如果需要独立维护，也可以是实体，但通常不是聚合根)
public class Comment {
    private Long id;
    private String content;
    private Author author;
    private boolean approved;

    public void approve() {
        this.approved = true;
    }
}

值对象在DDD中有什么作用？如何正确使用？

值对象用于描述领域中的一些概念，但它们没有唯一的标识符。值对象的值相等，则认为是相同的对象。例如，颜色（Color）、货币（Currency）、地址（Address）等都可以是值对象。

值对象应该具有以下特点：

不可变性： 值对象创建后，其状态不应该被修改。
值相等性： 两个值对象的值相等，则认为是相同的对象。
替换性： 可以用另一个值相同的值对象来替换当前的值对象。

正确使用值对象可以提高代码的可读性和可维护性。例如，如果我们在一个订单系统中需要表示货币，可以使用一个

Currency

值对象，而不是直接使用字符串或数字。这样可以避免一些潜在的错误，例如货币单位不一致等。

// Currency 值对象
public class Currency {
    private final String code;
    private final String symbol;

    public Currency(String code, String symbol) {
        this.code = code;
        this.symbol = symbol;
    }

    public String getCode() {
        return code;
    }

    public String getSymbol() {
        return symbol;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Currency currency = (Currency) o;
        return Objects.equals(code, currency.code);
    }

    @Override
    public int hashCode() {
        return Objects.hash(code);
    }
}

// 使用 Currency 值对象
public class Product {
    private String name;
    private BigDecimal price;
    private Currency currency;

    public Product(String name, BigDecimal price, Currency currency) {
        this.name = name;
        this.price = price;
        this.currency = currency;
    }
}

如何利用领域事件解耦领域模块？

领域事件用于表示领域中发生的一些重要事件。例如，订单创建事件、支付成功事件、商品库存不足事件等。通过发布和订阅领域事件，可以实现领域模块之间的解耦。

Text-To-Song

免费的实时语音转换器和调制器

下载

领域事件应该具有以下特点：

领域相关性： 领域事件应该与领域中的业务逻辑相关。
不可变性： 领域事件创建后，其状态不应该被修改。
及时性： 领域事件应该在事件发生后立即发布。

使用领域事件的步骤如下：

定义领域事件： 定义一个类来表示领域事件，包含事件发生时需要传递的数据。
发布领域事件： 在事件发生时，创建一个领域事件对象，并将其发布到事件总线。
订阅领域事件： 领域模块订阅自己关心的领域事件，并在事件发生时执行相应的操作。

例如，在一个订单系统中，当订单创建成功时，可以发布一个

OrderCreatedEvent

领域事件。库存模块可以订阅这个事件，并在事件发生时减少相应的商品库存。

// OrderCreatedEvent 领域事件
public class OrderCreatedEvent {
    private final Long orderId;

    public OrderCreatedEvent(Long orderId) {
        this.orderId = orderId;
    }

    public Long getOrderId() {
        return orderId;
    }
}

// 发布领域事件
public class OrderService {
    private final EventBus eventBus;

    public OrderService(EventBus eventBus) {
        this.eventBus = eventBus;
    }

    public Order createOrder(Long productId, int quantity) {
        // 创建订单的业务逻辑
        Order order = new Order(productId, quantity);
        eventBus.publish(new OrderCreatedEvent(order.getId()));
        return order;
    }
}

// 订阅领域事件
public class InventoryService {
    @Subscribe
    public void onOrderCreated(OrderCreatedEvent event) {
        // 减少商品库存的业务逻辑
        Long orderId = event.getOrderId();
        // ...
    }
}

需要注意的是，领域事件的发布和订阅需要一个事件总线（Event Bus）来实现。可以使用 Guava EventBus、Spring Event 等框架来实现事件总线。选择合适的事件总线取决于具体的项目需求。