akka2.6.21版本如何在k8s集群中进行节点发现

在Akka 2.6.21 版本中，要在 Kubernetes (K8s) 集群中实现节点发现，你需要使用Akka Cluster 的集成工具，如`akka-distributed-tools` 和 `akka-kubernetes`插件。以下是基本步骤：

1. **添加依赖**:
在你的项目中添加对`akka-cluster-kube-discovery`和`akka-stream`等库的依赖。例如，在`build.sbt`中添加：

   libraryDependencies += "com.typesafe.akka" %% "akka-cluster-kube-discovery" % "2.6.21"

2. **启用Kubernetes Discovery**:
在`application.conf`配置文件中，启用Kubernetes discovery机制。添加以下配置：

   akka.cluster {
     gossip {
       discovery {
         type = kubernetes
         host-name = "default-service-account"
         # 如果你的集群使用的是ServiceAccount泛型名称，可以省略下面两行
         service-account-name = ""
         service-account-namespace = "default"
       }
     }
   }

这里的`host-name`通常是指Kubernetes中用于识别服务的Service Account的名称。

3. **创建Cluster Singleton Actor**:
在启动应用时，需要创建一个集群单例Actor，以便作为集群状态的中心点。例如：

   val system = ActorSystem("my-system")
   clusterSingletonManager(system).start()

4. **监控和服务发现**:
当新节点加入集群时，`akka-cluster-kube-discovery`会自动发现和注册新的Kubernetes Pod，使得节点间能相互找到彼此。

5. **异常处理和恢复**:
K8s可能会有短暂的网络波动或Pod重启，为了保持高可用性，你需要设置合理的连接重试策略和断路器模式。