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 プロセッサーで Protobuf スキーマを生成します。

  生成された Protobuf スキーマは、target/<schemaFilePath>/ ディレクトリーにあります。

• CREATE 権限を持つユーザーを用意します。

  注記

  セキュリティー認可には、スキーマを追加するための CREATE 権限が必要です。デフォルト設定では、少なくとも deployer のロールが必要です。

• 任意のブラウザーで Data Grid コンソールを開き、Schema タブを選択してから Add Protobuf schema を選択します。

• Data Grid コマンドラインインターフェイス (CLI) から --upload= 引数を指定して schema コマンドを使用します。

  schema --upload=person.proto person

• REST API を使用して、POST 要求のペイロードに Protobuf スキーマを含めます。

  POST/rest/v2/schemas/<schema_name>

• 以下の例のように、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 ファイルも追加する必要があります。