如何确保与具有 objectify 的 Appengine 实体上的并发请求保持一致性？

Question

在我的应用程序中，并发写入发生在单个实体上，我注意到当超过3次写入/秒发生时，并非所有请求都被持久化。我从事务内部发出请求，但我也没有看到并发修改异常，我使用的是对象化，所以没有抛出异常可能是对象化的事情。我知道对于并发写入，我需要实现分片计数器，但即使在那里，我也想绝对确保如果写入被删除，我会被告知。在对象化中是否有相当于@version的内容，或者我可以在对象化实现中使用JPA/JDO中的@version机制吗？这是持久化我的实体的代码：

            while (true) {

                try {
                    ofy().transact(new VoidWork() {
                        public void vrun() {
                            Venue_Model tnxVenue = ofy().load()
                                    .type(Venue_Model.class).id(tnxVenueID)
                                    .now();
                            tnxVenue.doStuff();

                            ofy().save().entities(tnxVenue).now();
                        }
                    });
                    //There are cases where this part of the code is reached but updates to the entity are not reflected in the data store viewer.
                    break;
                } catch (ConcurrentModificationException e) {
                    // TODO Auto-generated catch block
                    if (retries == 0) {
                        e.printStackTrace();

                                + person_ref.getKey() + e.toString());
                        break;
                    }
                    retries--;


                } catch (Exception e) {

                }
            }
        }

要检查实体是否已持久化，我只需在 appengine 仪表板上查看我的数据存储查看器。

对于每个持久化一个场所的请求，我还尝试检索n个检查，检查实体是否已持久化，奇怪的是，在代码运行期间，它会正确返回-然而，数据存储查看器告诉一个不同的故事：/code检查数据是否已正确持久化。

               venue = ofy().load().type(Venue_Model.class).id(venue_id).now(); // search if person has checked in
                if (!venue.allCheckins.contains(person_ref)) {
                    log.warning("attempt " + i + " for"
                            + person_ref.getKey());   // Never entered :/
                    venue.doStuff(person_ref, subVenueName);
                    ofy().save().entities(venue).now();
                } 

Answer 1

您的代码实际上不执行事务中的任何数据存储操作。阅读关于事务的对象化文档:

https://code . Google . com/p/objectify-app engine/wiki/Transactions