Data Grid 開発者ガイド

手順

1. キーに text/plain を使用するようにキャッシュエンコーディングを設定します。

2. application/x-java- object 以外の適切な MediaType を値に指定します。

   Memcached クライアントは、鍵を text/plain としてのみ処理できます。値は、Data Grid が byte[] として保存する MediaType にすることができます。これは Protobuf、マーシャリングされた Java オブジェクト、またはテキストベースの形式になります。

   <encoding>
     <key media-type="text/plain"/>
     <value media-type="application/x-protostream"/>
   </encoding>

   Copy to Clipboard Toggle word wrap

手順

1. protostream-processor 依存関係を pom.xml に追加します。

   <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>
       <!--
         This dependency should be declared in the "provided" scope or made "optional"
         because it is a compile-only dependency and is not required at runtime.
         Transitive propagation of this dependency should be also be avoided.
       -->
       <scope>provided</scope>
     </dependency>
   </dependencies>

   Copy to Clipboard Toggle word wrap

2. マーシャリングする Java オブジェクトに @ProtoField と@ProtoFactory アノテーションを付けます。

   Author.java

   import org.infinispan.protostream.annotations.ProtoFactory;
   import org.infinispan.protostream.annotations.ProtoField;
   
   public class Author {
      @ProtoField(number = 1)
      final String name;
   
      @ProtoField(number = 2)
      final String surname;
   
      @ProtoFactory
      Author(String name, String surname) {
         this.name = name;
         this.surname = surname;
      }
      // public Getter methods omitted for brevity
   }

   Copy to Clipboard Toggle word wrap

   Book.java

   import org.infinispan.protostream.annotations.ProtoFactory;
   import org.infinispan.protostream.annotations.ProtoField;
   ...
   
   public class Book {
      @ProtoField(number = 1)
      final String title;
   
      @ProtoField(number = 2)
      final String description;
   
      @ProtoField(number = 3, defaultValue = "0")
      final int publicationYear;
   
      @ProtoField(number = 4, collectionImplementation = ArrayList.class)
      final List<Author> authors;
   
      @ProtoFactory
      Book(String title, String description, int publicationYear, List<Author> authors) {
         this.title = title;
         this.description = description;
         this.publicationYear = publicationYear;
         this.authors = authors;
      }
      // public Getter methods omitted for brevity
   }

   Copy to Clipboard Toggle word wrap

3. SerializationContextInitializer を拡張し、 @AutoProtoSchemaBuilder アノテーションが付けられたインターフェイスを定義します。

   @AutoProtoSchemaBuilder(
         includeClasses = {
               Book.class,
               Author.class,
         },
         schemaFileName = "library.proto", 

   1

   
         schemaFilePath = "proto/", 

   2

   
         schemaPackageName = "book_sample")
   interface LibraryInitializer extends SerializationContextInitializer {
   }

   Copy to Clipboard Toggle word wrap

   1

   生成された .proto スキーマファイルに名前を付けます。

   2

   スキーマファイルが生成される target/classes の下にパスを設定します。

手順

1. マーシャリングする Java オブジェクトの構造化表現を提供する Protobuf スキーマの .proto ファイルを作成します。

   package book_sample;
   
   message Book {
       optional string title = 1;
       optional string description = 2;
       optional int32 publicationYear = 3; // no native Date type available in Protobuf
   
       repeated Author authors = 4;
   }
   
   message Author {
       optional string name = 1;
       optional string surname = 2;
   }

   Copy to Clipboard Toggle word wrap

   前述の .library.proto ファイルは、book_sample パッケージに含まれる Book という名前のエンティティー (Protobuf メッセージタイプ) を定義します。Book は、プリミティブ型のいくつかのフィールドと、Author メッセージタイプである authors という名前のアレイ (Protobuf 反復可能フィールド) を宣言します。

   • メッセージをネストできますが、結果的に構造は厳密にツリーであり、グラフではありません。
   • 型の継承はできません。
   • コレクションはサポート対象外ですが、フィールドを繰り返してアレイをエミュレートできます。

