問題タブ [ignite]

シングル キャッシュのキャッシュ イベントを ignite に登録する方法を探しています。

このコードを使用して、ignite 環境のすべての put イベントを登録することができます。

しかし、パフォーマンス上の理由から、特定のマップ (キャッシュ) のキャッシュ イベントのみを登録したいと考えています。そうしないと、各イベントのキャッシュ名を確認する必要があり、多数のトランザクションでシステムに大きな負荷がかかる可能性があります。

ヘルプとガイダンスをありがとう。

以前は Java プロジェクトで ignite を使用していましたが、インフラストラクチャ/アーキテクチャのセットアップにさらされることはありませんでした...

今、私は .net プロジェクトを持っており、分散型メモリ キャッシュが完全に必要であると考えており、apacheignite-net に目を向けています。.net プロジェクトは、一連のバックエンド サービス (wcf と amqp) です。これらのサービスは水平方向にスケーリングできます。スループットを向上させるために、これらのサービスにサーバーを追加できます。

しかし、.net と一緒に ignite の展開/インフラストラクチャに関するアドバイス/ポインターが必要です: - キャッシュ用の追加/専用サーバーを追加することはできません: そのため、.net サービスと apacheignite-net の両方を同じボックスに置くことを考えています。
-キャッシュする必要があるオブジェクト(現在、すべてのリクエストでDBからそれらを探しています)はそれほど大きくありませんが、すべてをキャッシュする必要はありません:リードスルー/エビクションポリシーの組み合わせ?

私の質問は次のとおりです。ignite 用の JVM とこれらの .net サービスの両方を同じボックスに置くことは、通常/安全なことですか? 私はパフォーマンスのヒントを読みましたが、賢明な/経験豊富な人からの意見を求めています. これらのサーバーにはいつでもメモリを追加できますが、コアはあまり追加できません。これらの .net サービスは、提供されたすべての CPU を消費するわけではなく、RDBMS によって支えられており、必要に応じて RAM をもう少し追加するように要求できます。

Apache Ignite でのカスタム シリアライザーのプラグイン

Binary Configuration Bean に Kyro Serializer を追加しようとしましたが、実行時にクラス型変換エラーが発生しました。

私のコードは

エラーログは

Apache Ignite が提供する BinarySerializer を掘り下げると、それを実装するには、シリアライザーのカスタム実装を Other plugin Serializers として作成する必要があるという結論に達しました。

最適化されたマーシャラーはどのように有益ですか?

毎回のクエリ解析を回避するために IgniteCache API でサポートされているプリペアド ステートメントのような機能はありますか? これに対して Jira の問題が提起されていることを確認しました。バージョン 1.5.0.final で解決されたと書かれて いますが、ドキュメントは見つかりませんでした。これについては、Apache Ignite サイトを参照してください。JDBC接続を介して接続することで準備済みステートメントを使用できることは知っていますが、それは私のユースケースには合いません。

私のコードは以下のようになります。このクエリは、さまざまなパラメーターで何度も呼び出されます。

キャッシュにApache Igniteを使用していますが、テスト中にこのエラーに遭遇しました

java.lang.IllegalStateException: キャッシュが閉じられているか、破棄されています

内部に IGNITE が埋め込まれた Spring Restful クライアントがあります。キャッシュから更新および削除するための呼び出しが行われます。

発生した手順は次のとおりです

1. 実行中の Ignite サーバーの 1 つのインスタンス。
2. Ignite Embedded を使用して別のサーバーで実行されている Restful クライアントの 1 つのインスタンス。
3. Ignite サーバー インスタンスを強制終了しましたが、クライアントはまだ実行中です
4. Ignite サーバーが再起動されました。
5. クライアントがキャッシュに値を入れようとすると、上記の例外が発生します。
6. クライアントを再起動すると、すべてが正常に機能します

なぜこれが起こっているのかについて、誰かが洞察を投げかけることができますか。すべてのノードが離れるというイベントを処理し、キャッシュなどを手動で削除する必要がありますか。

どんな助けも歓迎されます

基本プリミタイプ タイプとオブジェクトでデルタ操作を実行しようとするとエラーが発生する

エラースタックトレースは次のとおりです

