message-queue

1熱

2答えて

私はソリューションのメッセージブローカーとしてazure service bus topicを使用しています。各サブスクリプションの私の理解によると、Azureメッセージバスは仮想キューを保持しているので、メッセージの受信終了時に妨害されるべきではありません。しかし、現実にはそれは私のシナリオでは、少し異なっている私はいつかのための受信機を外した場合、入力は大体2秒ごと後、（タイムスタンプが正

0熱

1答えて

各SQSメッセージにはどのような種類のデータが含まれていますか？

サードパーティのAPI呼び出しを介してユーザーを更新する作業があるとします。メッセージに実際のユーザーデータを入れても問題ありませんか？または、ワーカーがローカルデータベースから更新されたレコードを取得できるように、メッセージにIDのみを指定する必要がありますか？

1熱

2答えて

Microserviceアーキテクチャ依存

私はmicroserviceアーキテクチャについて多くを読んだが、私は達成するためにどのように理解しないと、あなたはこれで私を助けることを願って一つのこと... は、私は、Web-API-を持っていると言うことができますがありますOrderMicroserviceが処理するオーダーを受け取るエンドポイント。注文が行われると、OrderMSは購読者（例えばNatsを使用するpub/sub）にイベント

1熱

2答えて

ZeroMQ + ReactPHP：複数の生産者（プッシュ）と複数の消費者（プル）

私はreactphp/zmqを使用しています。複数のプルワーカーに複数のプッシュワーカーを配置するにはどうすれば可能ですか？私はconnectとしての両方を設定しようとすると $push->bind() $pull->connect() ： $push->connect() $pull->bind() またはシングルプルとマルチプッシュ： Aのみマルチプルとシングルプッシュ、READ

0熱

1答えて

JMSを使用してメッセージ作業プロセスを注文するベストプラクティス

私はタスクがあります：メッセージ受信プロセスを並列化したいと思います。タスクには細い場所があります。特別にマークされたメッセージは、サービスで受け取った順に特別な順序で処理する必要があります。私はJMSでこのタスクを解決しようとしています。メッセージはキューに配置され、いくつかのMessageDriveBeansはそれらのメッセージを処理しています。私は "古典的な要件"を持っています：メッセー

1熱

1答えて

消費者はいませんが、何かを公開するとすぐにackが返されます。なぜですか？（golang/rabbitmq）

以下は、私が使用する出版社のコードです。メッセージがキューから取り出される前に、acksが必要です。コンシューマーからのAckまたはナック（コードの最後に）を受け取ったことを印刷することを想定しています。下にパブリッシャーコードを単独で実行すると（コンシューマーコードを同時に実行せずに）、ハングアップしたり、待ち受けを待っていると思われますが、コンシューマーコードを送ったかのようにackを出力しま

1熱

1答えて

は、CLI

私はCLIを使用してFIFOを作成しようとしているを通じてFIFO SQSを作成することはできませんが、私は aws sqs create-queue --queue-name my-queue.fifo --attributes FifoQueue=true --region us-east-1 An error occurred (InvalidAttributeName) when ca

1熱

1答えて

システム間の互換性が最大です - 純粋なRabbitMQまたはNServiceBus、MassTransit？

メインサーバが.NET上で実装されている間に、システム間/言語の互換性を最大限に高める必要がある場合は、NServiceBusまたはMassTransitを使用できますか、純粋なRabbitMQを使用する方が良いでしょうか？ NServiceBusまたはMassTransitはかなり優れた抽象的なレベルを提供しますが、さまざまなソリューションと環境の間のコミュニケーションの容易さは非常に重要です。

1熱

1答えて

rabbitmqをロックサービスとして使用できない場合、何ができますか？

二つの主な問題点は以下のとおりです。ネットワーク障害へ弾力性のないネットワークパーティションへ弾力性のないそれがロックサービスとして使用することができますなぜこの記事は言う：https://www.rabbitmq.com/blog/2014/02/19/distributed-semaphores-with-rabbitmq/ この記事では、上記の問題のためになぜ使用できないのかを詳しく説

0熱

1答えて

デキューと同じトランザクションでキューに入れることは可能ですか？

デキューしたいメッセージがある場合は、デキューした直後に別のキューに別のメッセージをキューしたい場合があります。私は同じトランザクションでこれをすべてやりたいこれはrabbitmqやその他のキューイングサービスで可能ですか？