文章/答案/技术大牛

发布

社区首页 >问答首页 >NIO2和ByteBuffer用于读取可变长度消息

问NIO2和ByteBuffer用于读取可变长度消息
EN

Code Review用户

提问于 2015-06-07 09:29:17

回答 1查看 734关注 0票数 3

我正在读取可变长度的消息，其中每条消息都是int + msg字节。消息可以是任意大小的。

现在，我的策略是有一个从套接字读取的直接缓冲区，然后将读取的字节传输到数组支持的非直接缓冲区中。然而，我的解决方案有很多复制，一些循环，只是觉得有点“讨厌”。

有没有更好的解决办法？

以下是读取完成处理程序。我希望事情会变得很明显：

class DelimitedReadCompletionHandler implements CompletionHandler<Integer, Object> {

    private final AsynchronousByteChannel channel;
    private final Consumer<byte[]> onMessageCallback;
    private final ByteBuffer channelReadBuffer; // this is a direct buffer.

    private volatile ByteBuffer currentMessageBuffer;

    public DelimitedReadCompletionHandler(AsynchronousByteChannel channel,
                                          Consumer<byte[]> onMessageCallback,
                                          ByteBuffer channelReadBuffer) {

        this.channel = channel;
        this.onMessageCallback = onMessageCallback;
        this.channelReadBuffer = channelReadBuffer;
    }

    @Override
    public void completed(Integer result,
                          Object attachment) {

        channelReadBuffer.flip();

        do {
            if (currentMessageBuffer == null) {
                if (channelReadBuffer.remaining() < Integer.BYTES) {
                    channelReadBuffer.compact();
                    break;
                }

                currentMessageBuffer = ByteBuffer.allocate(channelReadBuffer.getInt());
            }

            int copyLength = Integer.min(currentMessageBuffer.remaining(), channelReadBuffer.remaining());

            for (int i = 0; i < copyLength; i++) {
                currentMessageBuffer.put(channelReadBuffer.get());
            }

            if (!currentMessageBuffer.hasRemaining()) {
                byte[] msg = currentMessageBuffer.array();
                ForkJoinPool.commonPool().execute(() -> onMessageCallback.accept(msg));

                currentMessageBuffer = null;
            }

            if (channelReadBuffer.hasRemaining()) {
                continue;
            }

            channelReadBuffer.clear();
            break;
        } while (true);

        channel.read(channelReadBuffer, null, this);
    }

    @Override
    public void failed(Throwable exc,
                       Object attachment) {

        exc.printStackTrace();
    }
}

java

回答 1

Code Review用户

发布于 2015-07-05 18:37:21

写一些JavaDoc！

如前所述，我对您的代码非常困惑。但是，如果您的方法中包含了JavaDoc，那么我就不会被这些名称弄糊涂了。

下面是一个简单方法上的JavaDoc示例：

/**
    Returns the sum of both of the parameters.
*/
public int add(int a, int b) {
    return a + b;
}

注意到/**__吗？要使它成为有效的JavaDoc，这是必需的。

在参数不清楚或返回值不清楚的更复杂的函数中，可以在JavaDoc中包括如下内容：

@param nameOfParameter -- description/purpose of parameter
@return -- description of return
        -- description of return
        -- description of return

如果存在多个潜在返回值，则会有多个-- description of return__s。

如果要检查的条件是do/while循环，则没有必要使用true；如果它只是一个普通的while循环，那么它至少会运行一次。

我建议您将do/while更改为while，因为while循环更常见。

我无法进入您试图解决问题的方式，因为我很难理解您的代码。我相信这只是我的责任，但我认为拥有更多的文档无论如何都会有帮助。

票数 1

页面原文内容由Code Review提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://codereview.stackexchange.com/questions/92896

复制

相似问题

问NIO2和ByteBuffer用于读取可变长度消息
EN

回答 1

Code Review用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问NIO2和ByteBuffer用于读取可变长度消息EN

回答 1

Code Review用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问NIO2和ByteBuffer用于读取可变长度消息
EN