2回答
我正在试着找出最好的方法来触发一个分片集群中特定类型的所有参与者，基于一个时间表(例如，在早上8点，9点，等等-以类似cron的方式)。我的计划是在集群中有一个单独的“计时器”参与者，它将按计划向其他集群的参与者发送广播消息。然而，我不确定这是否可行和最佳。不提供类似cron的配置。似乎不适合Akka集群。有没有可能从分片的Akka集群内部触发基于调度的操作，也许使用其他框架的功能，比如Spring scheduling？或者在<em
浏览 6提问于2020-08-20得票数 1
1回答
Akka集群文档没有指定如何自动扩展集群-添加或删除节点。这应该如何在Akka生态系统中实现呢？例如，在两种情况下-当我们使用VM作为节点，或者Kubernetes中的容器组成集群时。如果特定节点的负载较低，Akka Cluster是否会将Actor从该节点移动到其他节点，并自动关闭未充分利用的节点？如果Akka集群没有弹性能力，并且依赖于Kubernetes (如here所述)，那么如果Kubernetes决定删除未充分利用的Akka</em
浏览 67提问于2020-08-20得票数 0
我正在学习一个关于akka http的教程。但是想知道akka角色模型是如何在akka http中实现的。有人能解释一下吗？
浏览 2提问于2020-01-15得票数 0
1回答
我正在致力于将单节点akka参与者系统应用程序更改为akka集群。一种变化是将一种类型的有状态Actor (在运行时可以是多个)变成集群分片管理实体。现在它可以在多个节点上很好地工作。我面临的一个问题是如何查询(获取所有)集群中分片区域创建的实体。之前在单节点模式下，它使用actor系统ActorSelection进行actor路径匹配，得到匹配的actor列表，在集群分片中不再有效。
我想知道分片区域是否有一些内置
浏览 1提问于2017-05-06得票数 0
我在我的应用程序中使用akka流来处理实时数据。数据量如此之大，所以我想横向扩展我的应用程序。可以帮助我理解akka-streams是否支持集群吗？如果是，请分享例子。
浏览 1提问于2019-07-12得票数 0
1回答
如何在akka集群中创建一个参与者，使用集群客户端动态地分片，这将通过akka远程处理从集群的外部传递消息。
浏览 10提问于2022-05-11得票数 0
回答已采纳
1回答
有没有办法创建Actor并将其添加到Akka中已有的集群分片中? 1)在App启动时创建/启动集群分片2)为每个API请求创建Actor 3)将其添加到现有分片中
谢谢!！
浏览 1提问于2017-06-22得票数 1
1回答
我看到有一个名为“角色”的设置，您可以在Akka.Cluster配置中指定。我还在Akka.Cluster.Sharding中看到了另一个名为“角色”的配置设置。这个设置和上面的设置有什么不同？
浏览 8提问于2019-05-11得票数 0
回答已采纳
我想使用Akka.Cluster提供简单的用户配置文件服务。将会有一些http-api服务的实例，它将使用userprofile持久化参与者(Profile Actor)为一些后端实例发送消息。如何使用akka.cluster实现用户配置文件？也许在同样的情况下，它存在一些模式？
浏览 1提问于2015-08-25得票数 0
2回答
我正在编写一个Akka应用程序，我想使用Typsafe提供的Akka集群功能。我试图理解Akka集群、Akka集群Singleton和Akka集群切分之间的主要区别。在我的场景中，我希望有一个集群，其中包含：
可以存在于任何机器中的有状态参与者，但是我只需要在整个集群中使用它们的一个实例
浏览 2提问于2014-07-29得票数 2
回答已采纳
0回答
Akka集群分片不起作用
、、、
我在Scala 2.11.8上使用akka 2.4.7。定义了集群分片：typeName$unitId", e)
val extractShardId: ShardRegion.ExtractShardI
浏览 7提问于2016-07-09得票数 0
回答已采纳
1回答
要启动akka集群分片，我应该使用一些参数调用ClusterSharding(system).start。是否需要手动启动所有节点的集群分片？
浏览 1提问于2014-09-12得票数 1
我看到有几种可能性，我可以复制包含StateMachine的Akka演员，但我不确定这些解决方案中的任何一种可能有效！一个这样的方法是在这里
还有其他建议吗？
浏览 1提问于2018-03-21得票数 0
回答已采纳
我正在构建一个系统，在该系统中，客户端IoT设备将与微服务的单个实例建立持久的websocket连接。我们称它为“硬件网关”。终端设备将连接到这些服务实例之一，并且可以随时在服务之间迁移(可能是由于重启或网络中断)。 其他服务将通过一些硬件网关实例向这些硬件客户端推送通知。我需要一种方法将这些请求路由到维护与特定IoT设备的连接的特定实例。目前，我的解决方案是维护一个外部KV存储，在那里我可以将IoT设备的UUID映射到服务实例，但这会对所有其他服务产生额外的依赖，以了解该KV存储。更不用说这个查询引入的额外延迟了。 也许有一些反向代理可以让我动态更新它的匹配条件？我还研究过使用像Rabbi
浏览 34提问于2021-11-01得票数 0
我正在使用Akka分片集群跨多个节点分布我的工作负载，并使用context.watchWith(worker)检测子参与者的意外终止。似乎如果子参与者被分配到与父节点不同的节点上(通过集群分片)，并且如果该子节点关闭，父参与者将不会得到该子参与者的死亡通知。
我知道我可以添加自己的逻辑来跟踪子角色的生命周期。不过，我想知道，Akka对这种情况下的死亡守望者(远程节点上的子角色)是否有本机支持？
浏览 1提问于2020-03-13得票数 0
1回答
我有一个使用案例，集群中的一个分片需要向同一集群中的另一个分片询问一些信息。我知道我可以通过这样做来获得ShardRegion：然后像这样提出我的请求：但是，有没有办法从分片本身获取分片区域参与者ref呢？
浏览 17提问于2018-12-15得票数 0
我正在练习Akka集群分片功能。我使用分片函数在3个节点上启动了几个实体。但我不知道当一个节点崩溃时，如何在其他节点中恢复实体。
有没有人能帮我理解我是怎么做到的。
浏览 0提问于2016-12-21得票数 2
1回答
根据这个AKKA路线图，在失败时的自动角色迁移将在"Rollins“版本中可用。我想知道这个角色迁移是否可以手动完成，通过一些特殊的消息或任何东西？此外，在Scala中有类似的东西吗？
浏览 0提问于2013-07-22得票数 5
1回答
我的用例是，我想设置一个运行Akka Actor的节点集群。每个参与者都是同一个参与者的一个实例，以处理与某个用户的WebSocket连接。每个参与者都会使用唯一的路径注册自己。在非集群设置中，我可以简单地根据执行元的路径调用执行元，比如system.actorSelection(s"user/$client")，其中$client是执行元实例的惟一名称。显然，Akka集群提供了多种设置：
我想在Kubernetes上运行我的节点，在Kubernetes上我不能可靠地配置实例
浏览 1提问于2017-03-13得票数 1
1回答
单例集群参与者没有启动。
、、、
日志是：
运行-运行-集群套件启动远程处理信息ScalaTest-运行-运行-集群套件远程处理启动；侦听地址:akka.tcp://galaxyFarFarAway@127.0.0.1:59592 08/03/2016 11:43:59.035 akka.cluster.Cluster(akka:// Starting )集群节点akka.tcp://galaxyFarFarAway@12
浏览 1提问于2016-08-03得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
