nio

0熱

1答えて

thisガイドに従ってJava NIOソケットチャネルを使用してファイルを送信しようとしました。それはうまく動作します。私はファイルのリストを送信する方法を変更しました。基本的には、上記のガイドで既に実装されているファイルリストと呼び出しメソッドをループします。「Address already in use」というエラーがあり、FileSenderクラスのソケットクローズラインにコメントしました

-2熱

1答えて

NIO：バッファ内で利用可能なデータがない場合、socketChannel.read（バッファ）を避ける方法

NIO Server \ Clientアプリケーションを作成します。テスト目的のための私のデモでは、クライアントはサーバーに接続するだけでサーバーに要求を送信することはありませんが、selectionKey.isReadable（）は常にtrueを返します。クライアントが要求を送信しないので、私は期待していますisReadalble（） falseを返す必要があります。私がに直面している問題は、

0熱

1答えて

進捗状況を監視する最速のJavaファイルコピー方法は何ですか？

私はクライアントマシンからネットワークフォルダ（UNCパス）にファイルをコピーするために使用されるファイルコピーアプリケーションに取り組んでいます。クライアントとネットワークフォルダは10Gbps接続で接続されています。従来のストリーム/バッファ機構では最大250Mbpsしか使用できませんでした。だから私はNIOメソッドを使い始めたのです。 Files.copy()とtransferFrom()の

0熱

1答えて

Vertx Websocketsは、第2のクライアントを接続した後、ループでエンコードデコンディングを開始します。

私は単純なVertxベースのWebSocketチャットアプリケーションを持っています。これは、MsgServerVerticleとMsgClientVerticleの2つの部分（以下のソースコード）で構成されています。したがって、1つのサーバーと1つのクライアントのみをインスタンス化する場合、正常に動作するように見えます。 2番目のクライアントが接続すると、サーバーは他のクライアントに通知しようと

2熱

1答えて

フリンクシンクはバイオのみをサポートしますか？

シンクのinvokeメソッドは、非同期ioを作る方法のようですか？例えば返信Future？例えば、Redisのコネクターが同期Redisのコマンドを実行するためにjedis libにを使用しています： https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/f

-1熱

1答えて

System.getProperty（ "user.home"）はPaths.get（ "〜"）と同じですか？absolutePath？

等価とは、論理的な等価性であり、文字列の比較ではありません。など。もし私がとFiles.newBufferedReader(Paths.get("~").resolve(Paths.get("file.txt")))をしたら、Windowsや他のシステムで同じファイルを入手できますか？

0熱

1答えて

Java nio socketchannelはTLS1.2でサファリとIOSで早期のEOSを読む

私は本当に変わった問題を抱えています。私のサーバサイドにプロキシアプリケーションを書きました。プロキシはすべて、異なるアプリケーション（WebApplications、IOSApps、Android Appsなど）からのTLS/nonTLS要求と応答を管理し、トラフィックをサーバー上のアプリケーションにプロキシします。 Safari経由でhttps（TLSv1.2）経由で私のプロキシを使用するW

-5熱

1答えて

私はTIMOUTを設定すると、アプリが例外「IllegalBlockingModeException」

public TcpClientChannelSelector(String ip, int port) throws IOException { socketChannel = SocketChannel.open(); socketChannel.configureBlocking(false); socketChannel.socket().connec

1熱

1答えて

同じセレクターのsocketChannelの呼び出しは例外をスローする

私はそのソケットチャンネル&セレクターのキーをキャンセルするとセレクターでsocketchannelを登録しますが、そのキーは永久に無効のままです。したがって、セレクタにそのソケットチャネルを追加するための将来の呼び出しでは、CancelledKeyExceptionがスローされます。 Selection key = channel.register(selector, ops, this);

0熱

1答えて

転送されたデータの量は？

接続に障害が発生した場合にはモード bytesTransferred = fileIChannel.transferTo(0, fileIChannel.size(), socketChannel); // or using a buffer ByteBuffer byteBuffer = ByteBuffer.allocateDirect(1024*8); while (fileIChan