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

流程

• 将 protostream-processor 添加到 maven-compiler-plugin 的注解处理器配置中，到 pom.xml。

  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>...</version>
        <configuration>
          <annotationProcessorPaths>
            <annotationProcessorPath>
              <groupId>org.infinispan.protostream</groupId>
              <artifactId>protostream-processor</artifactId>
              <version>...</version>
            </annotationProcessorPath>
          </annotationProcessorPaths>
        </configuration>
      </plugin>
    </plugins>
  </build>

• UNRESTRICTED: 不执行任何检查
• LENIENT: 强制执行规则的子集
• STRICT: 所有规则都被强制执行（默认）

先决条件

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

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

• 具有 CREATE 权限的用户。

  注意

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

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

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

  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 服务器在启动时注册 Protobuf 模式。但是，您必须将存档添加到每台服务器安装中，因为模式不会保存在 ___protobuf_metadata 缓存中，或者在集群中自动分发。

  注意

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