啄木鸟软件测试培训网：www.3testing.com安全
本文来自：51Testing软件测试网采编服务器
由于最近工做的关系，要把异步任务从应用服务器中拆分到专门的异步处理服务器中.微信
方案一多线程
是采用MQ的方式将任务消息发出，在服务端进行处理，以下图所示：并发
这种方案是采用MQ做为中间的媒介，在服务端采用线程池异步处理任务，处理完成以后将结果发送到MQ中，客户端采用侦听的方式获得结果继续进行处理。框架
这种方案的不足是，可能在某些需求的状况下，须要将结果存放到共享的HashMap或者Threadlocal中进行存放结果，客户端会一直阻塞，直到获得结果，从多线程的角度来讲，仍是用了共享变量，虽然共享变量多是线程安全的，可是从并发模型的角度来说，并非一个最好的方式。异步
方案二分布式
采用比较流行的Akka框架来实现。ide
Akka的五大特性工具
易于构建并行和分布式应用
可靠性（Resilient by Design）
系统具有自愈能力，在本地/远程都有监护。
高性能（High Performance）
在单机中每秒可发送50000000个消息。内存占用小，1GB内存中可保存2500000个actors。
弹性，无中心（Elastic — Decentralized）
自适应的负责均衡，路由，分区，配置
可扩展（Extensible） 可使用Akka 扩展包进行扩展。
由于以前一直研究Scala，Scala的多线程处理的性能是很是高的，那基于Scala语言而开发出来的Akka框架获得了普遍使用。那么接下来我将使用一个很是简单的例子，以及一些测试用例展示一下它的性能。
代码以下：
import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props; import akka.actor.UntypedActor; /** * PROJECT_NAME: akkademo * DATE: 16/2/27 * CREATE BY: chao.cheng **/ public class ToStringActor extends UntypedActor { @Override public void onReceive(Object message) { System.out.println(message.toString()); try { Thread.sleep(500); } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { ActorSystem system = ActorSystem.create("toStringActor"); final ActorRef toString = system.actorOf(Props.create(ToStringActor.class),"toString"); for(int i=0;i<10000000;i++) { toString.tell("test"+i,toString); } System.out.println("[结束]======================="); } } |
程序的简单说明：
采用事件的机制，循环发送一千万条数据，经过onReceive方法异步处理任务。
用VisualVM工具截图能够看到：
顾翔凡言：
想作软件测试，最好先去作两到五年开发
啄木鸟软件测试培训中心，主打五门课：
初级：
1，你也想成为软件测试工程师吗～软件测试基础教程
中级：
2，软件测试工程师必须掌握的技能～软件测试设计方法实战。
高级：
3，让你的程序跑得更快～软件性能测试
4，让你找出更多的bug～探索式软件测试
5，让用户迷上你的产品～用户体验式测试
本文分享自微信公众号 - 软件测试培训（iTestTrain）。
若有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一块儿分享。