@Transactional
void a(){
  b();//插入數(shù)據(jù)a,id=101
  c(101);
}

/*
* 異步執(zhí)行
*/
@Async
void c(int id){
  // 查詢
  Obj data = query(id);
  // 調(diào)用mq 
 push(data)
}

在一個事務(wù)里面，插入數(shù)據(jù)，然后在另一個線程里查詢并推送數(shù)據(jù)。

這里query的時候，可能由于事務(wù)沒有提交，查詢不到數(shù)據(jù)的。

問題

mq異步調(diào)用失敗，如何保證數(shù)據(jù)一致性？

已知方案：調(diào)用失敗寫入數(shù)據(jù)庫，然后定時掃表，做補償，不過感覺這種效率不高。

還有其他更好的方案嗎？