ActiveMQプロデューサ間欠的な接続と永続性

Question

現在、TCPを介してプロデューサを通じてデータを永続的に配信するソリューションを探しています。接続が長期間停止する可能性があります。

これは、接続が確立されるのを待つ間にデータの永続性の独自の形式を実装する必要があることを意味しますか？または、フェールオーバーなどの方法があります。ここでは、ActiveMQが接続の再接続を待ってから、メッセージを永続的に配信できます。私の現在の問題は、接続がない場合はプロデューサーを作成できないため、接続を確立するために必要な時間内にメッセージがどこにも届かないということです。

私は自分のフォームを使用しても問題はありませんが、ActiveMQが提供する組み込みの永続性を使用したいと思います。

私の質問がはっきりしていることを願っています。

Answer 1

これは共通の問題であり、いくつかの点で解決できます。 1つの方法は、データを自分で保存し、接続が復活したときに送信する方法です。しばしば使用されるもう1つのアプローチは、embeddedまたはローカルブローカーを使用してメッセージを生成し、ローカルブローカーとリモートの間にnetwork connectionを作成することです。接続がダウンすると、埋め込まれたブローカはメッセージを保存し、ブローカ間のネットワーク接続が復元されると、ローカルのメッセージはリモートのブローカに転送されます（ハブとスポークの種類）。ローカルブローカは、ローカルブローカとリモートブローカ間の通常のダウンタイム中に蓄積すると予想されるメッセージの数を管理するのに十分なストレージが必要であることに注意してください。