2. org.infinispan.protostream.MessageMarshaller インターフェイスを使用して、クラスのマーシャラーを実装します。

   注記

   MessageMarshaller インターフェイスが非推奨になりました。

   次のバージョンの Data Grid は、外部のサードパーティー Java オブジェクトクラスに @ProtoAdaptor アノテーションを使用するアダプタークラスを作成できる代替実装を提供します。

   BookMarshaller.java

   import org.infinispan.protostream.MessageMarshaller;
   
   public class BookMarshaller implements MessageMarshaller<Book> {
   
      @Override
      public String getTypeName() {
         return "book_sample.Book";
      }
   
      @Override
      public Class<? extends Book> getJavaClass() {
         return Book.class;
      }
   
      @Override
      public void writeTo(MessageMarshaller.ProtoStreamWriter writer, Book book) throws IOException {
         writer.writeString("title", book.getTitle());
         writer.writeString("description", book.getDescription());
         writer.writeInt("publicationYear", book.getPublicationYear());
         writer.writeCollection("authors", book.getAuthors(), Author.class);
      }
   
      @Override
      public Book readFrom(MessageMarshaller.ProtoStreamReader reader) throws IOException {
         String title = reader.readString("title");
         String description = reader.readString("description");
         int publicationYear = reader.readInt("publicationYear");
         List<Author> authors = reader.readCollection("authors", new ArrayList<>(), Author.class);
         return new Book(title, description, publicationYear, authors);
      }
   }

   Copy to Clipboard Toggle word wrap

   AuthorMarshaller.java

   import org.infinispan.protostream.MessageMarshaller;
   
   public class AuthorMarshaller implements MessageMarshaller<Author> {
   
      @Override
      public String getTypeName() {
         return "book_sample.Author";
      }
   
      @Override
      public Class<? extends Author> getJavaClass() {
         return Author.class;
      }
   
      @Override
      public void writeTo(MessageMarshaller.ProtoStreamWriter writer, Author author) throws IOException {
         writer.writeString("name", author.getName());
         writer.writeString("surname", author.getSurname());
      }
   
      @Override
      public Author readFrom(MessageMarshaller.ProtoStreamReader reader) throws IOException {
         String name = reader.readString("name");
         String surname = reader.readString("surname");
         return new Author(name, surname);
      }
   }

   Copy to Clipboard Toggle word wrap

3. .proto スキーマと ProtoStream マーシャラー実装を SerializationContext に登録するSerializationContextInitializer 実装を作成します。

   ManualSerializationContextInitializer.java

   import org.infinispan.protostream.FileDescriptorSource;
   import org.infinispan.protostream.SerializationContext;
   import org.infinispan.protostream.SerializationContextInitializer;
   ...
   
   public class ManualSerializationContextInitializer implements SerializationContextInitializer {
      @Override
      public String getProtoFileName() {
         return "library.proto";
      }
   
      @Override
      public String getProtoFile() throws UncheckedIOException {
         // Assumes that the file is located in a Jar's resources, we must provide the path to the library.proto file
         return FileDescriptorSource.getResourceAsString(getClass(), "/" + getProtoFileName());
      }
   
      @Override
      public void registerSchema(SerializationContext serCtx) {
         serCtx.registerProtoFiles(FileDescriptorSource.fromString(getProtoFileName(), getProtoFile()));
      }
   
      @Override
      public void registerMarshallers(SerializationContext serCtx) {
         serCtx.registerMarshaller(new AuthorMarshaller());
         serCtx.registerMarshaller(new BookMarshaller());
      }
   }

   Copy to Clipboard Toggle word wrap

手順

1. infinispan-jboss-marshalling 依存関係をクラスパスに追加します。
2. GenericJBossMarshaller を使用するように Data Grid を設定します。

3. Java クラスをデシリアライズ許可リストに追加します。

   • プログラムで行う:

     GlobalConfigurationBuilder builder = new GlobalConfigurationBuilder();
     builder.serialization()
            .marshaller(new GenericJBossMarshaller())
            .whiteList()
            .addRegexps("org.infinispan.example.", "org.infinispan.concrete.SomeClass");

     Copy to Clipboard Toggle word wrap

   • 宣言的に行う:

     <serialization marshaller="org.infinispan.jboss.marshalling.commons.GenericJBossMarshaller">
       <white-list>
           <class>org.infinispan.concrete.SomeClass</class>
           <regex>org.infinispan.example.*</regex>
       <white-list>
     </serialization>

     Copy to Clipboard Toggle word wrap

手順

1. JavaSerializationMarshaller をマーシャラーとして使用するように Data Grid を設定します。

2. Java クラスをデシリアライズ許可リストに追加します。

   • プログラムで行う:

     GlobalConfigurationBuilder builder = new GlobalConfigurationBuilder();
     builder.serialization()
            .marshaller(new JavaSerializationMarshaller())
            .whiteList()
            .addRegexps("org.infinispan.example.", "org.infinispan.concrete.SomeClass");

     Copy to Clipboard Toggle word wrap

   • 宣言的に行う:

     <serialization marshaller="org.infinispan.commons.marshall.JavaSerializationMarshaller">
         <white-list>
             <class>org.infinispan.concrete.SomeClass</class>
             <regex>org.infinispan.example.*</regex>
         </white-list>
     </serialization>

     Copy to Clipboard Toggle word wrap

