Java Non-Blocking IO ObjectStream

Question

このトピックに関するいくつかの質問があることがわかりましたが、それは数年前か非常に精巧ではありません。

私は以前のアプリケーションをSocketの新しいNIO SocketChannelに移行していました。なぜなら、それは不安定な状態で動作していたため、もう一度（コードレビューの一環として）この作業を行うつもりだったからです。だから私は非ブロッキングSocketChannelを使用していて、ちょうどObjectInputStreamとObjectOutputStreamを使うことができないことを知りました。 明らかに、SocketChannelには転送されるデータのサイズが必要です。

この問題の解決方法はありますか？おそらくテンプレートが使えるのでしょうか、またはベストプラクティスとして一般的に承認されているソリューションですか（パターン）？私がちょうどとObjectOutputStreamを利用できるという事実は、すべてをもっと簡単にしました。独自の実装を作成する必要がある場合、おそらくあまりにも多くの時間を必要とし、より安定させるためにアプリケーションで多くのことを壊すでしょう。要約で

質問：

• 非ブロックSocketChannelにObjectInputStreamとObjectOutputStreamを使用するための一般的な解決策はありますか？
• ノンブロッキングモードで着信接続を受け入れるようなハイブリッドを作ることもできます。セレクタが読み込むものがあると分かったら、それはブロッキングモードに変わりますか？ （私はそれがひどいと思うけど、私はちょっと必死です。）

PS：Java 8を使用し、それはTCP-Streamです。

Answer 1

私はNon-Blocking SocketChannelを使用していますが、ObjectInputStreamとObjectOutputStreamを使用できないことがわかりました。なぜなら、非ブロック化されているからです。

デフォルトでSocketChannelはブロックされています。ノンブロッキングを望まない場合は、そのように設定しないでください。

ObjectInputStreamとObjectOutputStreamは、単純なJava IOで使用する方がはるかに簡単です。

明らかに、SocketChannelには転送されるデータのサイズが必要です。

これは必須ではありませんが、オブジェクト*ストリームを使用している場合は簡単です。

この問題の解決方法はありますか？

パートは、プレーンIOを使用しているか、NIOを使用する前にある長さのデータブロックを使用しています。

パフォーマンスを向上させたい場合は、別のシリアル化ライブラリを使用することをお勧めします。組み込みのものは最も遅いオプションの1つです。

多くのテンプレートが使用できますか、またはベストプラクティス（パターン）として一般に承認されている解決策がありますか？

プレーンIOと高速シリアライザの使用。

私がObjectInputStreamとObjectOutputStreamを利用できるという事実は、すべてをもっと簡単にしました。

NIOを使用したくない場合は、ノンブロッキングIOとセレクタを使用する場合には10倍の時間がかかります。

独自の実装を作成する必要がある場合、おそらくあまりにも多くの時間を必要とし、より安定させるためにアプリケーションで多くのことを行う必要があります。

選択肢が非常に多い場合は合意してください。

ノンブロッキングSocketChannelでObjectInputStreamおよびObjectOutputStreamを使用する一般的なソリューションはありますか？

全くありません。

私は多分非ブロックモードでの着信接続を受け入れるように、ハイブリッドを作り、セレクターが読むためのものがあることを発見したとき、それは、ブロッキング・モードに変更することはできますか？ （私はそれがひどいと思うけど、私はちょっと必死です。）

確かに、私が言ったように、SocketChannelはデフォルトでブロックされているので、何もする必要はありません。私はアクセプタもブロックするようにします。

PS：Java 8を使用していて、それはTCP-Streamです。

Java 1.4を使用していても問題はありません。これらの図書館は過去12年間で劇的に変化していません。

Answer 2

ByteArrayOutputStreamをラップするObjectOutputStreamを使用してオブジェクトをシリアライズし、結果としてbyte[]バッファを取得します。バッファをSocketChannel経由で送信します。他端に

、あなたSocketChannelからbyte[]バッファを抽出し、ByteArrayInputStreamを構築し、そしてObjectInputStream、あなたのオブジェクトを読み出します。