如何防止“Nucleus DataStoreException：并发修改”？

Question

我们的应用突然获得了大量流量，并且系统存在一些设计缺陷（或者更确切地说，我们从未想过它会获得如此多的流量，所以我们只是选择跳过它）。

正如主题所述，我正在寻找一种防止错误的方法：org.datanucleus.exceptions.NucleusDataStoreException: Concurrent Modification

目前我有一个名为 Group 的实体，看起来像这样：

@PersistenceCapable
public class Group extends PersistableString {
    private static final long serialVersionUID = 6215353466976945628L;

    @Persistent
    private int yesCount;
    @Persistent
    private int noCount;

    public void increaseYesCount()
    {
        yesCount++;
    }
    public void increaseNoCount()
    {
        noCount++;
    }
}

以下代码是实体的更新是如何完成的：

int answer = Integer.parseInt(req.getParameter("answer"))

try {
    PersistenceManager pm = PMF.getPersistenceManager();
    for(String groupId : allGroupsToBeUpdated)
    {
        Group group = pm.getObjectById(Group.class, groupId);
        if(answer == 0)
            group.increaseNoCount();
        else
            group.increaseYesCount();
    }
    pm.close();
} catch (Exception e) {
    e.printStackTrace();
}

allGroupsToBeUpdated 是一个包含大约 30 个字符串 ID 的列表。有什么方法可以避免Concurrent Modification-error 吗？我可以检查我检索的实体是否正在更新，然后丢弃（/忽略）更新？写入实际上是否成功并不重要，我只是想确保我没有收到错误（或者它一直试图成功写入），因为它导致请求需要 10-30 秒。

我是否应该在每次更新之间打开（获取新的PM-instance）并关闭连接（pm.close()），而不是等待所有 30 次更新完成？

我知道分片计数器并且应该（显然）使用它们，但现在我正在寻找解决这个问题的“快速解决方案”。

编辑： 我正在使用：

App Engine SDK 1.8.9

JDO 3.0

可以在以下位置找到 Stacktrace： http://pastebin.com/TWnmkpPU

Answer 1

由于篇幅原因，作为答案发布。

在您的情况下，事务可能并不好，因为您实际上只是想向用户隐藏问题，这在缓慢的请求时间中表现出来。也许启动异步推送任务以在请求之外的后台执行写入将是您最好的选择。

我真的不推荐基于隐藏错误和吞咽异常的设计。想要“防止”一个正在做它应该做的异常（表示由于争用而导致写入失败），意味着你应该首先避免导致它的条件。

我完全理解需要尽早让事情快速运行，但是一旦糟糕的设计决策开始产生影响，现在就开始采用最佳实践可能是个好主意。继续依赖“快速修复”和隐藏问题可能会让您日后陷入困境。