利用Channel完成非阻塞操作代码,Java代码库,德仔网

代码语言

代码分类

【Java】利用Channel完成非阻塞操作

作者:Dezai.CN / 发布于2011/12/1/ 609

<div> public class MyTest {
 public static void main(String[] args) throws IOException {
 String server = "10.1.24.199";
 int servPort = 5050;
 //创建一个客户端SocketChannel，并将其设置为非阻塞方式。
 SocketChannel clntChannel = SocketChannel.open();
 clntChannel.configureBlocking(false);
 //尝试连接服务器，由于当前的SocketChannel是非阻塞方式的，因此finishConnect()方法
 //在成功连接之前将会立即返回false，知道成功连接后在返回true。如果在这个过程中出现
 //任何网络错误，finishConnect()方法将会抛出IOException的异常。对于阻塞模式下的
 //SocketChannel，finishConnect()在没有成功连接之前将不会立即返回，而是阻塞等待连接
 //成功，或在出现网络错误时抛出异常。
 if (!clntChannel.connect(new InetSocketAddress(server, servPort))) {
 while (!clntChannel.finishConnect()) {
 //TODO: 做一些其他的事情，以避免这种忙等待消耗更多的系统资源。
 //即使是调用Thread.sleep(0);也可以降低这种忙等待产生的消耗。
 System.out.print(".");
 }
 }
 byte[] demoData = "hello world".getBytes();
 //构建ByteBuffer的两种常用方式，一种是包装已经存在的数组对象，
 //再有就是通过allocate静态方法直接分配内存。
 ByteBuffer writeBuf = ByteBuffer.wrap(demoData);
 ByteBuffer readBuf = ByteBuffer.allocate(demoData.length);
 int totalBytesRecv = 0;
 int bytesRecv;
 while (totalBytesRecv < demoData.length) {
 //由于该SocketChannel是非阻塞模式，因为write和read调用均会立即返回。
 //如果此时没有数据可读，read将返回0，只有在出现网络异常的情况下，read
 //才会返回-1。
 if (writeBuf.hasRemaining())
 clntChannel.write(writeBuf);
 if ((bytesRecv = clntChannel.read(readBuf)) == -1)
 throw new SocketException("Connection Closed Prematurely");
 totalBytesRecv += bytesRecv;
 System.out.print(".");
 }
 System.out.println("Received: " + new String(readBuf.array(),0,totalBytesRecv));
 clntChannel.close();
 }
 }

试试其它关键字

　非阻塞操作　

同语言下

可能有用的

Dezai.CN贡献的其它代码(4037)