请问下这里的BarrierID是做什么用的呢？

[lanlanlanlanlanchengzhu]

[yedf2]

dtm可以支持一个服务访问多个数据源，只需要吧每个数据源的访问放在一个barrier.Call里面即可

这个barrierId就是为了给每个Call分配一个新的id，避免唯一键冲突

[cometwk]

这里 originAffected 的 insert 语句， 这样处理，更合适???

if ti.BranchType == BranchCancel || ti.BranchType == BranchCompensate {
  // 放在这里,  更合适???
  originAffected, _ := insertBarrier(tx, ti.TransType, ti.Gid, ti.BranchID, originType, bid, ti.BranchType)
  if  originAffected > 0 {
    return
  }
}

[yedf2]

如果收到重复的cancel，那么你的这种处理不够完善

这里 originAffected 的 insert 语句， 这样处理，更合适???

if ti.BranchType == BranchCancel || ti.BranchType == BranchCompensate {
  // 放在这里,  更合适???
  originAffected, _ := insertBarrier(tx, ti.TransType, ti.Gid, ti.BranchID, originType, bid, ti.BranchType)
  if  originAffected > 0 {
    return
  }
}