問題タブ [gemfire]

Spring Data と Gemfire を使用してデータ サービスを開発しています。注釈あり

POJO を保存する Gemfire リージョンを指定します。

構成された Gemfire リージョンの名前が必要です。Gemfire クラスターは別のチームによって管理される予定であり、リージョン名は完全に構成可能であるべきだと考えているため、リージョンの名前をハードコーディングするのは悪い習慣だと思います。

地域名のハードコーディングを避けるためのより良い方法はありますか?

レプリケートされたリージョンをホストする 1 台のサーバーの Gemfire クラスターがあります。クライアントサーバーアーキテクチャを使用しています。

リージョンにはデータが事前にロードされます。

次に、新しいサーバーをクラスターに追加します。Pulse と gfsh で確認できます。一部の新しいクライアントは新しいサーバーに接続されますが、空のデータを受け取ります。 データは、最初のサーバーから新たに開始されたサーバーに複製されません。

2番目のサーバーのcacheserver.logには、次のような行が表示されます

1 台目のサーバーからのデータ レプリケーションだと思いますが、2 台目のサーバーにはデータが表示されないようです。

解決策はありますか？

更新: インデックスと関係があることに気付きました。次のように定義されたインデックスがあります

インデックスを削除すると、すべて正常に動作します。しかし、インデックスが有効になっている場合、キャッシュ サーバーは引き続きインデックスを使用しようとしますが、インデックスはレプリケートされないように見えます。したがって、新しく起動したサーバーからの空のデータ。

春のアプリケーションでデータを照会するように Java gemfire テンプレートを構成しようとしています。
Spring テンプレートを作成するには、クライアント リージョンを作成する必要があります。クライアント リージョンを作成するには、クライアント キャッシュを作成する必要があります。クライアント キャッシュを作成するには、プールを作成する必要があります。
プール パラメータの 1 つに server-goup があります。それらのいくつかを照会するには、gemfire テンプレートが必要です。
複数のサーバー グループに対して構成可能なプールが見つからなかったので、2 つのプール (異なるサーバー グループを使用) を作成しました。

私は何が欠けていますか？エラーを修正したり、複数のサーバー グループのクライアント リージョンを設定するにはどうすればよいですか?

春のコンテキストは次のとおりです。

ありがとう。

キャッシュとして gemfire を使用しています。キャッシュ ヒープ サイズは 100GB をはるかに超えています。クライアントから gemfire キャッシュにデータを入れると、データがシリアル化されてサーバーに送信され、サーバーではデータがシリアル化された形式で保存されることがわかりました。問題:

1. サーバー上の関数呼び出しを実行しようとすると、データの逆シリアル化が開始され、実際には時間がかかります。キャッシュ内のオブジェクトを反復処理するだけで 1 時間以上かかる場合もあります。(オブジェクトの数は 600 万に近い)。
2. gemfire カスタム シリアライゼーション (DataSerializer クラス) を使用してみました。また、すべてのデータがキャッシュに格納された後に必要なメモリの量は約 60 GB で、これは Java のデフォルトのシリアル化を使用した場合と同じです。
3. Kryo https://github.com/EsotericSoftware/kryoというライブラリを使用してみましたが、これは非常に役立ちますが、クラスの各属性を個別にシリアル化しているため、gemfire のシリアル化が役に立たない理由はまだわかりません。そのため、クラス ヘッダーやその他のメタ データを記述する負担はありません。

どんな助けでも本当に感謝しています。

私のコードには、値自体とそのクラスを含む一般的な「値」POJOがあります。

Spring Data GemFire と Spring Data の「リポジトリ」機能を使用しています (DAO はインターフェイスから自動的に作成されます)。Spring がこの Bean の DAO を作成すると、次のようになりました。

FactoryBean threw exception on object creation; nested exception is java.lang.SecurityException: Can not make a java.lang.Class constructor accessible:

java.lang.ClassSpring Data を使用して GemFireに保存するにはどうすればよいですか?

更新日:

こんにちは Pivotal Gemfire のベンチマークに YCSB を使用しています 私の Gemfire サーバーは適切に動作しており、次のコマンドを使用してベンチマーク テストを実行しています。

bin/ycsb load gemfire -P workloads/workloada -p gemfire.serverhost=xxxx -P gemfire-binding/conf/cache.xml -p gemfire.serverport=40404 -s > load.txt

ワークロードを読み込んでいます... テストを開始しています。0 秒: 0 操作。スレッド「Thread-1」の例外 java.lang.IllegalStateException: ClientCacheFactory を使用する場合は、cache.xml で client-cache を使用する必要があります。com.gemstone.gemfire.internal.cache.xmlcache.CacheCreation.create(CacheCreation.java:316) で com.gemstone.gemfire.internal.cache.xmlcache.CacheXmlParser.create(CacheXmlParser.java:274) で com.gemstone .gemfire.internal.cache.GemFireCacheImpl.loadCacheXml(GemFireCacheImpl.java:3495) com.gemstone.gemfire.internal.cache.GemFireCacheImpl.initializeDeclarativeCache(GemFireCacheImpl.java:926) com.gemstone.gemfire.internal.cache.GemFireCacheImpl .init(GemFireCacheImpl.java:708) com.gemstone.gemfire.internal.cache.GemFireCacheImpl.create(GemFireCacheImpl.java:533) com.gemstone.gemfire.cache.client.

どこが間違っているのか教えてください。

前もって感謝します

Spring-Integration 3.0 と Spring-Integration Gemfire サポートを使用しています。inbound-channel-adapter が SpEL 式に基づいてキャッシュ内のオブジェクトをペイロードとして取得するようにしたかったのです。入力アダプターによって選択されるペイロードのプロパティをチェックするカスタム式エバリュエーター クラスを作成しました。クラスコードは以下の通りです。

}

そして、構成コードは次のとおりです

ただし、このコードを実行した後、次のエラーが発生します。

何が問題なのかを理解するのを手伝ってくれる人はいますか?

@ を # に置き換えた後、次のエラーが発生しました。