MarkLogic Java API死锁检测

Question

我们的一个应用程序刚刚遇到了一些令人讨厌的死锁.我很难重新创建问题,因为死锁(或堆栈跟踪)没有立即出现在我的java应用程序日志中.

令我惊讶的是,marklogic java api重试失败的请求(例如,由于死锁).如果您的请求不是多语句请求,这可能是有意义的,否则我不确定它是否确实如此.

因此,请坚持这个死锁问题.我创建了一个简单的代码片段,其中我故意创建了一个死锁.该片段创建一个文档test.xml,然后尝试从两个不同的事务中读取和写入,每个事务都在一个新线程上.

public static void main(String[] args) throws Exception {
        final Logger root = (Logger) LoggerFactory.getLogger(Logger.ROOT_LOGGER_NAME);
        final Logger ok = (Logger) LoggerFactory.getLogger(OkHttpServices.class);
        root.setLevel(Level.ALL);
        ok.setLevel(Level.ALL);

        final DatabaseClient client = DatabaseClientFactory.newClient("localhost", 8000, new DatabaseClientFactory.DigestAuthContext("username", "password"));

        final StringHandle handle = new StringHandle("<doc><name>Test</name></doc>")
            .withFormat(Format.XML);
        client.newTextDocumentManager().write("test.xml", handle);

        root.info("t1: opening");
        final Transaction t1 = client.openTransaction();
        root.info("t1: reading");
        client.newXMLDocumentManager()
            .read("test.xml", new StringHandle(), t1);

        root.info("t2: opening");
        final Transaction t2 = client.openTransaction();
        root.info("t2: reading");
        client.newXMLDocumentManager()
            .read("test.xml", new StringHandle(), t2);

        new Thread(() -> {
            root.info("t1: writing");
            client.newXMLDocumentManager().write("test.xml", new StringHandle("<doc><t>t1</t></doc>").withFormat(Format.XML), t1);
            t1.commit();
        }).start();

        new Thread(() -> {
            root.info("t2: writing");
            client.newXMLDocumentManager().write("test.xml", new StringHandle("<doc><t>t2</t></doc>").withFormat(Format.XML), t2);
            t2.commit();
        }).start();

        TimeUnit.MINUTES.sleep(5);

        client.release();
    }

此代码将生成以下日志:

14:12:27.437 [main] DEBUG c.m.client.impl.OkHttpServices - Connecting to localhost at 8000 as admin
14:12:27.570 [main] DEBUG c.m.client.impl.OkHttpServices - Sending test.xml document in transaction null
14:12:27.608 [main] INFO  ROOT - t1: opening
14:12:27.609 [main] DEBUG c.m.client.impl.OkHttpServices - Opening transaction
14:12:27.962 [main] INFO  ROOT - t1: reading
14:12:27.963 [main] DEBUG c.m.client.impl.OkHttpServices - Getting test.xml in transaction 5298588351036278526
14:12:28.283 [main] INFO  ROOT - t2: opening
14:12:28.283 [main] DEBUG c.m.client.impl.OkHttpServices - Opening transaction
14:12:28.286 [main] INFO  ROOT - t2: reading
14:12:28.286 [main] DEBUG c.m.client.impl.OkHttpServices - Getting test.xml in transaction 8819382734425123844
14:12:28.289 [Thread-1] INFO  ROOT - t1: writing
14:12:28.289 [Thread-1] DEBUG c.m.client.impl.OkHttpServices - Sending test.xml document in transaction 5298588351036278526
14:12:28.289 [Thread-2] INFO  ROOT - t2: writing
14:12:28.290 [Thread-2] DEBUG c.m.client.impl.OkHttpServices - Sending test.xml document in transaction 8819382734425123844

既不会t1也t2不会被提交.MarkLogic日志确认实际存在死锁:

==> /var/opt/MarkLogic/Logs/8000_AccessLog.txt <==
127.0.0.1 - admin [24/Nov/2018:14:12:30 +0000] "PUT /v1/documents?txid=5298588351036278526&category=content&uri=test.xml HTTP/1.1" 503 1034 - "okhttp/3.9.0"

==> /var/opt/MarkLogic/Logs/ErrorLog.txt <==
2018-11-24 14:12:30.719 Info: Deadlock detected locking Documents test.xml

这不会是一个问题,如果其中一个请求失败并抛出异常,但事实并非如此.MarkLogic Java Api重试每个请求最多120秒,其中一个更新超时后大约120秒左右:

Exception in thread "Thread-1" com.marklogic.client.FailedRequestException: Service unavailable and maximum retry period elapsed: 121 seconds after 65 retries
    at com.marklogic.client.impl.OkHttpServices.putPostDocumentImpl(OkHttpServices.java:1422)
    at com.marklogic.client.impl.OkHttpServices.putDocument(OkHttpServices.java:1256)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:920)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:758)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:717)
    at Scratch.lambda$main$0(scratch.java:40)
    at java.lang.Thread.run(Thread.java:748)

有什么方法可以解决这个问题？一种方法可能是设置一个事务的最长生存时间(例如5秒),但这会让人感到烦躁和不可靠.还有其他想法吗？我应该检查出其他任何设置吗？

我正在使用MarkLogic 9.0-7.2并使用marklogic-client-api:4.0.3.

编辑:解决死锁的一种方法是同步调用函数,这实际上是我解决它的方式(见注释).但我认为潜在的问题仍然存在.在多语句事务中出现死锁不应该在120秒超时中隐藏.我宁愿有一个立即失败的请求,而不是我的一个文件上的120秒锁定+每个线程64次失败的重试.

Answer 1

死锁通常可以通过重试来解决。在内部，服务器执行内部重试循环，因为死锁通常是暂时的和偶然的，持续的时间很短。在您的情况下，您构建了一个案例，如果两个线程的超时时间相等，则该情况永远不会成功。通过在使用 REST API 时避免多语句事务，可以在应用程序层避免死锁。（这是 Java api 使用的）。由于客户端有责任管理事务 ID 并且服务器无法检测客户端错误或客户端身份，因此通过 REST 的多语句事务无法 100% 安全地实现。除非您积极主动地处理错误和多线程，否则非常微妙的问题可能而且确实会发生。如果您将逻辑“推送”到服务器（xquery 或 javascript），服务器就能够更好地管理事物。

至于 Java API 在这种情况下实现重试是否“好”，这是值得商榷的。（看似易于使用的界面的妥协是，许多原本是选项的事情都是作为惯例为您决定的。通常没有一刀切的答案。在这种情况下，我假设想法是死锁更有可能是由“意外”的独立代码/逻辑引起的，而不是在切线中运行的相同代码 - 在这种情况下重试将是一个不错的选择。在您的示例中，它不是，但早期的错误仍然会出现失败是可以预见的，直到您将代码更改为“不这样做”）。

如果它尚不存在，那么对可配置超时和重试行为的功能请求似乎确实是一个合理的请求。不过，我建议尝试避免任何导致开放事务的 REST 调用——这本质上是有问题的，特别是如果您没有预先注意到问题（那么它更有可能在生产中困扰您）。与 JDBC 保持连接打开以便服务器可以检测客户端断开连接不同，HTTP 和 ML Rest API 则不然，这导致了与 Java 中传统数据库编码不同的编程模型。