使用Akka处理1000万条消息

Akka演员承诺并发。 有什么更好的模拟方式,看看使用商品硬件和软件处理1000万条消息需要花费多少时间,而无需进行任何低级调整。我用Java编写了整个1000万条消息的处理过程,整个结果令我惊讶。

当我在具有Intel i5 – 4核,4 Gb RAM计算机和JVM堆的iMac计算机上以1024Mb运行该程序时,该程序在23秒内处理了1000万台计算机。 我多次运行该程序,平均时间为25秒。 因此,我收到的吞吐量几乎在每秒40万条消息的范围内,这是惊人的。

下图说明了用于模拟负载生成方案的流程。

警告:每条消息在1秒钟后发送响应,这对于实际情况而言并非正确的模拟。 在这种情况下,消息处理将消耗堆和gc活动上的一些资源,这些资源未考虑在内。

该程序使用了Akka发布者的总体指导:在75秒内处理了1000万条消息(每条消息1秒)! 尽管没有任何限制。

该程序的代码库位于以下位置– https://github.com/write2munish/Akka-Essentials

ApplicationManagerSystem创建actor,并在到WorkerActor的流量中进行泵送

private ActorSystem system;private final ActorRef router;private final static int no_of_msgs = 10 * 1000000;public ApplicationManagerSystem() {final int no_of_workers = 10;system = ActorSystem.create('LoadGeneratorApp');final ActorRef appManager = system.actorOf(new Props(new UntypedActorFactory() {public UntypedActor create() {return new JobControllerActor(no_of_msgs);}}), 'jobController');router = system.actorOf(new Props(new UntypedActorFactory() {public UntypedActor create() {return new WorkerActor(appManager);}}).withRouter(new RoundRobinRouter(no_of_workers)));}private void generateLoad() {for (int i = no_of_msgs; i >= 0; i--) {router.tell('Job Id ' + i + '# send');}System.out.println('All jobs sent successfully');}

一旦WorkerActor收到了消息,则计划将响应在1000毫秒后发送

public class WorkerActor extends UntypedActor {private ActorRef jobController;@Overridepublic void onReceive(Object message) throws Exception {using scheduler to send the reply after 1000 millisecondsgetContext().system().scheduler().scheduleOnce(Duration.create(1000, TimeUnit.MILLISECONDS),jobController, 'Done');}public WorkerActor(ActorRef inJobController) {jobController = inJobController;}}

来自WorkerActor的响应消息被发送到JobControllerActor,后者收集所有响应。

public class JobControllerActor extends UntypedActor {int count = 0;long startedTime = System.currentTimeMillis();int no_of_msgs = 0;@Overridepublic void onReceive(Object message) throws Exception {if (message instanceof String) {if (((String) message).compareTo('Done') == 0) {count++;if (count == no_of_msgs) {long now = System.currentTimeMillis();System.out.println('All messages processed in '+ (now - startedTime)  1000 + ' seconds');System.out.println('Total Number of messages processed '+ count);getContext().system().shutdown();}}}}}

参考: 教程:Hibernate,JPA和Spring MVC –来自Akka Essentials博客的JCG合作伙伴 Munish K Gupta的第2部分 。


翻译自: https://www.javacodegeeks.com/2012/05/processing-10-million-messages-with.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/372460.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

PHP中unset,array_splice删除数组中元素的区别

php中删除数组元素是非常的简单的,但有时删除数组需要对索引进行一些排序要求我们会使用到相关的函数,这里我们来介绍使用unset,array_splice删除数组中的元素区别吧 如果要在某个数组中删除一个元素,可以直接用的unset,但是数组的…

dart服务器开发性能,DartVM服务器开发(第四天)--代码优化

优化请求上一篇文章中,我们通过依赖第三方http_server这个包实现将html页面返回给浏览器,但是一般的服务器都包含请求html,json格式的传递,这样就有可能造成了混乱,下面我们使用http_server这个包进行优化吧&#xff0…

JBox2D和JavaFX:事件与力量

在昨天的示例中,您看到了如何创建一个简单的世界并使用WorldView进行显示,以及如何提供自定义渲染器。 现在,我们将添加一些用户输入。 我们将创建一个类似于弹球机中的鳍状肢的控件。 为此,我们将创建一个关节。 在JBox2D中&…

【Android】SVG和VectorDrawable——相关格式转换

SVG是矢量图,刚接触尚不能仔细介绍,但只需记得一点:放大不失真,存储也方便。 因为多数户型图使用SVG格式,Android要用的话必须通过相关转换工具,将原SVG格式文件,转换为XML后缀的VectorDrawable…

服务器时间维护制度,网络设备及服务器日常维护管理制度

第一章总则第一条:为保证机房设备与信息的安全,保障本校服务器及网络系统在良好、稳定、高效、快速的安全运行。特制定本制度。第二条:为确保中心机房网络设备特别是服务器安全,根据岗位职责设立机房管理员,负责对机房…

