Channel
Function:
[//]: 1. 一个通道就是一个阻塞队列,队列大小,默认为 1000,可以通过 channel_queue_size 修改
- A channel is a blocking queue. The size of the queue is 1000 by default, which can be accessed through the channel_ queue_ Size modification ( Bifrost.ini )
[//]: 2. 一个通道,可以绑定多个数据表
- A channel can bind multiple data tables
[//]: 3. 绑定了表的数据,从 Binlog 解析出来之后,写到入 通道队列中
- The data bound to the table is parsed from binlog and written to the channel queue
[//]: 4. 一个通道 可以设置 N 个消费者,默认情况下为 1 个,如果要顺序,请设置为 1
- A channel can set n consumers. By default, it is 1. If you want to order, please set it to 1
[//]: 5. 通道队列的消费者消费数据出来之后,判断数据表配置同步到哪些目标库里去,再将数据写到 目标库的队列中去
- After the consumer consumption data of the channel queue comes out, and then write the data to the queue of the target database
manager
[//]: 1. 进入通道管理界面
- Enter the channel management interface
[//]: 2. 通道管理
- channel management
1). Online start or stop
Stop :
Online start stop online pause channel queue data consumption, consumption process does not exit, the status will be changed to stop
Close :
The consumer who completely closes the queue exits the consumer agreement. The status is changed to close
Start :
In the stop or close state, click the start button to recover the consumption queue data, and the status is changed to running
2). Online channel addition
channel_name
CosumerCount : Number of channel queue consumers, set to 1 if data requires order
3). Other field
CurrentThreadNum : How many consumers are currently running
Status : channel status