Reactorコードでは、次のようなものを見ることができました

この「の」キーワードは何ですか?

PythonでReactor パターンを実装しようとしています。multiprocessingとを使い始めたのはかなりまともだと思いますselect.select。しかし、私は自分のサーバーのストレステストをしようとしているので、単純な DoS クライアントを作成して接続でフラッドさせました。しかし、興味深いエラーが発生します。

[WinError 10061] ターゲット マシンがアクティブに拒否したため、接続できませんでした

これについて興味深いのは、サーバー上socket.listen(5)のバックログの量を処理していることです。読者の準備が整ったらselect.select、カウントを表示します。期待する 5 ではなく、1 つまたは 2 つしかありません。

少数のスレッド (~20) の場合、チョークに気付かなかったが、多数 (50 以上) の場合、接続を拒否する傾向があります。

私の問題はサーバー側ですか、それともクライアント側にありますか (または単に OS/ソケット レベルにありますか)? これは私が修正できる問題ですか？もしそうなら、どのように？

これが私のコードです：

クライアント

サーバ

Reactor を次のように使用したい:

私のイベントは単純です：

そして、それらのイベントを次のように消費します。

しかし、私は両方の消費者と両方のイベントを受け取ります。

セレクターを使用すると、次のように機能します。

しかし、セレクターを使用すると、非常に多くの文字列を作成して維持する必要があります。

セレクターを使用することがすべてですか？または、どういうわけか「パラメータ化されたクラスタイプで選択」できますか?

Linux で timerfd (timerfd_create) を使用すると、Timer_Heap または Timer_Wheel よりもパフォーマンスが向上するかどうか疑問に思っていました。確かに、これは非常に高レベルの質問であり、どのフレームワークでも使用されているのを見た唯一の場所は「muduo」です。また、パフォーマンスの比較もありません。

ありがとう。

以下は、サーバーのコードです。

次のエラーが表示されます。

Windows 7でEclipseでpydevを使用しています。どこが間違っていますか?

ポーラーの代わりにzmqリアクターを使い始める前は、すべてうまく機能していたと言わざるを得ません。

これが私のzmqコードです。

そして、私は基本的にコールバックでマルチパートメッセージを受信して​​います。

そして、1 時間ごとに 1 つの部分だけで構成されるメッセージが届きます。だから私は得た

編集ここに私の完全なzmqコードがあります。

https://drive.google.com/file/d/0B7jQezPDaLZFQWxBMUdXQkxnS1k/edit?usp=sharing