第八节 netty前传-NIO 几种channel介绍02

ServerSocketChannel

ServerSocketChannel是一个用于监听传入TCP连接的channel,就像标准Java网络中的ServerSocket一样。

java bio中的serversocket和nio中的socket有些类似,两者使用可参考如下:
BIO模式

 ServerSocket ss = new ServerSocket(10086);
    System.out.println("服务器正常启动。。。");
    while(true){
      Socket socket = ss.accept();
      System.out.println("用户接入成功。。。");
      //do something 
    }
  }

NIO模式

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

serverSocketChannel.socket().bind(new InetSocketAddress(9999));

while(true){
    SocketChannel socketChannel =
            serverSocketChannel.accept();
    //do something 
}
  1. ServerSocketChannel 创建:

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

  1. ServerSocketChannel 关闭

serverSocketChannel.close();

  1. 绑定监听端口号:

serverSocketChannel.socket().bind(new InetSocketAddress(9999));

  1. 获取客户端的socket连接

SocketChannel socketChannel = serverSocketChannel.accept();

  1. 非阻塞模式

serverSocketChannel.configureBlocking(false);

  • 注意:非阻塞模式下accept方法会立刻返回客户端的socket连接,如果没有则返回为null
    下面为基本的使用的代码怕片段:
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.socket().bind(new InetSocketAddress(9999));
serverSocketChannel.configureBlocking(false);、
//不断的去获取socket连接
while(true){
    SocketChannel socketChannel =
            serverSocketChannel.accept();
//或取到连接后做处理
    if(socketChannel != null){
        //do something with socketChannel...
        }
}

UDPchannel,DatagramChannel

DatagramChannel是可以发送和接收UDP数据包的通道。 由于UDP是一种无连接的网络协议,因此无法像在其他通道中那样默认读取和写入DatagramChannel。 而是用来发送和接收数据包。

  1. 创建udp通道,并绑定端口号

DatagramChannel channel = DatagramChannel.open();
channel.socket().bind(new InetSocketAddress(9999));

  1. 接收数据包
ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
//receive方法能够将接受的数据写入buf中
channel.receive(buf);
  1. 发送数据包send方法
String newData = "new data";
ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip();
int bytesSent = channel.send(buf, new InetSocketAddress("xxx.com", 80));
  • 需要注意的: 字符串发送到UDP端口80上的“xxx.com”服务器。但是如果没有任何服务侦听该端口,发送端也不会收到任何响应。因为UDP是无连接的不保证数据发送是否成功。

补充:DatagramChannel也可以使用connect方法和指定地址建立连接,然后像操作socketchannel一样使用 write和read方法。但是本质上仍然是无连接的udp协议

channel.connect(new InetSocketAddress("xxx", 80));   
int bytesRead = channel.read(buf);   
int bytesWritten = channel.write(buf);
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • # Java NIO # Java NIO属于非阻塞IO,这是与传统IO最本质的区别。传统IO包括socket和文...
    Teddy_b阅读 649评论 0 0
  • 前言: 之前的文章《Java文件IO常用归纳》主要写了Java 标准IO要注意的细节和技巧,由于网上各种学习途径,...
    androidjp阅读 2,993评论 0 22
  • Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java I...
    JackChen1024阅读 7,647评论 1 143
  • 1 Channel简介 通道(Channel)可以理解为数据传输的管道。通道与流不同的是,流只是在一个方向上移动(...
    沉沦2014阅读 704评论 0 3
  • NIO 并发编程网 - ifeve.comJava NIO系列教程 笔记 http://ifeve.com...
    梓青阅读 609评论 0 0