- 综合排序
- 最热优先
- 最新优先
- 来自专栏后端码事
Java AIO 异步IO应用实例
if(serverChannel == null) return; serverChannel.accept(this, new CompletionHandler<AsynchronousSocketChannel final ByteBuffer echoBuffer = ByteBuffer.allocateDirect(1024); public void completed(AsynchronousSocketChannel ; import java.nio.channels.CompletionHandler; /** * AsynchronousSocketChannel */ public class AIOClient implements Runnable{ private AsynchronousSocketChannel client; private String host; private client = AsynchronousSocketChannel.open(group); //连接 client.connect(new InetSocketAddress
86230发布于 2020-09-11 从入门到精通IO模型：长连接、短连接与Java中的IO模型详解
3.4.1 底层原理在AIO模型中，用户线程通过AsynchronousServerSocketChannel或AsynchronousSocketChannel发起IO请求，并注册一个回调函数。 new InetSocketAddress(8080)); asynchronousServerSocketChannel.accept(null, new CompletionHandler<AsynchronousSocketChannel , Void>() {@Overridepublic void completed(AsynchronousSocketChannel asynchronousSocketChannel, Void attachment ) {ByteBuffer byteBuffer = ByteBuffer.allocate(1024); asynchronousSocketChannel.read(byteBuffer asynchronousSocketChannel = AsynchronousSocketChannel.open()) { Future<Void> future = asynchronousSocketChannel.connect
1.1K21编辑于 2025-01-05- 来自专栏精讲JAVA
Java 非阻塞 IO 和异步 IO
总共有三个类需要我们关注，分别是 AsynchronousSocketChannel，AsynchronousServerSocketChannel 和 AsynchronousFileChannel， , Object>() { public void completed( AsynchronousSocketChannel client, Object attachment) { AsynchronousSocketChannel 其实，说完上面的 AsynchronousServerSocketChannel，基本上读者也就知道怎么使用 AsynchronousSocketChannel client = AsynchronousSocketChannel.open(); // 来个 Future 形式的 Future<? client = AsynchronousSocketChannel.open(group); AsynchronousFileChannels 不属于 group。
1.5K90发布于 2018-03-21 - 来自专栏Coding Diary
Java网络编程 -- AIO异步网络编程
InetSocketAddress(8080)); serverSocketChannel.accept( null, new CompletionHandler<AsynchronousSocketChannel , Object>() { @Override public void completed(AsynchronousSocketChannel client, Object AIO客户端代码示例： public class AIOClient { public static void main(String[] args) throws Exception { AsynchronousSocketChannel socketChannel = AsynchronousSocketChannel.open(); socketChannel.connect(new InetSocketAddress("127.0.0.1
1.3K20发布于 2019-09-25 - 来自专栏微信公众号【Java技术江湖】
Java网络编程和NIO详解5：Java 非阻塞 IO 和异步 IO
总共有三个类需要我们关注，分别是 AsynchronousSocketChannel，AsynchronousServerSocketChannel 和 AsynchronousFileChannel， , Attachment>() { @Override public void completed(AsynchronousSocketChannel client AsynchronousSocketChannel 其实，说完上面的 AsynchronousServerSocketChannel，基本上读者也就知道怎么使用 AsynchronousSocketChannel client = AsynchronousSocketChannel.open(); // 来个 Future 形式的 Future<? client = AsynchronousSocketChannel.open(group); AsynchronousFileChannels 不属于 group。
69610发布于 2019-11-21 - 来自专栏个人开发
tomcat对AQS的扩展：使用LimitLatch控制连接数
下面我们看一下Nio2Endpoint中的内部类Nio2Acceptor protected class Nio2Acceptor extends Acceptor<AsynchronousSocketChannel > implements CompletionHandler<AsynchronousSocketChannel, Void> { protected int errorDelay = 0; , AsynchronousSocketChannel> endpoint) { super(endpoint); } @Override public void state = AcceptorState.PAUSED; } } @Override public void completed(AsynchronousSocketChannel
1K10发布于 2020-08-20 - 来自专栏平凡文摘
Java 非阻塞 IO 和异步 IO
总共有三个类需要我们关注，分别是 AsynchronousSocketChannel，AsynchronousServerSocketChannel 和 AsynchronousFileChannel， , Object>() { public void completed( AsynchronousSocketChannel client, Object attachment) { AsynchronousSocketChannel 其实，说完上面的 AsynchronousServerSocketChannel，基本上读者也就知道怎么使用 AsynchronousSocketChannel client = AsynchronousSocketChannel.open(); // 来个 Future 形式的 Future<? client = AsynchronousSocketChannel.open(group); AsynchronousFileChannels 不属于 group。
2.5K30发布于 2018-07-03 - 来自专栏JavaEdge
BIO NIO AIO演变1 BIO2 NIO3 AIO4 常见面试题5 总结
3.1 小结 AIO模型中通过AsynchronousSocketChannel和AsynchronousServerSocketChannel完成套接字通道的实现。非阻塞，异步。 com.itdragon.util.CalculatorUtil; public class ITDragonAIOServerHandler implements CompletionHandler<AsynchronousSocketChannel exc.printStackTrace(); } }); } // 写入数据 private void write(AsynchronousSocketChannel private static Integer PORT = 8888; private static String IP_ADDRESS = "127.0.0.1"; private AsynchronousSocketChannel 3 AIO模型中通过AsynchronousSocketChannel和AsynchronousServerSocketChannel完成套接字通道实现。非阻塞，异步。 ?
1.6K30发布于 2018-08-10 - 来自专栏Java后端技术栈cwnait
搞清IO的四种模式
)); latch.await(); } } public class AcceptCompletionHandler implements CompletionHandler<AsynchronousSocketChannel } public class ReadCompletionHandler implements CompletionHandler<Integer, ByteBuffer> { private AsynchronousSocketChannel channel; public ReadCompletionHandler(AsynchronousSocketChannel channel) { this.channel = channel IOException, InterruptedException { CountDownLatch latch = new CountDownLatch(1); // 创建一个客户端AsynchronousSocketChannel AsynchronousSocketChannel socketChannel = AsynchronousSocketChannel.open(); // 异步连接服务器，并且将连接后的处理交由
89420发布于 2019-07-16 - 来自专栏JavaEdge
Unix的I/O模型解析
main(String[] args) throws IOException, ExecutionException, InterruptedException { final AsynchronousSocketChannel asynchronousSocketChannel = AsynchronousSocketChannel.open(); Future<Void> connect = asynchronousSocketChannel.connect(InetSocketAddress.createUnresolved("192.168.31.80 3456)); connect.get(); ByteBuffer buffer = ByteBuffer.wrap(new byte[128]); asynchronousSocketChannel.read { //流中止，没有其他操作 } else{ asynchronousSocketChannel.read
72830发布于 2021-02-23 - 来自专栏Java进阶架构师
【015期】JavaSE面试题（十五）：网络IO流
ExecutionException, TimeoutException { while (true) {// 循环接收客户端请求 Future<AsynchronousSocketChannel > future = server.accept(); AsynchronousSocketChannel socket = future.get();// get() 是为了确保 accept 到一个连接 handleWithFuture(socket); } } public void handleWithFuture(AsynchronousSocketChannel , Object>() { public void completed(AsynchronousSocketChannel result, Object attachment } }); } public void handleWithCompletionHandler(final AsynchronousSocketChannel
51220发布于 2020-08-28 - 来自专栏Lambda
Netty序章之BIO NIO AIO演变
小结：AIO模型中通过AsynchronousSocketChannel和AsynchronousServerSocketChannel完成套接字通道的实现。非阻塞，异步。 com.itdragon.util.CalculatorUtil; public class ITDragonAIOServerHandler implements CompletionHandler<AsynchronousSocketChannel exc.printStackTrace(); } }); } // 写入数据 private void write(AsynchronousSocketChannel private static Integer PORT = 8888; private static String IP_ADDRESS = "127.0.0.1"; private AsynchronousSocketChannel 3 AIO模型中通过AsynchronousSocketChannel和AsynchronousServerSocketChannel完成套接字通道实现。非阻塞，异步。
74520编辑于 2022-04-13 - 来自专栏九州牧云
Java I/O 模型的演进
."); while (true) { Future<AsynchronousSocketChannel> asynchronousSocketChannelFuture asynchronousSocketChannel = asynchronousSocketChannelFuture .get(); (1024); // transmitting data while (asynchronousSocketChannel.read = -1) { buffer.flip(); asynchronousSocketChannel.write } } asynchronousSocketChannel.close
54850发布于 2019-08-21 - 来自专栏IT当时语_青山师_JAVA技术栈
从BIO到NIO、AIO和零拷贝
serverSocketChannel.bind(new InetSocketAddress(8080)); serverSocketChannel.accept(null, new CompletionHandler<AsynchronousSocketChannel , Void>() { @Override public void completed(AsynchronousSocketChannel channel }); Thread.sleep(Integer.MAX_VALUE); } } 在上面的例子中，我们使用了AsynchronousServerSocketChannel和AsynchronousSocketChannel
38310编辑于 2023-05-05 - 来自专栏云时代Java开发：原理、实战与优化
Java NIO.2 并发守卫：AcceptPendingException 源码深度剖析与异步状态机契约
语义歧义:两个并发accept如果同时成功，返回的两个AsynchronousSocketChannel的顺序是不确定的。对于需要按序处理连接的场景（如协议握手），这会引入难以调试的竞态条件。 /AsynchronousServerSocketChannelImpl.accept()简化伪代码publicvoidaccept(Aattachment,CompletionHandler<AsynchronousSocketChannel {returnsuspendCancellableCoroutine{cont->accept(null,object:CompletionHandler<AsynchronousSocketChannel ,Unit>{overridefuncompleted(result:AsynchronousSocketChannel,attachment:Unit){cont.resume(result)}overridefunfailed 的可能性privatefinalAtomicBooleanaccepting=newAtomicBoolean(false);publicvoidsafeAccept(CompletionHandler<AsynchronousSocketChannel
12320编辑于 2026-05-25 - 来自专栏CodeGuide | 程序员编码指南
netty案例，netty4.1基础入门篇零《初入JavaIO之门BIO、NIO、AIO实战练习》
客户端 public class AioClient { public static void main(String[] args) throws Exception { AsynchronousSocketChannel socketChannel = AsynchronousSocketChannel.open(); Future<Void> future = socketChannel.connect AioServerChannelInitializer extends ChannelInitializer { @Override protected void initChannel(AsynchronousSocketChannel public abstract class ChannelAdapter implements CompletionHandler<Integer, Object> { private AsynchronousSocketChannel channel; private Charset charset; public ChannelAdapter(AsynchronousSocketChannel channel,
74520发布于 2020-07-14 - 来自专栏九州牧云
Java IO: BIO, NIO, AIO
在JDK1.7中，这部分内容被称作NIO.2，主要在java.nio.channels包下增加了下面四个异步通道： AsynchronousSocketChannel AsynchronousServerSocketChannel serverChannel.accept(null, new CompletionHandler<AsynchronousSocketChannel, Object>() { @Override public void completed(final AsynchronousSocketChannel channel, Object attachment) { // final class EchoCompletionHandler implements CompletionHandler<Integer, ByteBuffer> { private final AsynchronousSocketChannel channel; EchoCompletionHandler(AsynchronousSocketChannel channel) { this.channel = channel
90740发布于 2019-08-21 - 来自专栏JavaEdge
Nio2Endpoint组件：Tomcat如何实现异步I/O？
回调类AcceptHandler 它实现了CompletionHandler接口 两个模板参数V和A，分别表示 I/O调用的返回值 比如accept的返回值就是AsynchronousSocketChannel 因此AcceptHandler带有了两个模板参数：AsynchronousSocketChannel和Nio2Server。 Nio2Acceptor接收新的连接后，得到一个AsynchronousSocketChannel，Nio2Acceptor把AsynchronousSocketChannel封装成一个Nio2SocketWrapper @Override public void completed(AsynchronousSocketChannel socket, Void attachment) {
83520编辑于 2021-12-07 - 来自专栏朱永胜的私房菜
【面试题精讲】javaIO模型之AIO
java.nio.ByteBuffer; import java.nio.channels.AsynchronousServerSocketChannel; import java.nio.channels.AsynchronousSocketChannel new InetSocketAddress("localhost", 8080)); server.accept(null, new CompletionHandler<AsynchronousSocketChannel , Void>() { @Override public void completed(AsynchronousSocketChannel client,
48940编辑于 2023-10-22 - 来自专栏云时代Java开发：原理、实战与优化
Java NIO.2 异步调度中枢：AsynchronousChannelGroup 源码深度剖析与线程池契约
大多数开发者在使用AsynchronousSocketChannel.open()时从不指定group，默默依赖JVM的默认组。 (myGroup);//隐式绑定到默认组AsynchronousSocketChannelch=AsynchronousSocketChannel.open();绑定是不可变的：通道一旦创建，其所属group 第五章：默认组的配置陷阱与生产建议5.1默认组的自动创建未指定group的通道自动绑定到JVM全局默认组：展开代码语言：TXTAI代码解释//等价于AsynchronousSocketChannel.open (AsynchronousChannelGroup.defaultGroup())AsynchronousSocketChannelch=AsynchronousSocketChannel.open() 开发者行动清单审查所有AsynchronousSocketChannel.open()调用，确认是否需要显式Group检查是否使用了withThreadPool+boundedqueue的危险组合验证CompletionHandler
8321编辑于 2026-05-25
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号