原文出处:http://tigerlchen.iteye.com/blog/1747221
Java7 AIO入门实例,首先是服务端实现:
服务端代码
SimpleServer:
public class SimpleServer {
public SimpleServer(int port) throws IOException {
final AsynchronousServerSocketChannel listener = AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(port));
listener.accept(null, new CompletionHandler<AsynchronousSocketChannel, Void>() {
public void completed(AsynchronousSocketChannel ch, Void att) {
// 接受下一个连接
listener.accept(null, this);
// 处理当前连接
handle(ch);
}
public void failed(Throwable exc, Void att) {
}
});
}
public void handle(AsynchronousSocketChannel ch) {
ByteBuffer byteBuffer = ByteBuffer.allocate(32);
try {
ch.read(byteBuffer).get();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
byteBuffer.flip();
System.out.println(byteBuffer.get());
// Do something
}
}
跟着是客户端实现:
客户端代码
SimpleClient:
public class SimpleClient {
private AsynchronousSocketChannel client;
public SimpleClient(String host, int port) throws IOException, InterruptedException, ExecutionException {
this.client = AsynchronousSocketChannel.open();
Future<?> future = client.connect(new InetSocketAddress(host, port));
future.get();
}
public void write(byte b) {
ByteBuffer byteBuffer = ByteBuffer.allocate(32);
byteBuffer.put(b);
byteBuffer.flip();
client.write(byteBuffer);
}
}
写一个简单的测试用例来跑服务端和客户端,先运行testServer(),在运行testClient();
测试用例
AIOTest
public class AIOTest {
@Test
public void testServer() throws IOException, InterruptedException {
SimpleServer server = new SimpleServer(7788);
Thread.sleep(10000);
}
@Test
public void testClient() throws IOException, InterruptedException, ExecutionException {
SimpleClient client = new SimpleClient("localhost", 7788);
client.write((byte) 11);
}
}
因为是异步的,所以在运行server的时候没有发生同步阻塞,在这里我加了一个线程sleep(),如果没有的话,程序会直接跑完回收掉。
分享到:
相关推荐
二、java NIO,AIO编程视频教程 1、java NIO,AIO编程_01.flv 2、java NIO,AIO编程_02.flv 3、java NIO,AIO编程_03.flv 4、java NIO,AIO编程_04.flv 5、java NIO,AIO编程_05.flv 三、Java语言基础教程-Java NIO...
Java基本功:Java入门:涵盖了Java语言的特点、JVM、JDK、JRE的详细解释,Oracle JDK与OpenJDK的对比,Java和C++的区别,以及Java程序的主类定义等。基本数据类型:详细介绍了Java中的基本数据类型及其包装类,...
"Java精华,不可错过"这个资源显然旨在提供一个全面的Java学习路径,涵盖了从入门到进阶的所有关键知识点。 首先,Java入门基础是学习任何编程语言的起点。这部分可能包含以下内容: 1. **Java环境配置**:安装JDK...
1. 深入浅出Java核心技术:这个专栏深入讲解了Java基础,结合实现原理和实例,涵盖Java集合、设计模式和Java 8新特性。 2. 深入理解JVM虚拟机:理解JVM是优化Java应用程序的关键。该专栏介绍了JVM的工作原理,包括...
- **NIO基本概念及BIO、AIO的对比分析**:理解NIO、BIO和AIO之间的区别。 - **Netty实现IM聊天系统**:基于Netty开发即时通讯系统。 **7.21 分布式缓存技术-Redis** - **Redis的安装及数据类型分析**:掌握Redis的...