zoukankan      html  css  js  c++  java
  • MySQL主从同步(基于docker)

    .

    主从配置原理

    mysql主从配置的流程大体如图:

    1)master会将变动记录到二进制日志里面;

    2)master有一个I/O线程将二进制日志发送到slave;

    3) slave有一个I/O线程把master发送的二进制写入到relay日志里面;

    4)slave有一个SQL线程,按照relay日志处理slave的数据;

    操作步骤

    2.1我们准备两台装好mysql的服务器(我在此用docker模拟了两台机器)

     用docker拉起两个mysql容器,步骤如下(对docker不熟悉的同学可以查看docker快速入门章节):

    # 拉取mysql5.7镜像
    docker pull mysql:5.7
    #在home目录下创建mysql文件夹,下面创建data和conf.d文件夹
    mkdir /home/mysql
    mkdir /home/mysql/conf.d
    mkdir /home/mysql/data/
     
    创建my.cnf配置文件
    touch /home/mysql/my.cnf
    
    my.cnf添加如下内容:
    [mysqld]
    user=mysql
    character-set-server=utf8
    default_authentication_plugin=mysql_native_password
    secure_file_priv=/var/lib/mysql
    expire_logs_days=7
    sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
    max_connections=1000
    ##主库----start--- 同一局域网内注意要唯一
    server-id=100  
    ## 开启二进制日志功能,可以随便取(关键)
    log-bin=mysql-bin
    ##主库----end--- 
    [client]
    default-character-set=utf8
    
    [mysql]
    default-character-set=utf8
    
    
    
    ##从库----start--- 
    # 拉取mysql5.7镜像
    docker pull mysql:5.7
    #在home目录下创建mysql文件夹,下面创建data和conf.d文件夹
    mkdir /home/mysql2
    mkdir /home/mysql2/conf.d
    mkdir /home/mysql2/data/
     
    创建my.cnf配置文件
    touch /home/mysql2/my.cnf
    
    my.cnf添加如下内容:
    [mysqld]
    user=mysql
    character-set-server=utf8
    default_authentication_plugin=mysql_native_password
    secure_file_priv=/var/lib/mysql
    expire_logs_days=7
    sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
    max_connections=1000
    ## 设置server_id,注意要唯一
    server-id=101  
    ## 开启二进制日志功能,以备Slave作为其它Slave的Master时使用
    log-bin=mysql-slave-bin   
    ## relay_log配置中继日志
    relay_log=edu-mysql-relay-bin 
    ##从库----end--- 
    
    [client]
    default-character-set=utf8
    
    [mysql]
    default-character-set=utf8
    
    
    
    #启动主库容器(挂载外部目录,端口映射成33307,密码设置为123456)
    docker run  -di -v /home/mysql/data/:/var/lib/mysql -v /home/mysql/conf.d:/etc/mysql/conf.d -v /home/mysql/my.cnf:/etc/mysql/my.cnf -p 33307:3306 --name mysql-master -e MYSQL_ROOT_PASSWORD=123456 mysql:5.7
    #启动从库容器(挂载外部目录,端口映射成33306,密码设置为123456)
    docker run  -di -v /home/mysql2/data/:/var/lib/mysql -v /home/mysql2/conf.d:/etc/mysql/conf.d -v /home/mysql2/my.cnf:/etc/mysql/my.cnf -p 33306:3306 --name mysql-slave -e MYSQL_ROOT_PASSWORD=123456 mysql:5.7

    2.2 远程连接入主库和从库

    #连接主库
    mysql -h 172.16.209.100 -P 33307 -u root -p123456
    #在主库创建用户并授权
    ##创建test用户
    create user 'test'@'%' identified by '123';
    ##授权用户
    grant all privileges on *.* to 'test'@'%' ;
    ###刷新权限
    flush privileges;
    #查看主服务器状态(显示如下图)
    show master status; 

    #连接从库
    mysql -h 172.16.209.100 -P 33306 -u root -p123456
    
    #配置详解
    /*
    change master to 
    master_host='MySQL主服务器IP地址', 
    master_user='之前在MySQL主服务器上面创建的用户名', 
    master_password='之前创建的密码', 
    master_log_file='MySQL主服务器状态中的二进制文件名', 
    master_log_pos='MySQL主服务器状态中的position值';
    */
    
    #命令如下
    change master to master_host='101.133.225.166',master_port=33307,master_user='test',master_password='123',master_log_file='mysql-bin.000003',master_log_pos=0;
    #启用从库
    start slave;
    #查看从库状态(如下图)
    show slave statusG;

     2.3 测试主从同步

    #在主库上创建数据库test1
    create database test1;
    use test1;
    #创建表
    create table tom (id int not null,name varchar(100)not null ,age tinyint);
    #插入数据
    insert tom (id,name,age) values(1,'xxx',20),(2,'yyy',7),(3,'zzz',23);
    #在从库上查看是否同步成功
    #查看数据库
    show database;
    use test1;
    #查看表
    show tables;
    #查看数据
    select * from test1;

    django实现读写分离

    # 执行两条数据库迁移命令
    makemigrations
    migrate app01 --databse="db1"  # 把刚刚的表同步到db1数据库中
    
    
    # 手动操作(queryset对象)
    ret=Book.objects.all().using("db1") 默认是从default数据库中查,设置成从db1数据库中查
    
    # 自动做(通过配置,程序,读去从库读,写去主库写)
    # 写一个router
    在项目路径下创建db_router.py
    在里面写一个类
    class Router1:
            def db_for_read(self, model, **hints):
                    return 'db1'
    
            def db_for_write(self, model, **hints):
                    return 'default'
          
    #在setting中配置
    DATABASE_ROUTERS = ['项目.db_router.Router1',]
    # 只要是写的操作,都到default上,只要是读的操作,都到db1上了
  • 相关阅读:
    Webforms与MVC的区别
    简易留言薄系统ASP.NET MVC(Model层)
    DataBase First 方法
    ASP.NET MVC 与 数据库交互
    简易留言薄系统ASP.NET MVC(Controller层)(上)
    简易留言簿系统ASP.NET MVC (后台基本完成)
    简易留言簿系统ASP.NET MVC (数据库设计)
    简易留言簿系统ASP.NET MVC(页面文档)
    互动媒体学习社区ASP.NET MVC 开发文档
    简易留言簿系统ASP.NET MVC(文档)
  • 原文地址:https://www.cnblogs.com/fjn839199790/p/12057537.html
Copyright © 2011-2022 走看看