SELinux入门简介

操作系统有两类访问控制:自主访问控制(DAC)和强制访问控制(MAC)。标准Linux安全是一种DAC,SELinux为Linux增加了一个灵活的和可配置的的MAC。 进程启动时所拥有的权限就是运行此进程的用户权限,…

RESTEasy教程第3部分:异常处理

在开发软件应用程序时,异常处理是显而易见的要求。 如果在处理用户请求时发生任何错误,我们应该向用户显示一个错误页面,其中包含详细的异常消息,错误代码(可选),更正输入和重试的提示&#xff…

WinForm关闭窗体彻底的退出方式

//System.Environment.Exit(0); //Process.GetCurrentProcess().Kill(); //System.Threading.Thread.CurrentThread.Abort(); System.Diagnostics.Process.GetCurrentProcess().Kill();Application.Exit(); 转载于:https://www.cnblogs.com/XuPengLB/p/5799178.html

创建css的时候选择器有哪几类,CSS3-CSS的选择器共有几类?

CSS 3对属性选择器的又增加了3种子字符串的匹配方式:E[att^"val"]匹配所有E元素中att属性的值以“val”开始的所有元素。E[att$"val"]匹配所有E元素中att属性的值以“val”结束的所有元素。E[att*”val”]匹配所有E元素中att属性的值中包含字符…

在Grails 2.0中使用Servlet 3.0异步功能

上周,我与某人谈论了Grails 2中对Servlet 3.0异步功能的新支持,并意识到我对可用功能并不了解。 所以我想我会尝试一下并分享一些例子。 该文档对这个主题有些了解,因此首先介绍一些背景信息。 在3.0规范中进行异步工作的主要方式是javax.ser…

接口怎么实例化?

最开始看到数据库连接的时候忽然想到这个问题: Connection connull;try {Class.forName(Driver);} catch (ClassNotFoundException e) {e.printStackTrace();}try {conDriverManager.getConnection(url, user, pass);} catch (SQLException e) {e.printStackTrace()…

css中基线指的是哪一条线,如何设置基线网络_CSS, Vertical Rhythm 教程_W3cplus

首先,当谈到排版,我们先要了解基线是什么?维基百科是这样定义)的:在排版和书法中,基线是以字终sit底线为基础,并且向两边延伸的直线。好极了,但我为什么要忽视他呢?好希望你充满激情…

libvirt里的面向对象的C语言

C语言:类的声明和定义 1 // 通用父类的定义2 struct _virClass {3 virClassPtr parent;4 5 unsigned int magic;6 char *name;7 size_t objectSize;8 9 virObjectDisposeCallback dispose; 10 }; 11 typedef struct _virClass virClass; 12 typ…

使用JGroups进行ElasticMQ消息复制

ElasticMQ是一台消息服务器,具有Scala,Java和与Amazon SQS兼容的接口。 它通过跨服务器群集复制消息来支持有保证的消息传递,并通过日志记录实现消息持久性。 消息复制是ElasticMQ的核心功能之一。 但是,如果您看一下代码&#xf…

ajax省市二级联动硬编码,AJAX请求接受硬编码的JSON,但不接受软编码

这个AJAX请求返回'成功'如果PHP中的输出被复制并粘贴了JSON,但是'失败'如果它是由文件生成的。看看下面api.php中的评论,看看我的意思。$.aj…

Fiddler高级技巧 - 映射路径到本地文件夹

适用场景: 你是前端开发人员,要开发一个小模块,需要用到线上的环境(账号、数据、跨域等),但你又没有权限往线上传文件你是移动测试人员,需要将一组接口的返回结果替换为另一组,最简单…

Spring Social入门

像我一样,无论是添加简单的Facebook“赞”按钮,一大堆“共享”按钮还是显示时间轴信息,您都不会注意到当前对应用程序“社交化”的热衷。 每个人都在做这件事,包括Spring的家伙,事实上,他们提供了一个称为S…

apache ajax 跨域访问,Apache 实现AJAX跨域请求

当使用ajax跨域请求时,浏览器报错:XmlHttpRequest error: Origin null is not allowed by Access-Control-Allow-Origin.肯定是跨域的问题,如果用jsonp或者pro更多:当使用ajax跨域请求时,浏览器报错:XmlHtt…

14、数据库

数据库转载于:https://www.cnblogs.com/quyong/p/6687924.html

EhCache复制:RMI与JGroups

最近,我正在研究一种需要复制缓存的产品。 缓存提供程序已经确定-EhCache,剩下的就是有关传输的问题。 哪一个是最佳选择? 这里的最佳选择是指性能更好的选择。 仅在两个可用传输之间进行了性能评估-JGroups和RMI,对其他传输不予考…