RocketMQ事務
分布式事務的兩種常見實作方式：
2pc tcc
2pc
兩階段提交 遵循XA協議 、其實可以理解為”預提交“
tcc
三階段提交 try confirm cancel
RocketMQ中采用2pc 兩階段提交
RocketMQ中事務訊息流程圖
原始碼：
private GetResult getHalfMsg(MessageQueue messageQueue, long offset) {
GetResult getResult = new GetResult();
PullResult result = pullHalfMsg(messageQueue, offset, PULL_MSG_RETRY_NUMBER);
getResult.setPullResult(result);
List<MessageExt> messageExts = result.getMsgFoundList();
if (messageExts == null) {
return getResult;
}
getResult.setMsg(messageExts.get(0));
return getResult;
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/423269.html
標籤：其他