Java - MDB - 如何避免并发问题

Question

我们实现了 MDB，它接受用户输入和并行处理。我们对用户数据进行了限制检查（例如用户可以拥有的电话号码数量）。

我面临的问题是两个不同的线程获取相同用户的数据并进行处理。第一个线程很好，它检查限制并将手机正确添加到用户配置文件中。第二个线程也做同样的事情。但是限制检查发生在第一个线程提交事务之前，因此限制检查通过了。但它超过了极限。

有什么办法可以解决吗？让同一线程挑选一个用户的数据很好。但我不知道该怎么做。

请帮忙。提前致谢。

编辑：我还想传达一件事。在不同节点运行时会出现此问题。

Answer 1

这取决于应用服务器、节点数量和应用程序，但以下场景对我来说是可以的：

• Weblogic 或 JBOSS 支持 订单单位 功能：

Message Unit-of-Order 是 WebLogic Server 的一项增值功能， 启用独立的消息生产者或一组生产者 作为一个，将消息分组到一个单元中 处理订单。这个单一的单元称为顺序单元，并且 要求来自该单元的所有消息按顺序处理 它们的创建顺序。

• 如果您更新同一条记录，第一个线程获取锁而第二个线程等待事务提交，那么第二个线程应该检查更新（乐观锁），它可以立即退出。

例如。

Thread 1: lastUpd = now() 
Thread 1: UPDATE MYTABLE SET LAST_UPDATE=${lastUpd} WHERE ID=${id}
Thread 2: lastUpd = now()
Thread 2: UPDATE MYTABLE SET LAST_UPDATE=${lastUpd} WHERE ID=${id} //remain locked
Thread 1: a lot of work ...
Thread 1 COMMIT
Thread 2: a lot of work ...
Thread 2: lastUpd2= SELECT LAST_UPDATE MYTABLE WHERE ID=${id}
Thread 2: IF lastUpd2!= lastUpd ROLLBACK