問題タブ [data-distribution-service]

スタックレス python を使用すると、同じマシン上にある必要のないタスク (pickling) を後で実行するためにシリアル化できます: http://www.stackless.com/wiki/Pickling

私の質問は、スタックレス python は、これらのピクルされたタスクをプロセスやマシン間で移動するための IPC、ミドルウェア、サービス ブローカー、または DDS テクノロジを提供しますか? ここで本当にソケットを使用する必要があるのでしょうか?

彼らはチャンネルのこの素晴らしいコンセプトを持っています: http://www.stackless.com/wiki/Pickling

チャネルがマシン間で機能し、ネットワーク上のサービス ブローカーにチャネルを簡単に登録できるとしたら、それはすばらしいことです。要するに、タスクを別のマシンにある別のスタックレス python サービスに移動できるようにします。

私は、プロセス（プロデューサーなど）が可変数のプロセス（コンシューマーなど）に一方向メッセージを送信する必要があるという要件に取り組んでいます。

パブリッシュ/サブスクライブ モデルは、コンシューマーがプロデューサーからのメッセージをサブスクライブするため、これには適しているように思われました。これを実現するためにZeroMQを使用してみました。

ただし、いくつかの問題があります。

1. コンシューマはメッセージを継続的にポーリングする必要があります。新しいメッセージがあるときに消費者に通知するようにします。

2. プロデューサー キューがいっぱいになる可能性があります。プロデューサーが何らかの条件に基づいてキューからメッセージを削除することを望んでいました (たとえば、5 秒以上経過したメッセージを削除する、または 5 回読み取られたメッセージを削除するなど)。

3. コンシューマーはポーリングしており、メッセージはキューから削除されないため、コンシューマーには新しいメッセージが着信するまでメッセージが重複して表示されます。新しいメッセージごとに 1 回だけコンシューマーに通知する必要があります。

間違ったモデルを使用している可能性があることを理解しています (publish-subscribe は適していない可能性があります)。request-reply を使用することを考えましたが、プロデューサーはコンシューマーの数を追跡したくないため、うまくいきません。

誰かが良い代替案を提案できますか?

OpenSpliceDDS を次のように構成するのが好きです。

一元化された OpenSpliceDDS を構成する必要があります。グローバルからすべてのデータを送受信します。集中型 dds サーバーでは、443 ポートのみが開かれます。

ポート 443 (セキュア層) で OpenSpliceDDS を構成する方法は??

クライアント マシンには、ローカルの OpenSpliceDDS があります。ローカルの OpenSpliceDDS は、セキュア レイヤー (443) を使用して、ローカル データを中央の OpenSpliceDDS に送信する必要があります。

クライアント側で設定する方法??

ありがとう

修正メッセージを送受信するためのクイックフィックス エンジンとその方法を使用する代わりに、dds を介して修正プロトコルを実装する場合、どのようにすすめますか?

私はddsが初めてです。トピックを構成する必要があるかもしれないことは理解していますが、修正するトピックは何ですか?

JavaでLinux環境を使用して、コンソールからEclipseアプリケーションを実行する前に構成する必要がある構成ファイルを持っています。

これは、次のディレクトリにあるソースへの OpenspliceDDS 構成ファイルです。

source /../HDE/x86.linx2.6./release.com --->コマンドラインで実行

しかし、ANT スクリプトでソース コマンドを実行する必要があります。

例 ：

コマンドのプロパティ タグを作成しました

プリミティブ型のパブリッシャーとサブスクライバーを正常に作成しました。ファイル (xml、txt、ビデオ、オーディオなど) を DDS に公開しようとすると問題が発生します。IDL ファイルで型を指定する方法と、ファイル全体を DDS に公開する方法 (サブスクライバー側でファイルを受け取る方法も) がわかりません。

もう 1 つ質問があります。「DDS でのパブリッシュにメモリ制限はありますか?」

（Javaプラットフォームを使用して）データをサブスクライブする際に問題が発生します。サブスクライバーがトピックをサブスクライブする場合、そのサブスクライブされたデータをDDSから削除する必要があります。しかし、私の場合、データをサブスクライブするたびに、同じデータが何度もサブスクライブされます。データはDDSから削除されません。QoSを試してみましたが、使い方がわかりません。

読み取ったデータをDDSから削除する方法を提案してください。

javaを使用して実装された通常のパブリッシャーとサブスクライバーを作成しました。これは、コンテンツを合計サイズ5MBの1MBとして読み取り、1MBごとにサブスクライバーに公開するように機能します。データは正常に公開されています。既存のファイルのコンテンツ。最後に、ファイル内の最後の1MBのデータしか見つかりませんでした。この問題を解決する方法を教えてください。また、発行者と加入者のソースコードを添付しました。

前もって感謝します

DDS での私の要件は、多くのサブスクライバーがいますが、パブリッシャーは 1 人です。サブスクライバーは DDS からデータを読み取り、メッセージがその特定のサブスクライバー向けであることを確認します。チェックが成功した場合、データのみが取得され、DDS から削除されます。メッセージは、認証されたサブスクライバーがデータを取得するまで DDS に保持する必要があります。(Java 環境で) DDS を使用してこれを達成するにはどうすればよいですか?

私は Linux プラットフォームで作業しており、IDE として Eclipse を使用して Java で Opensplice DDS を実装しています。メイン クラスのパブリッシャーとサブスクライバーが実行されています。現在、ツール EMMA を使用してコード カバレッジ部分で作業しています。Ant スクリプトを使用してビルド ファイルを作成し、EMMA のターゲットを作成しました。現在、下記のような問題に直面しています。これはコンソールのコンテンツ:

構成のいずれかを変更する必要がありますか?最終的に、DDS 実装でコード カバレッジを作成することは可能ですか? この問題について他の組織が認識している場合は、続行するように私を導いてください.

前もって感謝します