問題タブ [netty]

SSLを使用したnettyチャネルでの暗号化のサポートを追加します。

いくつかの参照とサンプルコードが必要です。

Doc http://docs.jboss.org/netty/3.2/guide/pdf/netty.pdfは、SSLHandlerを使用して可能であることのみを示しています。

JBOSS Netty を使用して、接続されたクライアントに継続的にデータを送信しようとしています。以下の例では、クライアントが接続 (channelConnected) されるとすぐに、5 秒ごとにクライアントに時間を送信しようとします。

しかし、これは機能していません。while ループにコメントを付けた場合にのみ機能します。

簡単な例として、nettyで2つのワーカースレッドのみを使用して3つの同時TCPクライアント接続を処理したいとします。どうすればよいですか？

質問A）以下のコードでは、3番目の接続はサーバーからデータを取得しません。接続はそこにあるだけです。注意-私のワーカーエグゼキュータとワーカー数は2です。したがって、2つのワーカースレッドと3つの接続がある場合、3つの接続すべてに2つのスレッドを提供するべきではありませんか？

B）別の質問は-nettyはjava.util.concurrentのCompletionServiceを使用していますか？使っていないようです。また、executor.submitまたはfuture.getを実行するソースコードは見当たりませんでした。これにより、ワーカースレッドよりも多い接続へのデータの処理と提供方法の混乱が増しました。

C）nettyが10000以上の同時TCP接続を処理する方法に迷いました.... 10000スレッドを作成しますか？接続ごとのスレッドはスケーラブルなソリューションではないため、テストコードが期待どおりに機能しないため、混乱しています。

この例 をパフォーマンステストに使用しました

netty のパフォーマンスはとても速いと誰かが言っています。1 秒あたり 1,00,000 件以上の同時リクエストを処理できます (以下のリンクを確認してください)。

http://www.jboss.org/netty/performance/20090303-mheath.html

http://www.jboss.org/netty/performance/20090607-asalihefendic.html

しかし、この例を試してみると、1000 の同時リクエストで 107 リクエスト/秒しか得られません

どこに問題があるのか​​教えてください

誰かが、netty のパフォーマンス ベンチマークを強調する Web の例または参照を共有できますか。

以下は、ConcurrentWeakKeyHashMap.javaのisEmpty（）メソッドです 。https：//github.com/netty/netty/blob/master/src/main/java/org/jboss/netty/util/internal/ConcurrentWeakKeyHashMap.java

なぜmcsumが必要なのですか？if（mcsum！= 0）{..}ブロックは何をしますか？

そしてもっと重要なのは、どうすれば取得できますか

真に評価するには？

編集：ブロックが現在ConcurrentWeakKeyHashMapTest にある場合に上記を評価するコード

基本的に、1つのスレッドがconcurrentMapを継続的に監視し、別のスレッドが同じキーペア値を継続的に追加/削除します

私はMinaとNettyを使用していましたが、現在、Androidでも使用できる軽量ライブラリを求めています。標準のio実装よりもNioまたはAsyncIoの方が好きです。

アップデート1
応答がないので、自分でライブラリを作成する必要があると思います。現在、私は生のNIOを使用していますが、それほど楽しいものではありません。

J2EEコンテナ内からのソケット接続を受け入れるためにJCAリソースアダプタを実装しようとしています。

どういうわけか、WorkManagerを使用してnettyのNioServerSocketChannelFactoryのスレッドを管理できるようにする必要があり ます。ヘルプをいただければ幸いです。

接続してハンドシェイクし、メッセージをリッスンする必要があるリモートホストで実行しているプログラムがあります。次のキャメルルートをセットアップしました：

私の質問は、どうすればこれを機能させることができますか? を使用してルートを確立すると

<from uri="netty:tcp://192.168.0.111:50001?decoders=#decoders&amp;sync=false" />

バインディング エラーで失敗します。

サーバーを変更せずに特定のポートで応答するように接続を設定するにはどうすればよいですか?

ChunkedFile を処理するために ChunkedWriteHandler をいじっていますが、次のような状況になりました。ChunkedFile を channelFuture リスナー内のチャネルに書き込むと、

そして、 java.nio.channels.ClosedChannelException と java.lang.NullPointerException の両方を取得しました

clientChannel.write() を実行するとき

これを機能させるために私が知っている唯一の方法は、-リスナーを使用しない-そして Thread.sleep(1000) を追加することです

私は何を間違えましたか？

完全なコード ( http://github.com/lydonchandra/netty/blob/master/src/test/java/org/jboss/netty/handler/stream/ChunkedWriteHandlerTest.javaでも)

私は現在 Play! を使用しています。1.2.2 とその新しい Netty クライアント フレームワーク。

HTTP と HTTPS を非同期で提供することはできますが、SSL を強制する簡単な方法は見つかりませんでした。Play! を使ったことのある人なら誰でも参加できます。SSL を強制する簡単な方法はありますか? リダイレクトを作成する必要があるかどうか、またはこれをファイルですばやく解決できるかどうかはわかりませんconf。