java nio socketChannel read返回值代表的意思

当socketChannel为阻塞方式时（默认就是阻塞方式）read函数，不会返回0，阻塞方式的socketChannel，若没有数据可读，或者缓冲区满了，就会阻塞，直到满足读的条件，所以一般阻塞方式的read是比较简单的，不过阻塞方式的socketChannel的问题也是显而易见的。这里我结合基于NIO 写ftp服务器调试过程中碰到的问题，总结一下非阻塞场景下的read碰到的问题。注意：这里的场景都是基于客户端以阻塞socket的方式发送数据。

1、read什么时候返回-1

read返回-1说明客户端的数据发送完毕，并且主动的close socket。所以在这种场景下，（服务器程序）你需要关闭socketChannel并且取消key，最好是退出当前函数。注意，这个时候服务端要是继续使用该socketChannel进行读操作的话，就会抛出“远程主机强迫关闭一个现有的连接”的IO异常。

2、read什么时候返回0

其实read返回0有3种情况，一是某一时刻socketChannel中当前（注意是当前）没有数据可以读，这时会返回0，其次是bytebuffer的position等于limit了，即bytebuffer的remaining等于0，这个时候也会返回0，最后一种情况就是客户端的数据发送完毕了（注意看后面的程序里有这样子的代码），这个时候客户端想获取服务端的反馈调用了recv函数，若服务端继续read，这个时候就会返回0。

总结：当客户端发送的是文件，而且大小未知的情况，服务端如何判断对方已经发送完毕。如单纯的判断是否等于0，可能会导致客户端发送的数据不完整。所以，这里加了一个检测0出现次数的判断，来判断客户端是否确实是数据发送完毕了，当然这个方法是比较笨拙的方法，大家若有更好的方法，期待大家给我答案。

网上也有类似的建议，比如自定义协议，在数据头部带上文件大小等。

注意：这里有一个问题就是通过这种while循环读取的方式，实际上它只有一次NIO事件通知，而且在这个处理过程中，其他事件就得不到及时处理，除非while结束。

更好的方式是整个体系中只有一个大的bytebuffer封装体，然后每次使用都从这个封装体中去取然后手工释放也就有些人说的“memcache”。

你说这句话的时候已经说明连入门级还没到。多个线程中不同的KEY读取的数据在同一个bytebuffer中交叉存放，然后如果分配给每个具体的处理程序？“手工释放”这种搞笑的话也说得出来？如何手工？用手去操作内存？除了因为理屈词穷而想出这种混乱思维，你说的有些人在哪里见到这种使用方式？

对sk.interestOps(SelectionKey.OP_READ);的两点你说明什么？说明你去看了底层的操作？底层如何操作了？只说明你根本没有能力看懂sk.interestOps(SelectionKey.OP_READ);的作用。

对于非阻塞IO的读操作（写相反），一次select只是通知载协议栈的读操作有数据可读，至于这次读到的数据是多少，是否是一次完整的交互数据，selector并不关心。如果客户端在发送了1024字节的数据，这次只读到512字节，那么余下的512只能等下次select，除非是阻塞方式可以等到一直读完。

那么到底是重新注册READ事件还是sk.interestOps(SelectionKey.OP_READ);，如果重新注册当然可以读到下面的数据，但是你就无法和上次的那部份数据合并，因为多个KEY的不完整数据同时存在，你不知道要合并到哪个现有上去，所以用sk.interestOps(SelectionKey.OP_READ);的意思其实就是用同一个KEY重新注册，下次读到的余下的数据合并到上次这个KEY的部分数据上，代表同一客户端的一次完整的发送。

对于同一次交互中比较大的数据，必须使用sk.interestOps(SelectionKey.OP_READ);来多次读取。无论你出于什么原因只要你知道他的作用就不可能说它不必要。就象阻塞方法中我们while((len = in.read(buf)) > 0){....};如果你说while不必要的话，那只能说明你根本不懂IO操作。

理论上即使对方发两个字节的数据，一次select也可能只读到第一个字节，除非在第一次select时，已经读到的数据中包含中约定好的结束标记或已经知道的长度。而楼主的代码只是将读到的数据打印出来，既没有判断是否已经读到结束标记，也没判断已经读到的数据长度是否达到多少而不需再读，那么sk.interestOps(SelectionKey.OP_READ);来读下次数据怎么会不必要？只要你懂这段代码的意思就不可能说出这样的话。说出这样的话只能代表你不懂

