Dispatcher解析 Dispathcer负责调度并行任务,负责将工作分配给Actor,还可以分配资源用于处理Future的回调,可以理解为Dispatcher和Executor为线程池中线程的调度器。 跟线程池一样,不自己创建Dispatcher时使用的是默认Dispathcer,如果任务中有些耗时任务,容易将默认线程池打满,影响其他任务的调度。 Excutor Dispatcher基于Excutor,介绍Dispatcher前先介绍下Excutor Excutor分为两种: ForkJoinPool、Thr…

2021年1月16日 0条评论 18点热度 阅读全文

Router即路由,是负责负载均衡和路由的抽象,有两种方法来创建router,1.Actor Group 2,Actor Pool 两者区别:        pool: 有Router来创建Actor      Group:创建时传入已经创建好的Actor Group 下面仅以Pool方式为例来介绍具体的编码方式 @RestController public class AdhaAkkaDetect { public void detect(St…

2021年1月16日 0条评论 16点热度 阅读全文

Closed. This question is opinion-based。它当前不接受答案。 想改善这个问题吗?更新问题,以便 editing this post用事实和引用来回答。 3年前关闭。 Improve this question 我正在启动一个新项目(基于Java)。我需要将其构建为模块化,分布式和 flex 架构。 因此,我希望业务流程能够相互通信,可互操作且独立。 我现在看的是两个框架,除了年龄不同外,它们还表达两种不同的观点: Akka(http://akka.io) 反应堆(https://…

2020年11月30日 0条评论 25点热度 阅读全文

我正在开发一个Android项目,想知道是否可以使用Akka framework v.2.5.2。该框架需要Java 8才能运行,并且我知道Android不支持Java8。是否有可以使其运行的配置?也许使用Kotlin? 解决方案如下: Android Studio 3.0现在支持 Java 8 ,您可以下载预览版here。有了它,您可以使用Java 8。

2020年11月12日 0条评论 21点热度 阅读全文

这是我的问题的简化版本: 在服务器上,我们有n*m-类型为int[][]的矩阵,我们将此矩阵拆分为n行向量的集合,并将其放入队列中。当队列准备就绪(充满了向量)后,我们循环遍历并将每个向量发送到网络上某个地方的k客户端中,当且仅当客户端可以自由使用该矢量时(某些客户端状态检查消息传递的形式很方便)。所有客户端使用给定的向量执行相同的操作-它们计算向量的范数(长度),并将结果发送回存储该结果的服务器。当所有客户端都完成后,服务器将在启动初始作业的机器上打印结果。 我将在Java中使用Akka分布式计算框架。您能否告诉…

2020年11月6日 0条评论 23点热度 阅读全文

例如:我有演员X和Y。 角色X将消息保留到日记中,然后将消息发送给Y。Y收到消息,然后将确认发送回X,以使其知道已收到消息。当X收到此确认时,我希望它a)从日志中删除邮件,以便在恢复时不重播该邮件。 (这部分似乎不可行)。b)在邮件上标记“已完成”(已发送)。我认为这部分将通过日志(使用登录恢复)或通过在日志中添加“标签”(通过事件适配器)来完成,但是我不确定如果可行的话是否会进行更新。 这使我意识到,akka持久性实际上是如何工作的。如果一个参与者保留了所有消息,然后该参与者失败了并且需要恢复,那么无论传递什么,…

2020年10月30日 0条评论 35点热度 阅读全文

Closed. This question is opinion-based。它当前不接受答案。 想改善这个问题吗?更新问题,以便 editing this post用事实和引用来回答。 3年前关闭。 Improve this question 我正在启动一个新项目(基于Java)。我需要将其构建为模块化,分布式和 flex 架构。 因此,我希望业务流程能够相互通信,可互操作且独立。 我现在看的是两个框架,除了年龄不同外,它们还表达两种不同的观点: Akka(http://akka.io) 反应堆(https://…

2020年10月14日 0条评论 40点热度 阅读全文

我想从主 Actor 那里知道每个 worker Actor 是否完成。请帮助我 ...我有个主要 Actor 和Worker1 Worker2 Worker3。这里,Worker1 Worker2和Worker3正在并行执行。我怎样才能确定每个工作人员是从mainActor完成的? 解决方案如下: 依赖关系将您的主引用注入(inject)到工作人员的构造函数中,并在工作完成时通知主。 这是一个示例Worker: public class CompletedJob { public ActorRef actorRe…

2020年10月11日 0条评论 22点热度 阅读全文

我到处都看过,无法真正获得信息,因此我可以基于此提供具体意见。 Akka eventbus只是一个“本地工具”(对于集群中的jvm / node),从我的阅读中可以知道:在同一个jvm中完成消息传递时要可靠得多。 因此,我有生产者A,B和C,以及消费者X,Y和Z,例如:如果我针对X正在收听的主题生成消息,则X是否一定会收到此消息(无论网络可靠性如何,如果我发布到总线上,它是否都会“在总线上”?)。我知道对于pub / sub来说,最多是交付,但是我找不到在线上任何地方都可以看到事件总线的信息。如果我发布到公共汽车上…

2020年9月20日 0条评论 29点热度 阅读全文

我已经开发了一个Java应用程序,该应用程序可以分析数据库中的大量数据,从而导致相当长的计算时间,并生成可以通过图表库进行可视化的cvs文件。 因此,为了避免在用户输入的java-swing接口和浏览器中的可视化之间切换,我决定开发一个Vaadin应用程序,该应用程序使用现有的代码作为后端,并为输入和可视化提供接口。 因为这是我第一次与Vaadin合作,所以我想弄清楚我想做的事情是可行的,尤其是因为耗时的计算肯定会导致会话超时。 如果我使用轮询,考虑到许多用户可能会在同一时间进行午餐计算,那么服务器上的工作量不会太…

2020年9月17日 0条评论 22点热度 阅读全文