問題タブ [message-queue]

C++ API からプライベート メッセージ キューを作成、追加、読み取り、破棄する方法の実例を教えてもらえますか? MSDN のコードを試してみましたが、正しく動作させることができません。

ありがとう

標準ウィンドウのキューにはいくつのメッセージが保持されますか? キューがオーバーフローするとどうなりますか?

and relativesのドキュメントではGetMessage、これについては何も述べられてPeekMessageおらず、メッセージ数ではなく、特定のクラスのメッセージについてのみ yes/no が示されます。

このページには、メモリ マップ ファイルを使用してキューが実装されており、メッセージ数の制限はないと書かれていますが、そのページは WinCE に関するものです。これはデスクトップ Win32 にも適用されますか?

WebSphere で MDB を実行していますが、MQ キューからメッセージを取得しようとすると、次の例外がスローされます。

com.ibm.mq.MQException: メッセージ カタログが見つかりません

これを解決する方法はありますか？

基本的に、メッセージをキューに入れることができるキューイング技術が必要です。これらのメッセージは、後で SMS テキストとして送信されます。API について調べてみると、RabbitMQ は非常に適しているようです。

私の現在のアーキテクチャ計画:

1. クライアントは、RabbitMQ でメッセージをキューに入れます。
2. 別のデーモンが RabbitMQ からメッセージを読み取り、それらをサードパーティの SMS ゲートウェイに送信します。デーモンは、複数のリスナー スレッドを生成できる必要があります。
3. Ubuntu Hardy を使用して、slicehost.com ですべてをホストする予定です。

この設計に何か問題があると思いますか? 私は Erlang について大雑把な知識しか持っていないので、本番環境でそれを実行する方法についてはまったく考えていません。Erlang や RabbitMQ の経験があれば、戦争の話を聞きたいです。

Java の世界では、メッセージ キューの選択肢がさらにいくつかありますが、.Net では、その数はわずかです。どちらを使用するかを評価する場合、どのような特徴を探す必要がありますか? 信頼できるメッセージ キューイング システムを構成する基本的な概念は何ですか?

異なるプロセス間でリクエストを渡すために activemq を使用しています。場合によっては、キューに複数の重複したメッセージ (リクエスト) があります。1つだけ持っていたいです。古いメッセージを同様の属性に置き換える方法でメッセージを送信する方法はありますか? 存在しない場合、キューを調べて特定の属性を持つメッセージを確認する方法はありますか (この場合、古いメッセージが存在する場合は新しいメッセージを送信しません)。

明確化 (Dave の回答に基づく): 実際には、消費者がメッセージを受け取るたびに発生する処理の量を減らすために、キューに重複したメッセージがないことを確認しようとしています。したがって、メッセージを置き換えるか、キューに入れないようにしたいと思います。

ありがとう。

System.Messaging.MessageQueueを使用して、LAN でマルチキャスト System.Messaging.Message を送受信しています。これは正常に動作します。

ただし、メッセージ キューを使用せずにメッセージを受信する必要があります。

MessageQueueは PGM プロトコル (113) を使用してメッセージを送信するため、ソケットを使用して PGM (プロトコル 113) をリッスンするタイプを構築しようとしています (例: new Socket(AddressFamily.InterNetwork, SocketType.Rdm, (ProtocolType)113);）。型はメッセージ データを受信して​​いますが、テキスト形式です (soap フォーマッタ セクションを使用 - msdn http://msdn.microsoft.com/en-us/library/cc219170.aspxの例を参照) 。

System.Messaging.Messageにキャストして実際のデータを取得できるように、明らかにバイナリ データが必要です。

これを行う方法についてのアイデアは大歓迎です。

スプリング注入エンドポイントの例は次のとおりです。

別のサーバーの特定のポートに接続するようにクライアント モード エンドポイントを設定するにはどうすればよいですか?

インバウンド接続をリッスンするようにエンドポイントを構成するにはどうすればよいですか? (この例は、説明的な ID で示されるようにリスナーのようですが、なぜですか?)

注: 私は実際には HL7 プロトコルまたはコーデックを使用していません。独自のプロトコル コーデック用に独自に開発する予定です。

AMQPについて頭を悩ませようとしています。アプリケーション間のマシン間 (クラスター、LAN、WAN) 通信には優れているように見えますが、1 台のマシン内でソフトウェア バスとして使用するのに (アーキテクチャ上および現在の実装面で) 適しているかどうかはわかりません。

現在の高性能メッセージ パッシング フレームワークを取り出して AMQP に置き換える価値はありますか? それとも、ローカル通信と非ローカル通信の区別が曖昧になり、RPC と同じ罠に陥るのでしょうか?

また、マシン内通信に WAN テクノロジを使用することによるパフォーマンスへの影響についても心配していますが、これはアーキテクチャよりも実装上の問題かもしれません。

戦争の話は大歓迎です。

私は実際の運用環境でメッセージング システムの良い面と悪い面を経験してきました。よく整理されたテーブルまたはテーブルのスキーマは、他の形式のメッセージング キューよりも優れていることを認めなければなりません。その理由は次のとおりです。

1. データはテーブルに永続的に保存されます。キャッチされない例外やその他のバグのために途中でメッセージが失われたり消えたりする、非常に多くの Java (jms) アプリケーションを見てきました。
2. キューはいっぱいになる傾向があります。代わりに、DB ストレージは事実上無限です。
3. テーブルには簡単にアクセスできますが、難解な手段を使用してキューから読み取る必要があります。

それぞれのアプローチについてどう思いますか?