1

BlockingQueue実装を使用して、キューからのサービスによってイベントを処理しました。ただし、サーバーがダウンした場合、そのキューからのすべてのイベントが削除されるため、処理するイベントがありません。(サーバーがキューからのイベント/メッセージを保存でき、サーバーがダウンおよびアップした場合、手動で介入することなく、すべてのイベント/メッセージをロードして再度処理できる内部DBを探しています)。

これに関する助け。ApacheActiveMQを使用する必要があるかどうかわかりません。私はapacheservicemixを使用しています。

前もって感謝します。

4

1 に答える 1

0

BlockingQueue でこれを行う方法についてはお答えできません。

ただし、ActiveMQ には次の 2 つの機能があります。

Persistent Queuesおよびおそらく、 Durable Queuesも参照することをお勧めします。

内部でこれを行う組み込みのデータベースがあり、ブローカーまたはコンシューマーを再起動する必要がある場合でも、メッセージをキューに保持できます。

于 2012-12-20T16:09:19.913 に答える