文档章节

AIO——AsynchronousServerSocketChannel

nifork
 nifork
发布于 2017/08/15 17:58
字数 655
阅读 27
收藏 1
AIO

  接上篇,接下来练习通过AIO实现一个简单的TCP server。熟悉NIO的朋友应该都了解ServerSocket,在AIO中与之对应的就是AsynchronousServerSocketChannel,查看其API文档,介绍如下”An asynchronous channel for stream-oriented listening sockets. “,就是一个异步的数据流监听Socket。其主要函数有如下几个: 

accept(): 接受一个连接,返回一个Future,可通过Future获取到Socket的状态,和数据。 
accept(A attachment, CompletionHandler<AsynchronousSocketChannel,? super A> handler):接受连接,并为连接绑定一个CompletionHandler处理Socket连接 

bind(SocketAddress local):把ServerSocket绑定到本地端口上,等待连接。 
bind(SocketAddress local, int backlog):功能和上面一个方法一样,添加了backlog参数指定队列中挂起的连接的最大个数 

open():开启一个异步Socket通道, 
open(AsynchronousChannelGroup group):开启一个异步Socket通道,并把通道加入指定的组做资源管理 

provider():返回这个Channel的创建者 

setOption(SocketOption<T> name, T value):配置Socket参数的方法。 


下面就是通过AsynchronousServerSocketChannel实现的一个简单的EchoServer,服务器会打印出收到的客户端输入,并把输入写回客户端。(注:代码只有在JDK1.7上才能编译通过)

package cn.bugsee.aio;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.StandardSocketOptions;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousChannelGroup;
import java.nio.channels.AsynchronousServerSocketChannel;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;

/**
 * @USER echo
 * @TIME 2017-08-15 17:20
 * @DESC AIOEchoServer
 **/
public class AIOEchoServer {
    private AsynchronousServerSocketChannel serverSocketChannel;
    public static void main(String[] args) throws IOException {
        AIOEchoServer echoServer = new AIOEchoServer();
        echoServer.init("localhost",8090);
    }

