目录

一、主从同步

二、Django实现MySQL读写分离

一、主从同步

分别在两台centos 7系统上安装mysql 5.7 

本文示例的两台服务器分别为

主服务器：192.168.2.111

从服务器：192.168.2.112

1. 分别在这两个服务器上创建 wangye_mall 数据库

关于新建数据库：

 ​​​​​​​Python项目实战 1.3：项目准备.工程创建和配置_mengnf的专栏-CSDN博客

 

 

2. 主服务器配置（192.168.2.111）

先 su 进行root登录，不然等下没权限编辑

先 locate my.cnf 找到配置文件

然后编辑my.cnf

vim /etc/my.cnf

在后面粘贴： 

server-id=1
log_bin=master-bin
log_bin_index=master-bin.index
binlog_do_db=wangye_mall

server-id：服务器唯一标识
binlog_do_db：需要复制的数据库名，如果复制多个数据库，重复设置这个选项即可。

然后重启mysql：

systemctl restart mysqld

重新登录：

mysql -uroot -p

创建从数据库的wangyedev用户和权限

grant replication slave on *.* to wangyedev@&＃39;192.168.2.%&＃39; identified by &＃39;123456&＃39;;

PS：192.168.2.%：表示0-255的IP都可访问主服务器

 如果报错：ERROR 1819 (HY000): Your password does not satisfy the current policy requirements 

则需要设置一下密码策略：

设置密码验证强度等级为低级

set global validate_password_policy=LOW; 

设置密码验证长度为6

set global validate_password_length=6;

拓展：

退出并重启mysql：

exit;

systemctl restart mysqld

登陆后 systemctl restart mysqld;查看

3. slave从服务器的配置 

配置文件 my.cnf 的修改

server-id=2
relay-log=slave-relay-bin
relay-log-index=slave-relay-bin.index
replicate-do-db=wangye_mall

重启 mysql 并登录后：

连接master主服务器

change master to master_host=&＃39;192.168.2.111&＃39;,master_port=3306,master_user=&＃39;wangyedev&＃39;,master_password=&＃39;123456&＃39;,master_log_file=&＃39;master-bin.000001&＃39;,master_log_pos=154;

启动slave数据同步（如有需要停止slave命令为 stop slave; ）

start slave;

查看slave信息

show slave status\G;

Slave_IO_Running和Slave_SQL_Running都为yes，则表示同步成功。

 

如果有报错

执行 rm -rf /var/lib/mysql/auto.cnf 后重启mysql 

Last_IO_Error: Fatal error: The slave I/O thread stops because master and slave have equal MySQL ser_mengnf的专栏-CSDN博客

测试

在 主服务器中添加表或者数据，然后在从服务器中查看

二、Django实现MySQL读写分离

1. 配置文件 dev.py

DATABASES = {# 写（主机）&＃39;default&＃39;: {&＃39;ENGINE&＃39;: &＃39;django.db.backends.mysql&＃39;, # 数据库引擎&＃39;HOST&＃39;: &＃39;192.168.2.111&＃39;, # 数据库主机&＃39;PORT&＃39;: 3306, # 数据库端口&＃39;USER&＃39;: &＃39;wangyedev&＃39;, # 数据库用户名&＃39;PASSWORD&＃39;: &＃39;123456&＃39;, # 数据库用户密码&＃39;NAME&＃39;: &＃39;wangye_mall&＃39; # 数据库名字},# 读（从机）&＃39;slave&＃39;: {&＃39;ENGINE&＃39;: &＃39;django.db.backends.mysql&＃39;,&＃39;HOST&＃39;: &＃39;192.168.2.112&＃39;,&＃39;PORT&＃39;: 3306,&＃39;USER&＃39;: &＃39;wangyedev&＃39;,&＃39;PASSWORD&＃39;: &＃39;123456&＃39;,&＃39;NAME&＃39;: &＃39;wangye_mall&＃39;}
}

 2. 创建和配置数据库读写路由

1. 创建数据库读写路由

新建 utils.db_router.py

 db_router.py：

class MasterSlaveDBRouter(object):"""数据库读写路由"""def db_for_read(self, model, **hints):"""读"""return "slave"def db_for_write(self, model, **hints):"""写"""return "default"def allow_relation(self, obj1, obj2, **hints):"""是否运行关联操作"""return True


2. 配置数据库读写路由（配置文件 dev.py）

DATABASE_ROUTERS = [&＃39;wangye_mall.utils.db_router.MasterSlaveDBRouter&＃39;]