微服务架构下,利用Sharding-jdbc解决读写分离查询延迟问题
创始人
2025-03-18 05:31:51
0

 前言

[[276966]]

当Mysql数据库数据达到一定量后,查询SQL执行会变慢起来,除了建索引、优化程序代码以及SQL语句等常规手段外,利用经典MHA数据库中间件做数据库读写分离是一个不错的选择。但是在读写分离架构中会出现一个共性问题:SQL读取延迟。

读写实时场景

比如在微服务应用端新增一条业务数据,然后立即读取,这个时候会遇到读取不到情况!

为什么呢?

利用sharding-jdbc解决Mysql读写分离查询延迟的问题

来源网络

因为在读写分离架构中,主节点负责写入数据,同时mysql利用多线程技术把数据同步到从节点,从节点负责应用端读取请求。

而Mysql主从数据同步数据存在同步时间差,带来的问题是从节点同步不到主节点(Master)数据,应用端从从节点(Slave)读取不到新增的数据情况。

解决方案

利用官方HintManager 分片键值管理器, 强制路由到主库查询

利用sharding-jdbc解决Mysql读写分离查询延迟的问题

通过调用hintManager.setMasterRouteOnly() 强制路由到主库查询,伪代码如下:

  1. public ArticleEntity getWithMasterDB(Long id, String wid) { 
  2.  HintManager hintManager = HintManager.getInstance() ; 
  3.  hintManager.setMasterRouteOnly(); 
  4.  ArticleEntity article = baseMapper.queryObject(id, wid); 

通过强制路由到主库查询有个风险,对于更新并实时查询业务场景比较多,如果都切到主库查询,势必会对主库服务器性能造成影响,可能还影响主从数据同步,所以要根据实际业务场景评估采用这种方式带来的服务器性能问题。

另外,如果业务层面可以做妥协的话,尽量减少这种更新并实时查询方式,一种思路是实时更新库,利用线程异步查询(例如更新后,睡眠1-2秒再查询),伪代码如下:

  1. public class ArticleCacheTask implements Runnable {  
  2.  @Override 
  3.  public void run() { 
  4.   
  5.  try { 
  6.  // 控制读写分离不同步设置 
  7.  Thread.sleep(2000); 
  8.  } catch (InterruptedException e) { 
  9.  e.printStackTrace(); 
  10.  } 
  11.  ArticleEntity articleEntity = articleService.getWithMasterDB(Long.valueOf(id), wid); 
  12.  } 

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...
为啥国人偏爱 Mybatis,... 关于 SQL 和 ORM 的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行...
《非诚勿扰》红人闫凤娇被曝厕所... 【51CTO.com 综合消息360安全专家提醒说,“闫凤娇”、“非诚勿扰”已经被黑客盯上成为了“木...
2012年第四季度互联网状况报... [[71653]]  北京时间4月25日消息,据国外媒体报道,全球知名的云平台公司Akamai Te...