問題タブ [apache-curator]

TransactionCreateBuilder は「creatingParentsIfNeeded」をサポートしていないようです。これは、典型的な CreateBuilder でサポートされている操作です。私は理想的にやりたいと思います：

curatorTransaction.create().creatingParentsIfNeeded().forPath(key, value).and()..

これはまったく可能ですか？またはZookeeperの制限ですか（アトミックサブパス操作をサポートしていません）

ありがとう！

Zookeeper を使用しているため、Netflix Curator ライブラリを使用しています。そして今、コードベースのjunitテストを書こうとしているので、Curatorライブラリのコードのいくつかをモックする必要があります. 私はモックに jmockit ライブラリを使用しています。

これは、飼育係で単純な znode を作成する以下のコードです。

現在、Zookeeper で実際の znode を作成しないように、使用create方法をモックしようとしています。CuratorFrameworkjmockit

しかし、どうすれば適切にモックできるか理解できませんか?

CuratorFramework コードとその実装は次のとおりです。

どんな提案も大いに役立ちますか?

Zookeeper でリクエストの数を増やして重い junit テストを実行しようとすると、次のエラーが発生します。接続がリセットされるようです。誰もがこれを回避するためのアイデアを持っています。また、Zookeeper で Curator インターフェイスを使用しています。これは、テスト スイートを実行するたびに発生します。いくつかのテスト ケースを削除すると、正常に動作します。誰でもこれについてアドバイスできますか。

開始時にノードが存在しないか削除される可能性があることを考慮して、ポーリングではなく監視のみを使用して、Zookeeper のノードの最新の状態 (データおよび/または子) を常に確認する簡単な方法はありますか?再現？私はこれをやろうとしましたが、それは非常に複雑であることが判明しました (必要な複数のウォッチを設定し、ノードが間違った時間に作成または削除された場合にデータがドロップされる可能性のある競合状態を回避するという点で)諦めて投票に切り替えました。(私のアプリケーションでは数秒遅れても問題ありませんが、変更を見逃すのは良くないことであり、将来のすべての変更を見逃すのは非常に悪いことです。)

私は Java で Curator を使用しています。これにはいくつかのことを簡単にするためのレシピがありますが、これはその 1 つではないようです。

いくつかのリソースを予約するために分散ロックを作成するために Curator フレームワークの Interprocess ミューテックスを使用しています。ただし、zookeeper がロックを取得するたびに 50 ～ 100 ミリ秒、ロックを解放するのに 20 ～ 40 ミリ秒かかることがわかります。私のアプリケーションは書き込みが多く、毎秒 10 ～ 50 の要求に対して 500 ミリ秒以内に応答する必要があり、ロックの取得と解放だけで 70 ～ 140 ミリ秒を費やす余裕はありません。1) これを改善する方法はありますか? Zookeeper サーバーとクライアントは同じホスト上にあります。管理ガイドに記載されているように、飼育係サーバーのセットアップを試みました。2）他のフレームワーク/テクノロジーを使用する必要がありますか。Redis SETNX がより良い解決策になるのか、Chubby を使用するのか疑問に思っていました。

LeaderLatch を使用してリーダー選挙で遊んでいます。ZooKeeper をローカルにインストールすると、インスタンスが 1 つしかないときにリーダーを選出するのに約 30 秒かかり、リーダーがダウンしたとき (プロセスを終了するとき) に新しいリーダーを選出するのにほぼ同時にかかります。これはこのように機能するはずで、速度を上げることはできますか?

次のコードを使用します。