缓存编码和 Marshalling

流程

• 为键和值指定 application/x-protostream 介质类型。

• accept: text/plain; charset=UTF-8 用于读取操作。
• content-Type: text/plain; charset=UTF-8 或 Key-Content-Type: text/plain; charset=UTF-8 用于写入操作。

• 接受：用于读取操作的应用程序/json。
• content-Type：用于写入操作的 application/json。

• byte[]
• BYTE
• 字符串
• 整数
• Long
• �
• 浮点值
• 布尔值
• 短
• 字符
• java.util.Date
• java.time.Instant

• java.math.BigDecimal
• java.math.BigInteger
• java.util.UUID

• 使用 AutoProtoSchemaBuilder 注解的 dependentOn 元素指定 CommonTypesSchema 和 CommonContainerTypesSchema 类。

• 使用 AutoProtoSchemaBuilder 注解的 includeClasses 元素指定所需的适配器类

• @ProtoFactory 结构或方法的字段名称和参数必须与对应的 Protobuf 消息匹配，但顺序并不重要。
• 如果您没有将 @ProtoFactory 注解构造器添加到类，则该类必须具有默认的 no-argument 构造器，否则编译过程中出现错误。

• 注释类，注解类必须具有一个 @ProtoFactory 注解工厂方法，用于每个字段的 marshalled 类和注解的 accessor 方法。这些方法可以是 instance 或 static 方法，其第一个参数必须是 marshalled 类。
• 目标 enum 中必须存在具有相同命名的 enum 值。

流程

• 将 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

先决条件

• 使用 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

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

  POST/rest/v2/schemas/<schema_name>

  Copy to clipboard

• 使用带有 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

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

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

  注意

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