1. Data Grid Maven リポジトリーから infinispan-marshaller-kryo-bundle.jar をコピーします。
2. JAR ファイルを Data Grid サーバーのインストールディレクトリーにある server/lib ディレクトリーに追加します。

1. infinispan-marshaller-kryo 依存関係を pom.xml に追加します。

   <dependency>
     <groupId>org.infinispan</groupId>
     <artifactId>infinispan-marshaller-kryo</artifactId>
     <version>${version.infinispan}</version>
   </dependency>

   Copy to Clipboard Toggle word wrap

2. org.infinispan.marshaller.kryo.KryoMarshaller クラスをマーシャラーとして指定します。

   GlobalConfigurationBuilder builder = new GlobalConfigurationBuilder();
   builder.serialization()
          .marshaller(new org.infinispan.marshaller.kryo.KryoMarshaller());

   Copy to Clipboard Toggle word wrap

手順

1. SerializerRegistryService.java インターフェイスのサービスプロバイダーを実装します。

2. register(Kryo) メソッドにすべてのシリアライザー登録を配置します。シリアライザーは、Kryo API を使用して提供された Kryo オブジェクトに登録されます。以下に例を示します。

   kryo.register(ExampleObject.class, new ExampleObjectSerializer())

   Copy to Clipboard Toggle word wrap

3. 以下の範囲内で、デプロイメント JAR ファイルにクラスを実装するためのフルパスを指定します。

   META-INF/services/org/infinispan/marshaller/kryo/SerializerRegistryService

   Copy to Clipboard Toggle word wrap

1. Data Grid Maven リポジトリーから infinispan-marshaller-protostuff-bundle.jar をコピーします。
2. JAR ファイルを Data Grid サーバーのインストールディレクトリーにある server/lib ディレクトリーに追加します。

1. infinispan-marshaller-protostuff 依存関係を pom.xml に追加します。

   <dependency>
     <groupId>org.infinispan</groupId>
     <artifactId>infinispan-marshaller-protostuff</artifactId>
     <version>${version.infinispan}</version>
   </dependency>

   Copy to Clipboard Toggle word wrap

2. org.infinispan.marshaller.protostuff.ProtostuffMarshaller クラスをマーシャラーとして指定します。

   GlobalConfigurationBuilder builder = new GlobalConfigurationBuilder();
   builder.serialization()
          .marshaller(new org.infinispan.marshaller.protostuff.ProtostuffMarshaller());

   Copy to Clipboard Toggle word wrap

手順

1. Marshaller インターフェイスを実装します。
2. マーシャラーを使用するように Data Grid を設定します。

3. Java クラスをデシリアライズ許可リストに追加します。

   • プログラムで行う:

     GlobalConfigurationBuilder builder = new GlobalConfigurationBuilder();
     builder.serialization()
           .marshaller(new org.infinispan.example.marshall.CustomMarshaller())
           .whiteList().addRegexp("org.infinispan.example.*");

     Copy to Clipboard Toggle word wrap

   • 宣言的に行う:

     <serialization marshaller="org.infinispan.example.marshall.CustomMarshaller">
         <white-list>
             <class>org.infinispan.concrete.SomeClass</class>
             <regex>org.infinispan.example.*</regex>
         </white-list>
     </serialization>

     Copy to Clipboard Toggle word wrap

1. ロック要求がプライマリー所有者に送信されます (明示的なロック要求または操作のいずれか)。

2. プライマリーの所有者はロックの取得を試みます。

   1. 成功した場合は、正の応答が返されます。
   2. そうでない場合は、負の応答が送信され、トランザクションはロールバックされます。

1. 準備はすべての所有者に送信されます。

2. プライマリーの所有者は、必要なロックの取得を試みます。

   1. ロックに成功すると、書き込みのスキューチェックが実行されます。
   2. 書き込みスキューチェックが成功した場合 (または無効化された場合) は、正の応答を送信します。
   3. それ以外の場合は、負の応答が送信され、トランザクションはロールバックされます。

1. 呼び出し中に取得したロックはバッチが完了するまで保持されます。
2. 変更はすべて、バッチ完了プロセスの一部として、クラスター内でバッチ内に複製されます。バッチの各更新のレプリケーションチャット数を減らします。
3. 同期のレプリケーションまたは無効化が使用された場合は、レプリケーション/無効化の失敗により、バッチがロールバックされます。
4. すべてのトランザクション関連の設定は、バッチ処理にも適用されます。