問題タブ [consumer]

ActiveMQでは、コンシューマーにメッセージを送信していましたが、コンシューマーはそのメッセージを別のプロセスに転送します。他のプロセスからブローカーに確認応答を送信できる方法があるかどうか知りたいですか？

他のプロセスへのソケット接続を使用してメッセージオブジェクトを送信してから、そのプロセスでacknowledge（）メソッドを呼び出してみましたが、機能していません。

（同じJAVAプロセス内の）他のクラスオブジェクトにメッセージを送信してから、acknowledge（）メソッドを呼び出してみましたが、機能しました。

プロデューサー/コンシューマーの問題を使用して、マルチスレッド DNS リゾルバーを作成しています。マルチスレッドなしで解決したので、コードのその部分が機能することは間違いありません。基本的に、書き込み用のプロデューサーを 1 つ作成し、読み取り用の多くのコンシューマー (作成予定) を作成しています。現時点では、IP アドレスが含まれるファイルから読み込んでいます。プロデューサー スレッドが実行されていない理由がわかりません。コンシューマーを稼働させる前に、これで何が起こっているのかを理解する必要があります。どんな助けでも大歓迎です。

これが私のコードです（これまでのところ）：

編集:コードの一部を修正しましたが、動作するはずだと思います。ただし、まだそうではありません。

何も機能していません。助言がありますか？

デバッグするとセグメンテーション違反が発生し続けます。なぜ、どこから来ているのかわかりません。私はpthreadsを初めて使用するので、何かを見落としているかもしれませんが、私にはうまくいくように見えます。

メッセージが yahoo! のような処理エンジンによって処理された後にメッセージを確認したい。S4. アダプターを使用してのみメッセージをエンジンに送信できます。

現在、処理エンジンがメッセージの JMScorrelationID を返し、メッセージが処理されたことを伝えるまで、各メッセージをアダプターに保存しています。ただし、これは、各メッセージを格納するためにアダプター上で多くのスペースを占有します。

JMScorrelationID を使用して確認応答を手動で作成し、それをブローカーに送信する方法はありますか??

Spring を使用してトピックをサブスクライブする正しい方法は何だろうか。

DefaultMessageListenerContainer非永続サブスクリプションを使用してを試しましたが、ほとんどの場合失敗します。未解決のバグ ( SPR-7833 ) があり、非永続トピック サブスクリプションでは機能しないことが指摘されているようです。

障害が発生した場合に自動再接続をサポートする DMLC に代わるものはありますか?

ところで、私はプログラムで DMLC を作成しており、自動再接続のために Failover Transport を使用して組み込みの ActiveMQ 5.5.1 ブローカーに接続しています。キューからのメッセージの消費は、最も奇妙なシナリオでも期待どおりに機能しますが、トピックではうまくいきません。

異なるスレッドがキュー（プロデューサー）にデータを入力し、1つのコンシューマーがこのキューから要素を取得する状況があります。私の問題は、これらの要素の1つがキューから取得されるときに、一部が欠落していることです（信号が欠落していますか？）。プロデューサーコードは次のとおりです。

そして、それらは次のもので作成および実行されます。

消費者コードは次のとおりです。

コードを実行すると、20個の要素が追加され、20個が取得されることがありますが、それ以外の場合、取得される要素は20未満です。これを修正する方法はありますか？

oauthを使用してGoogleサービスを活用するAndroidアプリを開発しています。必要に応じてアクションを実行できるように、コンシューマー キー/シークレットが侵害されているかどうかを検出する方法があるかどうかを知りたいですか?

OSコースのCPUスケジューリングシミュレータプロジェクトを行っています。プログラムは、プロデューサースレッドとコンシューマースレッドの2つのスレッドで構成されている必要があります。プロデューサースレッドには、システムでプロセスを生成するジェネレーターと、多数のプロセスを選択してReadyQueueタイプのBufferというオブジェクト（コンシューマーとプロデューサーによる共有オブジェクト）に配置する長期スケジューラーが含まれます。コンシューマースレッドには、キューからプロセスを取得してスケジューリングアルゴリズムを開始する短期スケジューラーが含まれています。スレッドを使用せずにプログラム全体を作成しましたが、正しく機能しましたが、スレッドを追加する必要があり、スレッドを使用したことがないので、必要なスレッドを実装するために以下に示すコードを変更する方法を誰かに教えてもらえれば幸いです。

Producerクラスの実装は次のとおりです。

これはConsumerクラスの実装です。

これがメインスレッドです：

前もって感謝します。

1 つのメッセージ キューと、このキューからメッセージを受信しようとする複数のスタンドアロン プログラムがあるとします。

どのクライアントプログラムが実際にメッセージを受け取るでしょうか? これはどのように決定されますか？ありがとうございました

コンシューマーがツリーの各レベルでいくつかの作業を行ってから、ツリーを再帰的に下って次のレベルで同じ作業を実行する必要があるという再帰的な問題があります。

ConcurrentBag/BlockingCollectionなどを使用してこれを並行して実行したいと思います。このシナリオでは、キューのコンシューマーはキューのプロデューサーでもあります。

私の問題はこれです：BlockingCollectionを使用すると、アイテムをデキューし、新しいアイテムをキューに入れるための非常に単純なforeachロジックを記述できます-キューが空の場合、ブロッキングコレクションは正しくブロックされ、他のいずれかによって新しい作業が生成されるのを待ちます消費者。

しかし、すべての消費者がブロックしているかどうかをどうやって知ることができますか？！

CompleteAdding（）については知っていますが、実際に完了するのは、すべてのプロデューサーがプロデュースを完了し、キューが空になったときだけであるため、それは役に立たないようです。 「無料」でCompleteAdding（）を設定します。これを検出する方法はありますか？（おそらく、ブロックすると発火し、ブロックを解除すると再び発火する可能性のあるイベントですか？）

foreachを使用せずに、手動でwhile（！complete）ループを作成し、TryTakeを使用することで、これを手動で処理できますが、手動でスリープする必要があります。これは非効率的です（ブロッキングコレクションを使用する理由とそもそも同時収集！）ループを通過するたびに、TryTakeがfalseの場合、アイドルフラグを設定し、キューが空で、すべてのスレッドがアイドル状態であるかどうかをマスターにチェックさせ、完全フラグを設定します。しかし、繰り返しになりますが、これは厄介なようです。

直感的に、ブロッキングコレクションを使用してこれを行う方法があると言われていますが、私はそこにたどり着くことができません。

とにかく、誰もが消費者がプロデューサーであるときの良いパターンを持っており、すべてのブロックをいつリリースするかを検出できるのは素晴らしいことです

http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.htmlと非常によく似た問題があります。

異なるエンドポイントで Camel ロックされたスレッドをどのように強制終了しますか? doneUoW を設定した後、エンドポイントを削除して ConsumerTemplate を停止しようとしましたが、うまくいきませんでした。