3

我正在尝试测试我的分布式锁实现，但我仍然没有找到让它工作的方法。我使用两种简单的方法部署了一个 REST 服务，如下所示：

@GET
@Path("/lock")
@Produces("text/*")
public String lock() throws InterruptedException {
    Lock lock = distributedService.getDistributedLock("test");
    boolean result = lock.tryLock(5, TimeUnit.SECONDS);
    return result ? "locked" : "timeout";
}

@GET
@Path("/unlock")
@Produces("text/*")
public String unlock() {
    Lock lock = distributedService.getDistributedLock("test");
    lock.unlock();
    return "unlocked";
}

DistributedService对象实现了 getDistributedLock() 方法：

@Override
public Lock getDistributedLock(String lockName) {
    return Hazelcast.getDefaultInstance().getLock(lockName);
}

在 hazelcast.xml 文件中，我启用了 TCP-IP 连接并禁用了其他所有内容：

<network>
<port auto-increment="true">5701</port>
<join>
  <multicast enabled="false" />
  <tcp-ip enabled="true">
    <interface>192.168.0.01</interface>
    <interface>192.168.0.02</interface>
  </tcp-ip>
</join>
<interfaces enabled="false" />
<symmetric-encryption enabled="false" />
<asymmetric-encryption enabled="false" />

我在两台机器上部署了应用程序，IP地址对应于.xml文件（192.168.0.01和192.168.0.02），当我从浏览器调用服务时它第一次工作（它锁定并返回“锁定” ) 并且每次我调用 unlock() 方法时它都会正确返回（我得到字符串“unlocked”）但是在第一次之后，每次我调用 lock() 方法时我都会超时。看起来 unlock() 方法并没有解锁它。

有人可以指出我使用分布式锁和榛树的正确方法吗？

4

1 回答 1

7

只有被锁定的线程才能解锁它。你是说你已经为锁定和解锁实现了 REST。而且我猜锁定和解锁的线程是不同的。这就是为什么它不起作用。尝试打印线程名称并查看自己。

于 2012-05-02T20:04:37.720 回答