java - Java の分散イベント処理メカニズム

Question

さまざまなホストで実行されているさまざまな JVM 間でイベントを生成および処理するために、Java でかなり高速なイベント処理メカニズムを探しています。

単一の JVM で複数のスレッドにまたがるイベント処理については、Jetlang のような有力候補をいくつか見つけました。しかし、分散型の同等のものを探したところ、優れたパフォーマンスを提供するのに十分なほど軽量なものは見つかりませんでした。

法案に合った実装を知っている人はいますか?

編集： パフォーマンスを示すために数字を入れるのは少し難しいです。ただし、たとえば、イベントを使用してハートビートメカニズムを実装し、ハートビート間隔が 5 秒の場合、ハートビートレシーバーは送信されたハートビートを 1 ～ 2 秒以内に受信する必要があります。

一般に、軽量の実装で良好なパフォーマンスが得られます。優れたパフォーマンスを実現するために強力なハードウェア (決して軽量ではない) を必要とする Web サーバーまたはあらゆる種類の集中型ハブを含むイベント処理メカニズムは、私が探しているものではありません。

score 9 · Accepted Answer

Hazelcast Topic は、分散 pub-sub メッセージングソリューションです。

public class Sample implements MessageListener {

    public static void main(String[] args) { 
        Sample sample = new Sample();
        Topic topic = Hazelcast.getTopic ("default");  
        topic.addMessageListener(sample);       
        topic.publish ("my-message-object");
    }  
     
    public void onMessage(Object msg) {
        System.out.println("Message received = " + msg);
    } 
}

Hazelcast は、分散キュー、マップ、セット、リストのイベントもサポートしています。すべてのイベントも注文されています。

よろしく、

-タリップ

http://www.hazelcast.com

score 4 · Accepted Answer

ユースケースによっては、テラコッタが最適な選択肢となる場合があります。

score 3 · Accepted Answer

AMQP（Advanced Message Queuing Protocol）-詳細： http： //en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocolはおそらくあなたが探しているものです。

これは、金融サービス会社が高いパフォーマンス要件のために使用しています-apacheには実装があります-http://cwiki.apache.org/qpid/

OpenAMQ- http: //www.openamq.org/は古いリファレンス実装です。

score 3 · Accepted Answer

分散イベント処理には、Esperを使用できます。デュアル CPU 2GHz Intel ベースのハードウェアで最大 500 000 イベント/秒を処理できます。多くの銀行がこのソリューションを使用しているため、非常に安定しています。Spring JMS テンプレートに基づく JMS 入出力アダプターをサポートします。したがって、イベント処理に任意の JMS 実装、つまりActiveMQを使用できます。

score 3 · Accepted Answer

ZeroMQ - http://www.zeromq.org/

これはトランスポート層ですが、イベント処理用に調整できます。

score 1 · Accepted Answer

akka (http://akka.io/) をご覧ください。Java と scala の両方の API を使用して、JVM の erlang と同じ流れで分散アクターモデルを提供します。

score 1 · Accepted Answer

どのツールを使用する場合でも、アプリケーションロジックからミドルウェア API を隠すことをお勧めします。たとえば、Apache Camel アプローチを使用してミドルウェアを非表示にした場合、正確な要件に基づいて、AMQP から SEDA、JMS、ActiveMQ、JavaSpaces、独自のカスタム MINA トランスポートに簡単に切り替えることができます。

メッセージブローカーを使用する場合は、Apache ActiveMQ を使用することをお勧めします。Apache ActiveMQは、最も人気があり強力なオープンソースメッセージブローカーであり、Apache の内部と外部の両方で最大かつ最も活発なコミュニティが背後にあります。

score 0 · Accepted Answer

Avis イベントルーターがニーズに適している場合があります。これは、リモートマウスコントロール (日常的に使用するアプリケーション) 用のマウスイベントの送信など、ほぼリアルタイムのイベント配信に十分な速さです。

Avis はチャット、バーチャルプレゼンス、スマートルームオートメーションにも使用されており、通常は 10 ～ 20 台のコンピューターが Avis ベースのメッセージングバスを介して通信しています。その商業的ないとこ (Mantara Elvin) は、大量の商取引イベントの処理に使用されます。

score 0 · Accepted Answer

JMS の実装が適切でない場合は、 XMPPアプローチに興味があるかもしれません。複数の実装があり、Publish-Subscribe 拡張機能もあります。

java - Java の分散イベント処理メカニズム

10 に答える 10

Related

Reference