300字范文 > MySQL搭建主从复制读写分离分库分表 MyCat高可用

MySQL搭建主从复制读写分离分库分表 MyCat高可用

时间：2019-07-08 10:29:13

主从演示

读写演示

分表演示

主从复制

环境的介绍

系统环境:centos7.0客户端连接工具:xshell远程文件传输工具:xftp服务器:192.168.126.138(主) 192.168.126.139(从)

基于rpm实现MySQL的安装

#查看有没有安装MySQLrpm -qa | grep -i mysql#卸载rpm -e --nodeps mysql-community-client-5.7.28-1.el7.x86_64#查找find / -name mysql#删除存在的MySQL文件rm -rf /etc/selinux/targeted/active/modules/100/mysql /usr/lib64/mysql /usr/share/mysql#安装serverrpm -ivh mysql-community-server-5.7.28-1.el7.x86_64.rpm --force --nodeps#安装客户端rpm -ivh mysql-community-client-5.7.28-1.el7.x86_64.rpm --force --nodeps

登录MySQL

[root@localhost home]# mysql -u root -pEnter password: ERROR 2002 (HY000): Can't connect to local MySQL server through socket '/var/lib/mysql/mysql.sock' (2)#出现错误(因为密码不正确)#实现免密登录#修改配置文件vi /etc/f#在MySQLd的下面加上跳过授权skip-grant-tables#重启MySQL的服务service mysqld restart#继续登录mysql -u root -pEnter password:(这个地方不用输入任何东西直接回车)#其实免密登录时不安全的,所以进来之后一定要设置密码#刷新系统权限表flush PRIVILEGES;#重新设置密码#alter user 'root'@'localhost' identified by '123456';SET PASSWORD FOR 'root'@'localhost' = PASSWORD('123456');#刷新系统权限表flush PRIVILEGES;#记得添加一个数据库mysql> create database youruike;Query OK, 1 row affected (0.00 sec)mysql> show databases;+--------------------+| Database |+--------------------+| information_schema || youruike|| mysql || performance_schema || sys|+--------------------+5 rows in set (0.00 sec)#退出MySQLmysql> exit;

实现MySQL的主从复制

#先配置主服务器#修改配置文件粘贴在放在[mysqld]下面的vi /etc/f#添加以下的内容#日志文件的名字log_bin=master-a-bin#日志文件的格式binlog-format=ROW#服务器的id(zk的集群),一定要是唯一的server-id=1#对应需要实现主从复制的数据库binlog_do_db=youruike#添加完之后需要登录主服务器给从服务器授权就是允许从服务器读取主服务器数据库grant replication slave on *.* to 'root'@'192.168.126.%' identified by '123456';#刷新系统权限表flush PRIVILEGES;

从服务器的配置

#修改配置文件vi /etc/f#添加以下的内容#日志文件的名字log_bin=master-a-bin#日志文件的格式binlog-format=ROW#服务器的id(zk的集群),一定要是唯一的server-id=2#双主互相备份(表示从服务器可能是另外一台服务器的主服务器)#log-slave-updates=true

设置并验证主从复制

