2

性能测试中Disruptor框架ExceptionHandler使用分享

 2 years ago
source link: https://blog.51cto.com/FunTester/5108050
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

性能测试中Disruptor框架ExceptionHandler使用分享

原创

FunTester 2022-03-16 11:51:10 博主文章分类：FunTester ©著作权

文章标签 性能测试 java 解决方案 文章分类 软件测试 软件研发 阅读数226

在使用Disruptor设计新的性能测试模型的过程中，在使用过程中，偶然发现会有一些异常，然后QPS就会不断下降，直到最后QPS能力降为零。经过查询相关资料后发现了一个小坑：com.lmax.disruptor.ExceptionHandler。

这个接口实现类是处理消费消息的过程中发生的异常，具体的源码位置在com.lmax.disruptor.WorkProcessor#run，有兴趣的可以看看。下面分享一下部分代码：

            catch (final Throwable ex)
            {
                // handle, mark as processed, unless the exception handler threw an exception
                exceptionHandler.handleEventException(ex, nextSequence, event);
                processedSequence = true;
            }

如果大家在使用Disruptor使用默认的方法的话，会使用默认的ExceptionHandler的实现类com.lmax.disruptor.FatalExceptionHandler，它的com.lmax.disruptor.FatalExceptionHandler#handleEventException方法如下：

    @Override
    public void handleEventException(final Throwable ex, final long sequence, final Object event)
    {
        logger.log(Level.SEVERE, "Exception processing: " + sequence + " " + event, ex);

        throw new RuntimeException(ex);
    }

最后还是会抛出一个异常，然后造成com.lmax.disruptor.WorkProcessor执行失败，如果消费消息异常比较多的话，基本上消费线程会很快被干掉，最终导致没有消费线程。

回到实际场景，使用消费线程进行并发请求，在之前的实现中都是直接抛出异常，导致BUG的出现。修复的方法也很简单，要不使用Disruptor提供的几种com.lmax.disruptor.IgnoreExceptionHandler或者org.apache.logging.log4j.core.async.AsyncLoggerDefaultExceptionHandler之类的，基本都是日志打印。不过还是喜欢自己实现，这样方便一些，所以下面是我的解决方案。

try{
    dosomething()
catth(e){

    }

因为随着QPS上升，报错的概率还是挺大的，毕竟是日志流量回放，由于流量文件中部分请求直接回放是会失败的。如果打印日志，即使每秒万分之一的概率，每秒错误QPS就得10+的QPS。不如直接使用专用的日志平台去统计这部分的异常日志。

Have Fun ~ Tester ！


report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK