Google App Engine：本地行为与部署行为不同，错误：无法在单个事务中对多个实体组进行操作

Question

我有一个 Java Google App Engine Web 应用程序，允许用户上传图像。在本地，效果很好。但是，一旦我将其部署到“云”并上传图像，就会收到以下错误：

java.lang.IllegalArgumentException：无法在单个事务中对多个实体组进行操作。

我使用 Blobstore 存储图像（Blobstore 参考 ）。我的方法如下：

    @RequestMapping(value = "/ajax/uploadWelcomeImage", method = RequestMethod.POST)
@ResponseBody
public String uploadWelcomeImage(@RequestParam("id") long id,
        HttpServletRequest request) throws IOException, ServletException {

    byte[] bytes = IOUtils.toByteArray(request.getInputStream());
    Key parentKey = KeyFactory.createKey(ParentClass.class.getSimpleName(),
            id);
    String blobKey = imageService.saveImageToBlobStore(bytes);
    imageService.save(blobKey, parentKey);

    return "{success:true, id:\"" + blobKey + "\"}";
}

您会注意到该方法首先调用“imageService.saveImageToBlobStore”。这实际上保存了图像的字节。 “imageService.save”方法获取生成的 blobKey 并将其包装在 ImageFile 对象中，该对象是包含 String blobKey 的对象。我的网站引用 imageFile.blobKey 来获取要显示的正确图像。 “saveImageToBlobStore”看起来像这样：

@Transactional
public String saveImageToBlobStore(byte[] bytes) {
    // Get a file service
    FileService fileService = FileServiceFactory.getFileService();

    // Create a new Blob file with mime-type "text/plain"
    AppEngineFile file = null;
    try {
        file = fileService.createNewBlobFile("image/jpeg");
    } catch (IOException e) {
        e.printStackTrace();
    }

    // Open a channel to write to it
    boolean lock = true;
    FileWriteChannel writeChannel = null;
    try {
        writeChannel = fileService.openWriteChannel(file, lock);
    } catch (FileNotFoundException e) {
        e.printStackTrace();
    } catch (FinalizationException e) {
        e.printStackTrace();
    } catch (LockException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }

    // This time we write to the channel using standard Java
    try {
        writeChannel.write(ByteBuffer.wrap(bytes));
    } catch (IOException e) {
        e.printStackTrace();
    }

    // Now finalize
    try {
        writeChannel.closeFinally();
    } catch (IllegalStateException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }

    // Now read from the file using the Blobstore API
    BlobKey blobKey = fileService.getBlobKey(file);
    while (blobKey == null) { //this is hacky, but necessary as sometimes the blobkey isn't available right away
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        blobKey = fileService.getBlobKey(file);
    }

    // return
    return blobKey.getKeyString();
}

我的其他保存方法看起来像这样：

public void save(String imageFileBlobKey, Key parentKey) {
    DatastoreService datastore = DatastoreServiceFactory
            .getDatastoreService();

    Entity imageFileEntity = new Entity("ImageFile", parentKey);
    imageFileEntity.setProperty("blobKey", imageFileBlobKey);

    datastore.put(imageFileEntity);
}

正如我之前所说，它在本地工作，但未部署。该错误出现在对 saveImageToBlobstore 的调用上，特别是在“fileservice.getBlobKey(file)”上。注释掉这一行可以消除错误，但我需要这一行将图像的字节保存到 blob 存储中。

我还尝试评论其他行（见下文），但没有运气。同样的错误：

@RequestMapping(value = "/ajax/uploadWelcomeImage", method = RequestMethod.POST)
@ResponseBody
public String uploadWelcomeImage(@RequestParam("id") long id,
        HttpServletRequest request) throws IOException, ServletException {

    //byte[] bytes = IOUtils.toByteArray(request.getInputStream());
    //Key parentKey= KeyFactory.createKey(ParentClass.class.getSimpleName(),
            //id);
    byte[] bytes = {0,1,0};
    String blobKey = imageService.saveImageToBlobStore(bytes);
    //imageService.save(blobKey, parentKey);

    return "{success:true, id:\"" + blobKey + "\"}";
}

有什么想法吗？我正在使用 GAE 1.5.2。谢谢你！

更新，找到解决方案： 我从事务性“saveImageToBlobStore”中取出了一些代码，并将其提升了一个级别。见下文：

@RequestMapping(value = "/ajax/uploadWelcomeImage", method = RequestMethod.POST)
@ResponseBody
public String uploadWelcomeImage(@RequestParam("id") long id,
        HttpServletRequest request) throws IOException, ServletException {

    byte[] bytes = IOUtils.toByteArray(request.getInputStream());
    Key parentKey = KeyFactory.createKey(ParentClass.class.getSimpleName(),
            id);

            //pulled the following out of transactional method:
    AppEngineFile file = imageService.saveImageToBlobStore(bytes);
    FileService fileService = FileServiceFactory.getFileService();
            //code below is similar to before//////////////
    BlobKey key = fileService.getBlobKey(file);
    String keyString = key.getKeyString();
    imageService.save(keyString, parentKey);

    return "{success:true, id:\"" + keyString + "\"}";

Answer 1

来自文档：

当应用程序创建一个实体时，它可以指定另一个实体作为新实体的父实体。将父实体分配给新实体会将新实体置于与父实体相同的实体组中。

还：

事务中的所有数据存储操作都必须对同一实体组中的实体进行操作。

因此，您必须选择：

• 在一种极端情况下，您可以创建一个“根”实体（没有任何父实体），并将其设置为其他所有实体的父实体。您将能够以任何您想要的方式使用交易；但每个实体组每秒可以发生的操作数是有限制的。此策略限制了您的可扩展性。

• 在另一个极端，您可以将每个实体单独放在它自己的组中。只需将每个实体设为根实体，即没有任何父实体。这将为您带来最大的可扩展性，因为底层系统可以自由地在大量机器之间均匀分配负载。不幸的是，这意味着您将无法使用交易。您必须仔细考虑并发一致性并避免竞争条件。

• 中间点需要一些规划：思考哪些流程会因包含在事务中而受益。然后定义哪些实体将参与交易。然后确保在创建时将所有这些放入同一个组中。

一个简单的例子是为每个用户使用一个实体组；主用户记录将是根实体，与该用户相关的其他所有内容都将指示该根实体作为其父实体。通过这种设计，任何用户内部的操作都可以封装在一个事务中；但任何用户间操作都不会。

这似乎过于限制，但你可以设计自己的出路。例如，您可以将任何用户-用户关系定义到一个新的实体组中，该实体组不属于任何一个用户组。或者对实体组之间交叉的所有内容使用批处理；如果您超出了 HTTP 请求/响应，则可以控制并发性，从而避免多种竞争条件。