rabbitmq

0熱

1答えて

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

1熱

1答えて

IISでホストされているWCFサービスでRabbitMQキューを消費する

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

0熱

1答えて

RabbitMQキューからたくさんのメッセージを読む最も良い方法は？

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

0熱

1答えて

RabbitMQサーバクラスタの設定方法と利点は何ですか？

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

2熱

3答えて

KubernetesでKafkaを実行するのは良い方法ですか？

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

2熱

1答えて

Logstash - RabbitMQ接続タイムアウトエラー

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

0熱

1答えて

RabbitMQとの接続解除後にApacheプロセスが終了しない

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

1熱

1答えて

RabbitMQキューのコンシューマ数を制限する方法はありますか？

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

0熱

1答えて

が一時的に後で

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