jafka里的filemessageset类的read方法的问题

Question

@imxylz 你好，想跟你请教个问题：

自己在看jafka的源码时，有个问题不理解，filemessageset的read方法在被Log类的read方法 调用的时候已经是文件内offset了，为什么read方法的实现里要加上this.offset,我感觉这个this.offset就是0.

    public MessageSet read(long offset, int length) throws IOException {
        List<LogSegment> views = segments.getView();
        LogSegment found = findRange(views, offset, views.size());
        if (found == null) {
            if (logger.isTraceEnabled()) {
                logger.trace(format("NOT FOUND MessageSet from Log[%s], offset=%d, length=%d", name, offset, length));
            }
            return MessageSet.Empty;
        }
        return found.getMessageSet().read(offset - found.start(), length);
    }

 public MessageSet read(long readOffset, long size) throws IOException {
        return new FileMessageSet(channel, this.offset + readOffset, //
                Math.min(this.offset + readOffset + size, highWaterMark()), false, new AtomicBoolean(false));
    }

Answer 1

感谢回复

Answer 2

目前FileMessageSet只有一次镜像，所以第一次镜像的offset应该都是0，这没问题。但为了保持this.offset在FileMessageSet中的语义，所以在读写FileMessageSet镜像的时候都带着offset定义。另外也许将来为了提升性能有多级FileMessageSet镜像的时候，这里offset就必须传入正确的值了（这是不一定为0）。