zoukankan      html  css  js  c++  java
  • 由@Transactional引发的异步消息数据不同步问题

    事件背景:由于项目使用的是spring cloud 架构,各个服务通过eureka注册,通过feign相互调用,对外暴露了一个服务给第三方公司调用,同时最终还要同步数据到另一家公司,结构如下图

     现在遇到一个问题,第三方业务回调的最新状态,我们自己修改了,到另外一家的时候状态还是之前的,由于中间穿插了4~6个服务,排查日志比较困难。

    发现问题:

      经过排查各个服务大量日志文件,发现各个关键的业务日志也正常打印了,但是到最后一步查询表1的数据有些是不正确的,经过层层排查,最终判断可能是下面这段代码导致的。这个方法是这么写的

    服务一代码:

      @Transactional

      public  xx   方法名(参数){

      //1.更新数据表1

      //2.更新数据表2

      //3.发送延时消息mq

    服务二代码:

      消费延时mq消息,然后查询数据库获取数据后同步到第三方服务,查询的数据包括数据表1、数据表2等数据

    原因猜想(由于时间问题,没来得及测试)

    @Transactional 能保保持数据回滚的一致性,应该是做了缓存的,修改完表1,再修改表2,然后发送mq,最后方法结束后才会提交修改到数据库进行修改,而mq消费时间设置过短,导致发送mq后,另一个服务很快就消费掉了,查询的数据是未更新前的,所以导致数据未更新,数据未更新就发送到数据接收方了,所以导致数据不同步。

    最终修改完延时消息的时间后问题得到解决。

    由于没有深入研究过@Transactional保持回滚的机制,可能有些想的不对,望见谅!

  • 相关阅读:
    java基础篇3---变量值转换(不使用中间变量)
    java基础篇2---逆序输出
    Java基础篇1---数据类型转换
    java基础篇8-----字符大小写字母的转换
    java基础篇7----java.util中的Scanner类的使用
    java基础篇0----运算符
    java基础篇5---循环结构
    ECMAScript arguments 对象(摘自W3C)
    JS中的this的应用总结
    定时器 + 简单的动画效果
  • 原文地址:https://www.cnblogs.com/qqq9527/p/15662251.html
Copyright © 2011-2022 走看看