老哥们，周二好。问一个跨库保证一致性的问题

[ayonel]

业务背景： 有一份数据，需要双写到两份存储（ Mysql、Neo4j ）

项目基于 springboot.我已经配置了 mysql 数据源的事务管理器，neo4j 没有配置。在不使用分布式事务的前提下，以下这种做法能否保证两份数据的一致性：

@Transactional
public void doService() {
	// 第一步，插 mysql
	insertMysql();
    // 第二步，插 neo4j
    insertNeo4j();
}

思路：

1. 如果插 mysql 出现异常，此时 mysql 事务直接回滚，neo4j 还没来得及插入。所以最终表现是：两个引擎数据都没写入，保持一致。
2. 如果插入 neo4j 出现异常，此时 mysql 事务也会回滚。而 neo4j 由于插入失败，也没有数据。所以最终表现是：两个引擎数据都没写入，保持一致。

看起来，这样简单的做法能保证一致性，老哥们能指出这种做法有啥坑吗？（ PS：假设 mysql、neo4j 都是一条操作语句）

[qiyuey]

放弃分布式事务，使用幂等重试

[ayonel]

这种做法也没有使用分布式事务。老哥看下这种 trick 做法可以保证一致性吗

[reus]

成功插入 neo4j 之后出现异常，mysql 回滚，而 neo4j 没有，不就不一致了？

[cmingxu]

感觉能完全说明白这个问题得一本厚书， 期待惊艳回答。

[iIli1iIliIllLiL]

3L+1

[ayonel]

@reus @iIli1iIliIllLiL 成功插入 neo4j 之后都没有其他逻辑了，还能发生异常吗？

[reus]

@ayonel 插入之后进程挂了呢？

[lhx2008]

@ayonel 能，网络问题，如果插完 neo4j 的瞬间拔了网线，则无法确定 neo4j 是否插入成功。

[lhx2008]

如果都在一台机器上面其实问题不大，除非进程自己挂了

[Yuicon]

在回滚的时候添加逻辑删除 neo4j 多余数据

[optional]

关键是你下面还有代码，，如果你下面的代码抛异常了呢？

[ysweics]

用 MQ 做最终一致性吧

[lhx2008]

比较简单的方法就是异步同步，先把资料持久化一份（ kafka 等），然后开一个后台程序去读，然后写到 neo4j，当然，代价是没有强一致性。不过强一致性不是那么容易搞的。

[ebony0319]

用最终一致性和事务补偿。

[ayonel]

@optional 下面可以认为没代码了

[ayonel]

@reus 这个概率太小了吧？还有其他 case 能造成数据不一致吗？

[wangyzj]

tcc

[lhx2008]

强一致一般可以用 2PC 两阶段提交，两个被调用方要保证落盘一份并能保证插入，然后再返回给调用方 2 个 OK，调用方再发提交给被调用方。如果调用方挂掉，也必须快速重启后跟上进度，否则就会卡住等人工处理。

[ayonel]

@ysweics
@lhx2008 感觉是个比较简单的业务逻辑，引入 MQ 有些大材小用。大神能指出我题目中这种写法的弊端吗？

[ayonel]

@wangyzj 不想引入分布式事务。单纯看我题中的解法会产生什么问题