rabbitmq

    0

    1答えて

    クラウド環境では、新しいインスタンスがデプロイされると、統合テストが実行されます。しかし、既存のインスタンス(以前のバージョン)は引き続き実行されている間に、新しいコードがデプロイするサービスのキューにメッセージを挿入しているため、扱いにくくなります。我々は青緑の展開をしています。 RabbitMQでは、リスナーがキューでリッスンすることは可能ですが、特定のバージョンでのみ可能ですか? たとえば、

    1

    1答えて

    IISでホストされているWCFサービスがあります。アプリケーションの初期化中にRabbitMQのリッスンが開始され、サービスが長期間実行された後Qサービスがメッセージを取得しており、処理に失敗しました。 しかし私たちは、異なったQのQ2に購読されている同じイベントにも興味があり、長期的にもすべてのイベントを処理することができた異なるWindowsサービスを持っています。 なぜ長期的にWCFが失敗す

    0

    1答えて

    私は定期的にRabbitMQから更新を取得し、それらを処理するPythonスクリプトcron-jobを書いています。私がそれらを処理するたびに、私はRMQキューの現在のスナップショットを取得する必要があります。私はqueue_declareを使用してメッセージの数を取得します。 basic_getでメッセージを1つずつ取得する方法を知っています。また、basic_consume/start_con

    0

    1答えて

    私は現在、20000から25672までのTCP接続をサポートする単一のRabbitMQサーバで作業しています。したがって、RabbitMQサーバクラスタを使用して TCP接続制限を拡張することは可能ですか?そうなら、どのように設定することができますか?

    2

    3答えて

    大規模なオンラインアプリケーションの場合は、k8sを使用して実行します。このスケールは、毎日の活動ユーザー500,000であってもよい。 K8S内部アプリケーションメッセージング機能必要 - パブ/サブを、これらのオプションがあります カフカ RabbitMQの Redisの カフカ それは飼育係が必要ですosで実行するとディスクI/Oに依存します。だからk8sクラスタにインストールすれば、どうで

    2

    1答えて

    2つのノードにlogstashをインストールして、RabbitMQにログを送信しました。 SSLはRabbitMQのlistenポート5671に設定されています。私は両方のlogstashを5671ポートのrabbitmqサーバーにログをプッシュするように設定しました。 これは私の設定です。 input { file { path => "/var/log/messages"

    0

    1答えて

    私のプロジェクトでメカニックServer Side Eventsを使用しようとしていました。 (これはステロイドのロングポーリングのようなものです) 「Sending events from the server」の例題は、美しく動作します。数秒後に切断されると、Apacheプロセスが強制終了されます。このメソッドは正常に動作します。 BUT! RabbitMQを使用しようとすると、ブラウザからサ

    1

    1答えて

    私はたくさんのキューを持つRabbitMQセットアップを持っています。各キューのデータの性質上、厳密な順序で処理する必要があるため、各キューでは単一のコンシューマしか許可できません。これは問題ではありませんが、誤って2番目の消費者をキューに入れてしまう危険がありますが、これは悪いことです。たくさんの待ち行列とたくさんのアプリケーションサーバーがあり、私たちがこのような状況に陥るのはちょっとしたタイ

    0

    1答えて

    私はJavaのRabbitMQのクライアント(https://mvnrepository.com/artifact/com.rabbitmq/amqp-client)を使用して、私は次のシナリオを実装する必要がRabbitMQのメッセージを消費して停止し、再開:ウサギのメッセージを受信して​​いる間 を、私は特定のキューからRabbitMQの消費量を一時停止する必要があるかもしれません私がデータを