#重启主服务器和从服务器service mysqld restart#登录主服务器mysql -u root -p#查看主服务器的状态mysql> show master status;+---------------------+----------+--------------+------------------+-------------------+| File| Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |+---------------------+----------+--------------+------------------+-------------------+| master-a-bin.000001 |154 | youruike| | |+---------------------+----------+--------------+------------------+-------------------+1 row in set (0.01 sec)#解释对应的一些名词#File 生成的日志文件名#Position 文件名所处的一个位置(偏移量)#Binlog_Do_DB需要实现主从复制的数据库#启动服务 systemctl mysqld restart#登录从服务器#设置从服务器如何找到主服务器#设置主从复制的日志和偏移量change master to master_host='192.168.126.165',master_port=3306,master_user='root',master_password='123456',master_log_file='master-a-bin.000001',master_log_pos=154;#启动slave的数据同步start slave;#停止slave的数据同步stop slave;#查看salve的配置信息show slave status\G;#这边还正在连接中mysql> show slave status\G;*************************** 1. row ***************************Slave_IO_State: Connecting to masterMaster_Host: 192.168.126.138Master_User: rootMaster_Port: 3306Connect_Retry: 60Master_Log_File: master-a-bin.000001Read_Master_Log_Pos: 154Relay_Log_File: localhost-relay-bin.000001Relay_Log_Pos: 4Relay_Master_Log_File: master-a-bin.000001Slave_IO_Running: ConnectingSlave_SQL_Running: YesReplicate_Do_DB: Replicate_Ignore_DB: Replicate_Do_Table: Replicate_Ignore_Table: Replicate_Wild_Do_Table: Replicate_Wild_Ignore_Table: Last_Errno: 0Last_Error: Skip_Counter: 0Exec_Master_Log_Pos: 154Relay_Log_Space: 154Until_Condition: NoneUntil_Log_File: Until_Log_Pos: 0Master_SSL_Allowed: NoMaster_SSL_CA_File: Master_SSL_CA_Path: Master_SSL_Cert: Master_SSL_Cipher: Master_SSL_Key: Seconds_Behind_Master: NULLMaster_SSL_Verify_Server_Cert: NoLast_IO_Errno: Last_IO_Error: error connecting to master 'root@192.168.126.138:3306' - retry-time: 60 retries: 1Last_SQL_Errno: 0Last_SQL_Error: Replicate_Ignore_Server_Ids: Master_Server_Id: 0Master_UUID: Master_Info_File: /var/lib/mysql/master.infoSQL_Delay: 0SQL_Remaining_Delay: NULLSlave_SQL_Running_State: Slave has read all relay log; waiting for more updatesMaster_Retry_Count: 86400Master_Bind: Last_IO_Error_Timestamp: 191119 20:48:42Last_SQL_Error_Timestamp: Master_SSL_Crl: Master_SSL_Crlpath: Retrieved_Gtid_Set: Executed_Gtid_Set: Auto_Position: 0Replicate_Rewrite_DB: Channel_Name: Master_TLS_Version: 1 row in set (0.00 sec)ERROR: No query specified#需要解决正在连接中的问题#使用navicat客户端进行连接,发现连接不上#1.防火墙的问题 2.端口未开放 3.未授权#可以开放端口3306firewall-cmd --zone=public --add-port=3306/tcp --permanent#重新加载防火墙firewall-cmd --reload#还是没有将权限授予客户端#with grant option 不仅仅是授予增删改查的权限,还授予权限的权限grant all privileges on *.* to root@'%' identified by '123456' with grant option;#授权报错mysql> grant all privileges on *.* to root@'%' identified by '123456' with grant option;ERROR 1819 (HY000): Unknown error 1819mysql> select @@validate_password_policy;+----------------------------+| @@validate_password_policy |+----------------------------+| MEDIUM |+----------------------------+1 row in set (0.00 sec)mysql> SHOW VARIABLES LIKE 'validate_password%';+--------------------------------------+--------+| Variable_name | Value |+--------------------------------------+--------+| validate_password_check_user_name | OFF || validate_password_dictionary_file | || validate_password_length | 8|| validate_password_mixed_case_count | 1|| validate_password_number_count | 1|| validate_password_policy | MEDIUM || validate_password_special_char_count | 1|+--------------------------------------+--------+7 rows in set (0.00 sec)mysql> set global validate_password_policy=0;Query OK, 0 rows affected (0.00 sec)mysql> set global validate_password_mixed_case_count=0;Query OK, 0 rows affected (0.00 sec)mysql> set global validate_password_number_count=3;Query OK, 0 rows affected (0.00 sec)mysql> set global validate_password_special_char_count=0;Query OK, 0 rows affected (0.00 sec)mysql> set global validate_password_length=3;Query OK, 0 rows affected (0.00 sec)mysql> SHOW VARIABLES LIKE 'validate_password%';+--------------------------------------+-------+| Variable_name | Value |+--------------------------------------+-------+| validate_password_check_user_name | OFF || validate_password_dictionary_file | || validate_password_length | 3|| validate_password_mixed_case_count | 0|| validate_password_number_count | 3|| validate_password_policy | LOW || validate_password_special_char_count | 0|+--------------------------------------+-------+7 rows in set (0.00 sec)mysql> SET PASSWORD FOR 'root'@'localhost' = PASSWORD('123456');Query OK, 0 rows affected (0.00 sec)mysql> flush privileges;Query OK, 0 rows affected (0.01 sec)mysql> grant all privileges on *.* to root@'%' identified by '123456' with grant option;Query OK, 0 rows affected, 1 warning (0.01 sec)mysql> flush privileges;Query OK, 0 rows affected (0.00 sec)#重启从服务器并且查看状态#表示成功Slave_IO_Running: Yes Slave_SQL_Running: Yesmysql> stop slave;Query OK, 0 rows affected (0.00 sec)mysql> start slave;Query OK, 0 rows affected (0.01 sec)mysql> show slave status\G;*************************** 1. row ***************************Slave_IO_State: Waiting for master to send eventMaster_Host: 192.168.126.138Master_User: rootMaster_Port: 3306Connect_Retry: 60Master_Log_File: master-a-bin.000001Read_Master_Log_Pos: 1000Relay_Log_File: localhost-relay-bin.000003Relay_Log_Pos: 323Relay_Master_Log_File: master-a-bin.000001Slave_IO_Running: YesSlave_SQL_Running: YesReplicate_Do_DB: Replicate_Ignore_DB: Replicate_Do_Table: Replicate_Ignore_Table: Replicate_Wild_Do_Table: Replicate_Wild_Ignore_Table: Last_Errno: 0Last_Error: Skip_Counter: 0Exec_Master_Log_Pos: 1000Relay_Log_Space: 1549Until_Condition: NoneUntil_Log_File: Until_Log_Pos: 0Master_SSL_Allowed: NoMaster_SSL_CA_File: Master_SSL_CA_Path: Master_SSL_Cert: Master_SSL_Cipher: Master_SSL_Key: Seconds_Behind_Master: 0Master_SSL_Verify_Server_Cert: NoLast_IO_Errno: 0Last_IO_Error: Last_SQL_Errno: 0Last_SQL_Error: Replicate_Ignore_Server_Ids: Master_Server_Id: 1Master_UUID: 0f900ff3-0ac6-11ea-aac7-000c299a89e6Master_Info_File: /var/lib/mysql/master.infoSQL_Delay: 0SQL_Remaining_Delay: NULLSlave_SQL_Running_State: Slave has read all relay log; waiting for more updatesMaster_Retry_Count: 86400Master_Bind: Last_IO_Error_Timestamp: Last_SQL_Error_Timestamp: Master_SSL_Crl: Master_SSL_Crlpath: Retrieved_Gtid_Set: Executed_Gtid_Set: Auto_Position: 0Replicate_Rewrite_DB: Channel_Name: Master_TLS_Version: 1 row in set (0.00 sec)ERROR: No query specified

