問題タブ [poller]

私はマルチユーザーシステム向けの電子メールポーリングソリューションに取り組んでいます。したがって、ユーザーはそれぞれのIDで電子メールを送信でき、ポーリングされてデータベースに挿入されます。

私が検討している2つのオプションがあります。

1. Perl/Unixベースの電子メールポーラー。
2. Javaベースのポーラー。

何をお勧めしますか..（他の提案も歓迎します）

メッセージがQueue1に到着した直後ではなく、指定された間隔でQueue1からQueue2にメッセージを転送する必要があります。以下は私の設定です。

上記の xml 構成は、 <int:poller> 構成を無視して、キュー 1 からキュー 2 にメッセージをすぐに転送します。間隔ベースのソリューションと cron ベースのソリューションの両方を試しましたが、どちらも同様に機能するようです (キュー 1 からキュー 2 にメッセージをすぐに配信します)。ここで「ポーラー」の設定に何か問題がありますか? どんな助けでも大歓迎です。

複数のZeromqソケットを処理するために推奨されるアプローチとその理由は、設計上およびパフォーマンス上です。

ZeroMQで使用されるTornadoのIOLoopは、複数のソケットを処理するためのwhileループで使用されるPollerよりもCPUの占有率が低いというのは本当ですか？

こんにちは、backbone.js を使用して paly2.0 フレームワーク アプリケーション (Java を使用) に取り組んでいます。私のアプリケーションでは、定期的にデータベースからテーブルデータを取得する必要があります (今後のイベントリストを表示するユースケースの場合、およびクロスした場合は古いイベントをリストから削除する必要があります)。表示するデータを取得していますが、問題は、データベースを定期的にヒットすることです。そのために、これらのリンクの Backbone.js ポーリングの概念を使用しようとしました。彼らはデータベースから最新のコレクションをポーリングしていません。それを達成する方法または他の代替手段を教えてください。前もって感謝します。

ディレクトリからファイルを読み取ろうとしています。ファイルを処理できない場合は、後で試行するためにそこにとどまります。

問題は、max-messages-per-poll がたとえば 10 に設定されている場合、ファイルが 1 つしかない場合でも、各ポーリングが正確に 10 個のメッセージを返すことです (つまり、10 個のメッセージはすべて同じになります)。

例外によってトランザクションがロールバックされた場合にメッセージが再配信されるように、トランザクション ポーラー (Spring 3.1.2 および Spring-Integration 2.2.3) があります。

これは、H2 データベースを使用した単体テスト時に正常に機能し、メソッドが例外をスローする限り、メッセージは再配信されます

しかし、本番環境で使用するSQLサーバー（重要な場合はREAD COMMITTED SNAPSHOTを分離レベルとして使用するms-sqlserver）を使用すると、例外の再配信が機能しません。これがなぜであるかのヒントはありますか？

編集：

TRACE ログでテストしましたが、疑わしいログ メッセージを見つけることができませんでした。最終的に動作するようになりました。通常の org.springframework.orm.jpa.JpaTransactionManager の代わりに、別個の dataSource (通常のデータベースと同じ構成) と transactionManager org.springframework.jdbc.datasource.DataSourceTransactionManager を宣言しました。

さまざまなジョブを実行するために、バッファの実装に取り​​組んでいます。私はSpringベースのプロジェクトに取り組んでいます。目的を達成するために Spring Integration を使用することにしました。SI がどのように機能するかを理解するために、Cafè サンプル プロジェクトを実行しました。

Spring Integration を示すために、実行するジョブを動的に挿入するテーブルを実装しました。このテーブルが「ゲートウェイ」です。次に、ルーターとさまざまなチャネルを構成しました。

私が完全に理解していないのは、「ゲートウェイ」に新しいジョブが存在するかどうかを確認する必要があるポーラー要素です。これは正しいです？

もしそうなら、どうすればポーラーを設定できますか? 前もって感謝します！ここでxmlコード：

FB

インスタンスを保持するために var を使用せずに、自己キャンセル ポーラーを安全に実装できるかどうか興味があります。akka.actor.Cancellable

これまでのところ、以下の例に示すようなものを思いつきました。ただし、ホットスワップが発生する前、つまりポーラーをスケジュールする行の前に「ティック」メッセージがディスパッチされることはないと想定しても安全かどうか、興味があります。

基本的には次と同じです:

したがって、場合によっては、ホットスワップが発生する前に最初のティックが受信されると思います...

私は Spring Integration を初めて使用し、メッセージのポーラーとトランザクション サポートを max-messages-per-poll 値と組み合わせて使用​​することに関して質問がありました。

以下の構成でポーラーを使用する場合

ドキュメントには、ポーリング タスクがポーリングごとに (または null が受信されるまで) 10 個のメッセージを生成することが記載されています。

各メッセージは独自のトランザクション境界で実行されますか? つまり、1 つのメッセージがトランザクション境界の終わりに到達できなかった場合、失敗したメッセージに対してのみロールバックが発生しますか? それとも、ポーリングの一部であった 10 個のメッセージすべてがロールバックされますか?

ありがとうRC

初歩的な質問で失礼します。