当前位置: 首页 > 知识库问答 >
问题:

跨节点的Akka有状态执行元复制

鲍钊
2023-03-14

我有一个Akka应用程序,我使用Play Framework作为Web应用程序运行。当我启动这个应用程序时,我创建了一组Actor,这些Actors具有状态。这些参与者响应外部消息,并对状态进行突变(我使用context.benge(...)机制对状态进行突变)。

我现在想要运行这个Web应用程序的多个实例,这样我就可以有弹性了。但这样做的问题是,web应用程序公开了一个前端应用程序连接到的WebSocketendpoint。然后,我每隔4秒通过WebSocketendpoint将Actor实例的状态流式传输到前端应用程序。

我在这里有几个问题:

共有1个答案

邵凯定
2023-03-14

有两种不同的方法可以设置akka集群来实现此目的:

  1. 按照您的建议让所有Play Framework实例形成一个集群
  2. 设置一个单独的akka集群(如果需要,可将其称为后端),并使用Play Framework实例中的集群客户端与集群连接和交互

在上述两种情况下,我将使用集群分片模块来实现您想要实现的目标。

    null
    null
 类似资料:
  • 我在看w3c书店xpath的例子。 基于xml: 我正在尝试使用XPath实现这一点: “这个XML文档是否有一本作者为‘詹姆斯·麦戈文’、价格为‘49.99’的书,这个XML文档是否也有一本作者为‘埃里克·雷’、价格为‘39.95’的书 人类的说法是正确的,XPath等效的是什么?是否可以跨兄弟节点运行表达式,如果可以,如何运行? 为了澄清,在其他语言中,可以这样做: 其中author1\pri

  • 我被卡住了,当我试图联系两个元素节点,我认为是相同的一个...我完成了匹配那些状态节点...需要帮助连接!!

  • 我不得不格式化我的驱动器,但我的一个项目不再工作了。所有其他相同类型的项目都运行良好。这是Laravel Vue JS。问题是我无法运行npm run watch/dev或prodution。他们都给出了错误。Laravel 5.7 npm ver 6.4.1 node ver 10.15.0 windows 10 我安装/卸载了不同的节点版本,没有骰子。我已经多次删除/安装节点模块,什么都没有。

  • 我遇到了在多个请求下扩展应用程序的问题。 每个请求都向一个参与者发送一个ask,然后生成其他参与者。这是很好的,但是,在负载下(一次5个以上的询问),会花费大量的时间将消息传递给目标执行元。最初的设计是均匀地隔离请求,但这造成了一个瓶颈。示例: 在此图片中,是在查询计划解析程序之后发送的。但是,当执行元接收到此消息时有一个多秒的间隔。这只在负载(5+请求/秒)下才会出现。我最初以为这是一个饥饿的问

  • 我试图弄清楚如何在使用actor系统时最好地处理数据库操作。事实上,数据库操作正在阻塞,而我们试图在Akka中不阻塞。 我在主文档中提到了一种处理方法,那就是在路由器后面创建一个参与者池,可能是在一个单独的executionContext上,它将处理数据库访问。