题目
如何在Akka中定义一个Actor并发送消息
信息
- 类型：问答
- 难度：⭐
考点
Actor定义,消息传递,Actor创建
快速回答
在Akka中定义和发送消息的基本步骤：
- 定义消息协议（通常使用case类/对象）
- 创建Actor类并实现
receive方法处理消息 - 通过
ActorSystem创建ActorRef - 使用
!或tell()发送消息
原理说明
Akka Actor模型基于消息驱动的并发模型：
- Actor：并发执行单元，通过异步消息进行通信
- 消息：不可变数据对象（推荐case类/对象）
- ActorRef：Actor的引用，用于发送消息
- Mailbox：每个Actor拥有独立的消息队列
代码示例
// 1. 定义消息协议
case class Greet(who: String)
case object SayHello
// 2. 定义Actor
class GreetingActor extends Actor {
def receive: Receive = {
case Greet(name) => println(s"Hello, $name!")
case SayHello => println("Hello there!")
}
}
// 3. 创建Actor并发送消息
val system = ActorSystem("SimpleSystem")
val greeter: ActorRef = system.actorOf(Props[GreetingActor](), "greeter")
greeter ! Greet("Alice") // 发送消息
// 或 greeter.tell(SayHello, Actor.noSender)最佳实践
- 消息不可变：使用case类/对象确保线程安全
- 命名规范：Actor名称应明确（如"userAuthenticator"）
- Props工厂：使用
Props()创建Actor配置，避免直接new Actor - 模式匹配：在receive中处理多种消息类型
常见错误
- 直接调用Actor方法：禁止通过引用直接调用Actor内部方法（破坏封装）
- 可变消息：发送可变对象可能导致并发问题
- 阻塞操作：在receive中执行阻塞调用会冻结整个Actor
- 过度创建：避免为每个任务创建新Actor（合理复用）
扩展知识
- Actor生命周期：
preStart()/postStop()钩子方法 - 消息顺序保证：同一发送者到同一接收者的消息保持顺序
- 死信队列：无法投递的消息会发送到
/deadLetters - 位置透明性：本地和远程Actor使用相同的消息发送语法
