带Spring的DDDJava-存储库返回单声道/通量

Question

我想知道在DDD项目中实现反应性Mongo存储库时遇到的一个问题，我使用Java和Spring Boot实现。假设我们有这样的包结构：

/app 
  |
  |------/application
  |        | 
  |        |------/order
  |                 |
  |                 |------OrderApplicationService.java
  |
  |------/domain
  |        |
  |        |------/order
  |                 |
  |                 |------Order.java
  |                 |------OrderRepository.java 
  |
  |------/infrastructure
           |
           |------/mongo
                    |
                    |------MongoOrderRepository.java

我需要我的订单存储库。java我想要一个保存订单的方法：

public interface OrderRepository {

    Order save(Order order);
}

并在我的应用服务中使用它：

@Service
public class OrderApplicationService {

    private final OrderRepository orderRepository;

    public OrderApplicationService(OrderRepository orderRepository) {
        this.orderRepository = orderRepository;
    }

    public void createOrder() {
        //Dumb order creation
        Order createdOrder = clientRepository.save(new Order());
    }
}

接下来，我想编写MongoOrderRepository，它实现了OrderRepository。假设我将使用ReactiveMongoTemplate。问题是它的所有方法都返回Flux或Mono，所以我无法从OrderRepository接口实现我的方法。

我认为可能的解决办法是：

1. 使OrderRepository中的“save”方法返回由Mono包装的订单。这种方法将使用特定于Reactor的类型来污染域层，并打破域层应该是无框架代码的规则
2. 开发某种包装层，但这将生成一些样板代码
3. 移动订单服务。java到基础架构层，但这也打破了一些基本的DDD概念

有人看到更好的解决方案了吗？

Answer 1

存储库应该对框架代码不可知，这是事实，这是一个很好的实践，但您也需要务实，我在存储库中使用了java lambda，这是语言级别的框架。

使用Flux或Mono的好处是什么？作为界面的一部分宣传它们的好处是什么？如果没有，则可以将实现细节保留在存储库实现中，并使接口没有反应对象。

但是，如果这需要跨越应用程序层到端口适配器，那么我看不出将它们放在存储库的接口定义中有任何问题。

也就是说，您可能希望检查另一种方法，使用CQR和六边形体系结构，您可以实现两个方面的最佳效果：

>

有一个干净的存储库接口的命令（更新和创建部分）

使用查询服务（如果您在java中，则在应用程序包中定义为普通POJO）为查询返回Mono或Flux（阅读部分）

OrderApplicationervice.java（这里是通过命令创建更新删除）OrderQueryService.java（这里是阅读部分）

您的应用程序服务包含对您的OrderRepository的引用，查询服务不使用存储库，因为它更直接地查询数据库，例如通过ReactiveMongoTem板。

例如，在我的查询服务中，我使用普通的JDBC模板，而在存储库实现中使用Hibernate。