mysql主从搭建

  1. # 1 主从同步的流程或原理
  2.     1）master会将变动记录到二进制日志里面；
  3.     2）master有一个I/O线程将二进制日志发送到slave;
  4.     3) slave有一个I/O线程把master发送的二进制写入到relay日志里面；
  5.     4）slave有一个SQL线程，按照relay日志处理slave的数据；
  6. # 2 
  10. # 3 修改配置文件
  11. ####主库的配置文件，server-id和开启binlog日志
  12. [mysqld]
  13. user=mysql
  14. character-set-server=utf8
  15. default_authentication_plugin=mysql_native_password
  16. secure_file_priv=/var/lib/mysql
  17. expire_logs_days=7
  18. sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
  19. max_connections=1000
  20. server-id=100  
  21. log-bin=mysql-bin
  22. [client]
  23. default-character-set=utf8
  24. [mysql]
  25. default-character-set=utf8
  30. #############从库的配置
  31. ####主库的配置文件，server-id和开启binlog日志
  32. [mysqld]
  33. user=mysql
  34. character-set-server=utf8
  35. default_authentication_plugin=mysql_native_password
  36. secure_file_priv=/var/lib/mysql
  37. expire_logs_days=7
  38. sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
  39. max_connections=1000
  40. server-id=101 
  41. log-bin=mysql-slave-bin
  42. relay_log=edu-mysql-relay-bin
  43. [client]
  44. default-character-set=utf8
  45. [mysql]
  46. default-character-set=utf8
  48. # 4 拉起两个mysql容器
  49. #启动主库容器（挂载外部目录，端口映射成33307，密码设置为123456）
  50. 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
  51. #启动从库容器（挂载外部目录，端口映射成33306，密码设置为123456）
  52. 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
  55. #5  创建test用户，并授权
  56. #在主库创建用户并授权
  57. ##创建test用户
  58. create user 'test'@'%' identified by '123';
  59. ##授权用户
  60. grant all privileges on *.* to 'test'@'%' ;
  61. ###刷新权限
  62. flush privileges;
  63. #查看主服务器状态(显示如下图)
  64. show master status;
  65. # 可以看到日志文件的名字，和现在处在哪个位置
  68. #6 连接从库，配置连接主库
  69. #连接从库
  70. mysql -h 172.16.209.100 -P 33306 -u root -p123456
  71. #配置详解
  72. /*
  73. change master to 
  74. master_host='MySQL主服务器IP地址', 
  75. master_user='之前在MySQL主服务器上面创建的用户名'， 
  76. master_password='之前创建的密码', 
  77. master_log_file='MySQL主服务器状态中的二进制文件名', 
  78. master_log_pos='MySQL主服务器状态中的position值';
  79. */
  80. #命令如下
  81. 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;
  82. #启用从库
  83. start slave;
  84. #查看从库状态（如下图）
  85. show slave status\G;
  86. ####这两个是yes表示配成功
  87.    Slave_IO_Running: Yes
  88.    Slave_SQL_Running: Yes
  90. # 7 测试
  91. #在主库上创建数据库test1
  92. create database test1;
  93. use test1;
  94. #创建表
  95. create table tom (id int not null,name varchar(100)not null ,age tinyint);
  96. #插入数据
  97. insert tom (id,name,age) values(1,'xxx',20),(2,'yyy',7),(3,'zzz',23);

django实现读写分离

#1  在setting中配置
DATABASES = {
    # 主库
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'lqz1',
        'USER': 'root',
        'PASSWORD': '123456',
        'HOST': '101.133.225.166',
        'PORT': 33307,
    },
    # 从库
    'db1': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'lqz1',
        'USER': 'root',
        'PASSWORD': '123456',
        'HOST': '101.133.225.166',
        'PORT': 33306,
    },
}

# 2 手动指定
    ####手动来做
    # 向default库写，主库
    # res=models.Book.objects.using('default').create(name='金瓶梅',price=33.4)
    # 去从库查
    # res=models.Book.objects.using('db1').all().first()
    # print(res.name)

# 3 自动指定（写router和配置setting）
    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',]
# 4 以后只要是写操作，就会用default，只要是读操作自动去db1



分库分表
# 5 更细粒度（）
class Router1:
    def db_for_read(self, model, **hints):
        if model._meta.model_name == 'book':
            return 'db1'
        else:
            return 'default'

    def db_for_write(self, model, **hints):
        return 'default'

# 6 在数据库迁移时，可以指定把哪个app的表结构迁移到哪个库
python manage.py migrate app01 --database=default