同一个项目中的多个Spring Boot应用实现CQRS - itnext

21-12-08 banq

展示了如何使用两种不同的代码路径实现 CQRS

  • 命令部分通过Spring Data JPA 实现
  • 通过jOOQ的查询部分

用例是一个银行应用程序,它提供了一个 REST 层,允许客户端调用任何部分。

在同一个项目中创建另一个带注释@SpringBootApplication的类:

@SpringBootApplication
public class GeneratorApplication {
    @Bean
    public CommandLineRunner run() {
        var template = new RestTemplate();
        return args -> {
            var operation = generateRandomOperation();          // 1
            LongStream.range(0, Long.parseLong(args[0]))        // 2
                .forEach(
                    operation -> template.postForObject(        // 3
                        "http://localhost:8080/operation",
                        operation,
                        Object.class));
        };
    }
    public static void main(String[] args) {
        new SpringApplicationBuilder(GeneratorApplication.class)
                .run(args);
    }
}

  1. Operation以某种方式生成随机
  2. 从参数中获取调用次数
  3. 调用主 Web 应用程序的 URL

当我在另一个 Web 应用程序之后启动此应用程序时,它失败了。有两个原因:

  1. 两个应用程序共享相同的 Maven POM。由于 位于spring-boot-starter-web类路径上,因此生成器应用程序会尝试启动 Tomcat。它失败是因为第一个应用程序确实绑定了默认端口。
  2. Spring Boot 默认依赖组件扫描。因此,Web 应用程序扫描生成器应用程序及其声明的 bean 并创建它们。可以通过这种方式重新定义一些 bean。但是,webapp 也会创建CommandLineRunner上面的bean。因此,当它的服务器还没有准备好时,它“向自己发布”。

最直接的解决方案是将每个应用程序的类移动到它们自己专用的 Maven 模块中。您需要在每个模块中创建一个 POM,其中只包含必要的依赖项。另外,我需要在 webapp 的运行器中使用几个类。虽然我可以在另一个模块中复制它们,但这是额外的工作和复杂性。

为了防止类路径扫描,我们将每个应用程序类移动到它的包中。请注意,当包具有父子关系时它不起作用:它们必须是兄弟姐妹。

要创建特定类的 bean,我们需要根据它们的性质依赖特定的注释:

  • 对于 JPA 实体,@EntityScan, 指向要扫描的包
  • 对于 JPA 存储库,@EnableJpaRepositories, 指向要扫描的包
  • 对于其他类,@Import指向要从中生成 bean 的类

最后一步是防止生成器应用程序启动网络服务器。您可以在启动应用程序时对其进行配置。

@SpringBootApplication
@EnableJpaRepositories("org.hazelcast.cqrs")                    // 1
@EntityScan("org.hazelcast.cqrs")                               // 2
public class GeneratorApplication {
    public static void main(String[] args) {
        new SpringApplicationBuilder(GeneratorApplication.class)
                .web(WebApplicationType.NONE)                   // 3
                .run(args);
    }
    // Command-line runner
}

  1. 扫描 JPA 存储库
  2. 扫描 JPA 实体
  3. 阻止 Web 服务器启动

它按预期工作,我们终于可以从设置中获益。

猜你喜欢