canal来实现mysql的数据同步

canal是主要用法是基于MySQL数据库增量日志解析，供给增量数据订阅和消费，本栏目细致介绍基于canal实现mysql的数据同步。

Mysql视频教程栏目介绍基于canal实现数据同步。

基于上面的解说，我们在实现canal以前，先简略做一个主从复制。一主 一从

• 第一下载mysql 镜像,并启动

docker pull mysql:latest
docker run -itd --name mysql-1 -p 23306:3306 -e MYSQL_ROOT_PASSWORD=root  mysql
docker run -itd --name mysql-2 -p 23307:3306 -e MYSQL_ROOT_PASSWORD=root  mysql 

• 相干下令再解释一下：

name xxx :xxx为容器名 p 111:222 其中111是宿主机端口，222是容器端口 MYSQL_ROOT_PASSWORD=root 设定root账户密码为root

• 设定 mysql-1为主，mysql-2为从库
• 修改一下 mysql的配置，安装vim编纂器

apt-get update
apt-get install vim 

• 在主库 新建一个mysql账户给从库运用

CREATE USER 'slave'@'%' IDENTIFIED BY '123456';
GRANT REPLICATION SLAVE, REPLICATION CLIENT ON . TO 'slave'@'%';
FLUSH PRIVILEGES； 

• 修改一下从办事器

[mysqld]
pid-file        = /var/run/mysqld/mysqld.pid
socket          = /var/run/mysqld/mysqld.sock
datadir         = /var/lib/mysql
secure-file-priv= NULL
server_id=100
log-bin=mysql-slave-bin
relay_log=edu-mysql-relay-bin 

• 退出重新启动从办事器docker
• 进入从办事器 施行

mysql> change master to master_host='172.17.0.4', master_user='slave', master_password='123456', master_port=3306, master_log_file='edu-mysql-bin.000001', master_log_pos= 877, master_connect_retry=30; 

相干下令解释 master_port：Master的端标语，指的是容器的端标语 master_user：用于数据同步的会员 master_password：用于同步的会员的密码 master_log_file：指定 Slave 从哪个日志文件开端复制数据，即上文中提到的 File 字段的值 master_log_pos：从哪个 Position 开端读，即上文中提到的 Position 字段的值 master_connect_retry：要是连贯失败，重试的工夫隔断，单位是秒，默许是60秒 在Slave 中的mysql终端施行show slave status \\\\G;用于查看主从同步状态。

• 涌现一下信息注明配置成功

为何再 将canal 以前要先说主从复制呢，其实canal 就是把本人假装成了从办事器，从而读取日志，拿到数据；

运用docker 部署canal

参照 链接

docker pull canal/canal-server:latest
# 下载足本
wget https://raw.githubusercontent.com/阿里巴巴/canal/master/docker/run.sh 

# 构建一个destination name为test的队列， address 对应的数据库ip+端口 ，dbUsername对应数据库会员名，dbPassword对应数据库密码，注意修改为本人的
sh run.sh -e canal.auto.scan=false \\\\
-e canal.destinations=test \\\\
-e canal.instance.master.address=172.17.0.4:3306  \\\\
-e canal.instance.dbUsername=canal  \\\\
-e canal.instance.dbPassword=canal  \\\\
-e canal.instance.connectionCharset=UTF-8 \\\\
-e canal.instance.tsdb.enable=true \\\\
-e canal.instance.gtidon=false  \\\\ 

• 启动之后可以进入容器，看一下里面的 日志,要是涌现了标红的信息，注明成功，不然就查看里面的报错信息吧！也不难

• 运用组件安装，此处我有一个laravel框架，直接在laravel里面安装运用了，相干代码贴出

 # 安装组件canal-php
 composer require xingwenge/canal_php
# 编写足本监听
connect("172.17.0.5", 11111);//此处修改为本人的配置
            $client->checkValid();
            $client->subscribe("1001", "test", ".*\\\\\\\\..*");//对应启动容器时test的队列名
            while (true) {
                $message = $client->get(100);
                if ($entries = $message->getEntries()) {
                    foreach ($entries as $entry) {
                        Fmt::println($entry);
                    }
                }
                sleep(1);
            }

            $client->disConnect();
        } catch (\\\\Exception $e) {
            echo $e->getMessage(), PHP_EOL;
        }

    }

} 

• 更改数据

相干免费学习举荐：mysql视频教程

以上就是canal来实现mysql的数据同步的细致内容，更多请关注 百分百源码网 其它相干文章！