Kubernetes - Akka 集群部署
我们有一个 docker 镜像和一个对应的 yaml 文件，用于使用 kubernetes 进行部署.我们构建的应用程序是在带有 akka-http 的 Scala 中.我们使用了 akka-cluster.我们在使用 pod ip 的应用程序代码中使用的配置文件中有一个特定的变量(在我们的例子中是种子节点 - akka 集群).但是，除非部署完成，否则我们不会获得 pod ip.我们应该如何着手
..
akka-cluster相关内容
在Akka.NET中，(使用Akka.Cluster)如何配置多个种子节点(Lighthouse)相互了解?
如果我想在不同的 PC 上运行两个 Lighthouse 种子节点，每个节点都应该知道另一个，我应该如何配置它们?尽管我发现提到使用多个 Lighthouse 实例并看到使用多个种子节点的非种子节点配置，但我无法在知道一个的单独 PC 上找到多个种子节点(特别是 Lighthouse)的示例另一个. 我目前有类似的东西，但我不确定它是否正确. 实际上，每个 BroadcastRouter
..
使用EC2和Docker运行Akka集群.节点未在Akka群集中注册
我实现了以下akka-cluster系统示例，请参见下图: ┌────host_D:3000────┐ ┌───────▶│ .... │ │ ┌────host_C:3000────┐ │
..
使用JMX控制台进行akka集群的信息和管理
我正在基于akka群集的项目上工作，在该项目中，我必须实现 JMX控制台来管理akka群集。 当我查看 akka文档我得到的信息很少。 然后我尝试查看Java VisualVM，找到了添加如下所示的新jmx连接的选项，那么那里的连接网址应该是什么？我尝试了localhost：8080，但未成功。 解决方案 在应用程序中，还应该配置什么以使JMX控制台到达我的akka群集？
..
Akka actor跨JVM和服务器进行扩展，例如akka.io
我发现Akka着陆页上提供的介绍性 Akka远程处理示例有点难以理解，以及学习出于介绍目的而处理远程结构错误的来龙去脉所需的文档长度。 以下是上述示例中的代码，我想要求在一个公平的上下文中描述该代码的含义，同时涉及是否可以仅通过更改配置就可以远程向任何参与者发送消息的问题。关于最后一点的先前答案似乎与当前的Akka文档有些矛盾，而该文档 // -------------- -----
..
Akka群集：如何禁用ClusterHeartbeat日志
我在玩Akka群集，并且设置了2个节点。正如预期的那样，两个节点相互聊天以表示它们通过 heartbeat 仍然存在。所以每秒钟我的日志中都会有一个这样的字符串 [debug] 15：42：10.683-acClusterHeartbeatSender：群集节点 [akka.tcp：//application@127.0.0.1：52650]- 心跳到[akka.tcp：//applic
..
Akka群集-迫使参与者停留在特定机器上
我有一个akka应用程序，我将在许多机器上进行部署。我希望每个应用程序都可以通过使用分布式发布/订阅事件总线功能来相互通信。 但是，如果我将系统设置为群集，那么我担心一个应用程序的参与者可能会在与其启动的节点不同的节点上创建。 很重要的一点是，参与者只能在计算机上创建， 基本上，我不需要参与者的弹性或集群，我只是想要分布式的pub / sub。我可以看到诸如以下内容的选项，如单例
..
带有akka集群的akka流
我的akka流继续学习。我想将我的akka-streams应用程序与 akka集成在一起-cluster和DistributedPubSubMediator 。 添加对Publish的支持相当简单，但是我遇到的“订阅”部分遇到了麻烦。 供参考，类型安全的示例： 类ChatClient（name：String）扩展Actor { val中介者= DistributedPu
..
在集群中任何未指定/随机的节点上创建actor
可以以编程方式在远程节点，如果您指定了确切的节点。 但是，我想简单地要求actor系统在随机的或可能是actor上创建一个actor 在给定了可选节点角色的情况下，是否可以在任何远程节点上创建角色？ 解决方案 在Akka 2.3中，您应该使用集群感知路由器 可以使所有路由器了解集群中的成员节点，即部署新路由或查找 因此您可以在这种情况下使用RnadomPool，Ro
..
Akka集群分片：Entry演员可以有动态道具吗
Akka群集共享看起来与用例非常匹配，我必须在Akka节点上创建有状态持久性参与者的单个实例。 我不清楚如果有可能具有需要参数进行构造的Entry actor类型。也许我需要重新考虑Entry actor如何获取此信息。 对象帐户{ def apply（region： String，accountId：String）：道具= Props（新Account（region，account
..
“最大允许大小128000字节，编码类scala的实际大小”。 Akka远程处理中的错误
我想使用Akka Remoting在演员之间通过网络交换消息，但是对于大型字符串消息，我遇到了以下错误： akka.remote.OversizedPayloadException：丢弃发送给Actor的超大有效载荷 ::允许的最大大小128000字节 ，即已编码类scala的实际大小。 如何解决此限制？ 解决方案 我添加了以下配置，现在一切正常： a
..
根据集群负载调整消息频率
我正在使用Akka 2.2.3和Scala编写一个简单的同质集群应用程序；一种粒子过滤算法，其中每个节点在随机的时间点与其他群集成员共享数据。目前，它是一个研究应用程序，而不是关键业务系统。 目前，每个节点每秒都会向随机选择的节点发送固定大小的消息。可行，但我担心扩展时的性能（例如，云与本地） 节点发送数据可能会过载 节点可能会过载其他群集成员的传入消息 网络可能成为瓶颈 我
..
使用Play框架的Akka群集设置
我目前正在尝试通过自动发现服务来实现集群播放+ akka实现.但是，我似乎在玩游戏中附带的Guice DI加载器时遇到了问题.他们的文档摘录指出: https://www.playframework.com/documentation/2.5.x/ScalaAkka#与Akka集成 虽然我们建议您使用内置的actor系统，因为它会设置所有内容，例如正确的类加载器，生命周期挂钩等，但没有
..
Kubernetes-Akka集群部署
我们有一个docker映像和一个相应的yaml文件，用于使用kubernetes进行部署.我们构建的应用程序在带有akka-http的scala中.我们使用了akka集群.我们在使用Pod ip的应用程序代码中使用的配置文件中，有一个特定的变量(在我们的情况下为种子节点-akka群集).但是，除非完成部署，否则我们不会获得Pod ip.我们应该如何解决这个问题?环境变量会有所帮助吗(如果是)如何?
..
akka中每个主机的最大演员数
akka中的一个方框可以有多少个最大角色？ public void MyActor扩展AkkaActor { 收到（Objet obj）{ //所以 } } 1）最大数量是否有限制演员实例？我打算在一个盒子上创建大约10K演员。我将有50个这样的盒子，以便我可以横向扩展 2）这有一些性能问题吗？ 解决方案 只需拥有足够的内存：一个actor的开销大约是
..
自动化微服务负载平衡/缩放
阅读微服务几天，我想知道人们如何去自动化负载平衡和扩展这些东西？ 我有一个特定的场景记住我想要实现什么，但不知道是否可能，或者我正在考虑错误。所以在这里它... ... 假设我有一个名为A，B和C的3台CoreOS机器 我想要的第一件事是我可以使用舰队的透明部署。 然后，我想检测到，当其中一个服务负载巨大并部署了另一个实例，并且部署了另一个实例，并且部署了第一个实例，自动负
..