在Akka参与者之间共享或访问大型不可变数据
Akka是一种基于Actor模型的并发编程框架，它提供了一种轻量级、高性能的方式来构建分布式、可扩展的应用程序。在Akka中，参与者（Actors）是并发执行的基本单元，它们通过消息传递进行通信和协作。
在Akka中，可以通过不同的方式来共享或访问大型不可变数据：
- 消息传递：Akka中的参与者之间通过消息传递来进行通信。可以将大型不可变数据封装在消息中，并将其发送给其他参与者。接收者可以解析消息并使用其中的数据。
- 分布式数据存储：Akka提供了一些分布式数据存储的解决方案，如Akka Cluster Sharding和Akka Distributed Data。这些解决方案可以帮助在参与者之间共享和访问大型不可变数据。
- 数据库访问：可以使用Akka与数据库进行交互，从而共享和访问大型不可变数据。可以使用Akka Persistence来实现参与者的事件持久化，并使用数据库作为数据存储。
- 内存共享：在Akka中，可以使用共享内存的方式来共享和访问大型不可变数据。可以使用Akka的分布式共享内存（Distributed Shared Memory）解决方案，如Akka Distributed Data或Akka Cluster。
- 缓存：可以使用缓存来存储和访问大型不可变数据。Akka提供了一些缓存解决方案，如Akka Cache或Akka Distributed Cache。
- 分布式文件系统：可以使用分布式文件系统来存储和访问大型不可变数据。Akka可以与分布式文件系统集成，如Hadoop Distributed File System（HDFS）或GlusterFS。
- 分布式共享对象：Akka提供了一些分布式共享对象的解决方案，如Akka Distributed Data。这些解决方案可以帮助在参与者之间共享和访问大型不可变数据。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云分布式缓存 Tendis：https://cloud.tencent.com/product/tendis
- 腾讯云分布式文件存储 CFS：https://cloud.tencent.com/product/cfs
- 腾讯云分布式数据库 TDSQL：https://cloud.tencent.com/product/tdsql
- 腾讯云云原生容器服务 TKE：https://cloud.tencent.com/product/tke
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和情况进行评估。
相关·内容
我正在开发一个应用程序，它在一个不可变的数据结构上进行大量的数字运算。(一个非常大的数组的集合--本质上是一个大的矩阵。假设一个典型的大小是200列乘以100,000行的双精度。)许多计算可以以不同的方式并行化，我想利用Akka角色模型来解决这个问题。我是不是想多了这个问题？(也就是说，如果一个主管参与者将这个矩阵的一些数组传递给它的下属，那么Akka运行时是否足够智能，可以将其作为引用传递--
浏览 3提问于2016-09-02得票数 0
回答已采纳
我有一个例子，每个Akka集群节点(JVM)只有一个参与者，负责创建和维护(读/写)一些大型对象的映射。同一节点上的其他参与者需要共享(读取)地图(地图将被传递到某个第三方库，因此无法通过Akka消息更改地图访问权限)。ShareMap(m)}我的问题是:对于我的情况(在同一个JVM中)，是否可以确保不会创建重
浏览 0提问于2020-04-09得票数 1
回答已采纳
1回答
我正在处理使用Akka的应用程序。我有一个场景，参与者将以数组或列表的形式从数据库中获取特定值。子参与者将引用此列表，但不允许他们修改或更新此列表。
有没有办法在参与者之间共享数据？
浏览 2提问于2018-08-24得票数 1
ParentActor(Data data) Data = data;}它是否取决于Data是否是可变的/不可变的？
浏览 5提问于2017-11-10得票数 0
回答已采纳
2回答
STM与AKKA的并发性
、、、、
我有需要以并发方式更新的数据。这些数据以单例对象的形式存在于PlayFramework中。在这种情况下，使用AKKA更新此数据会更好，还是我应该使用STM？这两种解决方案在共享状态并发方面有什么不同。
谢谢
浏览 2提问于2014-05-29得票数 3
我想知道Akka消息在JVM内部以及JVM之间是如何工作的。
我可以使用其他协议(例如JMS、SOAP、.)吗？用于JVM之间的通信吗？例如，Spring或Apache可以处理任何类型的通信协议。
浏览 4提问于2014-09-17得票数 8
回答已采纳
在非集群系统中，在参与者之间共享不变状态的缺点是什么？
很明显，为什么可变的共享状态与参与者模型提供的许多保证相反，但是如果状态是不可变的呢？在我们的例子中，我们有一个大型数据集，需要在内存中随时可用，以便对其执行操作(这是一个需要遍历的复杂图)。对于每个参与者来说，从持久性中提取数据集并将自己的副本保存在内存中是非常昂贵的。解决方案之一是将该数据</em
浏览 0提问于2020-08-02得票数 1
回答已采纳
据我所知，Scala管理一个线程池来运行参与者，在它们之间共享线程。我是否可以将某个特定的参与者设置为以独占方式在单独的线程中运行，而从不与其他参与者共享它？
浏览 1提问于2011-11-08得票数 3
回答已采纳
我问这个问题的原因是在我的代码中，我有一张保存一些记录的地图，并按如下方式工作：
许多用户同时执行此操作。步骤1和步骤3非常快，并且是在同一个线程中完成的( AKKA参与者线程是特定的)，步骤2需要时间并在单独的工作线程中完成。
浏览 5提问于2019-10-22得票数 1
回答已采纳
1回答
使用akka对代码块进行同步
、、、、
我想在我的应用程序中使用akka进行多个处理。因此，相同的代码块由每个参与者执行，结果将由侦听器聚合。因此，我的问题是，在这种情况下是否会出现同步问题。如果不是的话，阿克卡演员内部是如何处理的。
浏览 3提问于2013-08-19得票数 0
回答已采纳
._ -> akka.actor._
然而，没有看到InputChannel/OutputChannel/Channel.因此，要从Scala Actors迁移到Akka Actors，在哪里可以找到那些通道API？
浏览 2提问于2013-08-02得票数 1
回答已采纳
参与者模型的最大优点之一是去除锁定(参与者独立和连续地操作)。这是否意味着我们不能在一个参与者系统中拥有任何共享/全局状态(因为访问/更新会带来锁)？
浏览 5提问于2020-03-02得票数 1
回答已采纳
1回答
在检查出内存堆错误后，我可以看到有一个警告说，我正在每个物理集群创建多个集群/会话，而我不应该这样做。因为在我的Akka配置中，我最多只有32，所以我可以想象我正在创建32个集群/会话实例，而且很可能是我在强迫内存泄漏。问候
浏览 2提问于2017-05-27得票数 1
回答已采纳
1回答
我有一个POST方法，它收集请求对象，我们需要同时提交每个请求对象到后端数据源，聚合并返回结果。可以有100多个请求对象，响应大小约为1MB。我们希望响应在3秒内返回到通道，每个后端调用(对另一个数据源的web服务调用)所需时间少于500 ms。
我们能通过Akka.net实现这一点吗?
浏览 0提问于2018-05-15得票数 0
问题是我找不到任何高级教程或文档，而不是这个：当然，我已经阅读了API，但是我希望有一些代码示例、良好实践、建议等等。
注意：--我指的是关于主流文档中未涉及的内容的文档。我知道关于演员的书，但我在寻找免费的演员。
浏览 3提问于2012-02-01得票数 2
回答已采纳
2回答
我看到了很多词，比如“从性能的角度看这很好”，“没有锁，因为没有共享的资源，消息是不可变的”。但我还是不明白以下几点：交易处理(在线游戏，金融/银行，交易，统计，博彩，社会媒体，电信)，服务后端(任何行业，任何应用)。
而是关于真正的用例。因为对我来说，还不清楚为什么我更喜欢Akka.NET (我是.net开发人员)而不是“
浏览 0提问于2017-02-12得票数 6
我有一个很大的可变Map对象，它占用了太多的内存，父对象的所有子对象都需要访问或修改相同Map的值。我正在考虑只是在创建子对象时将可变映射作为构造函数参数传递给所有子对象，以便它们可以相应地访问或修改映射。
浏览 1提问于2015-02-20得票数 3
1回答
Akka断路器角色间共享
、、、
我有一个共享的外部资源(比如文件存储)，由一群参与者使用。每次向文件存储区发出新请求时，都会创建一个新的参与者，以使用传入的外部系统的引用来填充请求。当前的方法是为每个参与者创建一个断路器，这一方法不符合这个目的，因为为每个“请求”都创建了一个新的参与者，它在这个外部资源上执行一系列操作。breaker.withSyncCircuitBreaker(dangerousCallToExternalSystem()) pipeTo sender()}
更好的方法-在CBbrea
浏览 4提问于2014-06-18得票数 13
回答已采纳
2回答
传递上下文信息
、、
我们正在将akka.net参与者添加到遗留系统的一部分。
其基本思想是，消息来自外部系统，它被传递给由akka.net参与者管理的逻辑，然后与执行诸如将数据保存到数据库之类的操作的遗留组件进行对话。遗留代码依赖于这样一个事实，即在CallContext中设置了一个userId，然后它可以在进行数据库写入之前检索它(以存储诸如"CreatedBy“和”LastModifiedBy“之类的内容)。很明显，一旦消息通过参与者系统传
浏览 2提问于2016-02-20得票数 1
2回答
在akka中用于io操作时，我有一个关于jvm线程与os线程之间的比例的问题。从akka网站：
Akka支持事件驱动的轻量级线程的分派程序，允许在单个工作站上创建数百万个线程，以及基于线程的Actors，其中每个调度程序绑定到一个专用OS线程。因此，对于我的示例用例，我想要获取一个列表，比如1000‘用户’，然后查询一个数据库(或多个)中有关每个用户的各种信息。我知道我可能遗漏了一些东西，因为我对vm线程和os线程之间的交互不太了解
浏览 4提问于2011-09-18得票数 15
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
