disruptor-pattern

2熱

1答えて

AndroidでLMAX Disruptorを使用している人はいましたか？それは動作し、互換性の問題はありますか？

0熱

1答えて

Disruptor内のDisruptor EventReleaser.release()メソッド3.3.6 com.lmax.disruptor.WorkProcessor。方法はわかりませんsequence.set(Long.MAX_VALUE)。誰もがこの方法の目的は何かを詳細に説明できますか？

0熱

1答えて

LMAX Disruptor（unmarchalerからビジネスロジックまで）の下位層のコンシューマ間でデータを渡す？

https://martinfowler.com/articles/lmax.htmlで説明したように、私はRingBufferのイベントをまずUnmarchalerで処理し、次にBusiness Logic Processorで処理する必要があります。 Disruptor<MyEvent> disruptor = new Disruptor<MyEvent>(MyEvent.FACTORY, 3

3熱

1答えて

Disruptor dropping message issue

我々は、LMAX Disruptorを生産に1年近く使用しています。私たちがDisruptorから落とされたメッセージを見たとき、先週まですべてがうまくいっていました。私たちのかく乱構造が非常に簡単です：カフカ - >リングバッファ - > Eventhandler1 - > Eventhandler2 - > Eventhandler3 各EventHandlerはすべての例外をキャッチするt

2熱

1答えて

lmaxディスラプター内の処理を一時停止しますか？

私はLmaxをかく乱使用して性能試験を行いたいと思います：設定のdusruptor どういうわけか「一時停止」がリングバッファ「一時停止を解除」処理に多くのメッセージを追加処理このようにして、バッファがどれだけ空になったかをきれいに測定できました。多くのメッセージ（遅延を導入する）を追加して処理すると、処理速度が低下することがあります。私はLMAX Disruptor（https://

2熱

1答えて

EventHandler onEventのLMAXディスラプタータイムアウト

私はリングバッファーとイベントハンドラーを持っています。これは、メッセージングサーバーのインバウンドバッファとして使用されます。私の偶数ハンドラの中では、いくつかのAMQPサービス呼び出しを行いますが、その呼び出しがタイムアウト（AMQPサービスを呼び出すアンダーラインプロトコルライブラリのバグ）を待たずに何度か待機します。そして、2000tpsで、これは私の4096サイズのリングバッファをFU

6熱

2答えて

1人のパブリッシャーと4人の並列コンシューマーによる混乱の例

この例では、https://stackoverflow.com/a/9980346/93647とここにはWhy is my disruptor example so slow?（質問の最後にあります）のパブリッシャーとアイテムが1つあります。私の場合、消費者の仕事はずっと複雑で時間がかかります。ですから、データを並行して処理する4人の消費者が必要です。ですから、例えばプロデューサープロデュース

4熱

2答えて

DisruptorまたはJMS？

実際にはJMSの代わりにアプリケーションの代用者ですか？私は現在、JMSメッセージを使用してタスクを転送しています。ディスラプターは、メッセージ転送用に交換する予定ですか？それぞれの賛否両論は何ですか？現在、私はJMSを使用しています。メッセージをキューに送信し、コンシューマ（MDB）がキューからプルするプロデューサがあります。ありがとうございました。

2熱

2答えて

Lmax Disruptor、多くの消費者 - どのようにして消費者を特定の種類のメッセージにして、独立して進めるのか？

私は混乱の中で多くの並列消費者を持つことを計画しています。各消費者は、それらのためのメッセージを消費する必要があります。例えば、IはタイプA、B、Cのメッセージを持っていると私はタイプごとに消費者を有する #1 - type A, #2 - type B, #3 - type C, #4 - type A, #5 - type C, #6 - type C, (and so on) ように