锐客网

  1. 首页 > 睿知 > it技术 > >

java异步跑代码 java实现异步的几种方法( 四 )

IT技术代码


选择器和选择键介绍java异步跑代码：
选择器（Selector）的作用是：将通道感兴趣的事件放入队列中，而不是马上提交给应用程序，等已注册的通道自己来请求处理这些事件 。换句话说，就是选择器将会随时报告已经准备好了的通道，而且是按照先进先出的顺序 。那么，选择器是通过什么来报告的呢？选择键(SelectionKey) 。选择键的作用就是表明哪个通道已经做好了准备，准备干什么 。java异步跑代码你也许马上会想到，那一定是已注册的通道感兴趣的事件 。不错，例如对于服务器端serverChl来说，可以调用key.isAcceptable()来通知serverChl有客户端连接请求 。相应的函数还有：SelectionKey.isReadable(),SelectionKey.isWritable() 。一般的 ， 在一个循环中轮询感兴趣的事件（具体可参照下面的代码） 。如果选择器中尚无通道已注册事件发生，调用Selector.select()将阻塞，直到有事件发生为止 。另外，可以调用selectNow()或者select(long timeout) 。前者立即返回 ， 没有事件时返回0值；后者等待timeout时间后返回 。一个选择器最多可以同时被63个通道一起注册使用 。
应用实例：
下面是用异步输入输出机制实现的客户/服务器实例程序――程序清单1（限于篇幅，只给出了服务器端实现，读者可以参照着实现客户端代码）：
程序类图
public class NBlockingServer {
int port = 8000;
int BUFFERSIZE = 1024;
Selector selector = null;
ServerSocketChannel serverChannel = null;
HashMap clientChannelMap = null;//用来存放每一个客户连接对应的套接字和通道
public NBlockingServer( int port ) {
this.clientChannelMap = new HashMap();
this.port = port;
}
public void initialize() throws IOException {
//初始化 ， 分别实例化一个选择器，一个服务器端可选择通道
this.selector = Selector.open();
this.serverChannel = ServerSocketChannel.open();
this.serverChannel.configureBlocking(false);
InetAddress localhost = InetAddress.getLocalHost();
InetSocketAddress isa = new InetSocketAddress(localhost, this.port );
this.serverChannel.socket().bind(isa);//将该套接字绑定到服务器某一可用端口
}
//结束时释放资源
public void finalize() throws IOException {
this.serverChannel.close();
this.selector.close();
}
//将读入字节缓冲的信息解码
public String decode( ByteBuffer byteBuffer ) throws
CharacterCodingException {
Charset charset = Charset.forName( "ISO-8859-1" );
CharsetDecoder decoder = charset.newDecoder();
CharBuffer charBuffer = decoder.decode( byteBuffer );
String result = charBuffer.toString();
return result;
}
//监听端口，当通道准备好时进行相应操作
public void portListening() throws IOException, InterruptedException {
//服务器端通道注册OP_ACCEPT事件
SelectionKey acceptKey =this.serverChannel.register( this.selector,
SelectionKey.OP_ACCEPT );
//当有已注册的事件发生时,select()返回值将大于0
while (acceptKey.selector().select()0 ) {
System.out.println("event happened");
//取得所有已经准备好的所有选择键
Set readyKeys = this.selector.selectedKeys();
//使用迭代器对选择键进行轮询
Iterator i = readyKeys.iterator();
while (i
else if ( key.isReadable() ) {//如果是通道读准备好事件
System.out.println("Readable");
//取得选择键对应的通道和套接字
SelectableChannel nextReady =
(SelectableChannel) key.channel();
Socket socket = (Socket) key.attachment();
//处理该事件 ， 处理方法已封装在类ClientChInstance中
this.readFromChannel( socket.getChannel(),

推荐阅读


上一篇：jquery的is方法，jquery中常用的方法

下一篇：直播采集画笔技巧，直播采集画笔技巧是什么