服务端的代码（客户端发送的数据大小未知）

[java] view plaincopy

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import com.myftpnio.server.FtpNioServer;
public class ClientHandler implements NioHandler {
private SocketChannel sc;
@SuppressWarnings("unused")
private Selector selector;
private ByteBuffer buf = ByteBuffer.allocate(1024);
private long sum = 0;
private static int count_zore = 0;
public ClientHandler(SocketChannel sc, Selector selector) {
this.sc = sc;
this.selector = selector;
}
@Override
public void execute(SelectionKey key) {
// TODO Auto-generated method stub
if (key.isReadable()) {
try {
while(true) {
buf.clear();
int n = sc.read(buf);
if (n > 0) {
sum += n;
System.out.println("sum=" + sum + " n=" + n + " " + FtpNioServer.ByteBufferToString(buf));
} else if (n == 0) {
if (count_zore++ < FtpNioServer.MAX) {
continue; //这里表明还需要读取数据
} else {
key.interestOps(SelectionKey.OP_WRITE);
break; //这里表明已经读取到了所有需要的数据
}
} else if (n == -1) {
System.out.println("client close connect");
sc.close();
key.cancel();
return;
}
}
} catch (IOException e) {
//处理捕获到的IO异常
System.out.println(e.getMessage());
try {
sc.close();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
key.cancel();
return;
}
}
if (key.isWritable()) {
try {
String ret = "hello " + sc.socket().getRemoteSocketAddress().toString();
ByteBuffer send = ByteBuffer.wrap(ret.getBytes());
sc.write(send);
key.cancel();
sc.close();
FtpNioServer.connum--;
count_zore = 0;
} catch (Exception e) {
e.printStackTrace();
}
}
}
}

java nio socketChannel read返回值代表的意思相关推荐

java方法带参数返回值_Java方法中的参数太多，第6部分：方法返回
java方法带参数返回值在当前的系列文章中,我正在致力于减少调用Java方法和构造函数所需的参数数量,到目前为止,我一直专注于直接影响参数本身的方法( 自定义类型 , 参数对象 , 构建器模式 , ...
Java NIO SocketChannel+Buffer+Selector 详解（含多人聊天室实例）
一.Java NIO 的核心组件 Java NIO的核心组件包括:Channel(通道),Buffer(缓冲区),Selector(选择器),其中Channel和Buffer比较好理解简单来说 N ...
java 参数返回_Java基础---Java中带参数返回值方法的使用（四十）
Java 中带参带返回值方法的使用如果方法既包含参数,又带有返回值,我们称为带参带返回值的方法. 例如:下面的代码,定义了一个 show 方法,带有一个参数 name ,方法执行后返回一个 Stri ...
Java中使用有返回值的线程
在创建多线程程序的时候,我们常实现Runnable接口,Runnable没有返回值,要想获得返回值,Java5提供了一个新的接口Callable,可以获取线程中的返回值,但是获取线程的返回值的时候,需 ...
java 异步得到函数返回值_使用JavaScript进行异步编程
毫无疑问,虽然JavaScript的历史比较悠久,但这并不妨碍它成为当今最受欢迎的编程语言之一.对刚接触该语言的人来说,JavaScript的异步特性可能会有一些挑战.在本文中,我们将了解和使用Pro ...
java字符类型的返回值,Java字符类isWhitespace()方法及示例
Character 类isWhitespace()法isWhitespace()方法在java.lang包中可用. isWhitespace()方法用于检查给定的char值是否为空格,但是它包含空格中 ...
Java基础---Java中带参数返回值方法的使用（四十）
Java 中带参带返回值方法的使用如果方法既包含参数,又带有返回值,我们称为带参带返回值的方法. 例如:下面的代码,定义了一个 show 方法,带有一个参数 name ,方法执行后返回一个 Stri ...
Java NIO SocketChannel读
以读取百度的首页内容为例: import java.net.InetAddress; import java.net.InetSocketAddress; import java.nio.ByteBu ...
java的main函数返回值_Java中的main方法
首先需要说明的是: 1.main函数(主函数)是可以调用的,这种调用是没有意义的: 2. main函数只能出现在公共类中也就是public class中: 但我不明白的是:在eclipse中默认的in ...

java nio socketChannel read返回值代表的意思

java nio socketChannel read返回值代表的意思相关推荐

最新文章

热门文章