测试是否成功

mysql> show databases;+--------------------+| Database |+--------------------+| information_schema || youruike|| mysql || performance_schema || sys|+--------------------+5 rows in set (0.00 sec)mysql> use youruike;Database changedmysql> show tables;Empty set (0.00 sec)mysql> create table user(id int primary key auto_increment,name varchar(20) not null)charset='utf8';Query OK, 0 rows affected (0.12 sec)mysql> show tables;+---------------+| Tables_in_youruike |+---------------+| user|+---------------+1 row in set (0.00 sec)mysql> insert into user values(null,'a');Query OK, 1 row affected (0.01 sec)mysql> select * from user;+----+------+| id | name |+----+------+| 1 | a |+----+------+1 row in set (0.00 sec)mysql> insert into user values(null,'b');Query OK, 1 row affected (0.01 sec)mysql> insert into user values(null,'c');Query OK, 1 row affected (0.00 sec)mysql> delete from user where id = 3;Query OK, 1 row affected (0.00 sec)mysql> select * from user;+----+------+| id | name |+----+------+| 1 | a || 2 | b |+----+------+2 rows in set (0.00 sec)

读写分离

要想实现读写分离,一定要是基于主从复制而实现的

系统环境

系统环境:centos7.0mycat的版本:1.6MySQL主机:192.168.126.143(mycat也使用这台主机)MySQL从机:192.168.126.148mycat的下载地址:http://dl.mycat.io/1.6-RELEASE/Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz

