Netty：接続されたサーバーチャネルを取得するための呼び出しをブロックしますか？

Question

ServerBootstrap.bind()のコールはChannelを返しますが、これはConnectedステータスではないため、クライアントへの書き込みには使用できません。

channelConnectedのようなそのChannelHandlerのイベントからChannelにネッティードキュメント番組の書面でのすべての例 - 私はイベントに接続中のチャンネルではなく取得できるようにしたいが、イベント外の参考として、いくつかのクライアントを言うことができます私のサーバーコンポーネントを使用しているコード。 1つの方法は、手動でchannelConnectedイベントを待ってからコードを作成し、チャンネル参照をコピーすることです。しかし、これはホイールを再発明するかもしれません。

質問：接続されたチャンネルを返すNettyで利用可能なブロッキングコールはありますか？

編集：私はニオではなく、オオのチャンネルを使用しています。

Answer 1

ブロッキングコールを作成することもできますが、イベントベースのアプローチをあまりにも早く誤ったと思います。これはちょうど私があなたが何をしようとして理解を確認するために、不自然な例です：

1. ネッティーServerは
2. DataPusherサービスの開始を開始します。
3. クライアントが接続すると、DataPusherはクライアントチャネルへの参照を取得し、それに何らかのデータを書き込みます。
4. クライアントは接続直後にプッシュされたデータを受信します。

多かれ少なかれ正しいですか？

これを行うには、作成したサーバーパイプラインで、DataPusher（またはそれよりも優れたものの1つ）をChannelHandlerとして登録できます。それを延長するとorg.jboss.netty.channel.SimpleChannelHandlerになります。あなたはそれDataPusherの視点からブロッキング呼び出し作ると判断された場合は、ちょうどそれがラッチを待機して手先がラッチをドロップ持っている

DataPusher dataPusher = getMyDataPusherReference(); 

public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) { 
    dataPusher.doYourThing(e.getChannel()); // do something in another thread.... 
} 

：ハンドラは次のようになります。

あなたの探しているものがわからない場合.....

Answer 2

上記のすべての交換の後、私はまだこれが必要であるとは思わない。

あなたがしなければならないことは、外部サービスからの接続を受け入れるだけです。いかなるイベントのためにもそれを登録しないでください。他のクライアントが接続すると、両方のチャネルでI/Oイベントを登録します。

外部サービスは、別の接続を待っているスレッドでブロックされているのか、他の理由で応答していないのかを気にせず、気にしません。

もし彼があなたに書いているのであれば、あなたが実際に彼から読んでいない限り、ブロックしているかどうかにかかわらず、彼の書き込みはとにかく、あなたのソケット受信バッファのサイズまでは成功します。そのバッファがいっぱいになると、あなたがその一部を読むまでブロックされます。

あなたから読んでいる場合は、あなたが何かを送るまでブロックされ、その間にやっていることは彼には見えません。

だから、私はあなたの思考を単純化し、ノンブロッキングI/Oのすばらしい世界にもっと合わせる必要があると思います。