どのようにjava7 nioソケットWritePendingExceptionを解決するには？

Question

java docは書かなければならないと言いました。以前のwirteでは動作しませんでした。

非同期ソケットチャネルへの書き込みを試みて、前回の書き込みが完了しなかった場合にチェックされない例外がスローされます。

この段階を説明するための簡単なコード：

val writeLock = new ReentrantLock 

def sendMsg(data: ByteBuffer) = { 
    val p = Promise[Unit] 

    writeLock.lock() 

    socketChannel.write(data, 1, new CompletionHandler[Integer, Int] { 
    override def completed(result: Integer, attachment: Int): Unit = { 
     writeLock.unlock() 

     p.trySuccess(Unit) 
    } 

    override def failed(exc: Throwable, attachment: Int): Unit = { 
     p.tryFailure(exc) 
     writeLock.unlock() 
    } 
    }) 
    p.future 
} 

が、それはIllegalMonitorStateException例外をスロー：

sendMsg(data: ByteBuffer): Future[Unit] = { 
    val p = Promise[Unit] 
    this.synchronized { 
     //socketChannel: AsynchronousSocketChannel is connected socket 
     socketChannel.write(data, 1, new CompletionHandler[Integer, Int] { 
     override def completed(result: Integer, attachment: Int): Unit = { 
      p.trySuccess(Unit) 
     } 

     override def failed(exc: Throwable, attachment: Int): Unit = { 
      p.tryFailure(exc) 
     } 
     } 
    } 
    p.future 
    } 

私はそれがこのunworkコードで完了するまでwrite操作をロックしようとします。
これを同時に実行するにはいくつかの助けが必要です。 さらに、私は別の質問があります。それはjava.sdkとは関係ありません。非同期操作が完了するのを待つ必要があるようです。ありがとう

Answer 1

Javaはこれを処理する必要はありません。コード。

「待つ」必要はありません。あなたはあなたのデータを書いて、書くためにクライアントを「無効にする」。書き込みが完了すると（そのような方法があるため）、クライアントの書き込みを再検証します。

重要な概念は、書き込むチャネルを選択するときに、その時点で「無効」であるチャネルをスキップすることです。

私は数年前にNIOの非同期IOの実装を作った、あなたはさらにヒント

https://github.com/NadirRoGue/asyncnetworkengine/tree/master/src/org/mmocore/network

がMMOConnection.startWriteTask `で MMOClient.sendPacket() WriteHandler.completed()