問題タブ [subscriber]

画像メッセージをリッスンしている rospy サブスクライバーで遅延の問題が発生しています。

概要：

5Hz で /camera/image_raw に画像をストリーミングする rosbag があります。参照用の画像を表示するための image_view ノードもあります。この image_view は 5Hz で表示しています。

rospy サブスクライバー (キュー = 1 で初期化) では、画像も表示します (遅延時間を image_view ノードと比較するため)。サブスクライバーはその後、重い処理を行います。

期待される結果：

キュー サイズが 1 であるため、加入者は最新のフレームを処理し、その間に他のすべてのフレームをスキップする必要があります。処理が完了すると、次の最新フレームに移動する必要があります。古いフレームのキューイングがあってはなりません。これにより、途切れ途切れのビデオが発生しますが、遅延はありません (fps は低くなりますが、rosbag ストリームに対して「遅延」はありません)。

実結果：

サブスクライバーは公開されたストリームに遅れをとっています。具体的には、image_view ノードは 5Hz で画像を表示し、サブスクライバーは最新の画像を取得するだけでなく、すべての画像をキューに入れ、1 つずつ処理しているように見えます。遅延も時間の経過とともに大きくなります。rosbag ストリームを停止すると、サブスクライバーはキュー内の画像を処理し続けます (キュー = 1 であっても)。

以下のように、サブスクライバーのバッファー サイズを非常に大きくするように変更すると、期待どおりの動作が行われることに注意してください。

ただし、これはクリーンなソリューションではありません。

この問題は、バッファ サイズの解決策を見つけた次のリンクでも報告されています。公式の説明では、パブリッシャーが実際に速度を落としている可能性があると仮定していますが、image_view サブスクライバーは 5Hz で画像を表示するため、そうではありません。

https://github.com/ros/ros_comm/issues/536、Ros サブスクライバーが最新ではありません 、http://answers.ros.org/question/50112/unexpected-delay-in-rospy-subscriber/

どんな助けでも大歓迎です。ありがとう！

コード：

私は reactx とrxscalaObservableの初心者で、次のようなものを作成できます。

subscriberの中に新しい弦を入れることができますObservable.apply。

observable外部更新は可能ですか？つまり、次のような方法はありますかputNext:

既存のオブザーバブルに新しいものを入れさせるには？

誰かが私になぜこのようなコードを説明できますか:

インターネットがない場合は doOnError に入りますが、それをさらにスローするため、アプリはダウンしますが、次のようなコードを実行します。

私が期待するように動作します。つまり、インターネット接続がない場合は何もしません。

編集: DCPSInfoRepo から RTPS に切り替えましたが、すべて正常に動作しています。DCPSInfoRepoで作業しているすべての人の問題に答えるために、この質問を開いたままにしておくべきかどうかわかりません

私は OpenDDS の使用を検討しており、現在 Windows の「はじめに」ガイドに従っています。コマンドを使用してメッセンジャーの例を実行するステップに到達しました

エラーだと思われる次の出力が得られます。

この問題を解決する方法を教えてください。

2 つの非同期タスクを実行したいと考えています。ZIP や Flat について何か読んだことがありますが、よくわかりませんでした...

私の目的は、ローカル SQLite からデータをロードすることです。完了すると、クエリがサーバー (リモート) に呼び出されます。

誰かがそれを達成する方法を私に提案できますか?

これは、私が使用している RxJava Observable スケルトンです (単一タスク):

このスクリプトが機能しないのはなぜですか? 後でフォローアップできるように、サブスクライバーの電子メールを含む hello@weblabcompany.com に電子メールを送信したいだけです。

RxAndroid ライブラリを使用して、サブスクライバー/オブザーバブル パターンを使用してアイテムのリストを処理しています。私の問題は、アイテムが処理されると、更新が必要な進行状況バーがあることです。しかし、16 個のアイテムを処理した後、残りのアイテム (90 個) が処理されてから onNext メソッドを 90 回呼び出すまで、オブザーバブルは onNext メソッドを呼び出していないようです。なぜこうなった？これはメモリの問題ですか？

以下のコード。

加入者:

観測可能:

メソッドを認識して画像を処理するのは大変です。最初に考えたのは、このメソッドは多くのメモリを消費しており、すべてのメソッド呼び出しが完了するまで、オブザーバブルは処理されたアイテムをサブスクライバーに配信できないということでした。しかし、私は本当に確信が持てません、誰かがこれを確認できますか?

ありがとう！

ActiveMQ を使用して Mule Publisher Subscriber モデルをセットアップするにはどうすればよいですか? シンプルでわかりやすい完全な例をウェブで探していましたが、できませんでした。私がやりたいことは、(パブリッシャーを使用して) MQ トピックに文字列を送信し、(サブスクライバーを使用して) トピックからメッセージを読み取ることだけです。複雑すぎない

簡略化:
activemq にキューがあります。特定のメッセージがキューから読み取られると、そのプロセスが受信メッセージの処理を終了するまでキューをロックしたいと考えています。

詳細な説明:
多数のユーザーがいるシステムを使用しています。ユーザーがシステムで自分の状態 (プロファイル、ロール、アクセス、資産の所有権など) を変更するたびに、それらの変更でサードパーティ サーバーも更新する必要があります。そのサードパーティは私たちとは別のものであり、彼らが私に公開する API により、一度に 1 人のユーザーのみを更新でき、約 1 秒かかります。
ActiveMQ を使用して、メインの更新プロセスをサード パーティ システムの更新から切り離しています。

一晩に一度、何千ものユーザーの変更を含むフィード ファイルを受け取ります。これは重要なタスクであり、サード パーティの更新はそれほど時間に敏感ではないため、サード パーティの更新では同じテーブルから読み取る必要がある場合があるため、メイン プロセスは一括更新であるため、キューをロックする必要があります。つまり、メイン プロセスで変更した各ユーザーのメッセージを ActiveMQ に取得させたいのですが、メイン プロセスが完了するまで ActiveMQ にこれらのメッセージを保持させたいのです。

そうするための ActiveMQ の組み込みメカニズムはありますか?