問題タブ [hazelcast-imap]

私のアプリは、スプリング ブート + hazelcast に基づいています。

単純なエンティティをヘーゼルキャストに保存しようとしています:

私のサービスメソッドは次のようになります:

com.hazelcast.nio.serialization.HazelcastSerializationExceptionトレースで受け取ったエンティティを保存しようとすると:

ここに私のヘーゼルキャスト設定があります:

この問題を解決する方法を教えてください。

更新:

Mapstore が構成された IMap があります。複数のスレッドから IMap を取得すると、1 回のフェッチで正しく動作し、他は自動的にヒットするようです。したがって、キャッシュから取得しようとするとImapが自動的にロックメカニズムをオンにしているのだろうかと思いますが、実際にこれを確認したところはありませんが、ロックされているように動作します。

誰かがこれを確認できますか？

データベースに対して読み取り/書き込みを行う MapStore/Loader を持つ単一のメンバーと、EntryAddedListener リスナーを追加するクライアントがあります。

メンバーがバウンスされると、MapLoader がデータベースからデータをリロードするため、エントリが追加されたリスナーが起動されます。

ただし、これはクライアントに新しいエントリが追加されたことを示唆しますが、実際には、ノードのブートストラップのために「追加」されているだけです。

基本的に、MapLoader がマップをブートストラップした結果としてこれらのリスナーが起動されることは望ましくありません。後で起動する必要があります。

EntryAdded リスナーから発生するこれらの MapLoader イベントを停止するにはどうすればよいですか?

Hazelcast を使用するのは初めてです。Web アプリケーションのデータ ストレージとして Hazelcast 3.6-EA を使用しています。アプリケーションは複数のインスタンスで実行されるため、複数のスレッドが同じマップで動作しようとするときに、競合状態を回避するためにロック メカニズムを実装する必要があります。

必要な動作は次のとおりです。マップの操作を開始する最初のインスタンスは、マップをロックし、必要な更新を実行する必要があります。もう 1 つのインスタンスは、マップがロックされていることを確認し、更新の実行をスキップする必要があります。

したがって、このようなロックの主な利点は、同じコードが 2 回実行されるのを回避できることです。

ロック メカニズムを正しく理解しているかどうか、および上記の実装された動作で目的の結果が得られるかどうか、疑問があります。

詳細な説明をいただければ幸いです。

get(key)また、スレッドでマップをロックし、もう一方が操作のみを実行している場合の動作を教えてください。

私はヘーゼルキャストとキャメルが初めてです。camel を使用してマップ ローダーを作成しているときに、「load」メソッド内で camel ルートを呼び出しています。コンテナは「dataSyncLoad」コンテナが存在することを示していますが、アプリケーションの起動時にデータをロードしている間は、以下のエラーが発生します。

ヘーゼルキャスト・マップローダー

マップ構成

//dataSyncLoad]. Exchange[Message: CellDataSyncKey [locoid=20695, dataTemplate=3, deviceName=CCA]] at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47)[142:org.apache.camel.camel -core:2.12.0.redhat-610379] org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] ] org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:73)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] org.apache.camel.impl. ProducerCache$2.doInProducer(ProducerCache.java:378)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java: 346) [142:org.apache.camel.camel-core:2.12.0.redhat-610379] org.apache.camel.impl で。

データベースへのマップ ローダーを持つ 2 つのメンバーを持つクラスターがあります。

バージョン 3.6.1 では、起動時に問題は発生しませんが、3.7 にアップグレードすると、以下のような多くの例外が表示され、クラスターの起動に失敗しました!

それが何を意味するのか、何か考えはありますか？ありがとう

14:32:50.613)、waitTimeout=-1、callTimeout=60000、name=TRADE_SETTLEMENT}、tryCount=250、tryPauseMillis=500、invokeCount=240、callTimeoutMillis=60000、firstInvocationTimeMs=1473427838152、firstInvocationTime='2016-09-09 14 :30:38.152', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 01:00:00.000', target=[xxx.co.uk]:5702, pendingResponse={VOID}, backupsAcksExpected=0, backupsAcksReceived=0 , connection=null}, 理由: com.hazelcast.spi.exception.RetryableHazelcastException: マップ TRADE_SETTLEMENT はまだ外部ストアからデータをロードしています 2016 年 9 月 9 日 2:32:50 PM com.hazelcast.spi.impl.operationservice.impl.Invocation

IMap でその場で string、date、int 型の特定のポータブル フィールドにインデックスを追加する必要があります。

1. まず、特定のエントリを保持するマップにインデックスを追加すると、factory-id: XXX の PortableFactory が見つからないことを示す Hazelcast Unhandled Exception がスローされます。
2. 次に、エントリをマップにロードする前にインデックスを追加する別の方法を試しましたが、インデックスの追加時に問題は見つかりませんでしたが、エントリを再度設定しているときに、上記と同じ例外が発生しました。しかし、驚くべきことに、その例外シナリオのレコードをマップ内に見つけました。

サーバー側でクラス定義を期待するポータブル オブジェクトのインデックスを追加しましたか? ただし、Portable Serialization の場合、ドキュメントに従ってサーバー側でクラス定義を行う必要はありません。

メンバー構成:

以下のクライアントコードを見つけてください。