Java新AIO/NIO2：以CompletionHandler实现AsynchronousSocketChannel客户端读操作

缺乏、安全感 2023-10-18 15:11 29阅读 0赞

## Java新AIO/NIO2：以CompletionHandler实现AsynchronousSocketChannel客户端读操作 ##

import java.net.InetSocketAddress;
    import java.nio.ByteBuffer;
    import java.nio.channels.AsynchronousSocketChannel;
    import java.nio.channels.CompletionHandler;
    import java.util.concurrent.Future;
    
    public class Client {
    	public static void main(String[] args) {
    		try {
    			Client client = new Client();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    	public Client() throws Exception {
    		AsynchronousSocketChannel socketChannel = AsynchronousSocketChannel.open();
    		InetSocketAddress inetSocketAddress = new InetSocketAddress("localhost", 80);
    		Future<Void> connect = socketChannel.connect(inetSocketAddress);
    
    		while (!connect.isDone()) {
    			Thread.sleep(10);
    		}
    
    		System.out.println("建立连接" + socketChannel.getRemoteAddress());
    
    		ByteBuffer buffer = ByteBuffer.allocate(1024);
    		MyCompletionHandler completionHandler = new MyCompletionHandler();
    		socketChannel.read(buffer, buffer, completionHandler);
    	}
    
    	private class MyCompletionHandler implements CompletionHandler<Integer, ByteBuffer> {
    
    		@Override
    		public void completed(Integer result, ByteBuffer attachment) {
    			System.out.println("接收服务器数据:" + new String(attachment.array(), 0, result));
    		}
    
    		@Override
    		public void failed(Throwable t, ByteBuffer attachment) {
    			t.printStackTrace();
    		}
    	}
    }