Data Grid Spring Boot スターター
Data Grid を使用した Spring Boot アプリケーションのビルド
概要
前書き
Data Grid スターターは、Data Grid とシームレスに対話するために必要なすべての Spring Boot プロジェクトを含む、管理された推移的な依存関係のセットを提供します。
Data Grid Spring Boot スターターは、Spring Boot を使い始めるための便利な方法を提供しますが、これはオプションです。Spring Boot で Data Grid を使用するには、必要な依存関係を追加するだけです。
第1章 プロジェクトの設定
Data Grid Spring Boot スターターの依存関係をプロジェクトに追加します。
1.1. Spring Boot Starter バージョン
Data Grid は Spring Boot 1.5.x および 2.x をサポートします。Spring Boot 1.5.x の場合は、Spring 4 の依存関係を使用します。Spring Boot 2.x の場合は、Spring 5 の依存関係を使用します。
-
Spring Boot 1.5.x:
${version.infinispan.starter}
を 1.0.7.Final-redhat-00021
に置き換えます。 -
Spring Boot 2.x:
${version.infinispan.starter}
を2.1.10.Final-redhat-00007
に置き換えます。
1.2. 使用モードの依存関係の追加
Data Grid は、使用モードごとに異なる依存関係を提供します。次のいずれかを pom.xml
ファイルに追加します。
埋め込みモード
<dependency> <groupId>org.infinispan</groupId> <artifactId>infinispan-spring-boot-starter-embedded</artifactId> <version>${version.infinispan.starter}</version> </dependency>
リモートクライアント/サーバーモード
<dependency> <groupId>org.infinispan</groupId> <artifactId>infinispan-spring-boot-starter-remote</artifactId> <version>${version.infinispan.starter}</version> </dependency>
Data Grid Spring Boot スターターは、Red Hat OpenShift Application Runtimes などの他のプロジェクトとは異なる Spring Boot バージョンを使用します。他のプロジェクトと互換性を確保するために特定の Spring Boot バージョンを使用する場合は、プロジェクトに正しい依存関係を追加する必要があります。
第2章 埋め込みモードでの実行
インメモリーデータストレージ用にプロジェクトに Data Grid ライブラリーを埋め込みます。
2.1. EmbeddedCacheManager Bean の追加
infinispan-spring-boot-starter-embedded
をプロジェクトのクラスパスに追加して、埋め込みモードを有効にします。このスターターは、デフォルトでクラスパス上の
infinispan-spring-boot-starter-remote
で Remote Client/Server モードで動作します。次の例のように、Spring
@Autowired
アノテーションを使用して、Java 構成クラスにEmbeddedCacheManagerBean
を含めます。private final EmbeddedCacheManager cacheManager; @Autowired public YourClassName(EmbeddedCacheManager cacheManager) { this.cacheManager = cacheManager; }
これで、埋め込みモードで Data Grid を使用できるようになりました。以下は簡単な例です。
cacheManager.getCache("testCache").put("testKey", "testValue"); System.out.println("Received value from cache: " + cacheManager.getCache("testCache").get("testKey"));
2.2. キャッシュマネージャーの設定 Bean
以下の設定 Bean を使用してキャッシュマネージャーをカスタマイズします。
-
InfinispanGlobalConfigurer
-
InfinispanCacheConfigurer
-
設定
-
InfinispanConfigurationCustomizer
InfinispanGlobalConfigurationCustomizer
注記InfinispanGlobalConfigurerBean
は 1 つしか作成できません。ただし、他の Bean を使用して複数の構成を作成できます。
InfinispanCacheConfigurer Bean
@Bean public InfinispanCacheConfigurer cacheConfigurer() { return manager -> { final Configuration ispnConfig = new ConfigurationBuilder() .clustering() .cacheMode(CacheMode.LOCAL) .build(); manager.defineConfiguration("local-sync-config", ispnConfig); }; }
設定 Bean
次のように、設定するキャッシュに Bean 名をリンクします。
@Bean(name = "small-cache") public org.infinispan.configuration.cache.Configuration smallCache() { return new ConfigurationBuilder() .read(baseCache) .memory().size(1000L) .memory().evictionType(EvictionType.COUNT) .build(); } @Bean(name = "large-cache") public org.infinispan.configuration.cache.Configuration largeCache() { return new ConfigurationBuilder() .read(baseCache) .memory().size(2000L) .build(); }
カスタマイザー Bean
@Bean public InfinispanGlobalConfigurationCustomizer globalCustomizer() { return builder -> builder.transport().clusterName(CLUSTER_NAME); } @Bean public InfinispanConfigurationCustomizer configurationCustomizer() { return builder -> builder.memory().evictionType(EvictionType.COUNT); }
2.3. Spring キャッシュサポートの有効化
@EnableCaching
アノテーションをアプリケーションに追加し、Spring Cache のサポートを有効にします。
このスターターが EmbeddedCacheManager
Bean を検出すると、Spring Cache の実装を提供する新しい SpringEmbeddedCacheManager
をインスタンス化します。
第3章 サーバーモードでの実行
カスタム TCP バイナリーワイヤプロトコルである Hot Rod を使用して、リモートの Data Grid クラスターからデータを保存および取得します。
3.1. RemoteCacheManager の設定
スターターが
RemoteCacheManager
Bean を作成できるように Data Grid サーバーの場所を指定します。このスターターは、最初にクラスパスの
hotrod-client.properties
ファイルからサーバーを見つけようとします。見つからない場合は、スターターはapplication.properties
ファイルからサーバーの場所の特定を試みます。hotrod-client.properties
:infinispan.client.hotrod.server_list=127.0.0.1:11222
application.properties
:infinispan.remote.server-list=127.0.0.1:11222
Spring
@Autowired
アノテーションを使用して、独自のカスタムキャッシュマネージャークラスをアプリケーションに含めます。private final RemoteCacheManager cacheManager; @Autowired public YourClassName(RemoteCacheManager cacheManager) { this.cacheManager = cacheManager; }
3.2. キャッシュマネージャーの設定 Bean
次の設定 Bean を使用してキャッシュマネージャーをカスタマイズします。
-
InfinispanRemoteConfigurer
-
設定
InfinispanRemoteCacheCustomizer
注記InfinispanRemoteConfigurerBean
は 1 つしか作成できません。ただし、他の Bean を使用して複数の構成を作成できます。
InfinispanRemoteConfigurer Bean
@Bean public InfinispanRemoteConfigurer infinispanRemoteConfigurer() { return () -> new ConfigurationBuilder() .addServer() .host("127.0.0.1") .port(12345) .build(); }
設定 Bean
@Bean public org.infinispan.client.hotrod.configuration.Configuration customConfiguration() { new ConfigurationBuilder() .addServer() .host("127.0.0.1") .port(12345) .build(); }
InfinispanRemoteCacheCustomizer Bean
@Bean public InfinispanRemoteCacheCustomizer customizer() { return b -> b.tcpKeepAlive(false); }
@Ordered
アノテーションを使用して、カスタマイザーを特定の順序で適用します。
3.3. Spring キャッシュサポートの有効化
@EnableCaching
アノテーションをアプリケーションに追加し、Spring Cache のサポートを有効にします。
Data Grid スターターが RemoteCacheManager
Bean を検出すると、Spring Cache の実装を提供する新しい SpringRemoteCacheManager
をインスタンス化します。
3.4. Data Grid 統計の公開
Data Grid は、Spring Boot Actuator をサポートして、キャッシュ統計をメトリクスとして公開します。
Actuator を使用するには、以下を pom.xml
ファイルに追加します。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> <version>${version.spring.boot}</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>${version.spring.boot}</version> </dependency>
次に、プログラムまたは宣言的に、適切なキャッシュインスタンスの統計をアクティベートする必要があります。
プログラムで
@Bean public InfinispanCacheConfigurer cacheConfigurer() { return cacheManager -> { final org.infinispan.configuration.cache.Configuration config = new ConfigurationBuilder() .jmxStatistics().enable() .build(); cacheManager.defineConfiguration("my-cache", config); }; }
宣言
<local-cache name="my-cache" statistics="true"/>
Spring Boot Actuator レジストリーは、アプリケーションの起動時にキャッシュインスタンスをバインドします。キャッシュを動的に作成する場合は、次のように、 CacheMetricsRegistrarBean
を使用してキャッシュを Actuator レジストリーにバインドする必要があります。
@Autowire CacheMetricsRegistrar cacheMetricsRegistrar; @Autowire CacheManager cacheManager; ... cacheMetricsRegistrar.bindCacheToRegistry(cacheManager.getCache("my-cache"));
第4章 SpringSession の使用
4.1. Spring Session サポートの有効化
Data Grid Spring Session サポートは SpringRemoteCacheManager
と SpringEmbeddedCacheManager
をもとに構築されます。このスターターは、デフォルトでこれらの Bean を生成します。
プロジェクトで Spring セッションを使用するには、以下を実行します。
- このスターターをプロジェクトに追加します。
- Spring Session をクラスパスに追加します。
次のアノテーションを設定に追加します。
-
@EnableCaching
-
@EnableInfinispanRemoteHttpSession
-
@EnableInfinispanEmbeddedHttpSession
-
第5章 アプリケーションのプロパティー
application.properties
または application.yaml
を使用してプロジェクトを構成します。
# List Infinispan or Data Grid servers by IP address or hostname at port 11222. infinispan.remote.server-list=127.0.0.1:11222 # # Embedded Properties - Uncomment properties to use them. # # Enables Infinispan or Data Grid capabilities in your application. # Values are true (default) or false. #infinispan.embedded.enabled = # Sets the Spring state machine ID. #infinispan.embedded.machineId = # Sets the name of the Infinispan or Data Grid cluster. #infinispan.embedded.clusterName = # Specifies a XML configuration file that takes priority over the global # configuration bean or any configuration customizer. #infinispan.embedded.configXml = # # Server Properties - Uncomment properties to use them. # # Specifies a custom filename for Hot Rod client properties. #infinispan.remote.clientProperties = # Enables remote Infinispan or Data Grid servers. # Values are true (default) or false. #infinispan.remote.enabled = # Defines a comma-separated list of Infinispan or Data Grid servers # in this format: `host1[:port],host2[:port]`. #infinispan.remote.serverList = # Sets a timeout value, in milliseconds, for socket connections. #infinispan.remote.socketTimeout = # Sets a timeout value for initializing connections with Infinispan or # Data Grid servers. #infinispan.remote.connectTimeout = # Sets the maximum number of attempts to connect to Infinispan or # Data Grid servers. #infinispan.remote.maxRetries =