【MySQL】MySQL5.7+keepalived構成デュアルプライマリ

前言:MySQL 5.7+keepalivedデュアルプライマリ構成MySQL高可用性は比較的成熟したシナリオであり、主な構成手順を簡単に説明します.
一、ダブルマスターの配置
このステップは比較的簡単で,GTIDモードでの主従構成のみを論じた.

スレーブ構成:

    change master to master_host='master_ip',master_port=port,master_user='repl',master_password='xxxx',master_auto_position=1;

メインライブラリ構成

  change master to master_host='slave_ip',master_port=port,master_user='repl',master_password='xxxx',master_auto_position=1;

二、keepalivedの配置
1.keepalivedのインストール

yum install keepalived

インストールに成功したら、バージョンを表示できます.

[root@master vagrant]# keepalived -v
Keepalived v1.3.5 (03/19,2017), git commit v1.3.5-6-g6fa32f2

Copyright(C) 2001-2017 Alexandre Cassen, 

2.プロファイルの変更

vim /etc/keepalived/keepalived.conf
[root@master keepalived]# cat keepalived.conf
vrrp_script vs_mysql_82 {
    script "/etc/keepalived/checkMySQL.py -h 192.168.50.3 -P 3306"
    interval 60
}
vrrp_instance VI_82 {
    state BACKUP
    nopreempt
    interface enp0s8
    virtual_router_id 82
    priority 100
    advert_int 5
    authentication {
        auth_type PASS
        auth_pass 1111
    }
    track_script {
       vs_mysql_82
    }
    virtual_ipaddress {
        192.168.50.5
    }
}

MySQLチェックスクリプトを追加

[root@master keepalived]# cat checkMySQL.py
#!/usr/bin/python
#coding: utf-8
#

import sys
import os
import getopt
import MySQLdb
import logging



dbhost='localhost'
dbport=3306
dbuser='monitor'
dbpassword='m0n1tor'


def checkMySQL():
        global dbhost
        global dbport
        global dbuser
        global dbpassword

        shortargs='h:P:'
        opts, args=getopt.getopt(sys.argv[1:],shortargs)
        for opt, value in opts:
                if opt=='-h':
                        dbhost=value
                elif opt=='-P':
                        dbport=value
        #print "host : %s, port: %d, user: %s, password: %s" % (dbhost, int(dbport), dbuser, dbpassword)
        db = instanceMySQL(dbhost, dbport, dbuser, dbpassword)
        st = db.ishaveMySQL()
        #if ( db.connect() != 0 ):
        #       return 1
        #db.disconnect()
        return st

class instanceMySQL:
        conn = None
        def __init__(self, host=None,port=None, user=None, passwd=None):
                self.dbhost= host
                self.dbport = int(port)
                self.dbuser = user
                self.dbpassword = passwd

        def ishaveMySQL(self):
                cmd="ps -ef | egrep -i \"mysqld\" | grep %s | egrep -iv \"mysqld_safe\" | grep -v grep | wc -l" % self.dbport
                mysqldNum = os.popen(cmd).read()
                cmd ="netstat -tunlp | grep \":%s\" | wc -l" % self.dbport
                mysqlPortNum= os.popen(cmd).read()
                #print mysqldNum, mysqlPortNum
                if ( int(mysqldNum) <= 0):
                        print "error"
                        return 1
                if ( int(mysqldNum) > 0 and  mysqlPortNum <= 0):
                        return 1
                return 0

        def connect(self):
        #       print "in db conn"
#               print "host : %s, port: %d, user: %s, password: %s" % (self.dbhost, self.dbport, self.dbuser, self.dbpassword)
                try:
                        self.conn=MySQLdb.connect(host="%s"%self.dbhost, port=self.dbport,user="%s"%dbuser, passwd="%s"%self.dbpassword)
                except Exception, e:
#                       print " Error"
                        print e
                        return 1
                return 0
        def disconnect(self):
                if (self.conn):
                        self.conn.close()
                        self.conn = None


if __name__== "__main__":
        st=checkMySQL()
        sys.exit(st)

ライブラリから同様の構成を行い、バインドされたNICと実際のIPを修正することに注意し、2つのノードがkeepalivedを起動すればよい.