Axon聚合标识符类型转换器

编程问答 2022-08-15

问题描述

问题：：在聚合状态的Axon SpringBoot应用程序中，@AggregateIdentifier的类型为UUID，而Postgresql数据库列的类型为UUID。当坚持创建命令-标识符已成功存储。发送更新命令时，警告会上升，并且命令不会传递到聚合处理程序，因为@TargetAggregateIdentifier期望字符串类型为as described by Axon here：

java.lang.IllegalArgumentException：提供了错误类型的ID，用于 类.... MyAggregate。预期：类java.util.UUID，获得类java.lang.String

重新搜索：

  1. 有效的解决方案是将所有聚合标识符的域重构为String类型。归档的数据库@Id也应转换为varchar(36)类型，以存储UUID.toString()作为主键。主要缺点是效率低下：大小增加9倍，字符串读取速度慢。

  2. 最小的模板和折衷解决方案是将所有聚合标识符的域重构为String类型，并在持久化的同时使用javax.persistence.Converters在JPA层中将String转换为UUID：

    @Converter
public class UuidJpaConverter implements AttributeConverter<String,UUID> {

  @Override
  public UUID convertToDatabaseColumn(String uuid) {
    return fromString(uuid);
  }

  @Override
  public String convertToEntityAttribute(UUID uuid) {
    return uuid.toString();
  }
}

...

@Aggregate
@Entity
@IdClass(UuidKey.class)
public class MyAggregate implements Serializable {

  @AggregateIdentifier
  @Id
  private String uuid;
  ...
}

public class UuidKey implements Serializable {

  @Column(name = "uuid",nullable = false,updatable = false)
  @Convert(converter = UuidJpaConverter.class)
  private String uuid;
}

但是它导致：

o.h.engine.jdbc.spi.sqlExceptionHelper：错误：“ uuid”列的类型为uuid，但表达式的类型为bytea

  1. 使用Axon标识符转换器，但是它需要为每个聚合自定义GenericJpaRepository，并且实际上从不在断点上调用identifierConverter处理程序：

     @Configuration
 public class IdentifierConverter {

   @Bean
   public GenericJpaRepository<MyAggregate> aggregateJpaRepository(
       EntityManagerProvider provider,@Qualifier("eventBus") EventBus simpleEventBus) {

     GenericJpaRepository<MyAggregate> repository = GenericJpaRepository
         .builder(MyAggregate.class)
  ->       .identifierConverter(name -> UUID.fromString(name))
         .entityManagerProvider(provider)
         .eventBus(simpleEventBus)
         .build();

     return repository;
   }
 }

结果为：

o.h.engine.jdbc.spi.sqlExceptionHelper：错误：列“ uuid”属于 uuid类型，但表达式的字符类型不同

  1. 还有一个suggested universal GenericJpaRepository solution来查找聚合标识符的类型，并且-除非它已经是String-否则通过Spring转换服务对其进行转换。但是，当我们具有Axon自动配置功能并且期望bean支持Configurer时，尚不清楚将其绑定到配置器中的registeraggregateBeanDeFinitions的位置：

     final Class<?> aggregateIdentifierType = Stream.of( aggregateType.getDeclaredFields( ) )
 .filter( field -> field.isAnnotationPresent( AggregateIdentifier.class ) )
 .map( field -> field.getType( ) )
 .findFirst( )
 .orElseThrow( ( ) -> new IllegalStateException( "The aggregate '" + aggregate + "' does not have an identifier." ) );

 aggregateConf.configureRepository(
 c -> GenericJpaRepository.builder( aggregateType )
         .identifierConverter( string -> {
             if ( aggregateType == String.class ) {
                 return string;
             } else {
                 try {
                     final ConversionService conversionService = beanfactory.getBean( ConversionService.class );
                     return conversionService.convert( string,aggregateIdentifierType );
                 } catch ( final NoSuchBeanDeFinitionException ex ) {
                     throw new IllegalStateException( "Unable to convert String to aggregate identifier of type '" + aggregateIdentifierType.getName( ) + "'. A conversion service is missing." );
                 }
             }
         } )

 ...

 @Named
 final class MyIdConverter implements Converter<String,MyId> {

     ...

     @Override
     public MyId convert( final String source ) {
         return MyId.fromString( source );
     }

 }

问题：：如何在Postgresql数据库中保留聚合标识符的UUID类型-使用UUID作为@AggregateIdentifier或至少String的首选类型。另外，为什么at 2010 UUID was widely used in Axon仅当前支持String？

解决方法

说实话，@ Zon，您在这件事上已经深入了。不确定我是否能为您提供足够的帮助，但是无论如何，我都会努力的。

研究点1显然是最可行的解决方案，现在就可以正常工作。如果您要注意String与UUID相比的“效率低下”，那将是我的重任。因此，如果这绝对是不，则应继续进行调查。否则，它确实可以完成工作。

关于研究要点2和3，我相信您在PostgreSQL的方言方面遇到了问题，尽管我在这里不确定100％。尤其是PostgreSQL挥舞着几个“很棒”的类型，但是这些类型并不总是在所有情况下都能自动运行。我这里的“猜测”是基于强迫PostgreSQL使用BYTEA而不是OID的情况，以防万一您想降低Postgres的TOAST功能。如果您选择将Postgres用于事件存储，并且希望能够实际看到事件的内容，这将变得特别方便。例如，此博客文章指定了如何处理此问题。更重要的是，这篇blog帖子显示了如何例如调整所使用的方言。也许可以在解决方案2和3中为您服务？

在这种情况下，选项4应该是最合逻辑的解决方案。但是我从您的答复中得知，您目前没有使它起作用。将Axon与Spring结合使用时，SpringAxonAutoConfigurer（我相信您从中引用registerAggregateBeanDefinitions方法）将自动检查聚合上的可配置bean。它是根据@Aggregate中定义的字段（即Axon的Spring构造型注释）进行的。更具体地说，可以使用repository中的@Aggregate字段来定义要使用的存储库的Bean名称。

因此，您应该简单地能够为GenericJpaRepository bean提供所需的identifierConverter。可以在@Aggregate的{​​{1}}批注中指定该bean的名称，以便Axon的自动配置可以正确地对其进行选择。希望这对您有所帮助！

axonjavajavajpajpapostgresqlspring-boot