我正在使用 Galera 复制和 MaxScale 读写器路由器。
我遇到一个问题,因为应用程序是按照这个流程开发的:
- 开始交易
- 更新记录
- 犯罪
- 阅读该记录
结果是使用写入服务器更新记录,下一次读取在读取服务器上完成。由于复制延迟,它无法获取刚刚更新的数据。
不幸的是,重新考虑整个应用程序有点困难,我正在寻找是否存在某种解决方案来强制在写入服务器中进行读取,这样我就可以确保获取刚刚更新的数据。
我正在使用 Galera 复制和 MaxScale 读写器路由器。
我遇到一个问题,因为应用程序是按照这个流程开发的:
结果是使用写入服务器更新记录,下一次读取在读取服务器上完成。由于复制延迟,它无法获取刚刚更新的数据。
不幸的是,重新考虑整个应用程序有点困难,我正在寻找是否存在某种解决方案来强制在写入服务器中进行读取,这样我就可以确保获取刚刚更新的数据。
编辑:
causal_reads
原始答案中建议的功能仅适用于异步 MariaDB 复制。Galera 复制
对于 Galera 复制,实现读取因果关系的最佳方法是打开
wsrep_sync_wait
。您可以打开此功能而无需修改应用程序,只需写入SET SESSION wsrep_sync_wait=1
文件,然后connection_init_sql_file
在应用程序连接到的侦听器中使用该文件即可。另一种方法是使用一致关键读取过滤器将读取操作重定向到短暂完成写入的节点。
异步复制
readwritesplit 路由器中有一个专门针对此类工作负载的功能。causal_reads =local模式就是您要找的。此模式将同步您完成的读取和之前的写入,从而为您提供类似“读取您的写入”一致性的功能,并使 MaxScale 的行为就像您正在处理单个数据库节点而不是服务器集群一样。
该
local
模式优先考虑以延迟为代价的读取吞吐量,但您可以通过配置 将其更改为以读取吞吐量为代价的延迟causal_reads=fast
。在此模式下,读取不会与写入同步,而是定向到已复制这些写入的最新服务器。虽然通常在这种模式下,写入后不久完成的读取只会路由到完成写入的原始服务器。causal_reads=global
(有利于读取吞吐量)和(有利于延迟)模式causal_reads=fast_global
将这个想法从一个会话扩展到一个 MaxScale 实例。在这些模式下,不是查看一个会话的写入,而是通过单个 readwritesplit 完成的所有写入对于通过同一 readwritesplit 实例完成的其他会话的读取都是可见的。此模式提供与模式相同的保证,local
但代价是为可能不相关的读取和写入提供更多的同步。还有
causal_reads=universal
和causal_reads=fast_universal
模式,可以将这个想法从一个 MaxScale 实例扩展到任意数量的 MaxScale 实例。这些模式还具有保证在任何 MaxScale 实例之外进行的写入可见性的功能(例如,本地完成的数据加载对于通过 MaxScale 进行的读取是可见的)。像往常一样,这种“普遍因果关系”会带来高延迟和吞吐量成本,通常应该是最后的手段。