当前位置:网站首页>Bifrost 之 文件队列(一)
Bifrost 之 文件队列(一)
2020-11-09 00:28:00 【布哦】
为了解决表同步设置并行同步,共用一个Binlog解析线程,因为某一个同步出错等原因造成的 Binlog 解析阻塞的情况.
在 Bifrost v1.2.1 版本开始 , Bifrost 新增了一个文件队列功能,在表同步出现阻塞的时候,自动启动文件队列,并不影响 Binlog 解析,也不影响其他表数据同步。
简单的说 只要所有同步都足够快的时候, 就用的纯内存队列,只要有一个同步出错了,为了保证自己出错,不影响 其他表同步,当前同步线程,就自动启用的一个文件队列.
文件队列,是在同步出现问题,跟不上Binlog解析速度的时候 ,自动启动的,不需要人为界面点击启动.当前 管理系统界面 点提供了方法 让用户点击强制启动!
文件队列配置
#是否开启文件队列功能 true|false
file_queue_usable=true
#统计是否启文件队列的时间,单位毫秒
file_queue_usable_count_time_diff=5000
#file_queue_usable_count_time_diff 时间内内存队列被挤满的次数
file_queue_usable_count=10
假如配置 file_queue_usable = false ,不管什么情况,都不会启用文件队列
默认情况下,文件队列是在 5000ms 内 内存队列连续被写满10次,自动启动,不需要人为在管理界面任何操作
文件队列,是按表的同步配置为单位启动的,也就是说,假如一个表配置了 10 个同步, 其中第一个配置同步是同步到 Redis, 在这个同步到 Redis 的同步中同步慢了,出现了内存队列阻塞的情况下,则启用一个文件队列,用于缓冲 同步到当前这个表同步到 Redis
版权声明
本文为[布哦]所创,转载请带上原文链接,感谢
https://my.oschina.net/u/4233862/blog/4708421
边栏推荐
- The vowels in the inverted string of leetcode
- Have you ever thought about why the transaction and refund have to be split into different tables
- Teacher Liang's small class
- How to analyze Android anr problems
- Concurrent linked queue: a non blocking unbounded thread safe queue
- Factory Pattern模式(简单工厂、工厂方法、抽象工厂模式)
- 接口测试工具Eolinker进行post请求
- APP 莫名崩溃,开始以为是 Header 中 name 大小写的锅,最后发现原来是容器的错!
- Introduction skills of big data software learning
- 移动大数据自有网站精准营销精准获客
猜你喜欢

Linked blocking queue based on linked list

On buffer overflow

Python应用场景多不多?

Introduction and application of swagger

接口测试工具Eolinker进行post请求

The road of cloud computing - going to sea - small goal: Hello world from. Net 5.0 on AWS

程序员都应该知道的URI,一文帮你全面了解

Database design: paradigms and anti paradigms

Tips in Android Development: requires permission android.permission write_ Settings solution

Have you ever thought about why the transaction and refund have to be split into different tables
随机推荐
How does pipedrive support quality publishing with 50 + deployments per day?
API部分的知识点复习
表连接
理论与实践相结合彻底理解CORS
分库分表的几种常见玩法及如何解决跨库查询等问题
教你如何 分析 Android ANR 问题
Copy the picture
老大问我:“建表为啥还设置个自增 id ?用流水号当主键不正好么?”
How does semaphore, a thread synchronization tool that uses an up counter, look like?
Using annotation + interceptor to implement asynchronous execution
选择API管理平台之前要考虑的5个因素
What courses will AI programming learn?
leetcode之反转字符串中的元音字母
上线1周,B.Protocal已有7000ETH资产!
Octave basic syntax
基于链表的有界阻塞队列 —— LinkedBlockingQueue
六家公司CTO讲述曾经历的“宕机噩梦”
Chapter five
写时复制集合 —— CopyOnWriteArrayList
Brief introduction of Integrated Architecture