安装mycat

#查询有没有安装mycatfind / -name mycat#因为mycat是基于java语言编写的,所以一定要配置jdk的环境#解压jdktar -zxvf jdk-8u221-linux-x64.tar.gz#配置环境变量[root@localhost home]# lsange jdk1.8.0_221 jdk-8u221-linux-x64.tar.gz[root@localhost home]# mv jdk1.8.0_221/ jdk8[root@localhost home]# mv jdk8 /usr/[root@localhost home]# lsange jdk-8u221-linux-x64.tar.gz[root@localhost home]# cd /usr/[root@localhost usr]# lsbin etc games include jdk8 lib lib64 libexec local sbin share src tmp[root@localhost usr]# vi /etc/profile#加到最末尾JAVA_HOME=/usr/jdk8CLASSPATH=%JAVA_HOME%/lib:%JAVA_HOME%/jre/libPATH=$PATH:$JAVA_HOME/bin:$JAVA_HOME/jre/binexport PATH CLASSPATH JAVA_HOME[root@localhost usr]# source /etc/profile[root@localhost usr]# java -versionjava version "1.8.0_221"Java(TM) SE Runtime Environment (build 1.8.0_221-b11)Java HotSpot(TM) 64-Bit Server VM (build 25.221-b11, mixed mode)[root@localhost usr]# #安装mycat#报错[root@localhost usr]# wget http://dl.mycat.io/1.6-RELEASE/Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz-bash: wget: 未找到命令#安装wgetyum install wget#继续执行下载命令wget http://dl.mycat.io/1.6-RELEASE/Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz#加压下载好的压缩文件tar -zxvf Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz#mycat的目录结构-lib jar包存放的目录-conf-schema.xml-server.xml-rule.xml-log4j2.xml-logs-mycat.log-wrapper.log-bin-mycat.shlib jar包schema.xml主配置文件server.xml服务配置文件rule.xml分片的配置文件log.xml日志配置文件mycat.log启动日志文件wrapper.log运行配置日志文件mycat.sh启动的命令

配置mycat

先配置server.xml

<user name="root"><property name="password">123456</property><property name="schemas">TESTDB</property></user><user name="user"><property name="password">123456</property><property name="schemas">TESTDB</property><property name="readOnly">true</property></user>

schema.xml

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1"></schema><dataNode name="dn1" dataHost="localhost1" database="youruike" /><dataHost name="localhost1" maxCon="1000" minCon="10" balance="3"writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="hostM1" url="127.0.0.1:3306" user="root"password="123456"><readHost host="hostS2" url="192.168.126.148:3306" user="root" password="123456" /></writeHost></dataHost></mycat:schema>

启动mycat

[root@localhost bin]# ./mycat start consoleStarting Mycat-server...[root@localhost bin]# ./mycat status consoleMycat-server is running (11067).[root@localhost bin]# netstat -ntlp-bash: netstat: 未找到命令[root@localhost bin]# yum -y install net-tools[root@localhost bin]# netstat -ntlpActive Internet connections (only servers)Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name tcp 00 127.0.0.1:32000 0.0.0.0:*LISTEN11069/javatcp 00 0.0.0.0:22 0.0.0.0:*LISTEN1030/sshd tcp 00 127.0.0.1:25 0.0.0.0:*LISTEN1188/master tcp6 00 :::1984 :::*LISTEN11069/javatcp6 00 :::8066 :::*LISTEN11069/javatcp6 00 :::9066 :::*LISTEN11069/javatcp6 00 :::3306 :::*LISTEN1742/mysqld tcp6 00 :::39666:::*LISTEN11069/javatcp6 00 :::22 :::*LISTEN1030/sshd tcp6 00 :::41304:::*LISTEN11069/javatcp6 00 ::1:25 :::*LISTEN1188/master

