0
点赞
收藏
分享

微信扫一扫

全站最硬核 百万字强肝RocketMq源码 火热更新中~(一百零四)事务消息

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;
}
举报

相关推荐

0 条评论