Corda中Vault写入为同步还是异步？Flow执行效率问题咨询

我太懂这种糟心的感觉了——默认的FinalityFlow确实会卡在那里，直到所有交易参与方节点都成功持久化交易才会返回结果，这不仅让你的RPC调用慢得离谱，要是某个远程节点宕机，整个流程直接就僵住了。下面给你几个实用的解决思路：

1. 改用sendOnly模式让FinalityFlow快速返回 #

FinalityFlow有个容易被忽略的重载参数sendOnly，设置为true后，它只会完成交易公证，然后立即返回，不会等待所有参与方的确认回执。之后你可以异步给参与方发送交易，这样RPC调用就能秒级返回。

示例代码调整：

// 原代码（慢）
val signedTx = serviceHub.signInitialTransaction(txBuilder)
val finalizedTx = subFlow(FinalityFlow(signedTx, participantSessions))
return finalizedTx

// 修改后（快）
val signedTx = serviceHub.signInitialTransaction(txBuilder)
// 只做公证，不等待参与方确认
val finalizedTx = subFlow(FinalityFlow(signedTx, participantSessions, sendOnly = true))
// 异步给参与方发送交易（非阻塞）
participantSessions.forEach { session ->
    subFlow(SendTransactionFlow(session, finalizedTx))
}
return finalizedTx

⚠️ 注意：这种方式下要确保参与方最终能收到交易，建议给异步发送逻辑加个重试机制，或者在参与方节点监听Vault的状态更新，避免出现状态不一致。

2. 客户端改用异步回调，避免阻塞等待 #

不要在客户端直接调用getOrThrow()同步阻塞，改用CordaFuture的异步回调方法，这样客户端可以继续处理其他任务，不用傻等Flow返回。

示例客户端代码：

// 原代码（阻塞）
val flowFuture = rpc.startFlowDynamic(YourCustomFlow::class.java, flowArgs)
val txResult = flowFuture.getOrThrow()

// 修改后（异步）
val flowFuture = rpc.startFlowDynamic(YourCustomFlow::class.java, flowArgs)
flowFuture.thenAccept { txResult ->
    // 交易完成后的处理逻辑
    println("交易已完成，ID：${txResult.id}")
}
// 客户端可以继续执行其他操作

3. 添加超时机制，防止节点宕机导致无限等待 #

不管是Flow内部还是客户端RPC调用，都可以设置超时时间，避免因为某个节点宕机而无限阻塞。

• Flow内添加超时：

val signedTx = serviceHub.signInitialTransaction(txBuilder)
// 30秒内没完成就抛出超时异常
val finalizedTx = withTimeout(Duration.ofSeconds(30)) {
    subFlow(FinalityFlow(signedTx, participantSessions))
}
return finalizedTx

• 客户端RPC设置超时：

val rpcSettings = RPCClientSettings(
    connectionTimeout = Duration.ofSeconds(30),
    requestTimeout = Duration.ofSeconds(60)
)
val rpcConnection = CordaRPCClient(host, port).start(username, password, rpcSettings)
val rpc = rpcConnection.proxy

内容的提问来源于stack exchange，提问作者Bernd Stöger