具有后台作业的服务，如何确保作业仅在每个集群中定期运行一次

Question

我有一个基于游戏框架的服务，它是无状态的，旨在部署在多台机器上以实现水平扩展。

此服务正在处理 HTTP JSON 请求和响应，并再次使用 CouchDB 作为其数据存储以实现最大的可扩展性。

我们有少量后台作业需要在整个集群中每 X 秒运行一次。作业不要在每台机器上同时执行，这一点至关重要。

要执行我们使用 Actors 和 Akka Scheduler 的作业（因为我们使用的是 Scala）：

Akka.system().scheduler.schedule(
    Duration.create(0, TimeUnit.MILLISECONDS),
        Duration.create(10, TimeUnit.SECONDS),
        Akka.system().actorOf(LoggingJob.props),
        "tick")

（等）

object LoggingJob {
    def props = Props[LoggingJob]
}

class LoggingJob extends UntypedActor {
    override def onReceive(message: Any) {
        Logger.info("Job executed! " + message.toString())
    }
}

有吗：

• 我错过的 Akka/Actors/Play 中的任何内置技巧对我有用吗？
• 或者我可以在 Couchbase 之上放置一个公认的算法（分布式互斥锁？不完全是？）来做到这一点？

我不想让任何实例“特别”，因为它需要非常易于部署和管理。

Answer 1

查看 Akka 的 Cluster Singleton Pattern。

对于某些用例，它很方便，有时也是强制性的 确保你有一个特定类型的演员在运行 集群中的某处。

一些例子：

• 对某些集群范围内的一致决策或跨集群系统的行动协调的单一责任点
• 外部系统的单一入口点
• 单主，多工
• 集中命名服务或路由逻辑

使用单例不应该是第一个设计选择。它有 几个缺点，例如单点瓶颈。单点 失败也是一个相关问题，但在某些情况下，此功能 通过确保另一个单例实例将处理这个问题 最终开始。