nio问题

想请教大家的看法？

不知道有没有人使用nio做过网络通信。

我以前是使用普通的阻塞socket做java通信的。

通常的做法是客户端 和 服务器 定义好格式。 然后发送 消息。 两边在互相编解码消息。

最近在学习nio。 但是我发现一个问题。 就是nio的写。 比如 我不间断的调用
[code="java"]
while (true) {
try {
// Thread.sleep((long) (Math.random() * 1000));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

            for (SocketChannel client : sendSocketList) {
                if (client.isConnected()) {
                    try {
                        client.write(ByteBuffer.wrap(("随机回复: " + count
                                .addAndGet(1)).getBytes("UTF-8")));
                    } catch (UnsupportedEncodingException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }

        }

[/code]

这样会导致 对端读取到的消息格式不是合法的。 可能在一次读操作中。读取到了多次写入的信息。

但是如果采用原始的阻塞IO通信。 不管你如何连续的写入消息。 在对端读取到的都是你单次写入的内容。 不会读取到多次写入的内容。

我有个疑问。 要如何解决这个问题呢？

SelectableChannel的register方法有第三个参数
同时SelectionKey也有attach方法

都可以附加一个Object

这个Object根据自己需求使用，通常可以附上ByteBuffer之类的

利用这个可以处理你提到的问题

比如消息定义长度为1024，则buffer不到这个长度的时候就不需要解析。
buffer可以指定读取的多少

非阻塞读写本身不保证一次读写的字节数和你的期望值相同

这个应该就是需要自己来控制的吧