如果您想了解JPA：用于处理OptimisticLockException的模式的相关知识，那么本文是一篇不可错过的文章，我们将对jpa问题进行全面详尽的解释，并且为您提供关于activiti6乐观锁

如果您想了解JPA：用于处理OptimisticLockException的模式的相关知识，那么本文是一篇不可错过的文章，我们将对jpa问题进行全面详尽的解释，并且为您提供关于activiti6 乐观锁问题 org.activiti.engine.ActivitiOptimisticLockingException、Azure Cosmos DB - 间歇性 MongoConnectionException / IOException / SocketException、Error: java.io.IOException: org.apache.hadoop.hdfs.BlockMissingException: Could not obtain block、java – OptimisticLockException与Ebean / Play的有价值的信息。

• JPA：用于处理OptimisticLockException的模式（jpa问题）
• activiti6 乐观锁问题 org.activiti.engine.ActivitiOptimisticLockingException
• Azure Cosmos DB - 间歇性 MongoConnectionException / IOException / SocketException
• Error: java.io.IOException: org.apache.hadoop.hdfs.BlockMissingException: Could not obtain block
• java – OptimisticLockException与Ebean / Play

JPA：用于处理OptimisticLockException的模式（jpa问题）

在（REST）Web服务中处理OLE的正确模式是什么？例如，这就是我现在正在做的

protected void doDelete(HttpServletRequest request, HttpServletResponse response)        throws ServletException, IOException {    ...    ...    ...    try {        try {            em.getTransaction().begin();            // ... remove the entity            em.getTransaction().commit();        } catch (RollbackException e) {            if (e.getCause() instanceof OptimisticLockException) {                try {                    CLog.e("optimistic lock exception, waiting to retry ...");                    Thread.sleep(1000);                } catch (InterruptedException ex) {                }                doDelete(request, response);                return;            }        }        // ... write response    } catch (NoResultException e) {        response.sendError(HttpServletResponse.SC_NOT_FOUND, e.getMessage());        return;    } finally {        em.close();    }}

每当您在代码中看到睡眠时，很可能这是不正确的。有没有更好的方法来解决这个问题？

另一种方法是立即将故障发送回客户端，但我宁愿不要让他们为此担心。正确的事情似乎可以完成使请求在服务器上成功执行的所有操作，即使它需要一段时间。

谢谢。

答案1

如果收到乐观的锁定异常，则意味着其他某个事务已将更改 提交 给您尝试更新/删除的实体。由于其他事务已提交，因此立即重试可能会成功。

我还会使方法在N次尝试后失败，而不是等待StackOverflowException发生。

activiti6 乐观锁问题 org.activiti.engine.ActivitiOptimisticLockingException

activiti6 乐观锁问题 org.activiti.engine.ActivitiOptimisticLockingException

• 使用identityService.saveUser()添加用户时出现以下问题：

org.activiti.engine.ActivitiOptimisticLockingException: org.activiti.engine.impl.persistence.entity.UserEntityImpl@10718783 was updated by another transaction concurrently

• 出现问题的代码

    public void addUser(User user) {
	// todo ...
        identityService.saveUser(user);
    }

• 解决方法
  添加用户分两步操作：
  1. 先调用identityService.newUser()传入userId得到user
  2. 再调用 identityService.saveUser()，向数据库中添加数据
• 解决问题之后的代码

    public void addUser(User user, String systemId) {
        User userEntity = identityService.newUser(user.getId()));
        generalUser(userEntity, user);
        identityService.saveUser(userEntity);
    }
    
    //处理数据
    private void generalUser(User userEntity, User user){
        userEntity.setFirstName(user.getFirstName());
        userEntity.setLastName(user.getLastName());
        userEntity.setEmail(user.getEmail());
        userEntity.setPassword(user.getPassword());
    }

• 添加其他数据时也可能出现这种情况，比如添加用户组数据，解决方法如上一致

Azure Cosmos DB - 间歇性 MongoConnectionException / IOException / SocketException

//return new MongoClient(connectionString);
var settings = MongoClientSettings.FromConnectionString(connectionString);
settings.SslSettings = new SslSettings()
{
    EnabledSslProtocols = System.Security.Authentication.SslProtocols.Tls12
};
return new MongoClient(settings);

[root@slave1 sbin]# ./hadoop-daemon.sh start datanode

[OptimisticLockException: Data has changed. updated [0] rows sql[update person 
set name=? where id=? and email=? and name=? and password is null and created=? 
and deleted is null] bind[null]]

public void updateFromForm(Map<String,String[]> form) throws Exception {
    this.name = form.get("name")[0];

    String password = form.get("password")[0];
    if (password != null && password.length() != 0) {
        String hash = Password.getSaltedHash(password);
        this.password = hash;
    }

    this.update();
}

@RequiresAuthentication(clientName = "FormClient")
public static Result updateProfile() throws Exception {

    final CommonProfile profile = getUserProfile();
    String email = getEmail(profile);           
    Person p = Person.find.where().eq("email",email).findList().get(0);

    Map<String,String[]> form = request().body().asFormUrlEncoded();

    if (p == null) {
        Person.createFromForm(form);
    } else {
        p.updateFromForm(form);
    }

    return ok("HI");
}

@Version
public java.util.Date version;

update person set name='Bob' 
where id=1 and version='2014-03-03 22:07:35';