我正在尝试设置一个简单的服务器/客户端 akka(使用 Akka 2.0.3)应用程序,但无法连接。在此之前,这是基本代码:
import com.typesafe.config.ConfigFactory
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.Props
class Server extends Actor {
def receive = {
case s: String => println("Got " + s)
}
}
val serverSystem = ActorSystem("server", ConfigFactory.load(ConfigFactory.parseString("""
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
transport = "akka.remote.netty.NettyRemoteTransport"
netty {
hostname = "localhost"
port = 5678
}
}
}
""")))
val server = serverSystem.actorOf(Props[Server], name = "server")
Thread.sleep(500)
println("started")
Thread.sleep(500)
val clientSystem = ActorSystem("client", ConfigFactory.load(ConfigFactory.parseString("""
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
}
""")))
val remoteServer = clientSystem.actorFor("akka://server@XXX:5678/user/server")
remoteServer ! "HEY"
Thread.sleep(3000)
clientSystem.shutdown
serverSystem.shutdown
我知道配置应该放在外部文件中。
如果你更换XXX
with localhost
有用:
started
Got HEY
但是如果我使用我的外部(已解析)IP(家庭路由器后面的PC)XXX
the HEY
消息永远不会到达。我认为这是由于某些防火墙问题造成的,并在我的路由器上转发了相关的 TCP 和 UDP 端口,并在我的 Windows 防火墙上打开/允许它们。所以之后以下代码起作用了(也XXX
替换为我的外部IP)。开始了ServerTest
可以通过一个连接ClientTest
:
import java.net.ServerSocket
object ServerTest extends App {
println("START server")
val ss = new ServerSocket(5678)
val s = ss.accept()
println(s)
println("END")
}
import java.net.Socket
object ClientTest extends App {
println("START client")
val s = new Socket("XXX", 5678)
println(s)
println("END")
}
所以这不是端口/防火墙问题,不是吗?!那么问题出在哪里呢???
localhost
通常意味着127.0.0.1
,这只是计算机中可能存在的众多接口(卡)之一。绑定到 localhost 的服务器不会接收连接到其他接口(包括具有外部地址的接口)的连接。
您应该指定服务器中的外部地址,或者0.0.0.0
这意味着“绑定到所有接口”。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)