java - 锁定数据库记录以实现线程间的并发

Question

我敢肯定，这种事情已经做了一百万次，但我今天的搜索 foo 似乎很弱，我想就通常被认为是最佳的方法征求意见完成这个目标。

我的应用程序跟踪系统中在线用户的 session 。每个 session 对应于数据库中的单个记录。 session 可以通过两种方式之一结束。要么收到“停止”消息，要么 session 超时。前一种情况很简单，在消息处理线程中处理，一切正常。后一种情况是令人担忧的地方。

为了处理超时，每条记录都有一个结束时间列，每次收到该 session 的消息时都会更新该列。为了使超时工作，我有一个线程从数据库返回所有记录，其结束时间 < NOW() (过去有一个结束时间)，并通过处理关闭这些 session 。这里的问题是，当超时线程正在处理同一 session 时，我可能会收到一条 session 消息。我最终在超时线程和消息处理线程之间进行了竞争。

我可以使用信号量或类似的东西，只是在超时发生时阻止消息线程处理，因为它只需要每 30 秒或一分钟运行一次。但是，随着用户表变大，这会遇到一些严重的性能问题。我想我想要的是一种在消息线程中知道该记录当前正在由超时线程处理的方法。如果我能做到这一点，我可以丢弃消息或等待超时线程结束，但仅在现在发生冲突的情况下而不是总是发生冲突。

目前我的应用程序直接使用 JDBC。如果我使用 Hibernate 等框架，是否有更简单/标准的方法来解决这个问题？

Answer 1

这是出现各种疯狂错误的绝好机会，一些补救措施可能会导致性能问题。

经典的解决方案是使用事务 (http://dev.mysql.com/doc/refman/5.0/en/commit.html)。这使您可以保证数据的一致性——但是数据库上长时间运行的事务将其变成一个巨大的瓶颈；如果您的“查找超时 session ”代码运行了一分钟，事务可能会运行整个期间，从而有效地锁定对受影响表的写访问。大多数系统都不能很好地处理这个问题。

对于这种情况，我最喜欢的解决方案是为状态设置一个“状态机”；我喜欢将其实现为历史表，但这确实会导致数据库快速增长。

您将 session 的状态定义为“已启动”、“正在运行”、“超时 - 关闭”、“超时 - 关闭”和“已被用户停止”(例如)。

无论您拥有什么数据访问逻辑，您都可以实现支持状态转换逻辑的代码。您的“清理”脚本的伪代码可能是:

• 更新结束时间 < now() 且状态为“running, set status = "timed-out - closing"的所有记录
• 对于状态为“超时 - 关闭”的每条记录
  • 做任何你需要做的事情
  • 更新该记录以设置状态“超时 - 关闭”，其中状态 = “超时 - 关闭”
• 下一条记录

修改 session 记录当前状态的所有其他尝试必须检查当前状态对于尝试的更改是否有效。

例如，“手动”停止代码应该是这样的:

update sessions
set status = "stopped by user"
where session_id = xxxxx
and status = 'running'

如果自动关闭例程在显示用户界面和数据库代码之间的时间内启动，where 子句将不会匹配任何记录，因此其余代码根本不会运行。

为此，所有修改 session 状态的代码都必须检查其前提条件；最可维护的方法是将状态和允许的转换编码到一个单独的数据库表中。

您也可以编写触发器来强制执行此逻辑，但我通常不喜欢触发器 - 仅在必要时才这样做。

我认为这不会增加显着的性能问题 - 但要进行测试和优化。数据库的大部分额外工作是通过向更新语句添加额外的“where”子句；假设您有状态指数，它不太可能产生可衡量的影响。