原文出处: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 AIO,全称为Asynchronous Input/Output,是Java NIO的一个扩展,它引入了非阻塞的异步I/O操作,使得Java开发者能够更高效地处理I/O事件。AIO在Java 7中被引入,相较于传统的IO模型,它的优势在于能够提高并发...
基于java的开发源码-smart-socket 开源的Java AIO框架.zip 基于java的开发源码-smart-socket 开源的Java AIO框架.zip 基于java的开发源码-smart-socket 开源的Java AIO框架.zip 基于java的开发源码-smart-socket ...
Java AIO,全称为Asynchronous Input/Output,是Java NIO的一个扩展,它引入了非阻塞的异步I/O模型,使得在处理高并发、大数据传输时性能更优,尤其适合于物联网(IoT)场景,其中设备之间的通信效率至关重要。...
JAVA 7 AIO 学习笔记,很详细的讲解
9. **网络IO**:Java的NIO(Non-blocking I/O)和AIO(Asynchronous I/O)为网络编程提供了高效的I/O模型,特别是对于高并发场景,能够显著提升性能。 10. **实战案例**:书中可能包含各种实际的网络应用示例,如...
Java AIO(Asynchronous I/O)是Java 7中引入的用于处理异步I/O操作的接口,它提供了一种新的I/O操作方式,以提高应用程序处理大量并发连接的效率。在传统的Java NIO(New I/O)中,虽然可以通过选择器(Selector)...
Java AIO(Asynchronous Input/Output)是一种在Java中实现非阻塞I/O的方式,它在JDK 7中引入,提供了异步读写操作,能够显著提高高并发场景下的性能。基于Java AIO实现的MQTT客户端和broker服务,如标题和描述中...
二、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 AIO,全称为Asynchronous Input/Output,也被称为NIO 2,是Java平台提供的一种非阻塞I/O模型,旨在改善Java的I/O性能,特别是在处理大量并发连接时。RPC(Remote Procedure Call)是一种分布式计算技术,允许...
《深入解析Smart-Socket:基于Java AIO的高效网络通信框架》 Smart-Socket是一款开源的Java异步非阻塞I/O(AIO)框架,它以高效、稳定和易于扩展为特点,广泛应用于高性能、高并发的网络通信场景。在Java的世界里,...
在这样的技术背景下,基于Java AIO(异步非阻塞I/O)实现的Java MQTT组件和服务应运而生,旨在提供开源、简单、易用、低延迟和高性能的MQTT客户端与代理服务。 Java AIO是Java 7中引入的异步I/O操作,它允许开发者...
该项目利用Java的异步非阻塞I/O(Aio)来实现高效的网络通信,以支持大量并发客户端连接,满足高流量和低延迟的通信需求。 Java Aio是一种基于事件驱动的I/O模型,它能够在数据准备好处理时通知应用程序,而不是...
Java AIO支持异步读写操作,不会阻塞线程,能够在等待I/O操作完成期间继续执行其他操作,这对于处理大规模并发连接和提高系统性能具有重要意义。基于Java AIO实现的MQTT组件和broker服务能够更好地服务于高并发场景...
Java AIO,全称为Asynchronous Input/Output,是Java NIO的一个扩展,它提供了一种异步非阻塞的I/O操作方式,特别是在处理高并发、低延迟的网络通信场景时,AIO具有显著的优势。在RPC(Remote Procedure Call)框架...
涉及到java io, nio, aio相关知识点,学习过程中的一些总结,持续更新中,xmind 格式
Java中的异步套接字编程,也称为非阻塞I/O(Non-blocking I/O, NIO)或异步I/O(Asynchronous I/O, AIO),是Java在JDK 7引入的一种高级I/O模型,它极大地提高了网络编程的效率。AIO的主要目标是提供一种方法,使得...
基于 Java AIO 和 T-IO: 利用 Java 异步 I/O 和 T-IO 提供高效性能。引入 Spring-Boot 配置理念: 支持常用的 Spring-Boot 注解,但不使用 Spring 的 IOC 和 AOP。集成 JFinal AOP: 用于支持依赖注入 (DI)、控制反转 ...
基于 Java AIO 和 T-IO: 利用 Java 异步 I/O 和 T-IO 提供高效性能。引入 Spring-Boot 配置理念: 支持常用的 Spring-Boot 注解,但不使用 Spring 的 IOC 和 AOP。集成 JFinal AOP: 用于支持依赖注入 (DI)、控制反转 ...
该项目是一款基于Java AIO技术实现的百万级性能Java MQTT客户端与Broker服务设计源码,开源、轻量级且易于使用。它以低延迟和高性能著称,适用于构建大规模的Java MQTT应用。源码包含361个文件,其中Java文件280个,...