登录mycat查看配置内容

#登录mycat的管理端口mysql -uroot -p123456 -h127.0.0.1 -P9066#查看帮助手册show @@help;#查看读写分离情况show @@datasource;#查看心跳检测show @@heartbeat;RS_CODE 状态:OK_STATUS = 1;正常状态ERROR_STATUS = -1; 连接出错TIMEOUT_STATUS = -2; 连接超时INIT_STATUS = 0; 初始化状态#连接数据端口(登录mycat的主机，mycat在192.168.126.161)mysql -uroot -p123456 -h127.0.0.1 -P8066

测试读写分离情况

#修改日志打印情况<Loggers><asyncRoot level="debug" includeLocation="true"><AppenderRef ref="Console" /><AppenderRef ref="RollingFile"/></asyncRoot></Loggers>#查看日志情况tail -f wrapper.log

分库分表

为什么要分库分表（设计高并发系统的时候，数据库层面该如何设计）？用过哪些分库分表中间件？不同的分库分表中间件都有什么优点和缺点？你们具体是如何对数据库如何进行垂直拆分或水平拆分的？

为什么要分库分表？（设计高并发系统的时候，数据库层面该如何设计？）

说白了，分库分表是两回事儿，大家可别搞混了，可能是光分库不分表，也可能是光分表不分库，都有可能。给大家抛出来一个场景。

假如我们现在是一个小创业公司（或者是一个 BAT 公司刚兴起的一个新部门），现在注册用户就 20 万，每天活跃用户就 1 万，每天单表数据量就 1000，然后高峰期每秒钟并发请求最多就 10。天，就这种系统，随便找一个有几年工作经验的，然后带几个刚培训出来的，随便干干都可以。

结果没想到我们运气居然这么好，碰上个 CEO 带着我们走上了康庄大道，业务发展迅猛，过了几个月，注册用户数达到了 2000 万！每天活跃用户数 100 万！每天单表数据量 10 万条！高峰期每秒最大请求达到 1000！同时公司还顺带着融资了两轮，进账了几个亿人民币啊！公司估值达到了惊人的几亿美金！这是小独角兽的节奏！

好吧，没事，现在大家感觉压力已经有点大了，为啥呢？因为每天多 10 万条数据，一个月就多 300 万条数据，现在咱们单表已经几百万数据了，马上就破千万了。但是勉强还能撑着。高峰期请求现在是 1000，咱们线上部署了几台机器，负载均衡搞了一下，数据库撑 1000QPS 也还凑合。但是大家现在开始感觉有点担心了，接下来咋整呢……

再接下来几个月，我的天，CEO 太牛逼了，公司用户数已经达到 1 亿，公司继续融资几十亿人民币啊！公司估值达到了惊人的几十亿美金，成为了国内今年最牛逼的明星创业公司！天，我们太幸运了。

但是我们同时也是不幸的，因为此时每天活跃用户数上千万，每天单表新增数据多达 50 万，目前一个表总数据量都已经达到了两三千万了！扛不住啊！数据库磁盘容量不断消耗掉！高峰期并发达到惊人的 5000~8000 ！别开玩笑了，哥。我跟你保证，你的系统支撑不到现在，已经挂掉了！

好吧，所以你看到这里差不多就理解分库分表是怎么回事儿了，实际上这是跟着你的公司业务发展走的，你公司业务发展越好，用户就越多，数据量越大，请求量越大，那你单个数据库一定扛不住。

分表

比如你单表都几千万数据了，你确定你能扛住么？绝对不行，单表数据量太大，会极大影响你的 sql 执行的性能，到了后面你的 sql 可能就跑的很慢了。一般来说，就以我的经验来看，单表到几百万的时候，性能就会相对差一些了，你就得分表了。

分表是啥意思？就是把一个表的数据放到多个表中，然后查询的时候你就查一个表。比如按照用户 id 来分表，将一个用户的数据就放在一个表中。然后操作的时候你对一个用户就操作那个表就好了。这样可以控制每个表的数据量在可控的范围内，比如每个表就固定在 200 万以内。

