Corda事件日志记录方案咨询：vaultTrack与ServiceHub问题排查

嘿，这个问题我之前帮好几个开发者排查过——你遇到的重复触发本质上就是Observable订阅的生命周期没管好，要么是每次流调用都新建了订阅，要么是监听服务没做成单例。下面给你一步步拆解解决方案：

Corda里通过ServiceHub调用vaultTrack/trackBy会返回一个Observable<Vault.Update>，如果每次启动流都重新订阅一次，就会产生多个活跃的订阅，同一个状态事件自然会被多次捕获。另外，如果你的监听逻辑不是放在单例服务里，每次流调用都实例化新的监听对象，也会导致重复注册。

1. 用单例CordaService做一次性订阅 #

这是最根本的解决办法：把Vault事件监听逻辑放在单例Corda服务里，节点启动时只订阅一次，全程复用同一个订阅。

首先实现一个继承SingletonSerializeAsToken的单例服务，在初始化时完成订阅，销毁时取消订阅避免内存泄漏：

@CordaService
class VaultEventLoggerService : SingletonSerializeAsToken() {
    private var vaultSubscription: Disposable? = null
    private val log = loggerFor<VaultEventLoggerService>()

    init {
        // 初始化时只订阅一次Vault事件
        val vaultService = serviceHub.vaultService
        // 根据你的需求设置查询条件，比如只监听未消费状态
        val queryCriteria = QueryCriteria.VaultQueryCriteria(Vault.StateStatus.UNCONSUMED)
        
        vaultSubscription = vaultService.trackBy<YourCustomState>(queryCriteria).updates.subscribe { update ->
            // 处理新产生的状态，这里做日志记录
            update.produced.forEach { stateAndRef ->
                log.info("新提交状态捕获：状态ID=${stateAndRef.ref}，内容=${stateAndRef.state.data}")
            }
        }
    }

    override fun close() {
        // 服务销毁时取消订阅
        vaultSubscription?.dispose()
        super.close()
    }
}

用@CordaService注解后，节点启动时会自动初始化这个单例服务，全程只会有一个订阅，不会重复触发。

2. 绝对不要在流内部做订阅 #

如果你之前是在流的call()方法里调用serviceHub.vaultService.trackBy，那每次启动流都会创建新的Observable订阅——这就是重复触发的直接原因！

流只负责处理业务逻辑（比如创建状态、发起交易），事件监听交给独立的单例CordaService去做，两者完全解耦。

3. 兜底：给事件加去重逻辑 #

如果因为某些场景无法用单例服务（比如临时调试），可以在事件处理里加个去重机制，记录已经处理过的StateRef：

// 用线程安全的集合存已处理的状态引用
private val processedStateRefs = ConcurrentHashMap.newKeySet<StateRef>()

// 在订阅回调里
update.produced.forEach { stateAndRef ->
    if (processedStateRefs.add(stateAndRef.ref)) {
        // 只有当状态引用是新的时才处理
        log.info("新提交状态捕获：${stateAndRef.state.data}")
    }
}

注意定期清理这个集合，避免内存占用过高（比如可以定时移除超过N天的StateRef）。

4. 检查查询条件是否合理 #

确保你的Vault查询条件没有扩大范围导致重复匹配。比如如果用Vault.StateStatus.ALL，可能会同时捕获已消费和未消费的状态，这时候要结合update.produced（新产生的状态）来过滤，而不是直接处理所有结果。

• 对比RPC的vaultTrack，CorDapp内部用ServiceHub监听完全没有网络开销，性能提升非常明显；
• 订阅一定要记得取消！如果服务销毁时不调用dispose()，会导致内存泄漏和无效订阅残留；
• 如果需要监听特定类型的状态，在trackBy<YourState>里指定泛型即可，不需要额外过滤。

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