Hazelcast KeyValueRepository (spring-data-keyvalue) 不使用对象列表作为实体

Question

我们最近将我们的应用程序从 spring boot 2.1.6.RELEASE 升级到 2.6.14。与此同时，我们还升级了

spring-boot-starter-data-jpa

以兼容 spring-boot，这带来了这两个库的升级 `

• org.springframework.data:spring-data-keyvalue 从 2.1.9 到 2.6.10
• org.springframework.data:spring-data-commons 从 2.1.9 到 2.6.10 `

我们正在一个由 hazelcast 实体支持的应用程序中创建一个 KeyValueRepository（我们正在为 hazelcast 使用 v3.12）

//Creating an hazelcast entity with value as List of employees and key as a employeeId
@HazelcastEntity(backingStoreMapStoreClass = EmployeeCacheLoader::class)
interface TraderRepository : KeyValueRepository<List<EmployeeDetails>, String>

//EmployeeCacheLoader implementation
class TraderCacheLoader() : MapStore<String, List<EmployeeDetails>>() {

  override fun load(employeeId: String): List<EmployeeDetails> {
      //implementation to load an employee
   }

   override fun loadAll(requestList: Collection<String>): Map<String, List<EmployeeDetails>> {
      //implementation to load all
   }
}

这曾经在 spring-data-keyvalue v2.1.9 中正常工作而没有任何错误，但它不适用于 v2.6.10 并抛出此错误，

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'employeeRepository' defined in com.lab49.ca.salesandtrading.cache.EmployeerRepository defined in @EnableHazelcastRepositories declared on GenericRfqApp: Invocation of init method failed; nested exception is

 java.lang.IllegalArgumentException: Entity must not be 'null'.
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1804)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:620)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
    at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:936)
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583)
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:745)
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:423)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:307)
    at com.lab49.ca.ionapp.spring.ion20.ION20SpringApplicationModule$SpringApplicationService$1.onSuccess(ION20SpringApplicationModule.java:162)
    at com.lab49.ca.ionapp.spring.ion20.ION20SpringApplicationModule$SpringApplicationService$1.onSuccess(ION20SpringApplicationModule.java:127)
    at com.iontrading.isf.commons.async.impl.a$1.run(AsyncResultPromiseImpl.java:131)
    at com.iontrading.isf.executors.impl.monitoring.g.run(MonitoredRunnable.java:18)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalArgumentException: Entity must not be 'null'.
    at org.springframework.util.Assert.notNull(Assert.java:201)
    at org.springframework.data.hazelcast.repository.support.HazelcastRepositoryFactory.getEntityInformation(HazelcastRepositoryFactory.java:91)
    at org.springframework.data.keyvalue.repository.support.KeyValueRepositoryFactory.getTargetRepository(KeyValueRepositoryFactory.java:132)
    at org.springframework.data.repository.core.support.RepositoryFactorySupport.getRepository(RepositoryFactorySupport.java:325)
    at org.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.lambda$afterPropertiesSet$5(RepositoryFactoryBeanSupport.java:323)
    at org.springframework.data.util.Lazy.getNullable(Lazy.java:231)
    at org.springframework.data.util.Lazy.get(Lazy.java:115)
    at org.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.afterPropertiesSet(RepositoryFactoryBeanSupport.java:329)
    at org.springframework.data.keyvalue.repository.support.KeyValueRepositoryFactoryBean.afterPropertiesSet(KeyValueRepositoryFactoryBean.java:135)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1863)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1800)
    ... 19 more

调试后，我们发现下面的代码给出了 null，因为没有由 spring-data-keyvalue 为 java.util.List 创建的映射上下文，而之前的情况并非如此。

//domainClass will be java.util.List
PersistentEntity<T, ?> entity = (PersistentEntity<T, ?>) keyValueOperations.getMappingContext()
      .getPersistentEntity(domainClass)

升级后有什么办法可以解决这个问题吗？

我们已经尝试调试 spring-data-keyvalue 库的新旧实现，发现实现由于某种原因发生了变化。所以要么我们现在不支持它，要么有办法支持它。

新的实现（v2.6.10）

File Name: AbstractMappingContext.java

//code
Line 178: if (!this.shouldCreatePersistentEntityFor(type) is returing true and hence the result

//In this function the java.util.list is treated as a simple type which seems wrong to me
protected boolean shouldCreatePersistentEntityFor(TypeInformation<?> type) {
    if (this.simpleTypeHolder.isSimpleType(type.getType())) {
      return false; //it reaches here
    } else if (NullableWrapperConverters.supports(type.getType())) {
      return false;
    } else {
      return !KotlinDetector.isKotlinType(type.getType()) || KotlinReflectionUtils.isSupportedKotlinClass(type.getType());
    }
  }

旧的实现

//This function returns true and hence there is a mapping contecxt added for that domain type
protected boolean shouldCreatePersistentEntityFor(TypeInformation<?> type) {
    if (this.simpleTypeHolder.isSimpleType(type.getType())) {
      return false;
    } else {
      return !org.springframework.data.util.ReflectionUtils.isKotlinClass(type.getType()) || org.springframework.data.util.ReflectionUtils.isSupportedKotlinClass(type.getType());
    }
  }