如何解决Akka:优先邮箱不适用于 Akka Typed
我正在尝试使用 akka 类型创建一个自定义优先级邮箱框,该框根据消息类型对消息进行优先级排序。以下是我创建演员并向其发送消息的代码。但是,消息的处理顺序是它们接收的顺序,而不是自定义邮箱定义的顺序。
package com.akka.prac
import akka.actor.typed.{ActorSystem,Behavior,dispatcherSelector,Props,Settings}
import akka.actor.typed.scaladsl.Behaviors
import akka.dispatch.{PriorityGenerator,UnboundedPriorityMailBox}
import com.typesafe.config.{Config,ConfigFactory}
object PriorityMailBoxTyped extends App {
val config = ConfigFactory.load("applicationtyped.conf")
val actorSystem = ActorSystem(
MyPriorityActorTyped.receive,"PriorityMailBox",config,dispatcherSelector.fromConfig("prio-dispatcher")
)
actorSystem ! DoubleMessage(6.0)
actorSystem ! IntMessage(1)
actorSystem ! DoubleMessage(5.0)
actorSystem ! IntMessage(3)
actorSystem ! StringMessage("Hello")
actorSystem ! IntMessage(5)
actorSystem ! StringMessage("I am priority actor")
actorSystem ! StringMessage(
"I process string messages first,then integer,long and others"
)
}
class MyPriorityActorMailBoxTyped(settings: Settings,config: Config)
extends UnboundedPriorityMailBox(
// Create a new PriorityGenerator,lower prio means more important
PriorityGenerator {
// Int Messages
case x: IntMessage => 1
// String Messages
case x: StringMessage => 0
// Long messages
case x: LongMessage => 2
// other messages
case x: DoubleMessage => 3
case _ => 4
}
)
trait MyMessage
case class IntMessage(x: Int) extends MyMessage
case class LongMessage(x: Long) extends MyMessage
case class StringMessage(x: String) extends MyMessage
case class DoubleMessage(x: Double) extends MyMessage
object MyPriorityActorTyped {
def receive: Behavior[MyMessage] = Behaviors.receive { (context,message) =>
message match {
case IntMessage(x) => println(x)
case StringMessage(x) => println(x)
case LongMessage(x) => println(x)
case DoubleMessage(x) => println(x)
case _ => println()
}
Behaviors.same
}
}
prio-dispatcher {
mailBox-type = "com.akka.prac.MyPriorityActorMailBoxTyped"
}
同样的例子适用于 Akka Classic。我在这里错过了什么?
谢谢。
解决方法
Justed 对其进行了测试,它可以与 documentation 中的配置配合使用:
ActorSystem.create(Behaviors.setup(ctx -> someStaticBehavior(ctx)),"system",ConfigFactory.load("application.conf"),MailboxSelector.fromConfig("my-app.my-special-mailbox"));
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。