在Akka中使用IO/阻塞操作的最正确方式

libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "版本号"
libraryDependencies += "com.typesafe.akka" %% "akka-io" % "版本号"

import akka.actor.{Actor, ActorLogging, Props}
import akka.io.{IO, Tcp}

class MyIOActor extends Actor with ActorLogging {
  import Tcp._
  import context.system

  // 创建一个Tcp的Actor
  val tcpActor = context.actorOf(Props[TcpActor])

  // 绑定Tcp的Actor到指定的地址和端口
  IO(Tcp) ! Bind(tcpActor, address, port)

  def receive: Receive = {
    case Bound(localAddress) =>
      log.info("TcpActor is bound to {}", localAddress)

    case CommandFailed(_: Bind) =>
      log.error("Failed to bind TcpActor")

    // 处理其他消息
  }
}

class TcpActor extends Actor with ActorLogging {
  import Tcp._
  import context.system

  def receive: Receive = {
    case Connected(remote, local) =>
      log.info("Connected to remote address {}", remote)

      // 发送数据
      val connection = sender()
      connection ! Write(ByteString("Hello, world!"))

      // 接收数据
      connection ! Register(self)

    case Received(data) =>
      log.info("Received data: {}", data.utf8String)

    case PeerClosed =>
      log.info("Connection closed by peer")

    // 处理其他消息
  }
}

import akka.actor.ActorSystem

object MyApp extends App {
  val system = ActorSystem("MyApp")
  val ioActor = system.actorOf(Props[MyIOActor], "ioActor")

  // 等待Actor系统终止
  system.awaitTermination()
}