    private void init(String host, int port) throws IOException {
        //ChannelGroup用来管理共享资源
        AsynchronousChannelGroup asynchronousChannelGroup = AsynchronousChannelGroup.withCachedThreadPool(Executors.newCachedThreadPool(),10);
        serverSocketChannel = AsynchronousServerSocketChannel.open(asynchronousChannelGroup);
        //通过setOption配置Socket
        serverSocketChannel.setOption(StandardSocketOptions.SO_REUSEADDR, true);
        serverSocketChannel.setOption(StandardSocketOptions.SO_RCVBUF, 16 * 1024);
        //绑定到指定的主机,端口
        serverSocketChannel.bind(new InetSocketAddress(host, port));
        System.out.println("Listening on " + host + ":" + port);
        //输出provider
        System.out.println("Channel Provider : " + serverSocketChannel.provider());
        //等待连接,并注册CompletionHandler处理内核完成后的操作。
        serverSocketChannel.accept(null, new CompletionHandler<AsynchronousSocketChannel, Object>() {
            final ByteBuffer buffer = ByteBuffer.allocate(1024);
            @Override
            public void completed(AsynchronousSocketChannel result, Object attachment) {
                System.out.println("waiting....");
                buffer.clear();
                try {
                    result.read(buffer).get();
                    buffer.flip();
                    System.out.println("Echo "+ new String(buffer.array()).toString() + " 0 " + result);
                    result.write(buffer);
                    buffer.flip();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                } finally {

                    try {
                        //关闭处理完的socket,并重新调用accept等待新的连接
                        result.close();
                        serverSocketChannel.accept(null, this);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }

            @Override
            public void failed(Throwable exc, Object attachment) {
                System.out.println("Server failed... " + exc.getCause());
            }
        });
        //因为AIO不会阻塞调用进程,因此必须在主进程阻塞,才能保持进程存活。
        try {
            Thread.sleep(Integer.MAX_VALUE);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

运行时会打印出如下信息: 
Listening on localhost:6025 
Channel Provider : sun.nio.ch.BsdAsynchronousChannelProvider@625cb0bb 


在客户端,可以通过telnet localhost 6025验证服务 
Trying ::1... 
telnet: connect to address ::1: Connection refused 
Trying 127.0.0.1... 
Connected to localhost. 
Escape character is '^]'. 

输入 hello,回车,客户端会打印 
hello 
hello 
Connection closed by foreign host. 

服务器端会有打印 
waiting.... 
Echo hello to sun.nio.ch.UnixAsynchronousSocketChannelImpl[connected local=/127.0.0.1:6025 remote=/127.0.0.1:54611] 

本文转载自:http://blog.csdn.net/caomiao2006/article/details/47819255

nifork
粉丝 0
博文 27
码字总数 13098
作品 0
私信 提问
Java新AIO/NIO2:AsynchronousServerSocketChannel和AsynchronousSocketChannel简单服务器-客户端

版权声明:本文为Zhang Phil原创文章,请不要转载! https://blog.csdn.net/zhangphil/article/details/88184067 Java新AIO/NIO2:AsynchronousServerSocketChannel和AsynchronousSocketCha......

zhangphil
03/06
0
0
Java新AIO/NIO2:以CompletionHandler实现 AsynchronousServerSocketChannel服务器端

版权声明:本文为Zhang Phil原创文章,请不要转载! https://blog.csdn.net/zhangphil/article/details/88188043 Java新AIO/NIO2:以CompletionHandler实现 AsynchronousServerSocketChanne......

zhangphil
03/07
0
0
架构设计:系统间通信(5)——IO通信模型和JAVA实践 下篇

7、异步IO 上面两篇文章中,我们分别讲解了阻塞式同步IO、非阻塞式同步IO、多路复用IO 这三种IO模型,以及JAVA对于这三种IO模型的支持。重点说明了IO模型是由操作系统提供支持,且这三种IO模...

旋转木马-千里马
2016/03/22
67
0
I/O模型与Java

原文已同步至http://liumian.win/2016/11/23/io-model-and-java/ 学习I/O模型之前,首先要明白几个概念: 同步、异步 阻塞、非阻塞 这几个概念往往是成对出现的,我们常常能够看到,等描述,正...

那只是一股逆流
2016/11/23
34
0
Java IO: BIO, NIO, AIO

BIO, NIO, AIO,本身的描述都是在Java语言的基础上的。而描述IO,我们需要从三个层面: 编程语言 实现原理 底层基础 从编程语言层面 BIO, NIO, AIO以Java的角度理解: BIO,同步阻塞式IO,简...

丢失的羊羔
2015/12/29
514
2

没有更多内容

加载失败,请刷新页面

加载更多

前端技术之:Prisma Demo服务部署过程记录

安装前提条件: 1、已经安装了docker运行环境 2、以下命令执行记录发生在MackBook环境 3、已经安装了PostgreSQL(我使用的是11版本) 4、Node开发运行环境可以正常工作 首先需要通过Node包管...

popgis
今天
5
0
数组和链表

数组 链表 技巧一:掌握链表,想轻松写出正确的链表代码,需要理解指针获引用的含义: 对指针的理解,记住下面的这句话就可以了: 将某个变量赋值给指针,实际上就是将这个变量的地址赋值给指...

code-ortaerc
今天
4
0
栈-链式(c/c++实现)

上次说“栈是在线性表演变而来的,线性表很自由,想往哪里插数据就往哪里插数据,想删哪数据就删哪数据...。但给线性表一些限制呢,就没那么自由了,把线性表的三边封起来就变成了栈,栈只能...

白客C
今天
43
0
Mybatis Plus service

/** * @author beth * @data 2019-10-20 23:34 */@RunWith(SpringRunner.class)@SpringBootTestpublic class ServiceTest { @Autowired private IUserInfoService iUserInfoS......

一个yuanbeth
今天
5
0
php7-internal 7 zval的操作

## 7.7 zval的操作 扩展中经常会用到各种类型的zval,PHP提供了很多宏用于不同类型zval的操作,尽管我们也可以自己操作zval,但这并不是一个好习惯,因为zval有很多其它用途的标识,如果自己...

冻结not
昨天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部