問題タブ [reactor]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

649 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
0 に答える
306 参照

c++ - POCO C ++ソケットが読み取り可能なときに通知を1つだけ取得しますか?

私は今ゲームサーバーを書いています。ここに私の onReadable 関数があります:

スレッドプールのロジックハン​​ドラで読み込み中のパケットを移動しようとしたのですが、通知が重複して呼び出されます。

通知を 1 つだけ取得する方法はありますか? スレッドでの読み取りが遅く、onReadable を 5 ～ 9 回呼び出すためです。ありがとう。

0 投票する
1 に答える
402 参照

python - サーバーへの送信リクエスト用の「サーバー内クライアント」を作成します

私はこのようなものを作成したい: system_example

そして、別のサーバーに応答を送信するために、Twisted で「サーバー内のクライアント」を作成する方法がわかりませんでした。つまり
、たとえば、いくつかのファイルを fs1 に書き込みました:
Client -> Server -> FSClient(Server.onMessage() に作成) -> Fileserver
と応答を取得:
Fileserver -> FSClient -> Server -> Client

client.py:

server.py (および fileserver-client):

ファイルサーバー.py:

0 投票する
2 に答える
964 参照

spring - Spring の Reactor を使用した UDP ハンドラー

何千もの異なるクライアントから送信された UDP イベントにアプリが反応するようにしたいと考えています。各クライアントは、5 ～ 10 秒ごとに 1 ～ 10 個の UDP パケットを送信します。各パケットは非常に迅速に処理されます (主にメモリと小さな計算で、redis を使用し、たまに DB 呼び出しを行うだけです)。呼び出し元にデータが返されることはありません。

wikiで説明されているように、Reactor を Spring に実装しました。次に、Spring Integration ドキュメントで説明されているように、UDP インバウンド チャネルを実装しました。構成は次のとおりです。

そして、UDPAccumulator で、そのメッセージを reactor にパブリッシュします。

}

これは、高スループットが必要なことに関して、これを行う「正しい」方法ですか? int-ip:udp-inbound-channel-adapterの内部動作とは何ですか?メッセージをリアクターに渡す前にボトルネックになる可能性はありますか? リアクターにはいくつかの TCP 関連のクラスとサポートがありますが、UDP はありません。これを最善の方法で行う方法についての提案は大歓迎です!

ボーナス質問。リアクターにディスパッチされるよりも早くメッセージが到着した場合はどうなりますか? redisメッセージ ストア(記事の下部) は役に立ちますか? そして、リアクターでこのパケットをクランチするメソッドが遅い場合はどうなりますか?

0 投票する
1 に答える
710 参照

java - Reactor を使用してキーに一致するイベントを選択する

リアクター( https://github.com/reactor/reactor )を使用して、次のようないくつかのイベントを通知します

「CREATE」で始まるすべてのイベントを選択するセレクターを実装するにはどうすればよいですか? 何かのようなもの

前もって感謝します。

0 投票する
1 に答える
2210 参照

java - spring-reactor を使用するとメッセージが失われます。セットアップの何が問題になっていますか?

タイムリーに完了するにはマルチスレッドが必要な単純なプログラムを作成するために、Pivo​​tal の新しくリリースされたリアクター フレームワークを調べてみようと思いました。

フレームワークを理解し、それを使ってどのように使用されるかを理解するために、次のサンプル プロジェクトを作成しました。

Main.java:

MyProducer.java:

MyConsumer.java:

最後に、 MainConfiguration.java:

私の問題は、プログラムが決して終了しないことです。コンシューマーは、実行ごとに異なる情報も出力します。3 回連続して実行すると、次のように出力されます。

これは、注釈が構成されているのではなくjavaconfigであり、外部とのやり取りがないことを除けば、これがここの例とどのように異なるかがわからないため、本当に明白な何かを見逃したに違いないようです。

0 投票する
2 に答える
949 参照

python - Twisted Python の一時停止/延期リアクター

私はツイストにかなり慣れていません。レート制限のあるサーバーにクエリを実行する HTTP クライアントを持っています。この制限に達すると、サーバーは HTTP 204 で応答するため、応答を処理しているときに、おそらく厄介なことをしています。このような：

すべてのタスクを一時停止したいので、これを行っています。

次に、同じ実行で後で204にヒットしたタスクを再実行するか（可能かどうかはわかりません）、エラーをログに記録してから別の実行で再実行します。プログラムの。発生する可能性のある別の問題は、サーバーからの応答がない場合に、事前に定義された時間 (以下のコードを参照) の後に遅延をキャンセルするために、接続にタイムアウトを設定したことです。

私が遭遇する可能性のあるもう 1 つの問題は、睡眠中にこのタイムアウトに達する可能性があり、すべての要求がキャンセルされることです。

私が十分に正確であることを願っています。前もって感謝します。

ジェッポ


12345678910