最近工作上是在处理一个线程安全的问题,如何保证对某个资源的访问是独占的,不会有并发的隐患。在此过程中接了
checkthread,一个线程安全的静态分析工具,通过annotation标记在编译期检查可能的并发隐患,提供了一个eclipse插件,有兴趣可以看看他的 example。这个东西有个最不好的地方就是要依赖他的自定义annotation,如果不介意的话还是不错的选择,一些常见的隐患都能够标示出来。
另外就是去了解了下netty3,jboss的子项目,netty2和mina作者的另一个作品,关注它是因为在他的benchmark中,netty3的表现很优秀,可以看这篇报告《
Performance comparision between java nio framework》。大概看了下他的设计思路,其实与mina并无多大区别,不过使用了一些有意思的trick,例如对于write的处理,一般的nio框架都是放入一个队列,然后注册写事件(队列为空的时候),等待写,写通常也是单线程去写。而netty3做了一个优化,发送消息时同样有一个队列,在放入队列后判断当前是否正在写循环中,如果正在写,那么就注册一个WriteTask唤醒selector等待写;如果没有,那么发送线程立即就去执行这个写操作,这里的一个好处是少了两个开销:注册事件等待触发以及线程切换。Selector.wakeup的操作是比较昂贵的,netty3也做了优化。更多东西等待探索。
山寨nio框架yanf4j已经挺久没有做出任何改进,这次索性将很多过去考虑不成熟、实践中证明不必要的代码删除和简化,然后做了个与mina 2.0 -M5的性能对比,采用的netty3作者的benchmark源码,yanf4j的Echo Server如下:
Echo Server
import java.nio.ByteBuffer;import org.jboss.netty.benchmark.echo.Constant;import com.google.code.yanf4j.config.Configuration;import com.google.code.yanf4j.nio.Session;import com.google.code.yanf4j.nio.TCPController;import com.google.code.yanf4j.nio.impl.HandlerAdapter;public class Yanf4j { public static void main(String[] args) throws Exception { boolean threadPoolDisabled = args.length > 0 && args[0].equals("nothreadpool"); Configuration configuration = new Configuration(); configuration.setCheckSessionTimeoutInterval(0); configuration.setSessionIdleTimeout(0); configuration.setTcpNoDelay(true); configuration.setReadThreadCount(Runtime.getRuntime() .availableProcessors()); configuration.setPort(Constant.PORT); configuration .setSessionReadBufferSize(Constant.INITIAL_READ_BUFFER_SIZE); TCPController controller = new TCPController(configuration); controller.setHandler(new EchoHandler()); if (!threadPoolDisabled) { controller .setDispatchMessageThreadPoolSize(Constant.THREAD_POOL_SIZE); } controller.start(); System.out.println("Yanf4j EchoServer is ready to serve at port " + Constant.PORT + "."); System.out .println("Enter 'ant benchmark' on the client side to begin."); System.out.println("Thread pool: " + (threadPoolDisabled ? "DISABLED" : "ENABLED")); } static class EchoHandler extends HandlerAdapter { @Override public void onReceive(final Session session, final Object msg) { session.send(((ByteBuffer) msg).duplicate()); } @Override public void onException(Session session, Throwable t) { session.close(); } } }
最后的分析报表,可以看到yanf4j的性能与mina2的性能相近,不过mina在内存使用上非常狠。此外,Xmemcached 1.1.3 将采用最新的yanf4j 0.7.0。 (横坐标是并发连接数,纵坐标是吞吐量,单位为M/s,测试JDK为1.6.4,具体硬件环境不再详细列出,与xmemcached的benchmark同) 四张图分别是在消息长度为64、256、1024、4096字节下的对比。
文章转自庄周梦蝶 ,原文发布时间2009-06-26
相关资源:七夕情人节表白HTML源码(两款)