首頁  >  問答  >  主體

nio - 使用java7的AIO异步读取数据时发现有重复读取的现象

使用如下代码读取socket channel中的数据到缓冲区中,程序对读取到的数据进行处理。
如果读取到的一批数据中,存在半个message的情况下,程序会将本次剩余的半个message数据保存起来,
等下次读取到数据后,进行合并,然后判断程序是否能正常执行,若不能则表示第二次读取到的数据与
之前保存起来的半个message数据不是同一批,则程序继续重新处理第二次读取到的数据,然后第三次读取
后再合并,再试着处理...直到合并后能成功处理。

现在发现,合并后能成功处理,但是后面仍然会读取到已经处理过的半个消息的后半段数据,不知道各位大侠
有没有遇见过这种情况?

socket.read(byteBuffer, null, new CompletionHandler<Integer, Void>() {
    @Override
    public void completed(Integer result, Void attachment) {
        if(result==-1){
            close();
            return;
        }
        byteBuffer.clear();
        if (result > 0) {
            byteBuffer.limit(result);
            LOG.debug("server socket [{}] get " + result + " data from client:{}", clientIdentifier, getString(byteBuffer, result));
            if (!connectted) {
                handleConnect();
            } else {
                if (remainingData != null) {
                    combineBuffer();
                }
                
                while (byteBuffer.position() < result) {
                    doProcess();
                }
            }
        }
        byteBuffer.clear();
        socket.read(byteBuffer, null, this);
    }

    @Override
    public void failed(Throwable exc, Void attachment) {
        LOG.error("Server socket [{}] read failed,{}.", clientIdentifier, exc.toString());
        close();
    }
});
伊谢尔伦伊谢尔伦2714 天前421

全部回覆(1)我來回復

  • ringa_lee

    ringa_lee2017-04-17 15:06:56

    另外還有個問題,就是每次read到的位元組數是不一樣的,我的訊息大小定為2kb,通常情況下,客戶端每發一個訊息,那麼server端就會read到2kb的數據,但偶爾會有隻read到1kb或幾百個位元組的情況,有沒有人知道這是怎麼回事?

    回覆
    0
  • 取消回覆