分库

分库是啥意思？就是你一个库一般我们经验而言，最多支撑到并发 2000，一定要扩容了，而且一个健康的单库并发值你最好保持在每秒 1000 左右，不要太大。那么你可以将一个库的数据拆分到多个库中，访问的时候就访问一个库好了。

如何对数据库如何进行垂直拆分或水平拆分的？

水平拆分的意思，就是把一个表的数据给弄到多个库的多个表里去，但是每个库的表结构都一样，只不过每个库表放的数据是不同的，所有库表的数据加起来就是全部数据。水平拆分的意义，就是将数据均匀放更多的库里，然后用多个库来扛更高的并发，还有就是用多个库的存储容量来进行扩容。

垂直拆分的意思，就是把一个有很多字段的表给拆分成多个表，或者是多个库上去。每个库表的结构都不一样，每个库表都包含部分字段。一般来说，会将较少的访问频率很高的字段放到一个表里去，然后将较多的访问频率很低的字段放到另外一个表里去。因为数据库是有缓存的，你访问频率高的行字段越少，就可以在缓存里缓存更多的行，性能就越好。这个一般在表层面做的较多一些。

这个其实挺常见的，不一定我说，大家很多同学可能自己都做过，把一个大表拆开，订单表、订单支付表、订单商品表。

还有表层面的拆分，就是分表，将一个表变成 N 个表，就是让每个表的数据量控制在一定范围内，保证 SQL 的性能。否则单表数据量越大，SQL 性能就越差。一般是 200 万行左右，不要太多，但是也得看具体你怎么操作，也可能是 500 万，或者是 100 万。你的SQL越复杂，就最好让单表行数越少。

好了，无论分库还是分表，上面说的那些数据库中间件都是可以支持的。就是基本上那些中间件可以做到你分库分表之后，中间件可以根据你指定的某个字段值，比如说 userid，自动路由到对应的库上去，然后再自动路由到对应的表里去。

你就得考虑一下，你的项目里该如何分库分表？一般来说，垂直拆分，你可以在表层面来做，对一些字段特别多的表做一下拆分；水平拆分，你可以说是并发承载不了，或者是数据量太大，容量承载不了，你给拆了，按什么字段来拆，你自己想好；分表，你考虑一下，你如果哪怕是拆到每个库里去，并发和容量都ok了，但是每个库的表还是太大了，那么你就分表，将这个表分开，保证每个表的数据量并不是很大。

而且这儿还有两种分库分表的方式：

一种是按照 range 来分，就是每个库一段连续的数据，这个一般是按比如时间范围来的，但是这种一般较少用，因为很容易产生热点问题，大量的流量都打在最新的数据上了。或者是按照某个字段 hash 一下均匀分散，这个较为常用。

range 来分，好处在于说，扩容的时候很简单，因为你只要预备好，给每个月都准备一个库就可以了，到了一个新的月份的时候，自然而然，就会写新的库了；缺点，但是大部分的请求，都是访问最新的数据。实际生产用 range，要看场景。

hash 分发，好处在于说，可以平均分配每个库的数据量和请求压力；坏处在于说扩容起来比较麻烦，会有一个数据迁移的过程，之前的数据需要重新计算 hash 值重新分配到不同的库或表。

安装mycat

#解压缩tar xzvf Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz#需要jdk环境变量

配置mycat server.xml

<property name="sequnceHandlerType">0</property><user name="root"><property name="password">123456</property><property name="schemas">mycat_order</property></user><user name="user"><property name="password">123456</property><property name="schemas">mycat_order</property><property name="readOnly">true</property></user>

配置 schema.xml

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><schema name="mycat_order" checkSQLschema="false" sqlMaxLimit="100"><table name="t_order" dataNode="dn1,dn2" rule="mod-long"><childTable name="t_order_detail" primaryKey="od_id" joinKey="order_id"parentKey="order_id" /></table></schema><dataNode name="dn1" dataHost="host1" database="youruike2" /><dataNode name="dn2" dataHost="host2" database="youruike2" /><dataHost name="host1" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="host1" url="127.0.0.1:3306" user="root"password="123456"/></dataHost><dataHost name="host2" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="host2" url="192.168.126.147:3306" user="root"password="123456"/></dataHost></mycat:schema>

