2.2. 创建序列化上下文初始化器

流程

• 将 protostream-processor 依赖项添加到带有 提供的 范围的 pom.xml 中。

  注意

  这个依赖项只在编译时需要，因此您应该使用 所提供的 范围或将其标记为可选。您还应确保 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>

  Copy to Clipboard Toggle word wrap

先决条件

• 使用 ProtoStream 处理器生成 Protobuf 模式。

  您可以在 target/<schemaFilePath>/ 目录中找到生成的 Protobuf 模式。

• 具有 CREATE 权限的用户。

  注意

  安全授权需要 CREATE 权限来添加模式。使用默认设置时，您至少需要 deployer 角色。

• 在任何浏览器中打开 Data Grid Console，选择 Schema 选项卡，然后添加 Protobuf 模式。

• 使用带有 Data Grid 命令行界面(CLI)中的 --upload= 参数的 schema 命令。

  schema --upload=person.proto person

  Copy to Clipboard Toggle word wrap

• 使用 REST API 在 POST 请求有效负载中包含 Protobuf 模式。

  POST/rest/v2/schemas/<schema_name>

  Copy to Clipboard Toggle word wrap

• 使用带有 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());
    }
  }

  Copy to Clipboard Toggle word wrap

• 添加带有 SerializationContextInitializer 实现的 JAR 文件，并将自定义类添加到 $114G_HOME/server/lib 目录中。

  当您执行此操作时，Data Grid 服务器在启动时注册您的 Protobuf 模式。但是，您必须将存档添加到每台服务器安装中，因为 schema 不会保存在 ___protobuf_metadata 缓存中，或者在集群中自动分发。

  注意

  如果您需要 Data Grid Server 执行任何 application/x-protostream 到 application/x-java-object 转换，则必须执行此操作，在这种情况下，您必须为 POJO 添加任何 JAR 文件。