标签：object style mat creat slf4j version 创建 builder ted
Actor 类需要继承AbstractActor类
实现createReceive方法,绑定各类actor收到不同类型消息对应处理不同业务逻辑
默认提供了ReceiveBuilder类辅助创建 Receive
对actorOf的调用返回ActorRef的实例。这是 Actor 实例的句柄，也是与之交互的唯一方法。
ActorRef是不可变的，并且与它所表示的 Actor 有一对一的关系。ActorRef也是可序列化的， 序列化通过网络发送它，并在远程主机上使用它，并且它仍然在网络上表示原始节点上的同一个 Actor。
Actor的层级关系类似树模式
谁创建谁管理原则：
ActorSystem 创建就由ActorSystem负责监控管理（重启，异常，恢复等）
Actor中创建另外的Actor,则创建者看做为父级，负责监控管理它创建出来的actor
Props 创建 Actor 的配置选项，推荐在actor类提供一个通用的props方法来创建
注意：
１，同一个akka集群中创建的actor 实例 name不能重复，不然会报InvalidActorNameException异常
２，ActorSytem同一个集群，各节点的ActorSytem name必须相同
３，不允许自行new创建actor实例
如果直接new Actor实例方式创建Actor会报ActorInitializationException错误
示例：
<!-- Gradle --> dependencies { compile group: ‘com.typesafe.akka‘, name: ‘akka-actor_2.12‘, version: ‘2.5.21‘ }
package akka.demo.actor import akka.actor.AbstractActor import akka.actor.ActorRef import akka.actor.Props import akka.japi.pf.ReceiveBuilder import org.slf4j.LoggerFactory /** ** created by tankx ** 2019/9/10 **/ class HelloActor(val name: String) : AbstractActor() { //创建子actor private val childActor: ActorRef = context.actorOf(ChildActor.props()) companion object { private val log = LoggerFactory.getLogger(HelloActor::class.java) //提供静态通用对外的props fun props(name: String): Props { //return Props.create(HelloActor::class.java, name)//默认方式 return Props.create(HelloActor::class.java) { HelloActor(name) } } } override fun preStart() { log.info("preStart") super.preStart() } override fun postStop() { log.info("postStop") super.postStop() } override fun createReceive(): Receive { return ReceiveBuilder.create().matchAny(::onReceive).build() } fun onReceive(msg: Any) { log.info("$name say: $msg") log.info("sender:{}", sender.toString()) } }
package akka.demo.actor import akka.actor.AbstractActor import akka.actor.Props import akka.japi.pf.ReceiveBuilder import org.slf4j.LoggerFactory /** ** created by tankx ** 2019/9/10 **/ class ChildActor : AbstractActor() { private val log = LoggerFactory.getLogger(ChildActor::class.java) companion object { fun props(): Props { return Props.create(ChildActor::class.java) } } override fun preStart() { log.info("preStart") super.preStart() } override fun postStop() { log.info("postStop") super.postStop() } override fun createReceive(): Receive { return ReceiveBuilder.create().matchAny(::onReceive).build() } fun onReceive(msg: Any) { log.info("onReceive: $msg") } }
创建ACTOR，并发消息
val system = ActorSystem.create("akka-system")
val actorRef = system.actorOf(HelloActor.props("aa"), HelloActor::class.java.simpleName)
actorRef.tell("hi world", ActorRef.noSender()) //给actor发消息
如果有依赖注入的情况，需要传入依赖项来构建Actor
示例：
package akka.demo.actor import akka.actor.Actor import akka.actor.IndirectActorProducer /** ** created by tankx ** 2019/9/11 ** 如果有依赖注入方式可使用当前的工厂类的方式进行创建actor **/ class ActorFactory(var applicationContext: String) : IndirectActorProducer { override fun actorClass(): Class<out Actor> { return HelloActor::class.java } override fun produce(): Actor { return HelloActor(applicationContext) } }
创建方式:
val actorFactoryRef = system.actorOf(Props.create(ActorFactory::class.java, "aaa"), "aaa") actorFactoryRef.tell("hi factory", ActorRef.noSender())
AKKA创建Actor需要严格按照推荐的方式去创建，以避免破坏Actor 封装。
标签：object style mat creat slf4j version 创建 builder ted
原文地址：https://www.cnblogs.com/tankaixiong/p/11511251.html
