Как кэшировать PageImpl с помощью Spring Data Geode? - PullRequest
Новая
       77

Как кэшировать PageImpl с помощью Spring Data Geode?

0 голосов
/ 13 мая 2018

При попытке кэшировать ответ PageImpl из Spring Data JpaRepository с использованием Spring Data Geode, он не может кэшировать результат со следующей ошибкой: 

Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.domain.PageImpl]: No default constructor found; nested exception is java.lang.NoSuchMethodException: org.springframework.data.domain.PageImpl.<init>()
at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:127) ~[spring-beans-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.data.convert.ReflectionEntityInstantiator.createInstance(ReflectionEntityInstantiator.java:64) ~[spring-data-commons-2.0.7.RELEASE.jar:2.0.7.RELEASE]
at org.springframework.data.convert.ClassGeneratingEntityInstantiator.createInstance(ClassGeneratingEntityInstantiator.java:86) ~[spring-data-commons-2.0.7.RELEASE.jar:2.0.7.RELEASE]
at org.springframework.data.gemfire.mapping.MappingPdxSerializer.fromData(MappingPdxSerializer.java:422) ~[spring-data-gemfire-2.0.7.RELEASE.jar:2.0.7.RELEASE]
at org.apache.geode.pdx.internal.PdxReaderImpl.basicGetObject(PdxReaderImpl.java:741) ~[geode-core-9.1.1.jar:?]
at org.apache.geode.pdx.internal.PdxReaderImpl.getObject(PdxReaderImpl.java:682) ~[geode-core-9.1.1.jar:?]
at org.apache.geode.internal.InternalDataSerializer.readPdxSerializable(InternalDataSerializer.java:3054) ~[geode-core-9.1.1.jar:?]

Похоже, что MappingPdxSerializer ищет конструктор по умолчаниюно не находит его для класса PageImpl.

Вот maven pom для моих зависимостей: 

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.0.BUILD-SNAPSHOT</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
    <spring-cloud.version>Finchley.BUILD-SNAPSHOT</spring-cloud.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-logging</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-log4j2</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-cache</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-rest</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-hateoas</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-gemfire</artifactId>
    </dependency>
    <dependency>
        <groupId>javax.cache</groupId>
        <artifactId>cache-api</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-text</artifactId>
        <version>1.3</version>
    </dependency>
    <dependency>
        <groupId>commons-codec</groupId>
        <artifactId>commons-codec</artifactId>
        <version>1.11</version>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.6</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-configuration-processor</artifactId>
        <optional>true</optional>
    </dependency>

    <dependency>
        <groupId>org.postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>42.2.2</version>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

Я использую JpaRepository: 

@RepositoryRestResource
public interface RecordRepository extends JpaRepository<Record, Long>
{
    @Override
    @CacheEvict(cacheNames = { "Records" })
    <S extends Record> S save(S s);

    @Override
    @Cacheable(value = "Records")
    Optional<Record> findById(Long id);

    @Override
    @Cacheable(value = "Records", key = "#pageable.pageNumber + '.' + #pageable.pageSize + '.records'")
    Page<Record> findAll(Pageable pageable);

    @Override
    @Cacheable(value = "Records")
    Record getOne(Long aLong);
}

Код, используемый для вызова результата постраничного хранения в репозитории: 

int PAGE=0,PAGE_SIZE=100;
        Page<Record> recordPage;
        do {
            recordPage = recordRepository.findAll(PageRequest.of(PAGE, PAGE_SIZE));
            log.info("Retrieved page: [{}]", recordPage);
        } while (recordPage.hasNext());

Мне кажется, что это может быть возможная ошибка с MappingPdxSerializer, но я не уверен на 100%.Любая помощь в решении этой проблемы будет потрясающей!

Спасибо

1 Ответ

0 голосов
/ 14 мая 2018

Почему вы считаете, что это возможная ошибка с Spring Data Geode's (SDG) o.s.d.g.mapping.MappingPdxSerializer?

Довольно распространено и даже ожидается, что не все объекты, прошедшие через SDG MappingPdxSerializer, будут иметь конструктор по умолчанию (т.е. public, no-arg).

При использовании таких типов в вашем приложении (например, как класс SD PageImpl) и экземпляр этого типа считывается из Apache Geode (например, get(key)), объект десериализуется и восстанавливается в (Region ) операция доступа к данным (при условии, что атрибут конфигурации read-serialized Apache Geode не установлен на true ; что вызывает другие проблемы и не рекомендуется в этом случае), тогда вам необходимо зарегистрировать EntityInstantiator , который сообщает SDG MappingPdxSerializer, как создать экземпляр объекта, используя соответствующий конструктор.

«Соответствующий» конструктор определяется постоянным объектом PreferredConstructor, который оценивается во время оценки типа инфраструктурой отображения SD и может быть задан с помощью @PersistenceContructor аннотация, если необходимо. Это полезно в тех случаях, когда вы используете один из стандартных типов EntityIntantiator SD, например ReflectionEntityInstantiator, и тип вашего домена приложения имеет более 1 конструктора, отличного от используемого по умолчанию.

Таким образом, вы можете зарегистрировать 1 или более EntityInstantiator объектов для каждого объекта домена приложения по типу, используя составной класс EntityIntantiatiors, возможно с «отображением» между доменом приложения объект Class типа (например, Page) и EntityInstantiator, а затем регистр EntityInstantiators на SDG MappingPdxSerializer.

Конечно, вам нужно убедиться, что настроенный MappingPdxSerializer используется Apache Geode ... 

@Configuration
class ApacheGeodeConfiration {

  @Bean
  MappingPdxSerializer pdxSerializer() {

    Map<Class<?>, EntityInstantiator> customInstantiators = new HashMap<>();

    customInstantiators.put(Page.class, new MyPageEntityInstantiator());
    customInstantiators.put...

    MappingPdxSerializer pdxSerializer = 
      MappingPdxSerializer.newMappingPdxSerializer();

    pdxSerializer.setGemfireInstantiators(
      new EntityInstantiators(customInstantiators));

    return pdxSerializer;
  }

  @Bean
  CacheFactoryBean gemfireCache(MappingPdxSerializer pdxSerializer) {

    CacheFactoryBean gemfireCache = new CacheFactoryBean();

    gemfireCache.setPdxSerializer(pdxSerializer);
    gemfireCache.set...

    return gemfireCache;
  }

  ...
}

Надеюсь, это поможет!

-j

...