2.2. シリアル化のコンテキストイニシャライザーの作成

手順

• provided スコープで protostream-processor 依存関係を pom.xml に追加します。

  注記

  この依存関係はコンパイル時にのみ必要です。そのため、provided スコープを使用するか、オプションとしてマークする必要があります。また、protostream-processor が推移的な依存関係として伝播されないようにする必要があります。

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.infinispan</groupId>
        <artifactId>infinispan-bom</artifactId>
        <version>${version.infinispan}</version>
        <type>pom</type>
      </dependency>
    </dependencies>
  </dependencyManagement>
  
  <dependencies>
    <dependency>
      <groupId>org.infinispan.protostream</groupId>
      <artifactId>protostream-processor</artifactId>
      <scope>provided</scope>
    </dependency>
  </dependencies>

前提条件

• ProtoStream プロセッサーを使用して SerializationContextInitializer 実装を生成している。

  ビルドの完了後に、生成された Protobuf スキーマを target/<schemaFilePath>/ ディレクトリーに見つけることができます。

• 生成された Protobuf スキーマを、Data Grid コマンドラインインターフェイス (CLI)、REST インターフェイス、または ProtobufMetadataManager JMX MBean を使用して専用の ___protobuf_metadata キャッシュに追加します。

  この方法では、Data Grid がスキーマを自動的にクラスター全体に分散できるようにします。

  注記

  キャッシュのセキュリティー承認を有効にする場合、ユーザーは ___protobuf_metadata キャッシュにスキーマを追加する CREATE パーミッションを持っている必要があります。デフォルトの承認設定を使用する場合は、ユーザーに少なくとも deployer ロールを割り当てます。

• 以下の例のように、Hot Rod クライアントで生成された SerializationContextInitializer 実装を使用して、Protobuf スキーマを登録します。

  /**
   * Register generated Protobuf schema with Data Grid Server.
   * This requires the RemoteCacheManager to be initialized.
   *
   * @param initializer The serialization context initializer for the schema.
   */
  private void registerSchemas(SerializationContextInitializer initializer) {
    // Store schemas in the '___protobuf_metadata' cache to register them.
    // Using ProtobufMetadataManagerConstants might require the query dependency.
    final RemoteCache<String, String> protoMetadataCache = remoteCacheManager.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
    // Add the generated schema to the cache.
    protoMetadataCache.put(initializer.getProtoFileName(), initializer.getProtoFile());
  
    // Ensure the registered Protobuf schemas do not contain errors.
    // Throw an exception if errors exist.
    String errors = protoMetadataCache.get(ProtobufMetadataManagerConstants.ERRORS_KEY_SUFFIX);
    if (errors != null) {
      throw new IllegalStateException("Some Protobuf schema files contain errors: " + errors + "\nSchema :\n" + initializer.getProtoFileName());
    }
  }

• SerializationContextInitializer 実装およびカスタムクラスを持つ JAR ファイルを $RHDG_HOME/server/lib ディレクトリーに追加します。

  これを実行すると、Data Grid Server は起動時に Protobuf スキーマを登録します。ただし、スキーマは ___protobuf_metadata キャッシュに保存されたり、クラスター全体で自動的に分散されたりしないため、アーカイブを各サーバーインストールに追加する必要があります。

  注記

  Data Grid Server が application/x-protostream から application/x-java-object への変換を実施する必要がある場合、これを実行する必要があります。この場合、POJO 用の JAR ファイルも追加する必要があります。