馆长关于多重服务的分布式信号量

Question

我刚认识动物园管理员和馆长。

我想用动物园管理员和馆长来控制我们的服务。情况是，我们的服务是基于硬件设备的，因此每个设备作为提供者只能在一次中运行一个任务--。由于我们有很多设备，我设计使用策展人的信号量来计算整个数字，但是如何找到准确的设备是一个问题。因为一个作业一次可能需要多个设备才能运行(设备是独立的)，并且不能定义数字，所以每次需要锁定N个设备并发送任务信息

e.g.As我想，我们在馆长中把设备注册为EPHEMERAL_SEQUENTIAL：

/root/services/
              /devices00000001
              /devices00000002
              ...

无论我们在每个设备上使用一个锁，还是在znode的数据中使用一个标志，找到可用的设备将花费我们大量的时间。所以我想问一下，这些问题是否有共同的解决办法？也许我不应该使用动物园管理员而是其他软件？

Answer 1

对每个设备使用一个InterProcessMutex --我假设每个设备都有一些唯一的ID。

String path = ZKPaths.makePath("/some/base/path", deviceId);
InterProcessMutex lock = new InterProcessMutex(curator, path);
if ( lock.acquire(max, unit) ) {
    try {
        DO WORK HERE
    } finally {
        lock.release();
    }
}