Блог

Могу ли я узнать, как реализовать GemFire / Geode CacheListener в моем приложении Spring Boot?

Я хочу обнаруживать удаление и обновлять в моем регионе «Люди». Я использую org.springframework.data:зависимость spring-data-gemfire в Maven. Нужно ли мне включать какие-либо аннотации?

 @SpringBootApplication  
@ClientCacheApplication(name = "AccessingDataGemFireApplication", logLevel = "error")
@EnableEntityDefinedRegions(basePackageClasses = People.class)
@EnableGemfireRepositories  
public class Application
{
....
}
  

По-видимому, в последней версии GA CacheListener по-прежнему отсутствует поддержка аннотаций для обратных вызовов GemFire ( CacheLoader , spring-data-gemfire и т.д.). Некоторое время назад для реализации этого улучшения был создан тикет JIRA SGF-453, вы можете добавить себя в качестве наблюдателя, чтобы получать обновления о ходе выполнения.

Однако вы можете вручную связать a CacheListener с регионом, используя cache-listener элемент xml, как показано в документации. Или, еще один вариант, вы можете настроить прослушиватель непосредственно через API с помощью RegionFactoryBean.setListeners .

В качестве примера следующий класс запускает локальный сервер GemFire со встроенным локатором, создает REPLICATED регион с именем People и связывает с ним пользовательский CacheListener , который в основном выводит сообщение каждый раз, когда создается или удаляется запись:

 @EnableLogging
@EnableStatistics
@SpringBootApplication
@CacheServerApplication
public class GemFireServerApplication {

  public static void main(String[] args) {
    SpringApplication.run(GemFireServerApplication.class, args);
  }

  @EnableLocator
  @Profile("!clustered")
  @EnableManager(start = true)
  @Configuration
  static class LonerConfiguration { }

  @Bean("People")
  public ReplicatedRegionFactoryBean<?, ?> replicatedRegion(GemFireCache gemfireCache) {
    ReplicatedRegionFactoryBean<?, ?> replicatedRegion = new ReplicatedRegionFactoryBean<>();
    replicatedRegion.setCache(gemfireCache);
    replicatedRegion.setClose(false);
    replicatedRegion.setPersistent(false);
    replicatedRegion.setCacheListeners(new CacheListener[] { myCacheListener() });

    return replicatedRegion;
  }

  @Bean
  public CacheListener<?, ?> myCacheListener() {
    return new CacheListenerAdapter<String, String>() {
      @Override
      public void afterDestroy(EntryEvent<String, String> event) {
        System.out.println(String.format("AfterDestroy invoked for key %s !", event.getKey()));
        super.afterDestroy(event);
      }

      @Override
      public void afterCreate(EntryEvent<String, String> event) {
        System.out.println(String.format("AfterCreate invoked for key %s !", event.getKey()));
        super.afterCreate(event);
      }
    };
  }
}
  

Надеюсь, это поможет. Приветствия.

Поскольку вы используете более удобную @EnableEntityDefinedRegions аннотацию SDG (которая рекомендуется, особенно для простого UC), то вы явно не определяете определение компонента Region (например, используя ReplicationRegionFactoryBean или PartitionedRegionFactoryBean классы SDG), как это сделал Хуан Рамос в своем ответе.

В этом случае вы можете объявить a RegionConfigurer для изменения региона «Люди», а затем применить ту же технику, которую Хуан использовал в своем ответе, для предоставления CacheListener .

Например:

 @SpringBootApplication
@EnableEntityDefinedRegions(basePackageClasses = People.class)
@EnableGemfireRepositories(..)
class MySpringBootGemFireApplication {

  @Bean
  RegionConfigurer peopleRegionConfigurer(
      CacheListener<Long, Person> peopleRegionListener) {

    return new RegionConfigurer() {

      @Override
      public void configure(String beanName, 
          ClientRegionFactoryBean<Long, Person> regionFactory) {

        regionFactoryBean.setCacheListeners(
          new CacheListener[] { peopleRegionListener });
    };
  }

  @Bean
  CacheListenerAdapter<Long, Person> peopleRegionListener() {

    return new CacheListenerAdapter<>() {

        public void afterDestroy(EntryEvent<Long, Person> event) { ... }

        public void afterUpdate(EntryEvent<Long, Person> event) { ... }
    };
  }
}
  

ПРИМЕЧАНИЕ: при использовании Spring Boot, GemFire Starter ( org.springframework.geode:spring-gemfire-starter ), @ClientCacheApplication аннотация определенно не требуется, поскольку SBDG автоматически настраивает ClientCache экземпляр по умолчанию (см. Здесь).

Примечание: Кроме того, если ваше приложение GemfireRepositories находится в подпакете ниже основного класса Spring Boot application, вам также не нужно явно объявлять @EnableGemfireRepositories , поскольку SBDG автоматически настраивает инфраструктуру хранилища SD для вас (см. Здесь).

Для получения дополнительной информации о конфигураторах SDG смотрите здесь.

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