Java NIO学习8(Selector 补充版ServerSocketChannel)

大部分是javanio书上的内容 我来整理一番,外加一些解释,着色!

ServerSocketChannel

让我们从最简单的ServerSocketChannel来开始对socket通道类的讨论

ServerSocketChannel是一个基于通道的socket监听器。它同我们所熟悉的java.net.ServerSocket执行相同的基本任务,不过它增加了通道语义,因此能够在非阻塞模式下运行。

用静态的open( )工厂方法创建一个新的ServerSocketChannel对象,将会返回同一个未绑定的java.net.ServerSocket关联的通道。该对等ServerSocket可以通过在返回的ServerSocketChannel上调用socket( )方法来获取。作为ServerSocketChannel的对等体被创建的ServerSocket对象依赖通道实现。这些socket关联的SocketImpl能识别通道。通道不能被封装在随意的socket对象外面。

由于ServerSocketChannel没有bind( )方法,因此有必要取出对等的socket并使用它来绑定到一个端口以开始监听连接。我们也是使用对等ServerSocket的API来根据需要设置其他的socket选项

ServerSocketChannel ssc = ServerSocketChannel.open();ServerSocket serverSocket = ssc.socket(); // Listen on port 1234serverSocket.bind(new InetSocketAddress(1234));

同它的对等体java.net.ServerSocket一样,ServerSocketChannel也有accept( )方法。

一旦您创建了一个ServerSocketChannel并用对等socket绑定了它,然后您就可以在其中一个上调用accept( )。

如果您选择在ServerSocket上调用accept( )方法,那么它会同任何其他的ServerSocket表现一样的行为:总是阻塞并返回一个java.net.Socket对象(阻塞的!!!!)

。如果您选择在ServerSocketChannel上调用accept( )方法则会返回SocketChannel类型的对象,返回的对象能够在非阻塞模式下运行。假设系统已经有一个安全管理器(security manager),两种形式的方法调用都执行相同的安全检查。

如果以非阻塞模式被调用,当没有传入连接在等待时,ServerSocketChannel.accept( )会立即返回null (因为他是非阻塞的所以要有返回,)。

正是这种检查连接而不阻塞的能力实现了可伸缩性并降低了复杂性。可选择性也因此得到实现。我们可以使用一个选择器实例来注册一个ServerSocketChannel对象以实现新连接到达时自动通知的功能。

演示如何使用一个非阻塞的accept( )方法:

package com.anders.selector2;import java.net.InetSocketAddress;import java.net.ServerSocket;import java.nio.ByteBuffer;import java.nio.channels.ServerSocketChannel;import java.nio.channels.SocketChannel;public class ServerSocketChannelApp {private static final String MSG = "hello, I must be going \n";public static void main(String[] args) throws Exception {int port = 8989;ServerSocketChannel ssc = ServerSocketChannel.open();ServerSocket ss = ssc.socket();ss.bind(new InetSocketAddress(port));// set no blockingssc.configureBlocking(false);ByteBuffer buffer = ByteBuffer.wrap(MSG.getBytes());while (true) {System.out.println("wait for connection ……");SocketChannel sc = ssc.accept();if (sc == null) {// no connections, snooze a while ...Thread.sleep(1000);} else {System.out.println("Incoming connection from " + sc.socket().getRemoteSocketAddress());buffer.rewind();//write msg to clientsc.write(buffer);sc.close();}}}}

ps 阻塞和非阻塞

传统的serversocket阻塞模式:

public class ServerSocketApp {public static void main(String[] args) throws Exception {ServerSocket ss = new ServerSocket(8989);ss.accept();System.out.println(1);}}

运行这个程序 为什么没有输出1 ???

因为ServerSocket 是阻塞模式的 ,什么是阻塞,就是在没有任何连接之前,accept方法一直在那里阻塞着,直到有connection来继续往下执行,所以在运行程序的时候,并没输出1,若要输出 telnet一下就可以了

nio中的 非阻塞:

public static void main(String[] args) throws Exception {ServerSocketChannel ssc = ServerSocketChannel.open();ServerSocket ss = ssc.socket();ss.bind(new InetSocketAddress(8989));// set no blockingssc.configureBlocking(false);ssc.accept();System.out.println(1);}

运行这个程序 有1 输出!!

这就是因为 它是非阻塞模式的。

ServerSocketChannel就说道这里,尤其是阻塞和非阻塞!!!

下篇继续!

你不勇敢,没人替你坚强。

Java NIO学习8(Selector 补充版ServerSocketChannel)

相关文章:

你感兴趣的文章:

标签云: