jmeter登录返回数据给下一个接口_mysql读写分离实现

jmeter登录返回数据给下一个接口_mysql读写分离实现问题描述场景是这样的,我们的支付系统在一笔支付完成后,需要发出通知给到商户。支付完成的消息通过消息队列发送给通知的服务。通知服务的有一部分处理逻辑是这样的:notifyPersist.saveNotifyRecord(notifyRecord);notifyRecord=rpNotifyService.getNotifyByMerchant…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

问题描述

场景是这样的,我们的支付系统在一笔支付完成后,需要发出通知给到商户。支付完成的消息通过消息队列发送给通知的服务。通知服务的有一部分处理逻辑是这样的:

            notifyPersist.saveNotifyRecord(notifyRecord);
            notifyRecord = rpNotifyService.getNotifyByMerchantNoAndMerchantOrderNoAndNotifyType(notifyRecord.getMerchantNo(), notifyRecord.getMerchantOrderNo(), notifyRecord.getNotifyType());
            notifyQueue.addElementToList(notifyRecord);

三行代码。我解释下,通知服务收到消息解析成 notifyRecord 对象,然后存入数据库,然后马上取出添加到任务队列。另外又一个独立的线程去处理这个任务队列。

项目上线后,客户反馈偶尔会出现收不到通知的情况。

问题排查

经过日志跟踪,我发现是在上述代码的第二行,查询记录的时候数据库返回null,也就是没有查询到记录。导致任务队列没有该笔支付的通知任务。

一开始觉得非常不解,因为通过日志我们发现第一行代码是执行成功的,既然插入成功了,没理由查询不到啊??而且我去数据库看确定是有这条记录的。莫非是见鬼了!!

我先说下

慢慢静下心来思考,结合这个现象是偶发性的,我想到有没有可能是因为读写分离延时造成的。我先说下我们的存储架构:

centos 6.5 64位操作系统。mycat1.6版本,mysql 5.6.21

数据库服务器有两台,一台主,一台从,利用mycat配置了主从复制和读写分离。写操作在主机上,读操作在从机上。如下图所示:

在这里插入图片描述

有没有可能是主库上插入成功后,从库还没有来得急同步完成,应用就马上查询,所以查不到。为了验证我的想法,我把代码改成下面这样发布到生产先看看效果:

notifyPersist.saveNotifyRecord(notifyRecord);
Thread.sleep(300);
notifyRecord = rpNotifyService.getNotifyByMerchantNoAndMerchantOrderNoAndNotifyType(notifyRecord.getMerchantNo(), notifyRecord.getMerchantOrderNo(), notifyRecord.getNotifyType());
notifyQueue.addElementToList(notifyRecord);

思路也很简单粗暴,就是插入之后不马上读,而是等一会让从库同步完再读。发布后,跑了一个段时间,没有反馈异常。证明我怀疑的没错,问题确实出现在mycat读写分离延时上。

解决方案

当然,上面定位问题的sleep也勉强算是一个解决方案。只不过感觉比较low,原理很好理解。在插入数据和查询数据中间加一个sleep()方法,相当于等一会再读。如果应用对时效要求不高,
此方法也不失唯一种快速有效的方案。

找到了问题的根源我就去mycat的官网和相关论坛寻找解决方案。

功夫不负有心人,后来我查到相关资料,mycat可以通过注解的方式指定某些 sql 语句强制走主库,如下所示:

<select id="listBy" parameterType="java.util.Map" resultMap="BaseResultMap">
    /**mycat:db_type=master*/select * from rp_notify_record
    <where>
      <include refid="condition_sql" />
    </where>
    <![CDATA[ order by create_time desc]]>
  </select>

注意到 /** */里面的注解,通过指定 db_type=master 保证后面的 sql 语句走主库。这样就不存在延时导致查询不到的问题了。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/182491.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • linux防火墙端口设置_centos怎么关闭防火墙端口

    linux防火墙端口设置_centos怎么关闭防火墙端口Ubuntu18:测试:默认拒绝全部端口提示:端口修改后立即生效sudoufwstatus#查看端口状态sudoufwdisable#关闭防火墙sudoufwenable#打开防火墙sudoufwallow3306#允许tcp/udp访问端口sudoufwdeny3306#禁止端口或服务访问sudoufwdeleteallow3306#删除规则(或deny3306)CentOS7:测试:默认接收全部端口提示:端口修改后要重启防

  • mysql 各个版本驱动jar包

    mysql 各个版本驱动jar包http://central.maven.org/maven2/mysql/mysql-connector-java/

  • js对象和jquery对象的区别

    js对象和jquery对象的区别

    2021年10月18日
  • 切蛋糕(贪心 or 优先队列)

    切蛋糕(贪心 or 优先队列)

  • Android获取屏幕分辨率及DisplayMetrics简介[通俗易懂]

    Android 可设置为随着窗口大小调整缩放比例,但即便如此,手机程序设计人员还是必须知道手机屏幕的边界,以避免缩放造成的布局变形问题。手机的分辨率信息是手机的一项重要信息,很好的是,Android 已经提供DisplayMetircs 类可以很方便的获取分辨率。下面简要介绍 DisplayMetics 类:Andorid.util 包下的DisplayMetrics 类

  • 想入行3D游戏建模,看我这个你还敢想吗?

    想入行3D游戏建模,看我这个你还敢想吗?所有行业都是一样的,没有什么容易的,只不过这一行是偏向于技术的,一个有好的建模师月薪10k+是很常见的,这个需要有自己刻苦学习的成果。游戏建模前景在游戏模型行业,你基本不用担心找不到工作,因为游戏模型师人才缺口非常大。举个例子:游戏制作公司的人员配比大多数是这样的:比如100人的三维制作组,可能有60人在做模型贴图,10个人在K动画。只要你保证技能在手,一定是抢手的人才。在几年前游戏建模这个行业不仅仅缺人才,甚至连新手都非常稀缺,那个时候公司愿意招聘实习生,培养他们然后给公司干活,但是工资一定不会给开的很

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号