Corda V3驱动测试：vaultQueryBy多数情况无法从Vault检索数据

我之前在Corda V3的测试场景里也碰到过一模一样的问题，简直头疼——驱动程序闭包内调用vaultQueryBy时，经常拿不到之前流执行生成的数据，返回空集合，但偶尔又能正常返回，完全没规律。而且V2里根本没这茬，明显是V3的改动带来的问题。

问题根源 #

Corda V3对节点的状态提交和查询的并发处理逻辑做了调整，驱动程序闭包内的流执行和vault查询之间没有自动等待流完成提交状态到账本的机制。简单说，有时候你执行完流就立刻查vault，这时候状态可能还没完全写入账本或者同步到查询组件，所以查不到；而偶尔运气好，流的提交刚好在查询前完成，就拿到结果了，这就导致了随机性。

解决方案 #

要解决这个问题，核心就是确保在执行vaultQueryBy之前，流已经完全完成状态提交，并且vault已经同步了最新状态。这里有几个靠谱的做法：

• 等待流的Future完成：如果你是用node.startFlow()启动的流，一定要调用.get()方法等待流执行彻底完成，再执行查询。示例代码：

  val flowFuture = node.startFlow(YourFlow())
  flowFuture.get() // 阻塞等待流执行完毕，确保状态已提交到账本
  val queryResults = node.services.vaultService.vaultQueryBy<YourTargetState>().states
  

• 自定义等待状态的工具方法：可以写一个循环查询的逻辑，直到拿到预期结果（记得设置超时时间避免死循环），适合更复杂的测试场景：

  fun waitForExpectedState(node: NodeHandle, stateClass: Class<out ContractState>, timeoutSeconds: Long = 10) {
      val timeoutTimestamp = System.currentTimeMillis() + timeoutSeconds * 1000
      while (System.currentTimeMillis() < timeoutTimestamp) {
          val results = node.services.vaultService.vaultQueryBy(stateClass).states
          if (results.isNotEmpty()) return
          Thread.sleep(100) // 短时间休眠后重试
      }
      throw IllegalStateException("超时未查询到目标状态，请检查流执行逻辑")
  }
  

  在执行vaultQueryBy前调用这个方法，就能保证查询动作在状态写入后执行。

• 调整测试节点的vault配置：在测试驱动的节点配置中，关闭vault的异步同步优化（Corda V3默认可能为了性能启用了异步），确保状态提交后能立刻被查询到。可以在节点启动时添加相关配置参数：

  val node = driver.startNode(
      defaultParameters = NodeParameters(
          additionalConfig = mapOf("vault.async-update" to false)
      )
  ).get()
  

验证 #

按照上面的方法调整后，多跑几次测试场景，应该就不会再出现查询结果随机为空的情况了。本质上就是解决了流执行与vault查询之间的时序问题，确保查询动作发生在状态完全写入并同步到vault之后。

内容的提问来源于stack exchange，提问作者JohnZ