akka 简单例子总是 not delivered和dead letters encountered,求大神帮看下

发布于 2022-09-01 15:57:09 字数 980 浏览 12 评论 0

package spark;
import akka.actor.{ Actor, Props, ActorSystem, ExtendedActorSystem }
import com.typesafe.config.ConfigFactory
import akka.remote._

object MyApp extends App {
  val actorSystem1 = ActorSystem("actorSystem1", ConfigFactory.parseString("""
    akka {
      remote {
        enabled-transports = ["akka.remote.netty.tcp"]
        netty.tcp {
          hostname = "127.0.0.1"
          port = 5155
        }
       }
    }
   """))
  val actorSystem2 = ActorSystem("actorSystem2")

  actorSystem1.actorOf(Props(new Actor {
    def receive = {
      case x: String =>
        Thread.sleep(1000)
        println("RECEIVED MESSAGE: " + x)
    }
  }), "simplisticActor")

  val remoteActor = actorSystem2.actorSelection("akka.tcp://actorSystem1@localhost:" + 5155 + "/user/simplisticActor")

  remoteActor ! "TEST 1"
  remoteActor ! "TEST 2"
  remoteActor ! "TEST 2"

  Thread.sleep(1000)

  actorSystem1.shutdown()
  actorSystem2.shutdown()
}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文