java nio的严重BUG(续)

简介:
   上篇文章我谈到了 java nio的一个严重BUG,并且介绍了jetty是如何规避这个BUG的。我在将这部分代码整合进yanf4j的过程中发现了不少误判的情况,让我们看看误判是怎么发生的。jetty的解决方案是通过在select返回为0的情况下,计量Selector.select(timeout)执行的时间是否与传入的timeout参数相差太大(小于timeout的一半),如果相差太大,那么认为发生一次bug,如果发生的次数超过设定值,依据严重程度进行处理:第一尝试取消任何有效并且interestOps等于0的SelectionKey;第二次就是重新创建一个Selector,并将有效的Channel注册到新的Selector。误判的发生就产生于这个时间的计量上,看javadoc可以发现它是这样描述这个方法的:

    This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's wakeup method is invoked, or the current thread is interrupted, whichever comes first

    意思就是说这个方法将阻塞select调用,直到下列三种情况之一发生才返回:至少一个channel被选中;同一个Selector的wakeup方法被调用;或者调用所处的当前线程被中断。这三种情况无论谁先发生,都将导致select(timeout)返回。因此为了减少误判,你需要将这三种情况加入判断条件。Jetty的方案已经将select返回为0的情况考虑了,但是却没有考虑线程被中断或者Selector被wakeup的情况,在jetty的运行时也许不会有这两种情况的发生,不过我在windows上用jdk 6u7跑jetty的时候就发现了误判的日志产生。除了wakeup和线程中断这两种情形外,为了进一步提高判断效率,应该将操作系统版本和jdk版本考虑进来,如果是非linux系统直接不进行后续的判断,如果是jdk6u4以后版本也直接忽略判断,因此yanf4j里的实现大致如下:
            boolean  seeing  =   false ;
            
/**
             * 非linux系统或者超过java6u4版本,直接返回
             
*/
            
if  ( ! SystemUtils.isLinuxPlatform()
                    
||  SystemUtils.isAfterJava6u4Version()) {
                
return  seeing;
            }
            
/**
             * 判断是否发生BUG的要素:
             * (1)select返回为0
             * (2)wait时间大于0
             * (3)select耗时小于一定值
             * (4)非wakeup唤醒
             *  (5)非线程中断引起
             
*/
            
if  (JVMBUG_THRESHHOLD  >   0   &&  selected  ==   0
                    
&&  wait  >  JVMBUG_THRESHHOLD  &&  now  -  before  <  wait  /   4
                    
&&   ! this .wakenUp.get()  /*  waken up  */
                    
&&   ! Thread.currentThread().isInterrupted() /*  Interrupted  */ ) {
                
this .jvmBug.incrementAndGet();

    其中判断是否是线程中断引起的是通过Thread.currentThread().isInterrupted(),判断是否是wakeup是通过一个原子变量wakenUp,当调调用Selector.wakeup时候,这个原子变量更新为true。判断操作系统和jdk版本是通过System.getProperty得到系统属性做字符串处理即可。类似的代码示例:
public   static   final  String OS_NAME  =  System.getProperty( " os.name " );

    
private   static   boolean  isLinuxPlatform  =   false ;

    
static  {
        
if  (OS_NAME  !=   null   &&  OS_NAME.toLowerCase().indexOf( " linux " >=   0 ) {
            isLinuxPlatform 
=   true ;
        }
    }
    
public   static   final  String JAVA_VERSION  =  System
            .getProperty(
" java.version " );
    
private   static   boolean  isAfterJava6u4Version  =   false ;
    
static  {
        
if  (JAVA_VERSION  !=   null ) {
            
//  java4 or java5
             if  (JAVA_VERSION.indexOf( " 1.4. " >=   0
                    
||  JAVA_VERSION.indexOf( " 1.5. " >=   0 )
                isAfterJava6u4Version 
=   false ;
            
//  if it is java6,check sub version
             else   if  (JAVA_VERSION.indexOf( " 1.6. " >=   0 ) {
                
int  index  =  JAVA_VERSION.indexOf( " _ " );
                
if  (index  >   0 ) {
                    String subVersionStr 
=  JAVA_VERSION.substring(index  +   1 );
                    
if  (subVersionStr  !=   null   &&  subVersionStr.length()  >   0 ) {
                        
try  {
                            
int  subVersion  =  Integer.parseInt(subVersionStr);
                            
if  (subVersion  >=   4 )
                                isAfterJava6u4Version 
=   true ;
                        } 
catch  (NumberFormatException e) {

                        }
                    }
                }
                
//  after java6
            }  else
                isAfterJava6u4Version 
=   true ;
        }
    }
文章转自庄周梦蝶  ,原文发布时间2009-10-06
目录
相关文章
|
1月前
|
存储 Java 数据处理
|
1月前
|
Java API
java中IO与NIO有什么不同
java中IO与NIO有什么不同
|
7天前
|
监控 Java 开发者
深入理解 Java 网络编程和 NIO
【4月更文挑战第19天】Java网络编程基于Socket,但NIO(非阻塞I/O)提升了效率和性能。NIO特点是非阻塞模式、选择器机制和缓冲区,适合高并发场景。使用NIO涉及通道、选择器和事件处理,优点是高并发、资源利用率和可扩展性,但复杂度、错误处理和性能调优是挑战。开发者应根据需求选择是否使用NIO,并深入理解其原理。
|
2月前
|
移动开发 编解码 网络协议
用Java的BIO和NIO、Netty来实现HTTP服务器(三) 用Netty实现
用Java的BIO和NIO、Netty来实现HTTP服务器(三) 用Netty实现
|
2月前
|
网络协议 Java Linux
用Java来实现BIO和NIO模型的HTTP服务器(二) NIO的实现
用Java来实现BIO和NIO模型的HTTP服务器(二) NIO的实现
|
2月前
|
编解码 网络协议 Java
用Java的BIO和NIO、Netty实现HTTP服务器(一) BIO与绪论
用Java的BIO和NIO、Netty实现HTTP服务器(一) BIO与绪论
|
3月前
|
Java 应用服务中间件 Linux
java中的NIO,BIO,AIO
java中的NIO,BIO,AIO
17 0
|
9月前
|
Java
Java NIO系列教程三
​ 今天主要给大家介绍的是Buffer的基本使用这个也是NIO里面最总要的概率之一,里面的操作也是有一些复杂的同时也是需要大家必须要重点掌握的知识点,同时也介绍了一下Selector的用法下一篇文章我们将为大家介绍Pipe管道以及FileLock文件锁这也是NIO里面最后的一分部内容了。
79 0
|
9月前
|
安全 Java API
Java NIO系列教程四【完】-管道-文件锁-异步写入
​ 到此位置NIO的所有的内容都结束了,对于NIO来说主要是各种概念需要大家去理解然后有很多的用法和api也需要大家去熟悉所以想把NIO学懂学好其实并不容易一定要多写案例去测试巩固,也预祝大家能把NIO的知识看懂理顺!!!
81 0
|
9月前
|
网络协议 Java
Java NIO系列教程二
​ 今天主要是为大家详细的介绍了常见的各种Channel以及他们的用法,本文编写了大量的案例还需要大家认真的去实践以后才能真正的掌握住。介绍完Channel那么下一篇文章我们就可以为大家介绍Buffer和Selector的具体使用了。
65 0