腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Akka
:
我
应该在
参与者
中
使用
parallelStream
还是
executors
、
、
、
我
对
Akka
演员模型很陌生。据我所知,
akka
提供了超越并行性和并发性的抽象。话虽如此,
我
不认为在
参与者
本身
中
通过
parallelStream
或executor框架拥有并发性是正确的,
我
想知道这是否是反模式。另外,这是否意味着
参与者
中
的所有代码都将始终是连续的?
浏览 6
提问于2018-02-13
得票数 0
回答已采纳
2
回答
Scala标准库
中
的
参与者
是什么?
、
、
、
对于scala
中
当前版本的Actors是否需要
Akka
,
我
感到困惑。当我查看:时,
我
从"
Akka
是用scala编写的,并且,从Scala 2.10开始,
Akka
的
参与者
实现被作为Scala标准库的一部分“这一行
中
得到了
Akka
包含在Scala库
中
的想法。当我在IntelliJ
中
拉出
我
的全局scala库时,
我
可以看到我的默认scala安装中有
akk
浏览 3
提问于2016-09-23
得票数 0
回答已采纳
2
回答
ListenableFuture -在接收到集群
中
的消息并执行耗时的代码后完成
、
、
、
一开始
我
只想说
我
是阿克卡和期货公司的新手。所以,要温柔:)。 在返回ListenableFuture<Boolean>的类中有init方法。该方法
应该在
单独的线程
中
执行一些耗时的代码,并创建
akka
参与者
,它正在侦听
akka
集群
中
的一些消息。init方法返回的未来
应该在
此
参与者
接收到特定消息并完成耗时的代码之后才能完成。如何
使用
来自番石榴的ListenableFuture实现这一目标?
浏览 4
提问于2017-09-23
得票数 0
回答已采纳
1
回答
Akka
HTTP + actor + slick postgresql
、
、
、
、
我
正在重新学习Scala,
我
想做一个系统流程,如下所示精巧的模型def getRooms(): Future[Seq[Room]] = rooms.result
我
的问题是,
我
不确定何时解决房间。
我
<e
浏览 4
提问于2017-02-18
得票数 0
1
回答
如何在
Akka
集群
中
透明地创建
参与者
、
、
、
Monitor
参与者
发出一条消息,告诉自己每30秒检查一次设备库存。对于库存
中
存在的每个设备,它都会向主管
参与者
发送一条消息来注册该设备。当从Monitor
参与者
接收到注册设备的消息时,主管角色启动设备
参与者
。在单个JVM实例
中
,一切都运行得很好,但是当谈到集群模式时,
我
开始感到困惑。正如我所预期的那样,
使用
下面的配置,前面的
参与者
树
应该在
集群机器
中</em
浏览 3
提问于2017-12-04
得票数 1
回答已采纳
1
回答
如何在崩溃后重新创建动态创建的持久化
AKKA
参与者
、
我
正在为一个项目评估
Akka
,并且
我
试图通过将
参与者
状态保存在一个高可用数据存储
中
来确定
我
是否能够通过
Akka
持久化来实现高可用性的服务。(
我
不缩进
使用
Akka
-群集)
我
理解了保存
参与者
状态的概念,但是
我
很难找到在备份主机上恢复失败(崩溃)服务时重新创建
参与者
(而不是
参与者
状态)的方法。在
我
的设计
中<
浏览 4
提问于2017-08-31
得票数 3
回答已采纳
1
回答
是否要求明令禁止阿克卡演员担任监督?
、
、
在“
我
的主管
参与者
”
中
,子
参与者
发送一条消息以指示其已完成。然后在onReceive方法
中
停止这个
参与者
:public void onReceive(Object msg) { if (msg == Messages.SUCCESS-6] [
akka
://Main/user/app/$l] Message [
akka
.dispatch.sysmsg.Terminate] f
浏览 4
提问于2014-10-24
得票数 2
回答已采纳
1
回答
为什么lagom在生产中
使用
异步附加器
、
、
、
以下资源指出,Lagom在生产中
使用
异步记录器。但是,lagom也
使用
akka
,并且
akka
建议您
使用
akka
-way登录您的actors -> 这些组合导致了双重异步日志记录,
我
说的对吗?这是一个问题吗?
浏览 6
提问于2018-01-10
得票数 3
回答已采纳
1
回答
将websocket客户端放在
Akka
.NET内部或外部的代理
中
的位置?
、
我
是
Akka
.NET的新手,
我
正在构建某种websockets,
我
想
使用
Akka
.NET来处理(转换和转发)传入的流量,
使用
它的
参与者
系统。但我想知道怎样才是最好的办法。
我
有以下问题:
我
是否
应该在
Actor之外创建主侦听器,并为每个传入的“侦听”客户端实例化一个
参与者
?或者
我
应该把
我
的主要听众也放在一个演员里面?
我
是否应该
浏览 1
提问于2017-10-10
得票数 2
回答已采纳
1
回答
Akka
远程配置未命名的
参与者
、
、
我
是一个新手
Akka
开发人员,
我
刚刚开始远程处理。
我
总是看到这种类型的配置: provider = "
akka
.remote.RemoteActorRefProvider" hostname = "127.0.0.1" } 例如,"mainRepository“
浏览 4
提问于2015-07-07
得票数 0
回答已采纳
1
回答
Akka
2.4.6 -问(或?)方法?
、
、
我
目前正在学习与
Akka
和Scala玩游戏。它是移到某个地方
还是
被废弃了?
浏览 3
提问于2016-05-28
得票数 4
回答已采纳
1
回答
如何将
Akka
Pub/Sub配置为在同一台计算机上运行?
、
、
我
正在遵循
Akka
中
的集群
中
的分布式发布订阅示例。但是,
我
想在同一个节点(
我
的笔记本电脑)上运行所有的
参与者
(发布者和订阅者)。
我
不知道
我
是否知道如何配置,有人能帮我吗?是否可以
使用
runOn,或者
应该在
配置文件
中
声明它?目前,
我
遇到了以下错误: Caused by:
akka
.ConfigurationException: ActorSyste
浏览 0
提问于2016-09-19
得票数 5
回答已采纳
1
回答
如何
使用
多个数据源获得3个线程池?
、
、
、
、
Map,在该地图中,当应用程序初始化时(为此
使用
@PostConstruct方法),将包含来自application.yml文件的所有数据源。在doCheck方法方法
中
,
我
创建了一个线程池=映射中的数据源数(3个项),并提前
使用
Map方法对数据库进行调用。必须对所有数据库并行调用template.query(查询,ResultSet::getRow) performQuery方法
中
的,而不是顺序调用。对
我
来说很重要。如果在application.yml文件2数据库
中
,那
浏览 0
提问于2019-06-26
得票数 2
回答已采纳
3
回答
这不是每次都会创建新的ActorSystem吗?
、
是否确认每次调用
Akka
.system.actorOf或
Akka
.system.scheduler都会在应用程序
中
创建一个新的ActorSystem?查看一些代码,其中它在每次必须创建新的actor时调用
Akka
.system.actorOf,
我
认为它应该是context.actorOf才能
使用
现有的ActorSystem (
应该在
应用程序启动时创建
我
的理解是否正确,即每次调用
Akka
.system.actorOf来创建一个新的<em
浏览 2
提问于2014-03-23
得票数 0
1
回答
如何在argo和kubernetes
中
运行
akka
流媒体应用?
、
、
、
、
如何在argo和kubernetes
中
运行
akka
streams应用程序,
我
找到了关于kubernetes和
akka
集群的文档,但我不需要
akka
集群,
我
只需要运行一个具有许多
参与者
的短暂
akka
应用程序;
还是
akka
集群是必要的?
浏览 29
提问于2021-02-12
得票数 0
回答已采纳
1
回答
这是
Akka
角色的正确用例吗?
、
、
、
、
我
正在更新一个
Akka
集群,其中特定的
参与者
应该根据配置值在集群
中
的一个节点上启动。最初,
我
考虑
使用
自定义的
Akka
集群角色,并做了一些研究,阅读了 void register(Member member) { if (member.hasRole相反,会根据路径将消息传递给另一个
参与者
。由于派生方法在
Akka
classic
中
不可用,因此无法在
Akka
浏览 11
提问于2021-06-06
得票数 0
回答已采纳
2
回答
在
Akka
应用程序中选择未来的ExecutionContext是什么?
、
Afaik,我们可以
使用
以下解决方案:import scala.concurrent.ExecutionContext.Implicits.globalimport context.dispatcher或3.
我
的问题是:他们之间有什么区别?例如,Solution2将重用<e
浏览 1
提问于2018-02-24
得票数 10
回答已采纳
1
回答
Akka
参与者
在JVM和服务器之间进行伸缩,以及
akka
.io的示例
、
我
发现介绍性的作为介绍性的东西有点难以接受,而且为了介绍性的目的,学习远程处理的细节所需的文档也很长。下面是上述示例的代码,
我
想在一些公平的上下文中描述该代码的含义,同时涉及到是否可以远程发送任何
参与者
,就好像它是本地的一样,只需更改配置即可。之前关于的回答似乎与当前的
Akka
文档有些矛盾,而文档本身在这一点上是不确定的。// ------------------------------
akka
{ actor
浏览 2
提问于2014-06-14
得票数 0
2
回答
在分片
Akka
集群
中
调度广播消息
、
、
、
我
正在试着找出最好的方法来触发一个分片集群
中
特定类型的所有
参与者
,基于一个时间表(例如,在早上8点,9点,等等-以类似cron的方式)。
我
的计划是在集群中有一个单独的“计时器”
参与者
,它将按计划向其他集群的
参与者
发送广播消息。然而,
我
不确定这是否可行和最佳。不提供类似cron的配置。似乎不适合
Akka
集群。有没有可能从分片的
Akka
集群内部触发基于调度的操作,也许
使用
其他框架的功能,比如Spring scheduli
浏览 6
提问于2020-08-20
得票数 1
2
回答
Scala是如何实现并行的?
、
、
、
、
我
正在上一门关于分布式系统的课程,我们必须
使用
Scala来完成我们的项目。我们的导师告诉我们,Scala很好,因为它
使用
多个核来进行计算,并在集成到
参与者
模型的同时
使用
并行性来解决问题。
我
已经学习了关于
使用
Akka
的演员模型的一些基础知识,
我
的问题是,在编程时,用户是否必须向编译器提供细节,以便不同的
参与者
在多个核上工作,
还是
Scala负责处理这个问题,并为不同的
参与者
使用
浏览 9
提问于2013-09-13
得票数 13
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Akka 宣布更改许可,创始人:Apache 2.0 许可模式风险越来越大
从0到1搞懂分布式架构:Uber大型支付系统构建经验总结
Kafka消息队列学习进阶(四)-优化(配置/代码/集群
如何在生产中为机器学习模型提供服务?
1.30日实盘,无操作,我们站在了时代的浪尖上
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券