在Akka集群中配置种子节点的方法如下:
akka {
actor {
provider = "cluster"
}
remote {
netty.tcp {
hostname = "127.0.0.1" // 本地IP地址
port = 2551 // 端口号
}
}
cluster {
seed-nodes = [
"akka.tcp://cluster-system@127.0.0.1:2551" // 种子节点的地址
]
}
}
import akka.actor.ActorSystem
import com.typesafe.config.ConfigFactory
object ClusterSystem {
def main(args: Array[String]): Unit = {
val config = ConfigFactory.load()
val system = ActorSystem("cluster-system", config) // 系统名称需与种子节点配置中的一致
// 创建并启动Actor
val actor = system.actorOf(Props[MyActor], "my-actor")
}
}
注意:种子节点是集群中的初始节点,新加入的节点会从种子节点那里获取集群的初始状态和配置信息。种子节点的地址应该是可靠的,最好是一个或多个已知的稳定节点。