创建 youruike2数据库和数据库表：t_order、t_order_detail

CREATE TABLE `t_order` (`order_id` BIGINT (20),`user_id` INT (11),`pay_mode` TINYINT (4),`amount` FLOAT,`order_date` datetime,PRIMARY KEY (`order_id`));CREATE TABLE `t_order_detail` (`od_id` BIGINT (20),`order_id` INT (11),`goods_id` INT (11),`unit_price` FLOAT,`qty` INT (11),PRIMARY KEY (`od_id`));

配置rule.xml

<tableRule name="mod-long"><rule><columns>order_id</columns><algorithm>mod-long</algorithm></rule></tableRule><function name="mod-long" class="io.mycat.route.function.PartitionByMod"><property name="count">2</property></function>

配置sequence_conf.properties

#default global sequenceGLOBAL.HISIDS=GLOBAL.MINID=10001GLOBAL.MAXID=20000GLOBAL.CURID=10000# self define sequenceCOMPANY.HISIDS=COMPANY.MINID=1001COMPANY.MAXID=2000COMPANY.CURID=1000CUSTOMER.HISIDS=CUSTOMER.MINID=1001CUSTOMER.MAXID=2000CUSTOMER.CURID=1000ORDER.HISIDS=ORDER.MINID=1001ORDER.MAXID=2000ORDER.CURID=1000ORDERDETAIL.HISIDS=ORDERDETAIL.MINID=1001ORDERDETAIL.MAXID=2000ORDERDETAIL.CURID=1000

启动并测试

./mycat start

插入测试数据

insert into t_order(order_id,user_id,pay_mode,amount) values(next value for MYCATSEQ_ORDER,101,5,11.1);insert into t_order(order_id,user_id,pay_mode,amount) values(next value for MYCATSEQ_ORDER,102,5,22.2);insert into t_order(order_id,user_id,pay_mode,amount) values(next value for MYCATSEQ_ORDER,103,7,33.3);insert into t_order_detail(od_id,order_id,goods_id,unit_price,qty) values(next value for MYCATSEQ_ORDERDETAIL,1001,55,10,20);insert into t_order_detail(od_id,order_id,goods_id,unit_price,qty) values(next value for MYCATSEQ_ORDERDETAIL,1002,66,14,30);insert into t_order_detail(od_id,order_id,goods_id,unit_price,qty) values(next value for MYCATSEQ_ORDERDETAIL,1003,77,14,60);

myCat高可用

我们可以使用 HAProxy + Keepalived 配合两台 Mycat 搭起 Mycat 集群，实现高可用性。HAProxy

实现了 MyCat 多节点的集群高可用和负载均衡，而 HAProxy 自身的高可用则可以通过 Keepalived 来

实现。

编号角色 IP 地址机器名

1 Mycat1 192.168.140.128 host79.youruike

2 Mycat2 192.168.140.127 host80.youruike

3 HAProxy（master） 192.168.140.126 host81.youruike

4 Keepalived（master） 192.168.140.126 host81.youruike

5 HAProxy（backup） 192.168.140.125 host82.youruike

6 Keepalived（backup） 192.168.140.125 host82.youruike

安装配置 HAProxy

#1准备好HAProxy安装包，传到/opt目录下#2解压到/usr/local/srctar -zxvf haproxy-1.5.14.tar.gz -C /usr/local/src#3进入解压后的目录，查看内核版本，进行编译cd /usr/local/src/haproxy-1.5.14/uname -rmake TARGET=linux310 PREFIX=/usr/local/haproxy ARCH=x86_64# TARGET=linux310，内核版本，使用uname -r查看内核，如：3.10.0-514.el7，此时该参数就为linux310； #ARCH=x86_64，系统位数；#PREFIX=/usr/local/haprpxy #/usr/local/haprpxy，为haprpxy安装路径。#4编译完成后，进行安装make install PREFIX=/usr/local/haproxy#5安装完成后，创建目录、创建HAProxy配置文件mkdir -p /usr/data/haproxy/vi /usr/local/haproxy/haproxy.conf#6向配置文件中插入以下配置信息,并保存

