0

我正在尝试连接本地主机上的两个远程参与者(防火墙已禁用),但没有消息通过。我创建了一些简单的代码来表达我的问题:

演员1:

package test

import scala.actors._
import scala.actors.Actor._
import scala.actors.remote._
import scala.actors.remote.RemoteActor._

object Actor1 {
  RemoteActor.classLoader = getClass().getClassLoader()
}

class Actor1 extends Actor {

  def act {
    alive(9000)
    register('actor1, self)

    println("Actor1 running")
    while (true) {
      react {
        case s: String => {
          println("received1: " + s)
          sender ! "Server reply"
        }

        case _ => println("Received wierdness;)")
      }
    }
  }
}

演员2:

package test

import scala.actors._
import scala.actors.Actor._
import scala.actors.remote._
import scala.actors.remote.RemoteActor._

object Actor2 {
  RemoteActor.classLoader = getClass().getClassLoader()
}

class Actor2 extends Actor {

  val actor1 = select(Node("127.0.0.1", 9000), 'actor1)

  def act {
    println("Sending message to actor1(" + actor1 + ")")
    actor1 ! "Message to server"

    println("Actor2 running")
    while (true) {
      react {
        case s: String => println("received2: " + s)
        case _ => println("Received wierdness;)")
      }
    }
  }
}

和主要课程:

封装测试

object Test {

  def main(args: Array[String]): Unit = {
    val a1 = new Actor1()
    val a2 = new Actor2()

    println("Starting actors")
    a1.start
    a2.start
  }

}

我究竟做错了什么?提前感谢您的帮助。

4

0 回答 0