問題タブ [netty]

どちらもほぼ同じ機能を提供します。高性能TCPサーバーを開発するためにどちらを選択する必要がありますか？長所と短所は何ですか？

参照リンク：

Apache MINA（ソース）

Netty（ソース）

nettyフレームワークを使用してロングポーリングを行うにはどうすればよいですか? たとえば、私がフェッチするとしますhttp://localhost/waitforx

waitforxイベントを待たなければならないので非同期ですか？たとえば、ブロッキング キューから何かをフェッチするとします (データがキューにある場合にのみフェッチできます)。キューからアイテムを取得するときに、データをクライアントに送り返したいと思います。うまくいけば、誰かがこれを行う方法のヒントを教えてくれます。

どうもありがとう

Netty を使用して非常に単純な UDP サーバーを作成しました。これは非常にうまくバインドされ、メッセージを受け入れますが、バインドを解除する方法がわかりません。

それとも、Netty がサーバーのアンバインドに必要な API を公開していないのでしょうか?

編集

サーバーをバインドするために使用しているコードは次のとおりです。

HTTPComponents を使用して、SQLite データベースにアクセスするカスタム Web サーバーを実装しました。リクエストは TCP/IP 経由で送信され、REST の概念を使用しています。ちなみに私のフロントエンドは HTML/jQuery です。サーブレットを作成するだけで簡単になることはわかっていますが、Apache http サーバーのみを使用するように制限されています。HTTP コンポーネントを使用してもパフォーマンスがよくありません。任意の提案をお願いします。前もって感謝します。

私は1つのアプリを持っています。「マネージャー」と「ワーカー」で構成されます。現在、ワーカーは常に接続を開始し、マネージャーに何かを伝え、マネージャーが応答を送信します。

Manager と Worker の間にはたくさんの通信があるので、両者の間でソケットを開いて通信を行うことを検討しています。また、マネージャーが必要なときにいつでもワーカーに何かを言うことができるように、両方の側から対話を開始したいと考えています。

しかし、「衝突」をどのように処理するかについて、私は少し混乱しています。たとえば、マネージャーがワーカーに何かを言うことに決め、同時にワーカーがマネージャーに何かを言うことにしました。何が起こるか？このような状況はどのように処理されるべきですか？

PS 実際の実装には Netty を使用する予定です。

誰かが私に説明してもらえますか、ネットで「ダウンストリーム例外」はどのように処理されますか？javadocによると、ダウンストリーム例外はありません。

http://docs.jboss.org/netty/3.1/api/org/jboss/netty/channel/ExceptionEvent.html

ダウンストリームハンドラーの1つで例外が発生した場合、またはI / 0スレッド自体で発生した場合、これらのエラーをどこでキャッチして処理できますか？

トムありがとうございます

Netty/NIO ベースのサービスを構築しており、このサービスを運用環境に展開することを検討しています。サービスをデプロイする標準的な方法は、WAR として Tomcat 内にデプロイすることです。

ここで同じアプローチを提案したところ、Netty と Tomcat の両方がサーバーであり、「あるサーバーを別のサーバーでホストするのは意味がない」ため、「実行すべきではない」という叫び声と苦情が寄せられました。

展開の問題が完全に解決され、他のコードを書く必要がなくなるので、私にとっては完全に理にかなっています。なぜそれはそんなに大きな「いいえ」なのですか？

自分のサーバーを実装するために netty をいじり始めました。コツをつかむのに少し時間がかかりましたが、独自の MessageHandler を作成することでクライアントを受け入れることができ、messageReceived 内でバッファーから読み取り、受信したデータに関連するビジネス ロジックを実行できるようになりました。

しかし、問題は、接続されたクライアントにデータを書き込むにはどうすればよいかということです。次のような新しいメッセージが発生した場合にチャネルに書き込むことができるサンプル コードを見ました。

しかし、その時点でデータを書き戻したくない場合はどうすればよいでしょうか? クライアントがソケットに接続されたままで、サーバーで何らかのイベントが発生するまで待機するとどうなるでしょうか? その場合、サーバーはどのようにして書き込み先の正しいソケットを見つけるのでしょうか? チャネル オブジェクトへの参照を保持する必要がありますか? これはコンベンションですか？

コードをさらに調べたところ、writeRequested というメソッドが見つかりました。それは関係ありますか？誰がそれを呼んでいますか？そして、それは必要ですか？

私のnettyプロジェクトには次の簡単なコードがあり、アップストリームから整数を読み取ることを想定しています。パイプラインにエンコーダーはありません。

データがネットワークから着信すると、メソッドは正しく起動されますが（良い兆候）、読み取ろうとすると、次のエラーが発生します。

何か案は？

これは netty で何をしますか?