cache.ROCCacheTest$$Lambda$9/1985869725 org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1618) org.apache.ignite.internal.processors.cache.IgniteCacheProxy.cacheException(IgniteCacheProxy) .java:1841) org.apache.ignite.internal.processors.cache.IgniteCacheProxy.invokeAll(IgniteCacheProxy.java:1544) で cache.ROCCache.invokeAll(ROCCache.java:129) で cache.ROCCacheTest.testDeltaOnAllListOfPojoFields(ROCCacheTest. java:529) で sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) で sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) で sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) で java.lang org.junit.runners.model.FrameworkMethod$1 の .reflect.Method.invoke(Method.java:497)。org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) で runReflectiveCall(FrameworkMethod.java:50) org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) で.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75) org.springframework.test.context .junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86) org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84) org.junit.runners.ParentRunner.runLeaf(ParentRunner) .java:325) org.springframework.test.context.junit4.SpringJUnit4ClassRunner で。runChild(SpringJUnit4ClassRunner.java:254) at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:89) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) at org. junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) で org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61) で org.springframework.test.context. junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70) org.junit.runners.ParentRunner.run(ParentRunner.java:363) org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:193) at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86) at org.eclipse.jdt.internal. junit.runner.TestExecution.run(TestExecution.java:38) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459) at org.eclipse.jdt.internal.junit.runner. org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382) の RemoteTestRunner.runTests(RemoteTestRunner.java:675) org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main( RemoteTestRunner.java:192) 原因: クラス org.apache.ignite.IgniteCheckedException: org.apache.ignite.internal.processors.cache.GridCacheIoManager の cache.ROCCacheTest$$Lambda$9/1985869725。unmarshall(GridCacheIoManager.java:1044) で org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:275) で org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager. java:204) org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$000(GridCacheIoManager.java:80) で org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java: 163) org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:821) で org.apache.ignite.internal.managers.communication.GridIoManager.access$1600(GridIoManager.java:103) でorg.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:784) java.util.クラスorg.apache.ignite.binary.BinaryInvalidTypeException: org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:492) で org.apache.ignite.internal.binary で cache.ROCCacheTest$$Lambda$9/1985869725 org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1443) の .BinaryContext.descriptorForTypeId(BinaryContext.java:489) org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java) :292) org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal(BinaryMarshaller.java:112) org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateRequest.finishUnmarshal(GridNearAtomicUpdateRequest. java:621) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.unmarshall(GridCacheIoManager.java:1038) ... 10 以上原因: java.lang.ClassNotFoundException: cache.ROCCacheTest$$Lambda$9/1985869725 java.lang.Class.forName0(Native Method) で java.lang.Class.forName(Class.java:340) で org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8172) で org org.apache.ignite.internal.binary の .apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185)。BinaryContext.descriptorForTypeId(BinaryContext.java:483) ... 17 詳細

以前は、すべてのテストが正常に実行されていました。クライアントとサーバーのセットアップを試みた後、テストが失敗し、同じ 2 つのシステムがサーバーとして使用されている場合、または構成がサーバーのみのモードである場合にテストが失敗します。

構成は次のとおりです

3 つの質問があります。

1. Ignite でのデルタ操作は、基本的にオブジェクト全体を再送信するオーバーヘッドを回避するために使用されますが、pojo でデルタを実行している間、バイナリ オブジェクトが再構築されます。決まり文句じゃない？他の多くのオーバーヘッドが削減されることに同意します。

2.レプリケーションを使用するクライアント サーバー モードを検討する場合、デルタはどのようにレプリカを介して転送されますか?

3.SQL クエリを使用してキャッシュにアクセスしようとしているときに、動的 POJO を実装するにはどうすればよいですか?

Config で永続ストアを H2 から MYSQL に変更しましたが、ignite インスタンスが起動しません。

コンソールにはこれらのみが表示されます

デフォルトのインメモリ H2 データベースを検討する

構成のどこにも、データソースを定義する Bean が参照として使用されていません。間違っている場合は訂正してください。ただし、私の理解では、キャッシュ ストアには、キャッシュとの間でデータをロードする役割しかなく、永続ストアの選択は処理されません。 .Ignite は永続ストアをどのように認識しますか?

Ignite キャッシュに永続ストアを実装しようとしています。CacheJdbcPojoStoreFactory を使用しています。私のキャッシュ ストア ファクトリの初期化は次のようになります。

私のキャッシュの実装は次のようになります

（私は正しいクエリ Entities と JdbcTypes を渡しています。簡単にするために、ここではそのコードを示していません）しかし、このコードを実行すると、以下のスタックトレースが得られます

デバッグすると、データソース パラメータが cacheJdbcdPojoStorefactory オブジェクト内で正しく設定されていることがわかります。どこが間違っていますか？