• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:akka

java

学习akka之dispatcher

学习akka之dispatcher
Dispatcher解析 Dispathcer负责调度并行任务,负责将工作分配给Actor,还可以分配资源用于处理Future的回调,可以理解为Dispatcher和Executor为线程池中线程的调度器。 跟线程池一样,不自己创建Dispatcher时使用的是默认Dispathcer,如果任务中有些耗时任务,容易将默认线程池打满,影响其他任务的调度。 ……继续阅读 »

java

学习akka之Router

学习akka之Router
Router即路由,是负责负载均衡和路由的抽象,有两种方法来创建router,1.Actor Group 2,Actor Pool 两者区别:        pool: 有Router来创建Actor      Group:创建时传入已经创建好的Actor Group 下面仅以Pool方式……继续阅读 »

akka

Akka或Reactor

Akka或Reactor
Closed. This question is opinion-based。它当前不接受答案。 想改善这个问题吗?更新问题,以便 editing this post用事实和引用来回答。 3年前关闭。 Improve this question 我正在启动一个新项目(基于Java)。我需要将其构建为模块化,分布式和 flex 架构。 因此……继续阅读 »

akka

分布式自然任务和Akka

分布式自然任务和Akka
这是我的问题的简化版本: 在服务器上,我们有n*m-类型为int[][]的矩阵,我们将此矩阵拆分为n行向量的集合,并将其放入队列中。当队列准备就绪(充满了向量)后,我们循环遍历并将每个向量发送到网络上某个地方的k客户端中,当且仅当客户端可以自由使用该矢量时(某些客户端状态检查消息传递的形式很方便)。所有客户端使用给定的向量执行相同的操作-它们计算向量的范数(……继续阅读 »

akka

Akka持久性-收到邮件传递确认消息后,从日志中删除邮件(或标记为已确认)

Akka持久性-收到邮件传递确认消息后,从日志中删除邮件(或标记为已确认)
例如:我有演员X和Y。 角色X将消息保留到日记中,然后将消息发送给Y。Y收到消息,然后将确认发送回X,以使其知道已收到消息。当X收到此确认时,我希望它a)从日志中删除邮件,以便在恢复时不重播该邮件。 (这部分似乎不可行)。b)在邮件上标记“已完成”(已发送)。我认为这部分将通过日志(使用登录恢复)或通过在日志中添加“标签”(通过事件适配器)来完成,但是我不确……继续阅读 »

akka

Akka或Reactor

Akka或Reactor
Closed. This question is opinion-based。它当前不接受答案。 想改善这个问题吗?更新问题,以便 editing this post用事实和引用来回答。 3年前关闭。 Improve this question 我正在启动一个新项目(基于Java)。我需要将其构建为模块化,分布式和 flex 架构。 因此……继续阅读 »

akka

如何知道 Actor 完成了执行?

如何知道 Actor 完成了执行?
我想从主 Actor 那里知道每个 worker Actor 是否完成。请帮助我 …我有个主要 Actor 和Worker1 Worker2 Worker3。这里,Worker1 Worker2和Worker3正在并行执行。我怎样才能确定每个工作人员是从mainActor完成的? 解决方案如下: 依赖关系将您的主引用注入(inject)到……继续阅读 »

actor

akka eventbus-消息保证-发布到总线保证

akka eventbus-消息保证-发布到总线保证
我到处都看过,无法真正获得信息,因此我可以基于此提供具体意见。 Akka eventbus只是一个“本地工具”(对于集群中的jvm / node),从我的阅读中可以知道:在同一个jvm中完成消息传递时要可靠得多。 因此,我有生产者A,B和C,以及消费者X,Y和Z,例如:如果我针对X正在收听的主题生成消息,则X是否一定会收到此消息(无论网络可靠性如何,如果我发……继续阅读 »

akka

具有计算密集后端的Vaadin Web应用程序

具有计算密集后端的Vaadin Web应用程序
我已经开发了一个Java应用程序,该应用程序可以分析数据库中的大量数据,从而导致相当长的计算时间,并生成可以通过图表库进行可视化的cvs文件。 因此,为了避免在用户输入的java-swing接口和浏览器中的可视化之间切换,我决定开发一个Vaadin应用程序,该应用程序使用现有的代码作为后端,并为输入和可视化提供接口。 因为这是我第一次与Vaadin合作,所以……继续阅读 »