【发布时间】：2014-08-12 12:35:46
【问题描述】：
我正在处理的一个项目遇到了一个非常奇怪的问题。如果有人能在这里指出正确的方向，我将不胜感激。
// 设置
有多个 Web 服务器，并且在它们前面有一个负载均衡器。服务器正在处理可能来自多个部分的请求，并且部分可以由不同的服务器处理。一旦收到所有部分，这些多部分请求应合并为一个单独的事务。 进行最终处理的服务器无关紧要，但只有一台服务器可以完成。接收之前部分的其他服务器应该只标记接收到的部分，存储数据并立即回复。
现在我使用数据库表来处理节点之间的同步。 基本思想是，当服务器获得一个部件时，它会尝试使用请求附带的事务 id 来获取锁。这是通过尝试以 txid 作为主键向 Lock 表插入一行来完成的。如果插入成功，则该服务器获取锁并处理它收到的部分，通过将其存储到数据库检查是否已收到其他部分，如果没有则立即返回响应。
// 问题
我遇到的问题是线程似乎随机锁定在数据库中，从而冻结了整个处理过程。我已经对其进行了调试，以至于在多个请求同时处理的情况下，它们只是卡在尝试获取锁并最终在 30 秒后超时。第一个请求可能很少被处理，或者看起来是随机的，但即使是 7 个并发请求也会阻塞数据库。
对我来说，这应该不会卡住，而且我还没有什么想法。
// 信息
我正在使用带有 InnoDB 引擎的 MySQL。服务器运行 Java 代码，Hibernate 用作 ORM 层来访问数据库。
锁表：
CREATE TABLE `lock` (
`id` varchar(255) NOT NULL,
`expiryDate` datetime DEFAULT NULL,
`issueDate` datetime DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
id是用于组合部分的事务id。
我有一个管理锁访问的基本界面。
public interface LockProviderDao {
public boolean lock(String id);
public boolean unlock(String id);
}
以及使用 Hibernate 访问数据库的该类的实现。
@Override
public boolean lock(String id) {
Session session = this.sessionFactory.openSession();
Lock lock = new Lock(id);
Transaction tx = null;
boolean locked = false;
try {
// Try to lock
tx = session.beginTransaction();
session.save(lock);
tx.commit();
locked = true;
} catch(Exception e) {
if(tx != null) {
tx.rollback();
}
} finally {
session.close();
}
return locked;
}
@Override
public boolean unlock(String id) {
Session session = this.sessionFactory.openSession();
boolean status = true;
Transaction tx = null;
try {
Lock lock = (Lock) session.load(Lock.class, id);
tx = session.beginTransaction();
session.delete(lock);
tx.commit();
} catch(Exception e) {
if(tx != null) {
tx.rollback();
}
status = false;
} finally {
session.close();
}
return status;
}
看起来很简单。这是进行处理的代码。这个线程已经打开了一个 Hibernate 会话，所以在 lock 和 unlock 方法中打开的 Session 是一个嵌套的 Session，如果这有什么不同的话。
int counter = 0;
boolean lockAcquired = false;
do {
// Try to acquire the lock
lockAcquired = this.lockProviderDao.lock(txId);
if (!lockAcquired) {
// Didn't get it try a bit later
try {
Thread.sleep(defaultSleepPeriod);
} catch (Exception e) {
}
if (counter >= defaultSleepCycles) {
return;
}
counter++;
}
} while (!lockAcquired);
// DO THE PROCESSING HERE ONCE LOCK ACQUIRED
// Release the lock
this.lockProviderDao.unlock(txId);
【问题讨论】：
标签： java mysql multithreading hibernate