腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Akka
classic
-
发送
自定义
类
消息
类型
java
、
akka
、
akka-persistence
我正在尝试遵循在
Akka
参与者之间
发送
消息
的最佳实践,并阅读以下内容: https://github.com/
akka
/
akka
/blob/v2.6.15/
akka
-docs/src/test/java/jdocs/actor/ActorDocTest.java#L101-L129 https://doc.
akka
.io&
浏览 41
提问于2021-08-15
得票数 1
回答已采纳
2
回答
以
Akka
类型
将
消息
发送
到父执行元
scala
、
akka
、
akka-typed
标题是不言自明的,我希望能够向家长角色
发送
消息
(意思是我想要家长的ActorRef)。在
Akka
Classic
(非
类型
化)中,可以通过以下方式从子角色的ActorContext获取父角色的ActorRef: context.parent (例如,参见this question (in但是,
Akka
类型
的
akka
.actor.typed.scaladsl.ActorContext不公开父级的ActorRef。在Scala中有没有一种惯用的方法来获取父
浏览 51
提问于2020-12-07
得票数 4
回答已采纳
1
回答
Akka
:优先级邮箱无法与键入的
Akka
一起工作
scala
、
akka
、
akka-typed
我正在尝试创建一个
自定义
优先级邮箱与
akka
类型
,根据
消息
的
类型
确定
消息
的优先级。下面是我创建执行元并向其
发送
消息
的代码。但是,将按照接收邮件的顺序处理邮件,而不是按照
自定义
邮箱定义的顺序处理邮件。package com.
akka
.prac import
akka
.actor.typed.{ActorSystem, Behavior, DispatcherSelector, Props, Sett
浏览 14
提问于2021-03-09
得票数 2
回答已采纳
1
回答
向
akka
类型
的演员
发送
消息
的经典演员系统
scala
、
akka
、
akka-typed
在我的应用程序中,我有一个经典的演员系统和一个typedGuardian (使用
akka
类型
的)。implicit val system =
akka
.actor.ActorSystem("my-
classic
-actor-system") 我的
akka
类型
的设置从下面的演员开始,我需要将客户
浏览 3
提问于2022-01-27
得票数 0
回答已采纳
1
回答
AbstractLoggingActor不写入文件附加器,而是在Java
Akka
中写入控制台
akka
、
logback
但不知何故,
akka
日志只被写入控制台,而不是日志文件,并且没有抛出错误。 <append>true</append> <filter class="ch.qos.logback.
classic
.filter.ThresholdFilter">-appender name="Sen
浏览 12
提问于2017-12-26
得票数 0
1
回答
使用Java的
Akka
远程路由
java
、
routing
、
akka
、
dead-letter
它是在远程机器上部署本地参与者,然后向它们
发送
消息
,还是连接到远程计算机上的远程参与者,然后向它们
发送
消息
?使用我的代码,我能够向远程计算机
发送
简单的
消息
(使用参与者选择)-- remoteActor.tell(msg,getSelf()) (注释代码)在LocalApp中
发送
和接收
消息
,不会产生任何错误。[INFO] [02/04/2014 16:34:58.408] [RemoteApp-
akka
.actor.
浏览 0
提问于2014-02-04
得票数 2
回答已采纳
1
回答
akka
消息
应该实现系列化吗?
java
、
serialization
、
akka
我遇到了实现Serializable的
自定义
Akka
消息
类型
:{} } return this.id; } 我不知道为什么将Serializable作为
发送
给参与者的
消息
的一部分来实现我能想到的唯一原因是,
Akka
通过电
浏览 1
提问于2015-02-14
得票数 0
回答已采纳
3
回答
Akka
要求工作绕过
发送
者的忽略
java
、
scala
、
akka
、
future
我正在尝试存储某个
消息
的
发送
者,以便将来可以检查它是否与之前
发送
操作的
发送
者相同。现在这不起作用,我读到它是因为
Akka
ask忽略了实际的
发送
者,并创建了自己的临时角色,作为
发送
者使用,直到未来解决。有没有办法解决这个问题,这样您就可以在不使用tell操作的情况下访问
消息
的真正
发送
者?
浏览 0
提问于2021-05-03
得票数 1
1
回答
InvalidDefinitionException:无法构造`org.slf4j.Logger`实例
scala
、
jackson
、
deserialization
、
slf4j
、
akka-cluster
我有一个运行在节点上的
akka
微服务集群。我试图使用Jackson序列化程序来处理节点(微服务)之间交换的特定于应用程序的
消息
。我的代码是用scala编写的,而不是用Java编写的警告
akka
.remote.ar
浏览 2
提问于2021-08-08
得票数 1
回答已采纳
1
回答
通过
自定义
反序列化实现
Akka
远程和截获未知
类
java
、
class
、
serialization
、
akka
、
akka-remote-actor
Problem/Context.我需要给一个远程演员
发送
一些信息。这些
消息
可能包含接收方未知的
类
的对象。为了避免ClassNotFoundException,我需要拦截这种情况。一种解决方案可能包含在
消息
反序列化时拦截未知
类
。然后,可以将
消息
替换为不同的应用程序级
消息
,以便远程参与者可以与
发送
方通信,说明它没有所需的
类
。我不知道这样的拦截是否可能,因为
自定义
反/序列化程序必须实现
akka<
浏览 2
提问于2016-02-08
得票数 1
回答已采纳
1
回答
在
Akka
中处理已死的参与者
类型
scala
、
akka
、
dead-letter
、
akka-typed
拥有ActorRefs的演员正在关注他们的Terminated(ref),但是在终止到达之前
发送
给演员的
消息
存在竞争条件,我正在尝试找出一种干净的方法来处理它。我正在考虑订阅DeadLetter,并用它来通知
发送
者他们的ref已经过时,他们需要获得或产生一个新的目标ActorRef。然而,在
Akka
Typed中,除了使用无
类型
共存路径之外,我找不到任何方法来获取死信,所以我认为我很可能是在错误地处理这个问题。有没有一种更好的模式来处理死的下游引用,并将
消息
重定向到新的下游引用,而不是要
浏览 13
提问于2019-05-13
得票数 1
回答已采纳
2
回答
发送
可序列化
消息
时出现远程
akka
执行元错误
scala
、
serialization
、
akka
我正在使用远程
akka
执行元,我想
发送
序列化的
消息
,使用ObjectOutputStream,但有abd错误当本地执行元
发送
消息
到远程执行元时,错误是: java.io.NotRerializableException没有为
类
java.io.ObjectOutputStream配置序列化绑定推荐哪种
类型
的序列化?
浏览 5
提问于2014-12-15
得票数 0
2
回答
从包含参与者引用的可迭代对象中选择特定项
scala
、
akka
、
actor
每个元素下面的注释行是它的
类
类型
(不包括在可迭代中)。Actor[
akka
.tcp:/ /ServerSystem@127.0.0.1:5555/user/ServerActor#318394851]/&
浏览 1
提问于2014-05-04
得票数 0
回答已采纳
1
回答
试图从
akka
类型
的应用程序内部创建一个经典演员
scala
、
akka
、
akka-typed
我有一个
akka
演员,它使用基于TCP连接示例的经典样式:。 我正在尝试从
akka
类型
化的应用程序内部实例化这个参与者(因为我找不到这个使用
类型
化的TCP连接的例子--不确定API是否可用?)implicit val system = ActorSystem(SomeActor(), "typed-actorSystem") // import
akka
.actor.typed.ActorSystemsystem.classicSystem.actorOf(Cl
浏览 4
提问于2022-01-10
得票数 1
回答已采纳
1
回答
这是
Akka
角色的正确用例吗?
java
、
scala
、
kubernetes
、
akka
、
akka-supervision
我正在更新一个
Akka
集群,其中特定的参与者应该根据配置值在集群中的一个节点上启动。最初,我考虑使用
自定义
的
Akka
集群角色,并做了一些研究,阅读了 void register(Member member) { if (member.hasRole相反,会根据路径将
消息
传递给另一个参与者。由于派生方法在
Akka
classic
中不可用,因此无法在
Akka
classic
中实现基于角色的演员创建?为角色键入的<
浏览 11
提问于2021-06-06
得票数 0
回答已采纳
1
回答
Play 2.4-Java - Actor
消息
协议最佳实践
java
、
playframework
、
akka
我正在阅读有关在Playframework中实现
Akka
角色的文档, “此处显示的另一个最佳实践是,HelloActor
发送
和接收的
消息
被定义为另一个
类
为什么message要定义为其他
类
的静态嵌套
类
? 提前谢谢你!
浏览 1
提问于2015-09-09
得票数 1
2
回答
Java-
Akka
:组装来自多个参与者的
消息
java
、
akka
、
akka-stream
我是新来
Akka
的。我有4个演员。 Actor1将Message1
发送
到Actor4。Actor2将Message2
发送
到Actor4。Actor3将Message3
发送
到Actor4。Actor4应在收到1条Message1
类型
的
消息
、1条Message2
类型
的
消息
和2条Message3
类型
的
消息
时创建Message4。
浏览 1
提问于2015-06-29
得票数 0
1
回答
Akka
系统按
类
获取角色选择
scala
、
akka
、
actor
是否可以将
消息
发送
到某些参与者选择的特定
类型
的
类
?
Akka
.system.actorSelection("/path")
浏览 0
提问于2015-07-16
得票数 0
1
回答
经典演员的Akkatype给了我一个错误:不支持从演员外部访问ActorContext
scala
、
akka
我在我的
akka
应用程序中得到以下运行时错误(使用
akka
类型
化和经典) Actorakka://my-
classic
-actor-system/user/ChatServer#1583147696.外部对ActorContext的不支持访问 java.lang.UnsupportedOperationException当前参与者没有处理任何
消息
,但是Threadmy-
classic
-actor-system-
akka
.actor
浏览 5
提问于2022-01-14
得票数 1
回答已采纳
1
回答
当添加slf4j/logback时,
akka
-http崩溃
scala
、
sbt
、
akka
、
akka-http
、
akka-stream
" % "logback-
classic
" % "1.2.3",)
akka
appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> <en
浏览 6
提问于2017-06-17
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Akka Actor及其在商业智能数据服务中的应用
使用akka-http-testkit测试route
整合Akka实现分布式爬虫
关于Spark的RPC机制
GrowingIO 响应式编程探索和实践
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券