在Corda上创建代币后，如何让发行方实时知晓各节点代币余额？

嘿，针对你提出的两个关于Corda代币余额追踪的问题，我结合Corda Token SDK的实践经验来给你详细拆解解决方案：

一、创建代币时，如何确保发行方知晓所有节点的代币余额 #

在Corda的代币体系中，状态的传播和存储完全依赖**参与者(Participants)**机制——只有被纳入状态参与者集合的节点，才会收到该状态的副本并保存在自身Vault中。要让发行方全程追踪所有节点的代币余额，核心是把发行方绑定到所有该代币的状态生命周期里：

• 将发行方纳入代币状态的参与者列表：
  在铸造（Mint）代币时，创建FungibleToken（或NonFungibleToken）实例时，把发行方的Party对象加入participants集合。后续任何代币转移、销毁操作生成的新状态，都要保留发行方作为参与者（可以通过自定义Token SDK的转移流实现自动继承）。示例代码：

  val token = FungibleToken(
      amount = Amount(1000, CustomTokenType()),
      holder = recipientParty,
      issuer = issuerParty,
      participants = listOf(recipientParty, issuerParty) // 发行方作为参与者加入
  )
  

  这样发行方节点会自动接收所有涉及该代币的交易状态副本，为后续余额查询打下基础。

• 通过发行约束强化可见性：
  定义自定义TokenType时，设置发行约束为IssuedTokenType，确保只有发行方可以签名铸造交易；同时在铸造流中把发行方设为必需签名者和观察者，从源头保证发行方能获取代币的初始状态及所有后续变更通知。

二、已创建代币后，如何让发行方随时了解各节点的代币余额 #

当发行方已经是所有该代币状态的参与者/观察者后，就可以通过以下几种方式快速查询余额：

• 直接查询本地Vault的代币状态：
  发行方节点的Vault中已经存储了所有该代币的状态副本，只需通过Vault查询API过滤并汇总即可。示例Kotlin代码：

  // 定义目标代币类型
  val targetToken = CustomTokenType()
  // 构建查询条件：过滤所有状态的该代币
  val queryCriteria = VaultQueryCriteria(Vault.StateStatus.ALL)
      .withTokenType(targetToken)
  // 查询Vault中的代币状态
  val tokenStates = serviceHub.vaultService.queryBy<FungibleToken>(queryCriteria).states
  // 按持有方分组计算余额
  val balanceMap = tokenStates.groupBy { it.state.data.holder }
      .mapValues { (_, states) -> states.sumOf { it.state.data.amount.quantity } }
  

  执行后会得到一个Map，key是持有代币的节点Party，value是对应的代币余额。

• 编写自定义查询流（可选场景）：
  如果某些特殊场景下发行方不是所有状态的参与者，可以编写一个以发行方为发起方的查询流，请求其他节点返回该代币的余额。不过这种方式需要其他节点配合实现响应流，效率远不如直接查询本地Vault。

• 设置定期自动汇总机制：
  如果需要实时监控或定期生成余额报表，可以使用Corda的ScheduledFlow编写定时任务，定期执行上述Vault查询，将结果存储到发行方节点的本地数据库，或通过邮件、内部API等方式推送相关人员。

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