Java Socket:Java-NIO-ServerSocketChannel
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选项[java]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( )方法:[java]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阻塞模式:[java]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中的 非阻塞:[java]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 输出!!这就是因为 它是非阻塞模式的。SocketChannel[java]public abstract class SocketChannel extends AbstractSelectableChannel implements ByteChannel, ScatteringByteChannel, GatheringByteChannel {// This is a partial API listingpublic static SocketChannel open() throws IOException;public static SocketChannel open(InetSocketAddress remote) throws IOException;public abstract Socket socket();public abstract boolean connect(SocketAddress remote) throws IOException;public abstract boolean isConnectionPending();public abstract boolean finishConnect() throws IOException;public abstract boolean isConnected();public final int validOps();}Socket和SocketChannel类封装点对点、有序的网络连接,类似于我们所熟知并喜爱的TCP/IP网络连接。SocketChannel扮演客户端发起同一个监听服务器的连接。直到连接成功,它才能收到数据并且只会从连接到的地址接收补充:软件开发 , Java ,
上一个:用jdbc操作数据库的简单例子
下一个:容器(JFrame)
- 更多JAVA疑问解答:
- java怎么在线读取ftp服务器上的文件内容
- 关于程序员的职业规划
- HTML和JSP矛盾吗?
- java小程序如何打包?
- java怎么split路径文件名?
- jsp+javaBean中Column 'ordersPrice' specified twice的错误
- Java TCP/IP Socket网络编程系列
- 大家来讨论一下我到底该用什么好?Swing 还是 JavaFX
- 关于Hibernate实体自身多对一的抓取问题
- 关于apache2+tomcat群集出现的问题
- spring 获取上下文问题
- SSH 导入导出excel 谁有这块的资料吗?
- Ext TreePanel 刷新问题
- springmvc 加载一个jsp页面执行多个方法 报404
- checkbox数组action怎么向页面传值