Mycat之——高可用负载均衡集群的实现（HAProxy + Keepalived + Mycat）_冰河的专栏-CSDN博客_mycat负载均衡配置

globallog 127.0.0.1 local0maxconn 4096chroot /usr/local/haproxypidfile /usr/data/haproxy/haproxy.piduid 99gid 99daemon#debug#quietdefaultslog globalmode tcpoption abortoncloseoption redispatchretries 3maxconn 2000timeout connect 5000timeout client 50000timeout server 50000listen proxy_statusbind :48066mode tcpbalance roundrobinserver mycat_1 192.168.126.161:8066 check inter 10sserver mycat_2 192.168.126.171:8066 check inter 10sfrontend admin_stats bind :7777mode httpstats enableoption httplogmaxconn 10stats refresh 30sstats uri /adminstats auth admin:123123stats hide-versionstats admin if TRUE

启动验证

#1启动HAProxy/usr/local/haproxy/sbin/haproxy -f /usr/local/haproxy/haproxy.conf#2查看HAProxy进程ps -ef|grep haproxy#3打开浏览器访问http://192.168.126.172:7777/admin#在弹出框输入用户名：admin密码：123123#如果Mycat主备机均已启动，则可以看到绿色说明成功#4验证负载均衡，通过HAProxy访问Mycatmysql -uroot -p123456 -h 127.0.0.1 -P 48066

配置 Keepalived

#1准备好Keepalived安装包，传到/opt目录下#2解压到/usr/local/srctar -zxvf keepalived-1.4.2.tar.gz -C /usr/local/src#3安装依赖插件yum install -y gcc openssl-devel popt-devel#3进入解压后的目录，进行配置，进行编译cd /usr/local/src/keepalived-1.4.2./configure --prefix=/usr/local/keepalived#4进行编译，完成后进行安装make && make install#5运行前配置cp /usr/local/src/keepalived-1.4.2/keepalived/etc/init.d/keepalived /etc/init.d/mkdir /etc/keepalivedcp /usr/local/keepalived/etc/keepalived/keepalived.conf /etc/keepalived/cp /usr/local/src/keepalived-1.4.2/keepalived/etc/sysconfig/keepalived /etc/sysconfig/cp /usr/local/keepalived/sbin/keepalived /usr/sbin/#6修改配置文件vi /etc/keepalived/keepalived.conf#修改内容如下

! Configuration File for keepalivedglobal_defs {notification_email {xlcocoon@}notification_email_from keepalived@smtp_server 127.0.0.1smtp_connect_timeout 30router_id LVS_DEVELvrrp_skip_check_adv_addrvrrp_garp_interval 0vrrp_gna_interval 0}vrrp_instance VI_1 {#主机配MASTER，备机配BACKUPstate MASTER#所在机器网卡interface ens33virtual_router_id 51#数值越大优先级越高priority 100advert_int 1authentication {auth_type PASSauth_pass 1111}virtual_ipaddress {#虚拟IP192.168.140.200} }virtual_server 192.168.140.200 48066 {delay_loop 6lb_algo rrlb_kind NATpersistence_timeout 50protocol TCPreal_server 192.168.126.172 48066 {weight 1TCP_CHECK {connect_timeout 3retry 3delay_before_retry 3} }real_server 192.168.126.173 48066 {weight 1TCP_CHECK {connect_timeout 3nb_get_retry 3delay_before_retry 3} }}

启动验证

#启动Keepalivedservice keepalived start#查看启动情况ps -ef | grep keepalived#登录验证mysql -uroot -p123456 -h 192.168.140.200 -P 48066

测试高可用

#1关闭mycat#2通过虚拟ip查询数据mysql -uroot -p123456 -h 192.168.140.200 -P 48066

本内容不代表本网观点和政治立场，如有侵犯你的权益请联系我们处理。

网友评论

网友评论仅供其表达个人看法，并不表明网站立场。