因为最近工作的关系,要把异步任务从应用服务器中拆分到专门的异步处理服务器中.
方案一
是采用MQ的方式将任务消息发出,在服务端进行处理,如下图所示:
这种方案是采用MQ作为中间的媒介,在服务端采用线程池异步处理任务,处理完成之后将结果发送到MQ中,客户端采用侦听的方式得到结果继续进行处理。
这种方案的不足是,可能在某些需求的情况下,需要将结果存放到共享的HashMap或者Threadlocal中进行存放结果,客户端会一直阻塞,直到得到结果,从多线程的角度来说,还是用了共享变量,虽然共享变量可能是线程安全的,但是从并发模型的角度来讲,并不是一个最好的方式。
方案二
采用比较流行的Akka框架来实现。
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工具截图可以看到:
后台其实自适应只起了三个线程在运行,分别是dispatcher-2,dispatcher-3,dispatcher-4。
正在分析性能耗时。
服务器整体CPU占比时间为15.9%。
相关推荐
Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成,同时提供了Scala和JAVA的开发接口。
.net框架下的分布式akka的例子。akka是基于actor模型的一个成熟的应用,可用于改造现有框架。
基于Akka的高性能可伸缩的JAVA网络游戏服务器。简单的单服务器开发与集群开发的切换。使用Actor处理高并发。易于测试。服务的插件管理。高性能,可伸缩的Java Tcp服务器架构,1.Avalon基于Akka构建的服务器核心。...
基于akka 高性能分布式框架。使用 spring 配置请求参数。自动管理代理地址Ip,http请求重试, 超过重复次数丢弃请求。针对任务请求,任务响应实现过滤(需要根据自己业务实现过滤逻辑)。配置多数据源存储 抓取数据...
阿卡Scala使用Scala语言对Akka框架... 该存储库包含Akka框架的简单示例。 它使用Akka actor来计算是否存在复数。 通过将复数范围的计算委派给不同的参与者,我们可以同时执行计算,并减少计算复数整个范围所需的时间。
使用 akka 框架的 JavaFX 的 EventBus 使用命令构建并安装到本地 maven: gradle install 然后你可以从你的本地 Maven 中包含这个依赖: repositories { mavenCentral() mavenLocal() } dependencies { ...
另外,本书介绍了 Actor 模型的一个实现框架 Akka 以及它的工具,而后讨论了在充分利用 actor 架构的基础上使用 Akka 框架来设计软件系统的方法,以及使用它来开发并发性和分布式应用程序的方怯。本书还介绍了领域 ...
用Scala写的akka actor简单demo,已经打包成SBT程序,因为上传大小限制依赖包没上传,用户安装了sbt后只需要执行update命令即可
Akka is a distributed computing toolkit that enables developers to build correct concurrent and distributed applications using Java and Scala with ease, applications that scale across servers and ...
akka框架,对应scala2.12版本。Akka用Scala语言写成,同时提供了Scala和JAVA的开发接口。Akka用Scala语言写成,同时提供了Scala和JAVA的开发接口。
基于 Akka 框架与 TCP 参与者的聊天示例。 使用 Akka v2.2.3。 要求: sbt >= 0.12 发射: example@local:~/akka-tcp-chat$ sbt "run server" example@local:~/akka-tcp-chat$ sbt "run client
此合集包含了 Akka Concurrency ;Akka Essentials;akka_in_action;AkkaScala; reactive.programming.with.scala.and.akka;...其中除了AkkaScala是官方文档,其余都是纯英文电子书,包你搞定akka框架!
Akka Essentials,学习akka很好的一本书
Spring-Boot 的示例应用程序使用 Typesafe Akka 框架进行了响应。 GCCHR 医学研究中心自动化一个医学研究中心流程自动化项目,处理患者、医生、员工、工资、财务、库存、预约安排、付款等数据... 基于最新技术的完整...
在我们的框架中,最初使用Akka Stream读取数据,我们要做的是提供一个 ,可用作流的接收器,并行处理数据块,并在流结束时汇总来自多个reducer的结果。 我们的Wiki有了地图缩减数据处理问题的。 我们认为,在某些...
详情介绍:https://www.yuque.com/sxbn/ks/100010261 基于akka与scala实现一个简单rpc框架 RPC,即 Remote Procedure Call(远程过程调用)。
一个非常简单的实现,似乎有点工作。 但: 没有背压。 websocket 协议没有定义它,尽管它可能在 tcp 级别上是可能的。 另一种选择是在顶部实现一个用于背压的自定义协议,并对每个用户级帧进行编码。 然而,那时将...
Akka-DDD是一个框架,用于在Akka平台之上遵循DDD / CQRS / ES架构来构建分布式服务。 由于Akka-Persistence的可插拔体系结构,Akka-DDD不受任何特定事件日志提供程序的束缚。 服务被构建为参与者系统。 不同的服务...
Akka in Action shows you how to build message-oriented systems with Akka. This comprehensive, hands-on tutorial introduces each concept with a working example. You’ll start with the big picture of ...
Learning Akka Learning Akka Learning AkkaLearning Akka