Django中实现MySQL主从同步实现读写分离【黑马python培训】

1.主从同步介绍和优点

• 在多台数据服务器中，分为主服务器和从服务器。一台主服务器对应多台从服务器。
• 主服务器只负责写入数据，从服务器只负责同步主服务器的数据，并让外部程序读取数据。
• 主服务器写入数据后，即刻将写入数据的命令发送给从服务器，从而使得主从数据同步。
• 应用程序可以随机读取某一台从服务器的数据，这样就可以分摊读取数据的压力。
• 当从服务器不能工作时，整个系统将不受影响；当主服务器不能工作时，可以方便地从从服务器选举一台来当主服务器
• 使用主从同步的优点：
  
  • 提高读写性能
    
    • 因为主从同步之后，数据写入和读取是在不同的服务器上进行的，而且可以通过增加从服务器来提高数据库的读取性能。
      
  • 提高数据安全
    
    • 因为数据已复制到从服务器，可以在从服务器上备份而不破坏主服务器相应数据。
      
    
    
  
  

2.主从同步机制

MySQL服务器之间的主从同步是基于二进制日志机制，主服务器使用二进制日志来记录数据库的变动情况，从服务器通过读取和执行该日志文件来保持和主服务器的数据一致。

提示：

• 本项目中我们搭建一主一从的主从同步。
• 主服务器：ubuntu操作系统中的MySQL。
• 从服务器：Docker容器中的MySQL。
  

1.获取MySQL镜像

• 主从同步尽量保证多台MySQL的版本相同或相近。
  

2.指定MySQL从机配置文件

• 在使用Docker安装运行MySQL从机之前，需要准备好从机的配置文件。
• 为了快速准备从机的配置文件，我们直接把主机的配置文件拷贝到从机中。
  

3.修改MySQL从机配置文件

• 编辑 ~/mysql_slave/mysql.conf.d/mysqld.cnf文件。
• 由于主从机都在同一个电脑中，所以我们选择使用不同的端口号区分主从机，从机端口号是8306。
  

4.Docker安装运行MySQL从机

• MYSQL_ROOT_PASSWORD：创建 root 用户的密码为 mysql。
  

5.测试从机是否创建成功

1.配置主机（ubuntu中MySQL）

• 配置文件如有修改，需要重启主机。
  
  • sudo service mysql restart
    
  
  

2.从机备份主机原有数据

• 在做主从同步时，如果从机需要主机上原有数据，就要先复制一份到从机。
  

3.主从同步实现

• 1.创建用于从服务器同步数据的帐号
  

• 2.展示ubuntu中MySQL主机的二进制日志信息
  

• 3.Docker中MySQL从机连接ubuntu中MySQL主机
  

测试：

在主机中新建一个数据库后，直接在从机查看是否存在。

2 Django实现MySQL读写分离1. 增加slave数据库的配置DATABASES = {    'default': { # 写（主机）        'ENGINE': 'django.db.backends.mysql', # 数据库引擎        'HOST': '192.168.103.158', # 数据库主机        'PORT': 3306, # 数据库端口        'USER': 'itcast', # 数据库用户名        'PASSWORD': '123456', # 数据库用户密码        'NAME': 'meiduo_mall' # 数据库名字    },    'slave': { # 读（从机）        'ENGINE': 'django.db.backends.mysql',        'HOST': '192.168.103.158',        'PORT': 8306,        'USER': 'root',        'PASSWORD': 'mysql',        'NAME': 'meiduo_mall'    }}2. 创建和配置数据库读写路由

1.创建数据库读写路由

• 在meiduo_mall.utils.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.配置数据库读写路由

DATABASE_ROUTERS = ['meiduo_mall.utils.db_router.MasterSlaveDBRouter']