nio - 使用java7的AIO异步读取数据时发现有重复读取的现象
伊谢尔伦
伊谢尔伦 2017-04-17 15:04:56
0
1
443

使用如下代码读取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();
    }
});
伊谢尔伦
伊谢尔伦

小伙看你根骨奇佳,潜力无限,来学PHP伐。

全部回覆(1)
左手右手慢动作

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

熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!