mysql负载均衡与高可用环境配置教程详解

#这个时后 vip 地址会移动到 Slave 主机上； HA 搭建的是否成功体现于查询所获取值的变化；
#当将 MASTER 恢复后，VIP 又会回到 11 的设备上；
#至此 keepalived 为 mysql 做HA 模式成功；
[install_haproxy]
#用于将请求分别轮询到 192.168.5.11 192.168.5.12
tar xf /opt/soft/haproxy-1.4.20.tar.gz -C /opt/soft/
cd /opt/soft/haproxy-1.4.20/
make TARGET=linux26 PREFIX=/opt/haproxy install
mkdir /opt/haproxy/conf
mkdir /opt/haproxy/logs
touch /opt/haproxy/conf/haproxy.cfg

[mysql_config]
#修改 mysql 监听，使 mysql 避开 192.168.5.111，因为 haproxy 也要监听 111:3306 这个IP地址和端口；
vim /etc/my.cnf
#server1
[mysqld]
bind-address=192.168.5.11 #mysql 的监听,添加这一句就好了
#server2
[mysqld]
bind-address=192.168.5.12
#重启mysql
service mysqld restart
#到现在已不能通过 192.168.5.111 访问数据库了，接下来配置 haproxy

[config_haproxy]
#主备服务器的主配文件一致；
vim /opt/haproxy/conf/haproxy.cfg
global         #全局系统配置
log 127.0.0.1 local0 info   #定义日志级别[err warning info debug]
#local0 是日志设备，必须为24种标准syslog设备之一；
maxconn 4096        #最大链接数
uid 0           #运行该程序的用户,此处没有其它用户了，就用的 root
gid 0
daemon          #以后台形式运行
nbproc 1        #进程数量
defaults            #默认配置
mode tcp        #所处理的类别 http | tcp | health
option redispatch   #serverId对应的服务器挂掉后,强制定向到其他健康的服务器
retries 3       #三次连接失败则服务器不用
timeout connect 5000    #连接超时
timeout client 50000    #客户端超时
timeout server 50000    #服务器超时
timeout check 2000  #心跳检测超时
listen proxy
bind 192.168.5.111:3306     #监听地址
mode tcp
balance roundrobin      #定义负载方式，此处为轮询
log 127.0.0.1 local0 info   #定义日志类型
#rise 3三次正确表示服务器可用，fall 3表示3次失败表示服务器不可用
server db1 192.168.5.11:3306 check inter 1200 rise 2 fall 3 weight 1
server db2 192.168.5.12:3306 check inter 1200 rise 2 fall 3 weight 1
#服务器状态监控配置，可以通过定义的地址查看集群状态；
listen haproxy_stats
log 127.0.0.1 local0 info
mode http
bind 192.168.5.111:8888
option httplog
stats uri /status
stats realm Haproxy Manager
stats auth admin:admin      #设置监控地址的帐号与密码
#在keepalived 主配文件中添加刚才在其末端说明的外部定义脚本
#启动服务
/opt/haproxy/sbin/haproxy -f /opt/haproxy/conf/haproxy.cfg
#说明事项，keepalived 的服务主备设备上都可以同时运行，实则只有获得VIP的服务器才有效；
#但是 haproxy 启动的时候需要监听 VIP 地址，所以第一次备用设备是手动起不了服务的；
#需要在 keepalived 的notify_master配置项中设定脚本，当此设备获得VIP地址后才启动 haproxy;
#有个问题在这里，我们只设定了当keepalived 停止服务时，才结束 haproxy ，没有设定移交VIP时是否结束；
#其实这也不用担心，因为主机上已经没有VIP地址了，即便是监听也无效果，并无干扰；

##开始测试
#检测监听
netstat -tunlp | grep ha
netstat -tunlp | grep 3306
# master 设备上才会有两个程序监听不同地址的 3306；
#暂未配置 mysql 互为主备就是为了方便这一阶段的排错，这样能更准确的测试；
mysql -udiaosi -p123456 -h 192.168.5.111 -e "select * from test.mywait;"
#返回值应该是在 server1 server2 之间徘徊；
sed -i 's/^mysql.*$/#&/' /etc/passwd #注释掉mysql的用户
service mysqld stop
#这个时候 mysql 服务已经启动不起了，mysql_chke.sh 脚本会把 keepalived 停止掉；
keepalived 停止前，又会把 haproxy 杀死；当备份的设备获得 vip 后，则会通过start_haproxy.sh 脚本将 haproxy 启动起来；
于是并不会因为服务器当机或mysql故障，影响我们客户端对 111 的查询操作，实验完成一半了；
#但是测试时，在VIP地址切换过程中，客户端会有那么2-3秒不能访问到数据库，这个暂时忽略不计；
sed 's/^#//' /etc/passwd #测试完后，记得恢复mysql用户哦；
#恢复mysql 后，启动主设备的 mysqld keepalived ，然后使用 ip a 查看VIP 地址是否有返回来；
#在其中一台设备上 killall haproxy ，之后查看集群状态；
http://192.168.5.111:8888/status
#查看后再将 haproxy 启动
#至此，已经完成 负载均衡 + 高可用 两部分，负载方式为轮询

