栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

分布式TC事务TCC模式

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

分布式TC事务TCC模式

第一阶段
Try 对操作数据进行 预留、冻结 资源
第二阶段‘
Confirm 提交
Cancel 回滚

@LocalTCC
public interface OrderTccAction { 
    
    @TwoPhaseBusinessAction(name = "xOrderTccAction") //加上这个注解就是第一阶段方法,commitMeth="commit"默认
    boolean prepare(BusinessActionContext ctx,
                    @BusinessActionContextParameter(paramName = "orderId") Long orderId,
                    Long userId,
                    Long productId,
                    Integer count,
                    BigDecimal money);

    boolean commit(BusinessActionContext ctx);
    boolean rollback(BusinessActionContext ctx);
}
幂等性问题

public class ResultHolder {
    private static Map, Map> map = new ConcurrentHashMap, Map>();

    public static void setResult(Class actionClass, String xid, String v) {
        Map results = map.get(actionClass);

        if (results == null) {
            synchronized (map) {
                if (results == null) {
                    results = new ConcurrentHashMap<>();
                    map.put(actionClass, results);
                }
            }
        }

        results.put(xid, v);
    }

    public static String getResult(Class actionClass, String xid) {
        Map results = map.get(actionClass);
        if (results != null) {
            return results.get(xid);
        }

        return null;
    }

    public static void removeResult(Class actionClass, String xid) {
        Map results = map.get(actionClass);
        if (results != null) {
            results.remove(xid);
        }
    }
}
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/295032.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号