##三个脚本,很简单，就不再介绍了哈；主要是做日志和结束服务；
#!/bin/bash
#start_haproxy.sh
sleep 5
get=`ip addr  |grep 192.168.5.111 |wc -l`
echo $get >> /opt/log/start_haproxy.log
if [ $get -eq 1 ]
then
echo "`date +%c` success to get vip" >> /opt/log/start_haproxy.log
/opt/haproxy/sbin/haproxy -f /opt/haproxy/conf/haproxy.cfg
else
echo "`date +%c` can not get vip" >> /opt/log/start_haproxy.log
fi
#!/bin/bash
#stop_haproxy.sh
pid=`pidof haproxy`
echo "`date +%c` stop haproxy" >> /opt/log/stop_haproxy.log
kill -9 $pid
#!/bin/bash
#stop_keepalived.sh
pid=`pidof keepalived`
if [ $pid == "" ]
then
echo "`date +%c` no keepalived process id"  >> /opt/log/stop_keepalived.log
else
echo "`date +%c` will stop keepalived "  >> /opt/log/stop_keepalived.log
/etc/init.d/keepalived stop
fi

[mysql Manager Slave]
#mysql 主备配置；两台设备上添加用户哦；

root#mysql
create database db1;
GRANT REPLICATION SLAVE ON *.* TO 'diaosi1'@'%' IDENTIFIED BY '123456';
#此处注意哦，Slave 权限必须的,我最初使用 all 权限，结果主备始终不同步，改成 Slave 就OK了；
flush privileges;
show grants for diaosi1@'%';

#server1 的 mysql 配置
server_id=1 #服务器标识，唯一
log_bin=mysqlbinlog #启用二进制日志
log_bin_index=mysqlbinlog-index #日志索引文件
log_slave_updates=1 #让从服务器把自身复制的事件和记录都写到自己的二进制日志里
relay_log=relay-log #中继日志位置；存放slave端获取到master端的二进制文件信息
replicate_do_db=db1 ##指定需要同步的数据库
#server2 的 mysql 配置
server_id=2
log_bin=mysqlbinlog
log_bin_index=mysqlbinlog-index
log_slave_updates=1
relay_log=relay-log
replicate_do_db=db1
#分别重启两服务
service mysqld restart
mysql> show master status; #查看mysql 的当前二进制日志文件
+--------------------+----------+--------------+------------------+
| File | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+--------------------+----------+--------------+------------------+
| mysqlbinlog.000001 | 98 | | |
+--------------------+----------+--------------+------------------+
1 row in set (0.28 sec)
#分别连接对方 mysql 日志，开始备份；记得替换 Master_Host 和日志名及MASTER_LOG_POS；
>CHANGE MASTER TO MASTER_HOST='192.168.5.12',master_port=3306,MASTER_USER='diaosi1',MASTER_PASSWORD='123456',MASTER_LOG_FILE='mysqlbinlog.000001',MASTER_LOG_POS=98;
>START SLAVE; #开始同步
mysql> SHOW SLAVE STATUSG #查看mysql同步状态
*************************** 1. row ***************************
Slave_IO_State: Waiting for master to send event
Master_Host: 192.168.5.11
Master_User: mywait
Master_Port: 3306
Connect_Retry: 60
Master_Log_File: mysqlbinlog.000001
Read_Master_Log_Pos: 98
Relay_Log_File: relay-log.000002
Relay_Log_Pos: 237
Relay_Master_Log_File: mysqlbinlog.000001
Slave_IO_Running: Yes #表明获取对方日志文件的连接成功；
Slave_SQL_Running: Yes #将获取到的日志转成sql语句回写本地数据库成功；
Replicate_Do_DB: db1
Replicate_Ignore_DB:
Replicate_Do_Table:
Replicate_Ignore_Table:
Replicate_Wild_Do_Table:
Replicate_Wild_Ignore_Table:
Last_Errno: 0
Last_Error:
Skip_Counter: 0
Exec_Master_Log_Pos: 98
Relay_Log_Space: 237
Until_Condition: None
Until_Log_File:
Until_Log_Pos: 0
Master_SSL_Allowed: No
Master_SSL_CA_File:
Master_SSL_CA_Path:
Master_SSL_Cert:
Master_SSL_Cipher:
Master_SSL_Key:
Seconds_Behind_Master: 0
1 row in set (0.00 sec)
#主要就是看 Slave_IO_Running，Slave_SQL_Running
#这里错误的话，多数情况是 Slave_IO_Running 的问题，防火墙，用户权限，日志是否有启用等都需要判断；

#至此 mysql 双主互备搭建完成，我们的全部实验规划也全部完成；
#进入全面测试阶段；
#在 server1 的DB1里新建一张表，并赋值
>use db1;
>create table mywait(name char(9),phone char(14));
>insert into mywait(name,phone) values('wait',15888888888);
#新建一个具有 db1 权限的用户
grant all on db1.* to diaosi2@'%' identified by '123456';
>flush privileges;
#切换到 test 库,在mywait 表中插入一条数据；
use test;
insert into mywait(name,phone) values ('diaosi',15002839961);
#在 server2做验证；
>use db1;
>show tables;
>select * from mywait;
#此时数据与 server1 的会数据一致，表示mysql同步成功；
select user,host,password from mysql.user;
#在 server1 创建的用户也会被 server2 所同步；
#select * from test.mywait
#可以看到 server1上的 test 库并没有被同步；
#客户机上测试
mysql -udiaosi2 -p123456 -h 192.168.5.111 -e "select * from db1.mywait;"
#完毕；