5大主流方案對(duì)比：MySQL千億級(jí)數(shù)據(jù)線上平滑擴(kuò)容實(shí)戰(zhàn)

在項(xiàng)目初期，我們部署了三個(gè)數(shù)據(jù)庫(kù)A、B、C，此時(shí)數(shù)據(jù)庫(kù)的規(guī)?？梢詽M足我們的業(yè)務(wù)需求。為了將數(shù)據(jù)做到平均分配，我們?cè)赟ervice服務(wù)層使用uid%3進(jìn)行取模分片，從而將數(shù)據(jù)平均分配到三個(gè)數(shù)據(jù)庫(kù)中。

如圖所示：

后期隨著用戶量的增加，用戶產(chǎn)生的數(shù)據(jù)信息被源源不斷的添加到數(shù)據(jù)庫(kù)中，最終達(dá)到數(shù)據(jù)庫(kù)的最佳存儲(chǔ)容量。如果此時(shí)繼續(xù)向數(shù)據(jù)庫(kù)中新增數(shù)據(jù)，會(huì)導(dǎo)致數(shù)據(jù)庫(kù)的CRUD等基本操作變慢，進(jìn)而影響整個(gè)服務(wù)的響應(yīng)速度。

這時(shí)，我們需要增加新的節(jié)點(diǎn)，對(duì)數(shù)據(jù)庫(kù)進(jìn)行水平擴(kuò)容，那么加入新的數(shù)據(jù)庫(kù)D后，數(shù)據(jù)庫(kù)的規(guī)模由原來(lái)的3個(gè)變?yōu)?個(gè)。

如圖所示：

此時(shí)由于分片規(guī)則發(fā)生了變化（uid%3 變?yōu)閡id%4），導(dǎo)致大部分的數(shù)據(jù)，無(wú)法命中原有的數(shù)據(jù)，需要重新進(jìn)行分配，要做大量的數(shù)據(jù)遷移處理。

比如之前uid如果是uid=3取模3%3=0， 是分配在A庫(kù)上，新加入D庫(kù)后， uid=3取模3%4=3，分配在D庫(kù)上；

新增一個(gè)節(jié)點(diǎn)， 大概會(huì)有90%的數(shù)據(jù)需要遷移， 這樣會(huì)面臨大量的數(shù)據(jù)壓力，并且對(duì)服務(wù)造成極大的不穩(wěn)定性。

1. 五個(gè)方案

1.1 停機(jī)方案

發(fā)布公告：為了進(jìn)行數(shù)據(jù)的重新拆分，在停止服務(wù)之前，我們需要提前通知用戶，比如：我們的服務(wù)會(huì)在yyyy-MM-dd進(jìn)行升級(jí)，給您帶來(lái)的不便敬請(qǐng)諒解。

停止服務(wù)：關(guān)閉Service

離線數(shù)據(jù)遷移（拆分，重新分配數(shù)據(jù)）：將舊庫(kù)中的數(shù)據(jù)按照Service層的算法，將數(shù)據(jù)拆分，重新分配數(shù)據(jù)

數(shù)據(jù)校驗(yàn)：開(kāi)發(fā)定制一個(gè)程序?qū)εf庫(kù)和新庫(kù)中的數(shù)據(jù)進(jìn)行校驗(yàn)，比對(duì)

更改配置：修改Service層的配置算法，也就是將原來(lái)的uid%3變?yōu)閡id%4

恢復(fù)服務(wù)：重啟Service服務(wù)

回滾預(yù)案：針對(duì)上述的每個(gè)步驟都要有數(shù)據(jù)回滾預(yù)案，一旦某個(gè)環(huán)節(jié)（如：數(shù)據(jù)遷移，恢復(fù)服務(wù)等）執(zhí)行失敗，立刻進(jìn)行回滾，重新再來(lái)

停止服務(wù)之后， 能夠保證遷移工作的正常進(jìn)行， 但是服務(wù)停止，傷害用戶體驗(yàn)， 并造成了時(shí)間壓力， 必須在指定的時(shí)間內(nèi)完成遷移。

1.2 停寫(xiě)方案

支持讀寫(xiě)分離：數(shù)據(jù)庫(kù)支持讀寫(xiě)分離，在擴(kuò)容之前，每個(gè)數(shù)據(jù)庫(kù)都提供了讀寫(xiě)功能，數(shù)據(jù)重新分配的過(guò)程中，將每個(gè)數(shù)據(jù)庫(kù)設(shè)置為只讀狀態(tài)，關(guān)閉寫(xiě)的功能

升級(jí)公告：為了進(jìn)行數(shù)據(jù)的重新拆分，在停寫(xiě)之前，我們需要提前通知用戶，比如：我們的服務(wù)會(huì)在yyyy-MM-dd進(jìn)行升級(jí)，給您帶來(lái)的不便敬請(qǐng)諒解。

中斷寫(xiě)操作，隔離寫(xiě)數(shù)據(jù)源（或攔截返回統(tǒng)一提示）：在Service層對(duì)所有的寫(xiě)請(qǐng)求進(jìn)行攔截，統(tǒng)一返回提示信息，如：服務(wù)正在升級(jí)中，只對(duì)外提供讀服務(wù)

數(shù)據(jù)同步處理：將舊庫(kù)中的數(shù)據(jù)按照Service層的算法，將數(shù)據(jù)重新分配，遷移（復(fù)制數(shù)據(jù)）

數(shù)據(jù)校驗(yàn)：開(kāi)發(fā)定制一個(gè)程序?qū)εf庫(kù)中的數(shù)據(jù)進(jìn)行備份，使用備份的數(shù)據(jù)和重新分配后的數(shù)據(jù)進(jìn)行校驗(yàn)，比對(duì)

更改配置：通過(guò)配置中心，修改Service層的配置算法，也就是將原來(lái)的uid%3變?yōu)閡id%4，這個(gè)過(guò)程不需要重啟服務(wù)

恢復(fù)寫(xiě)操作：設(shè)置數(shù)據(jù)庫(kù)恢復(fù)讀寫(xiě)功能，去除Service層的攔截提示

數(shù)據(jù)清理：使用delete語(yǔ)句對(duì)冗余數(shù)據(jù)進(jìn)行刪除

回滾預(yù)案：針對(duì)上述的每個(gè)步驟都要有數(shù)據(jù)回滾預(yù)案，一旦某個(gè)環(huán)節(jié)（如：數(shù)據(jù)遷移等）執(zhí)行失敗，立刻進(jìn)行回滾，重新再來(lái)

缺點(diǎn)：在數(shù)據(jù)的復(fù)制過(guò)程需要消耗大量的時(shí)間，停寫(xiě)時(shí)間太長(zhǎng)，數(shù)據(jù)需要先復(fù)制，再清理冗余數(shù)據(jù)

1.3 日志方案

核心是通過(guò)日志進(jìn)行數(shù)據(jù)庫(kù)的同步遷移， 主要操作步驟如下：

1、數(shù)據(jù)遷移之前， 業(yè)務(wù)應(yīng)用訪問(wèn)舊的數(shù)據(jù)庫(kù)節(jié)點(diǎn)。

2、日志記錄

在升級(jí)之前， 記錄“對(duì)舊數(shù)據(jù)庫(kù)上的數(shù)據(jù)修改”的日志（這里修改包括增、刪、改），這個(gè)日志不需要記錄詳細(xì)的數(shù)據(jù)信息，主要記錄：

（1）修改的庫(kù)；

（2）修改的表；

（3）修改的唯一主鍵；

（4）修改操作類型。

日志記錄不用關(guān)注新增了哪些信息，修改的數(shù)據(jù)格式，只需要記錄以上數(shù)據(jù)信息，這樣日志格式是固定的， 這樣能保證方案的通用性。

服務(wù)升級(jí)日志記錄功能風(fēng)險(xiǎn)較小：

寫(xiě)和修改接口是少數(shù)， 改動(dòng)點(diǎn)少；

升級(jí)只是增加了一些日志，采用異步方式實(shí)現(xiàn)， 對(duì)業(yè)務(wù)功能沒(méi)有太多影響。

3、數(shù)據(jù)遷移：

研發(fā)定制數(shù)據(jù)遷移工具， 作用是把舊庫(kù)中的數(shù)據(jù)遷移至新庫(kù)中。

整個(gè)過(guò)程仍然采用舊庫(kù)進(jìn)行對(duì)外服務(wù)。

數(shù)據(jù)同步工具實(shí)現(xiàn)復(fù)雜度不高。

只對(duì)舊庫(kù)進(jìn)行讀取操作， 如果同步出現(xiàn)問(wèn)題， 都可以對(duì)新庫(kù)進(jìn)行回滾操作。

可以限速或分批遷移執(zhí)行， 不會(huì)有時(shí)間壓力。

數(shù)據(jù)遷移完成之后， 并不能切換至新庫(kù)提供服務(wù)。

因?yàn)榕f庫(kù)依然對(duì)線上提供服務(wù)， 庫(kù)中的數(shù)據(jù)隨時(shí)會(huì)發(fā)生變化， 但這些變化的數(shù)據(jù)并沒(méi)有同步到新庫(kù)中， 舊庫(kù)和新庫(kù)數(shù)據(jù)不一致， 所以不能直接進(jìn)行切換， 需要將數(shù)據(jù)同步完整。

4、日志增量遷移

研發(fā)一個(gè)日志遷移工具，把上面遷移數(shù)據(jù)過(guò)程中的差異數(shù)據(jù)追平，處理步驟：

讀取log日志，獲取具體是哪個(gè)庫(kù)、表和主鍵發(fā)生了變化修改；

把舊庫(kù)中的主鍵記錄讀取出來(lái)

根據(jù)主鍵ID，把新庫(kù)中的記錄替換掉

這樣可以最大程度的保障數(shù)據(jù)的一致性。風(fēng)險(xiǎn)分析：

整個(gè)過(guò)程， 仍然是舊庫(kù)對(duì)線上提供服務(wù)；

日志遷移工具實(shí)現(xiàn)的復(fù)雜度較低；

任何時(shí)間發(fā)現(xiàn)問(wèn)題， 可以重新再來(lái)，有充分的容錯(cuò)空間；

可以限速重放處理日志， 處理過(guò)程不會(huì)因?yàn)閷?duì)線上影響造成時(shí)間壓力。

但是， 日志增量同步完成之后， 還不能切換到新的數(shù)據(jù)庫(kù)。

因?yàn)槿罩驹隽客竭^(guò)程中，舊庫(kù)中可能有數(shù)據(jù)發(fā)生變化， 導(dǎo)致數(shù)據(jù)不一致，所以需要進(jìn)一步讀取日志， 追平數(shù)據(jù)記錄； 日志增量同步過(guò)程隨時(shí)可能會(huì)產(chǎn)生新的數(shù)據(jù)， 新庫(kù)與舊庫(kù)的數(shù)據(jù)追平也會(huì)是一個(gè)無(wú)限逼近的過(guò)程。

5、數(shù)據(jù)校驗(yàn)

準(zhǔn)備好數(shù)據(jù)校驗(yàn)工具，將舊庫(kù)和新庫(kù)中的數(shù)據(jù)進(jìn)行比對(duì)，直到數(shù)據(jù)完全一致。

6、切換新庫(kù)

數(shù)據(jù)比對(duì)完成之后， 將流量轉(zhuǎn)移切換至新庫(kù)， 至此新庫(kù)提供服務(wù)， 完成遷移。

但是在極限情況下， 即便通過(guò)上面的數(shù)據(jù)校驗(yàn)處理， 也有可能出現(xiàn)99.99%數(shù)據(jù)一致， 不能保障完全一致，這個(gè)時(shí)候可以在舊庫(kù)做一個(gè)readonly只讀功能， 或者將流量屏蔽降級(jí)，等待日志增量同步工具完全追平后， 再進(jìn)行新庫(kù)的切換。

至此，完成日志方案的遷移擴(kuò)容處理， 整個(gè)過(guò)程能夠持續(xù)對(duì)線上提供服務(wù)， 只會(huì)短暫的影響服務(wù)的可用性。

這種方案的弊端，是操作繁瑣，需要適配多個(gè)同步處理工具，成本較高， 需要制定個(gè)性化業(yè)務(wù)的同步處理， 不具備普遍性，耗費(fèi)的時(shí)間周期也較長(zhǎng)。

1.4 雙寫(xiě)方案（中小型數(shù)據(jù)）

雙寫(xiě)方案可通過(guò)canal或mq做實(shí)現(xiàn)。

增加新庫(kù)，按照現(xiàn)有節(jié)點(diǎn)， 增加對(duì)應(yīng)的數(shù)量。

數(shù)據(jù)遷移：避免增量影響， 先斷開(kāi)主從，再導(dǎo)入（耗時(shí)較長(zhǎng)）， 同步完成并做校驗(yàn)

增量同步：開(kāi)啟Canal同步服務(wù)， 監(jiān)聽(tīng)從節(jié)點(diǎn)數(shù)據(jù)庫(kù)， 再開(kāi)啟主從同步，從節(jié)點(diǎn)收到數(shù)據(jù)后會(huì)通過(guò)Canal服務(wù)， 傳遞至新的DB節(jié)點(diǎn)。

切換新庫(kù)：通過(guò)Nginx，切換訪問(wèn)流量至新的服務(wù)。

修復(fù)切換異常數(shù)據(jù)：在切換過(guò)程中， 如果出現(xiàn)，Canal未同步，但已切換至新庫(kù)的請(qǐng)求（比如下單，修改了資金， 但還未同步 ）， 可以通過(guò)定制程序， 讀取檢測(cè)異常日志，做自動(dòng)修復(fù)或人工處理。

針對(duì)此種情況， 最好是在凌晨用戶量小的時(shí)候， 或?qū)ｉT停止外網(wǎng)訪問(wèn)，進(jìn)行切換，減少異常數(shù)據(jù)的產(chǎn)生。

數(shù)據(jù)校驗(yàn)：為保障數(shù)據(jù)的完全一致， 有必要對(duì)數(shù)據(jù)的數(shù)量完整性做校驗(yàn)。

1.5平滑2N方案（大數(shù)據(jù)量）

線上數(shù)據(jù)庫(kù)，為了保障其高可用，一般每臺(tái)主庫(kù)會(huì)配置一臺(tái)從庫(kù)，主庫(kù)負(fù)責(zé)讀寫(xiě)，從庫(kù)負(fù)責(zé)讀取。下圖所示，A，B是主庫(kù)，A0和B0是從庫(kù)。

1、當(dāng)需要擴(kuò)容的時(shí)候，我們把A0和B0升級(jí)為新的主庫(kù)節(jié)點(diǎn)，如此由2個(gè)分庫(kù)變?yōu)?個(gè)分庫(kù)。同時(shí)在上層的分片配置，做好映射，規(guī)則如下:

把uid%4=0和uid%4=2的數(shù)據(jù)分別分配到A和A0主庫(kù)中

把uid%4=1和uid%4=3的數(shù)據(jù)分配到B和B0主庫(kù)中

2、因?yàn)锳和A0庫(kù)的數(shù)據(jù)相同，B和B0數(shù)據(jù)相同，此時(shí)無(wú)需做數(shù)據(jù)遷移。只需調(diào)整變更一下分片配置即可，通過(guò)配置中心更新，不需要重啟。

由于之前uid%2的數(shù)據(jù)是分配在2個(gè)庫(kù)里面，擴(kuò)容之后需要分布到4個(gè)庫(kù)中，但由于舊數(shù)據(jù)仍存在（uid%4=0的節(jié)點(diǎn),還有一半uid%4=2的數(shù)據(jù)），所以需要對(duì)冗余數(shù)據(jù)做一次清理。

這個(gè)清理，并不會(huì)影響線上數(shù)據(jù)的一致性，可以隨時(shí)隨地進(jìn)行。

3、處理完成之后，為保證數(shù)據(jù)的高可用，以及將來(lái)下一步的擴(kuò)容需求。

可以為現(xiàn)有的主庫(kù)再次分配一個(gè)從庫(kù)。

基于 Spring Boot + MyBatis Plus + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

2. 平滑2N擴(kuò)容方案實(shí)踐

2.1 實(shí)現(xiàn)應(yīng)用服務(wù)級(jí)別的動(dòng)態(tài)擴(kuò)容

擴(kuò)容前部署架構(gòu)：

2.1.1 MariaDB服務(wù)安裝

切換阿里云鏡像服務(wù)（YUM安裝過(guò)慢可以切換）

yum-yinstallwget
#備份CentOS-Base.repo
mv/etc/yum.repos.d/CentOS-Base.repo/etc/yum.repos.d/CentOS-Base.repo.bak

wget-O/etc/yum.repos.d/CentOS-Base.repohttp://mirrors.aliyun.com/repo/Centos-7.repo

wget-P/etc/yum.repos.d/http://mirrors.aliyun.com/repo/epel-7.repo

yumcleanall

yummakecache

配置YUM源

vi/etc/yum.repos.d/mariadb-10.2.repo

增加以下內(nèi)容：

[mariadb]
name=MariaDB
baseurl=https://mirrors.ustc.edu.cn/mariadb/yum/10.2/centos7-amd64
gpgkey=https://yum.mariadb.org/RPM-GPG-KEY-MariaDB
gpgcheck=1

執(zhí)行安裝

yum-yinstallmariadbmariadb-serverMariaDB-clientMariaDB-common

如果之前已經(jīng)安裝， 需要先刪除（如果之前沒(méi)有安裝， 可以忽略此步驟）

停止Mariadb服務(wù)

[root@localhostyum.repos.d]#ps-ef|grepmysql
root195410Oct04?0043/usr/sbin/mysqld--wsrep-new-cluster--user=root
root8952181403007:40pts/00000grep--color=automysql
[root@localhostyum.repos.d]#kill1954

卸載Mariadb服務(wù)

yum-yremoveMaria*

刪除數(shù)據(jù)與配置：

rm-rf/var/lib/mysql/*
rm-rf/etc/my.cnf.d/
rm-rf/etc/my.cnf

啟動(dòng)MariaDB后，執(zhí)行安全配置向?qū)睿筛鶕?jù)安全配置向?qū)岣邤?shù)據(jù)庫(kù)的安全性

systemctlstartmariadb

mysql_secure_installation

開(kāi)啟用戶遠(yuǎn)程連接權(quán)限

將連接用戶root開(kāi)啟遠(yuǎn)程連接權(quán)限；

mysql-uroot-p654321

進(jìn)入MySQL服務(wù)， 執(zhí)行以下操作：

usemysql;

deletefromuser;
#配置root用戶使用密碼654321從任何主機(jī)都可以連接到mysql服務(wù)器
GRANTALLPRIVILEGESON*.*TO'root'@'%'IDENTIFIEDBY'654321'WITHGRANTOPTION;

FLUSHPRIVILEGES;

2.1.2 MariaDB雙主同步

在Server1增加配置：

在/etc/my.cnf中添加以下配置：

[mysqld]
server-id=1
log-bin=mysql-bin
relay-log=mysql-relay-bin
#忽略mysql、information_schema庫(kù)下對(duì)表的操作
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
#默認(rèn)的情況下mysql是關(guān)閉的;
log-slave-updates=on
#復(fù)制過(guò)程中，有任何錯(cuò)誤，直接跳過(guò)
slave-skip-errors=all
auto-increment-offset=1
auto-increment-increment=2
#binlog的格式：STATEMENT，ROW，MIXED
binlog_format=mixed
#自動(dòng)過(guò)期清理binlog，默認(rèn)0天，即不自動(dòng)清理
expire_logs_days=10

注意， Server1自增為奇數(shù)位：

auto-increment-offset=1 主鍵自增基數(shù), 從1開(kāi)始。

auto-increment-increment=2 主鍵自增偏移量，每次為2。

在Server2增加配置：

修改/etc/my.cnf:

[mysqld]
server-id=2
log-bin=mysql-bin
relay-log=mysql-relay-bin
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
log-slave-updates=on
slave-skip-errors=all
auto-increment-offset=2
auto-increment-increment=2
binlog_format=mixed
expire_logs_days=10

Server2自增為偶數(shù)位：

auto-increment-offset=2 主鍵自增基數(shù), 從2開(kāi)始。

auto-increment-increment=2 主鍵自增偏移量，每次為2。

配置修改完成后， 重啟數(shù)據(jù)庫(kù)。

同步授權(quán)配置

在Server1創(chuàng)建replica用于主從同步的用戶：

MariaDB[(none)]>grantreplicationslave,replicationclienton*.*to'replica'@'%'identifiedby'replica';
mysql>flushprivileges;

查詢?nèi)罩疚募c偏移量，開(kāi)啟同步時(shí)需使用：

MariaDB[(none)]>showmasterstatus;
+------------------+----------+--------------+------------------+
||Position|Binlog_Do_DB|Binlog_Ignore_DB|
+------------------+----------+--------------+------------------+
|mysql-bin.000001|663|||
+------------------+----------+--------------+------------------+

同樣， 在Server2創(chuàng)建replica用于主從同步的用戶：

MariaDB[(none)]>grantreplicationslave,replicationclienton*.*to'replica'@'%'identifiedby'replica';
mysql>flushprivileges;

查詢?nèi)罩疚募c偏移量：

MariaDB[(none)]>showmasterstatus;
+------------------+----------+--------------+------------------+
||Position|Binlog_Do_DB|Binlog_Ignore_DB|
+------------------+----------+--------------+------------------+
|mysql-bin.000001|663|||
+------------------+----------+--------------+------------------+

配置主從同步信息

在Server1中執(zhí)行：

MariaDB[(none)]>changemastertomaster_host='192.168.116.141',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000007',master_log_pos=374,master_connect_retry=30;

在Server2中執(zhí)行：

MariaDB[(none)]>changemastertomaster_host='192.168.116.140',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000015',master_log_pos=374,master_connect_retry=30;

開(kāi)啟雙主同步

在Server1和Server2中分別執(zhí)行：

MariaDB[(none)]>startslave;
QueryOK,0rowsaffected(0.00sec)

在Server1查詢同步信息：

MariaDB[(none)]>showslavestatusG;
***************************1.row***************************
Slave_IO_State:Waitingformastertosendevent
Master_Host:10.10.20.126
Master_User:replica
Master_Port:3306
Connect_Retry:30
Master_Log_:mysql-bin.000001
Read_Master_Log_Pos:663
Relay_Log_:mysql-relay-bin.000002
Relay_Log_Pos:555
Relay_Master_Log_:mysql-bin.000001
Slave_IO_Running:Yes
Slave_SQL_Running:Yes
...

在Server2查詢同步信息：

MariaDB[(none)]>showslavestatusG;
***************************1.row***************************
Slave_IO_State:Waitingformastertosendevent
Master_Host:10.10.20.125
Master_User:replica
Master_Port:3306
Connect_Retry:30
Master_Log_:mysql-bin.000001
Read_Master_Log_Pos:663
Relay_Log_:mysql-relay-bin.000002
Relay_Log_Pos:555
Relay_Master_Log_:mysql-bin.000001
Slave_IO_Running:Yes
Slave_SQL_Running:Yes
...

Slave_IO_Running和Slave_SQL_Running 都是Yes，說(shuō)明雙主同步配置成功。

2.1.3 KeepAlived安裝與高可用配置

在Server1與Server2兩臺(tái)節(jié)點(diǎn)安裝keepalived：

yum-yinstallkeepalived

關(guān)閉防火墻

systemctlstopfirewalld
systemctldisablefirewalld

設(shè)置主機(jī)名稱：

Server1節(jié)點(diǎn)：

hostnamectlset-hostnamevip1

Server2節(jié)點(diǎn)：

hostnamectlset-hostnamevip2

Server1節(jié)點(diǎn)配置

/etc/keepalived/keepalived.conf：

global_defs{
router_idvip1#機(jī)器標(biāo)識(shí)，和主機(jī)名保持一致，運(yùn)行keepalived服務(wù)器的一個(gè)標(biāo)識(shí)
}
vrrp_instanceVI_1{#vrrp實(shí)例定義
stateBACKUP#lvs的狀態(tài)模式，MASTER代表主，BACKUP代表備份節(jié)點(diǎn)
interfaceens33#綁定對(duì)外訪問(wèn)的網(wǎng)卡，vrrp實(shí)例綁定的網(wǎng)卡
virtual_router_id111#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority100#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
advert_int1#master與backup節(jié)點(diǎn)同步檢查的時(shí)間間隔，單位是秒
authentication{#設(shè)置驗(yàn)證信息
auth_typePASS#有PASS和AH兩種
auth_pass6666#驗(yàn)證密碼，BACKUP密碼須相同
}
virtual_ipaddress{#KeepAlived虛擬的IP地址
192.168.116.150
}
}
virtual_server192.168.116.1503306{#配置虛擬服務(wù)器IP與訪問(wèn)端口
delay_loop6#健康檢查時(shí)間
lb_algorr#負(fù)載均衡調(diào)度算法，rr代表輪詢
lb_kindDR#負(fù)載均衡轉(zhuǎn)發(fā)規(guī)則DR/NAT/
persistence_timeout0#會(huì)話保持時(shí)間，這里要做測(cè)試，所以設(shè)為0，實(shí)際可根據(jù)session有效時(shí)間配置
protocolTCP#轉(zhuǎn)發(fā)協(xié)議類型，支持TCP和UDP
real_server192.168.116.1403306{#配置服務(wù)器節(jié)點(diǎn)VIP1
notify_down/usr/local/shell/mariadb.sh#當(dāng)服務(wù)掛掉時(shí)，會(huì)執(zhí)行此腳本，結(jié)束keepalived進(jìn)程
weight1#設(shè)置權(quán)重，越大權(quán)重越高
TCP_CHECK{#狀態(tài)監(jiān)測(cè)設(shè)置
connect_timeout10#超時(shí)配置，單位秒
retry3#重試次數(shù)
delay_before_retry3#重試間隔
connect_port3306#連接端口，和上面保持一致
}
}

}

創(chuàng)建關(guān)閉腳本mariadb.sh

/usr/local/shell/mariadb.sh：

pkillkeepalived

加入執(zhí)行權(quán)限：

chmoda+xmariadb.sh

Server2節(jié)點(diǎn)配置：

global_defs{
router_idvip2#機(jī)器標(biāo)識(shí)，和主機(jī)名保持一致，運(yùn)行keepalived服務(wù)器的一個(gè)標(biāo)識(shí)
}
vrrp_instanceVI_1{#vrrp實(shí)例定義
stateBACKUP#lvs的狀態(tài)模式，MASTER代表主，BACKUP代表備份節(jié)點(diǎn)
interfaceens33#綁定對(duì)外訪問(wèn)的網(wǎng)卡
virtual_router_id111#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority98#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
advert_int1#master與backup節(jié)點(diǎn)同步檢查的時(shí)間間隔，單位是秒
authentication{#設(shè)置驗(yàn)證信息
auth_typePASS#有PASS和AH兩種
auth_pass6666#驗(yàn)證密碼，BACKUP密碼須相同
}
virtual_ipaddress{#KeepAlived虛擬的IP地址
192.168.116.150
}
}
virtual_server192.168.116.1503306{#配置虛擬服務(wù)器IP與訪問(wèn)端口
delay_loop6#健康檢查時(shí)間
lb_algorr#負(fù)載均衡調(diào)度算法，rr代表輪詢,可以關(guān)閉
lb_kindDR#負(fù)載均衡轉(zhuǎn)發(fā)規(guī)則,可以關(guān)閉
persistence_timeout0#會(huì)話保持時(shí)間，這里要做測(cè)試，所以設(shè)為0，實(shí)際可根據(jù)session有效時(shí)間配置
protocolTCP#轉(zhuǎn)發(fā)協(xié)議類型，支持TCP和UDP
real_server192.168.116.1413306{#配置服務(wù)器節(jié)點(diǎn)VIP2
notify_down/usr/local/shell/mariadb.sh#當(dāng)服務(wù)掛掉時(shí)，會(huì)執(zhí)行此腳本，結(jié)束keepalived進(jìn)程
weight1#設(shè)置權(quán)重，越大權(quán)重越高
TCP_CHECK{#r狀態(tài)監(jiān)測(cè)設(shè)置
connect_timeout10#超時(shí)配置，單位秒
retry3#重試次數(shù)
delay_before_retry3#重試間隔
connect_port3306#連接端口，和上面保持一致
}
}

}

和Server1的差異項(xiàng)：

router_idvip2#機(jī)器標(biāo)識(shí)，和主機(jī)名保持一致
priority98#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
real_server10.10.20.1263306#配置服務(wù)器節(jié)點(diǎn)VIP2

注意， 兩臺(tái)節(jié)點(diǎn)都設(shè)為BACKUP

virtual_router_id111#同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
stateBACKUP

如果不想重啟后， 爭(zhēng)奪備用節(jié)點(diǎn)的VIP， 可以設(shè)置此項(xiàng)

nopreempt#不主動(dòng)搶占資源

注意：這個(gè)配置只能設(shè)置在backup主機(jī)上，而且這個(gè)主機(jī)優(yōu)先級(jí)要比另外一臺(tái)高

驗(yàn)證高可用

停止主節(jié)點(diǎn)MariaDB服務(wù)， 驗(yàn)證是否自動(dòng)切換。

2.1.4 搭建應(yīng)用服務(wù)工程

ShardingJDBC的介紹

是ShardingSphere 下的一個(gè)產(chǎn)品

定位為輕量級(jí) Java 框架，在 Java 的 JDBC 層提供的額外服務(wù)。 它使用客戶端直連數(shù)據(jù)庫(kù)，以 jar 包形式提供服務(wù)，無(wú)需額外部署和依賴，可理解為增強(qiáng)版的 JDBC 驅(qū)動(dòng)，完全兼容 JDBC 和各種 ORM 框架。

適用于任何基于 JDBC 的 ORM 框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template 或直接使用 JDBC。

支持任何第三方的數(shù)據(jù)庫(kù)連接池，如：DBCP, C3P0, BoneCP, Druid, HikariCP 等。

支持任意實(shí)現(xiàn) JDBC 規(guī)范的數(shù)據(jù)庫(kù)，目前支持 MySQL，Oracle，SQLServer，PostgreSQL 以及任何遵循 SQL92 標(biāo)準(zhǔn)的數(shù)據(jù)庫(kù)

ShardingJDBC初始化流程

1）配置ShardingRuleConfiguration對(duì)象

2）配置表分片規(guī)則TableRuleConfiguration對(duì)象，設(shè)置分庫(kù)、分表策略

3）通過(guò)Factory對(duì)象將Rule對(duì)象與DataSource對(duì)象裝配

4）ShardingJDBC使用DataSource對(duì)象進(jìn)行分庫(kù)

ShardingJDBC集成配置

1）maven依賴

2）規(guī)則配置application.yml

3）創(chuàng)建DataSource

驗(yàn)證應(yīng)用服務(wù)動(dòng)態(tài)擴(kuò)容

//動(dòng)態(tài)數(shù)據(jù)源配置實(shí)現(xiàn)擴(kuò)容
Propertiesproperties=loadProperties("datasource1.properties");
try{
log.info("loaddatasourceconfigurl:"+properties.get("url"));
DruidDataSourcedruidDataSource=(DruidDataSource)DruidDataSourceFactory.createDataSource(properties);
druidDataSource.setRemoveAbandoned(true);
druidDataSource.setRemoveAbandonedTimeout(600);
druidDataSource.setLogAbandoned(true);
//設(shè)置數(shù)據(jù)源錯(cuò)誤重連時(shí)間
druidDataSource.setTimeBetweenConnectErrorMillis(60000);
druidDataSource.init();
OrchestrationShardingDataSourcedataSource=SpringContextUtil.getBean("tradeSystemDataSource",OrchestrationShardingDataSource.class);
MapdataSourceMap=dataSource.getDataSource().getDataSourceMap();
dataSourceMap.put(DatasourceEnum.DATASOURCE_2.getValue(),druidDataSource);

MapdataSourceConfigMap=newHashMap();
for(Stringkey:dataSourceMap.keySet()){
dataSourceConfigMap.put(key,DataSourceConfiguration.getDataSourceConfiguration(dataSourceMap.get(key)));
}
Stringresult=SHARDING_RULE_TABLE_ORDER.replace(SHARDING_RULE_DATASOURCE,newRule);
replaceActualDataNodes(result);
SHARDING_RULE_DATASOURCE=newRule;

dataSource.renew(newDataSourceChangedEvent(
"/"+DruidSystemDataSourceConfiguration.DYNAMIC_SHARDING+"/config/schema/logic_db/datasource",
dataSourceConfigMap));
return;


}catch(Exceptione){
log.error(e.getMessage(),e);
}

配置兩個(gè)數(shù)據(jù)源，分別指向Server1和Server2

分片只配置一個(gè)數(shù)據(jù)源

動(dòng)態(tài)增加另一個(gè)數(shù)據(jù)源

注意事項(xiàng)

Sharding JDBC, Mycat, Drds 等產(chǎn)品都是分布式數(shù)據(jù)庫(kù)中間件, 相比直接的數(shù)據(jù)源操作, 會(huì)存在一些限制, Sharding JDBC在使用時(shí), 要注意以下問(wèn)題:

有限支持子查詢

不支持HAVING

不支持OR，UNION 和 UNION ALL

不支持特殊INSERT

每條INSERT語(yǔ)句只能插入一條數(shù)據(jù)，不支持VALUES后有多行數(shù)據(jù)的語(yǔ)句

不支持DISTINCT聚合

不支持dual虛擬表查詢

不支持SELECT LAST_INSERT_ID(), 不支持自增序列

不支持CASE WHEN

2.2 實(shí)現(xiàn)數(shù)據(jù)庫(kù)的秒級(jí)平滑2N擴(kuò)容

擴(kuò)容部署架構(gòu)：

2.2.1 新增數(shù)據(jù)庫(kù)VIP

在Server2節(jié)點(diǎn)， 增加VIP

修改/etc/keepalived/keepalived.conf

global_defs{
router_idvip2
}
vrrp_instanceVI_1{#vrrp實(shí)例定義
stateBACKUP#lvs的狀態(tài)模式，MASTER代表主，BACKUP代表備份節(jié)點(diǎn)
interfaceens33#綁定對(duì)外訪問(wèn)的網(wǎng)卡
virtual_router_id112#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority100#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
advert_int1#master與backup節(jié)點(diǎn)同步檢查的時(shí)間間隔，單位是秒
authentication{#設(shè)置驗(yàn)證信息
auth_typePASS#有PASS和AH兩種
auth_pass6666#驗(yàn)證密碼，BACKUP密碼須相同
}
virtual_ipaddress{#KeepAlived虛擬的IP地址
192.168.116.151
}
}
virtual_server192.168.116.1513306{#配置虛擬服務(wù)器IP與訪問(wèn)端口
delay_loop6#健康檢查時(shí)間
persistence_timeout0#會(huì)話保持時(shí)間，這里要做測(cè)試，所以設(shè)為0，實(shí)際可根據(jù)session有效時(shí)間配置
protocolTCP#轉(zhuǎn)發(fā)協(xié)議類型，支持TCP和UDP
real_server192.168.116.1413306{#配置服務(wù)器節(jié)點(diǎn)VIP1
notify_down/usr/local/shell/mariadb.sh
weight1#設(shè)置權(quán)重，越大權(quán)重越高
TCP_CHECK{#r狀態(tài)監(jiān)測(cè)設(shè)置
connect_timeout10#超時(shí)配置，單位秒
retry3#重試次數(shù)
delay_before_retry3#重試間隔
connect_port3306#連接端口，和上面保持一致
}
}

}

注意配置項(xiàng)：

virtual_router_id112#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority100#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高

2.2.2 應(yīng)用服務(wù)增加動(dòng)態(tài)數(shù)據(jù)源

修改應(yīng)用服務(wù)配置， 增加新的數(shù)據(jù)源， 指向新設(shè)置的VIP： 192.168.116.151

通過(guò)應(yīng)用服務(wù)接口， 動(dòng)態(tài)擴(kuò)容調(diào)整

2.2.3 解除原雙主同步

mysql -uroot -p654321

進(jìn)入Server1:

MariaDB[(none)]>stopslave;

進(jìn)入Server2:

MariaDB[(none)]>stopslave;

通過(guò)應(yīng)用服務(wù)接口驗(yàn)證數(shù)據(jù)是否解除同步

2.2.4 安裝MariaDB擴(kuò)容服務(wù)器

新建兩臺(tái)虛擬機(jī)， 分別為Server3和Server4。

在Server3和Server4兩臺(tái)節(jié)點(diǎn)上安裝MariaDB服務(wù)

參考2.1.1 MariaDB服務(wù)安裝

配置Server3與Server1，實(shí)現(xiàn)新的雙主同步

[mysqld]
server-id=3
log-bin=mysql-bin
relay-log=mysql-relay-bin
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
log-slave-updates=on
slave-skip-errors=all
auto-increment-offset=2
auto-increment-increment=2
binlog_format=mixed
expire_logs_days=10

servicemariadbrestart

MariaDB[(none)]>grantreplicationslave,replicationclienton*.*to'replica'@'%'identifiedby'replica';
mysql>flushprivileges;

mysqldump-uroot-p654321--routines--single_transaction--master-data=2--databasessmooth>server1.sql

...
--
--Positiontostartreplicationorpoint-in-timerecoveryfrom
--

--CHANGEMASTERTOMASTER_LOG_='mysql-bin.000002',MASTER_LOG_POS=17748;
...

scpserver1.sqlroot@192.168.116.142:/usr/local/

mysql-uroot-p654321

	

	根據(jù)上面的master status信息， 在Server3中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.140',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000016',master_log_pos=1754,master_connect_retry=30;
QueryOK,0rowsaffected(0.01sec)

MariaDB[(none)]>startslave;
QueryOK,0rowsaffected(0.00sec)


	

	如果出現(xiàn)問(wèn)題， 復(fù)原主從同步信息：

	
MariaDB[(none)]>resetslave;
QueryOK,0rowsaffected(0.01sec)

MariaDB[(none)]>showslavestatusG
***************************1.row***************************
Slave_IO_State:Waitingformastertosendevent
Master_Host:10.10.20.125
Master_User:replica
Master_Port:3306
Connect_Retry:30
Master_Log_:mysql-bin.000004
Read_Master_Log_Pos:11174
Relay_Log_:mysql-relay-bin.000002
Relay_Log_Pos:1746
Relay_Master_Log_:mysql-bin.000004
Slave_IO_Running:Yes
Slave_SQL_Running:Yes


	

	查看Server3的日志信息：

	
MariaDB[(none)]>showmasterstatus;
+------------------+----------+--------------+------------------+
||Position|Binlog_Do_DB|Binlog_Ignore_DB|
+------------------+----------+--------------+------------------+
|mysql-bin.000001|4781|||
+------------------+----------+--------------+------------------+


	

	在Server1節(jié)點(diǎn)， 配置同步信息：

	
MariaDB[(none)]>resetslave;
QueryOK,0rowsaffected(0.00sec)

MariaDB[(none)]>changemastertomaster_host='192.168.116.142',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000005',master_log_pos=6931,master_connect_retry=30;

MariaDB[(none)]>startslave;
QueryOK,0rowsaffected(0.00sec)


	

	配置Server1與Server3節(jié)點(diǎn)的同步

	檢查同步狀態(tài)信息：

	開(kāi)啟主從同步：

	配置主從同步信息

	將數(shù)據(jù)還原至Server3節(jié)點(diǎn)：

	將備份的server1.sql通過(guò)scp命令拷貝至Server3節(jié)點(diǎn)。

	查看并記錄master status信息：

	在Server1節(jié)點(diǎn)，進(jìn)行數(shù)據(jù)全量備份：

	創(chuàng)建replica用于主從同步的用戶：

	重啟Server3數(shù)據(jù)庫(kù)

	Server3節(jié)點(diǎn)， 修改/etc/my.cnf:

	配置Server4與Server2的雙主同步

	
[mysqld]
server-id=4
log-bin=mysql-bin
relay-log=mysql-relay-bin
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
log-slave-updates=on
slave-skip-errors=all
auto-increment-offset=2
auto-increment-increment=2
binlog_format=mixed
expire_logs_days=10

servicemariadbrestart

MariaDB[(none)]>grantreplicationslave,replicationclienton*.*to'replica'@'%'identifiedby'replica';
mysql>flushprivileges;

mysqldump-uroot-p654321--routines--single_transaction--master-data=2--databasessmooth>server2.sql

...
--
--Positiontostartreplicationorpoint-in-timerecoveryfrom
--

--CHANGEMASTERTOMASTER_LOG_='mysql-bin.000003',MASTER_LOG_POS=4208;

...

scpserver2.sqlroot@192.168.116.143:/usr/local/

mysql-uroot-p654321

	

	根據(jù)上面的master status信息， 在Server4中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.141',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000007',master_log_pos=3006,master_connect_retry=30;
QueryOK,0rowsaffected(0.01sec)

MariaDB[(none)]>startslave;
QueryOK,0rowsaffected(0.00sec)


	

	注意， 如果出現(xiàn)問(wèn)題， 復(fù)原主從同步信息：

	
MariaDB[(none)]>resetslave;
QueryOK,0rowsaffected(0.01sec)

MariaDB[(none)]>showslavestatusG
***************************1.row***************************
Slave_IO_State:Waitingformastertosendevent
Master_Host:10.10.20.125
Master_User:replica
Master_Port:3306
Connect_Retry:30
Master_Log_:mysql-bin.000004
Read_Master_Log_Pos:11174
Relay_Log_:mysql-relay-bin.000002
Relay_Log_Pos:1746
Relay_Master_Log_:mysql-bin.000004
Slave_IO_Running:Yes
Slave_SQL_Running:Yes


	

	查看Server4的日志信息：

	
MariaDB[(none)]>showmasterstatus;
+------------------+----------+--------------+------------------+
||Position|Binlog_Do_DB|Binlog_Ignore_DB|
+------------------+----------+--------------+------------------+
|mysql-bin.000001|3696|||
+------------------+----------+--------------+------------------+


	

	在Server2節(jié)點(diǎn)， 配置同步信息：

	
MariaDB[(none)]>resetslave;
QueryOK,0rowsaffected(0.00sec)

MariaDB[(none)]>changemastertomaster_host='192.168.116.143',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000005',master_log_pos=5787,master_connect_retry=30;

MariaDB[(none)]>startslave;
QueryOK,0rowsaffected(0.00sec)


	

	配置Server2與Server4節(jié)點(diǎn)的同步

	檢查同步狀態(tài)信息：

	開(kāi)啟主從同步：

	配置主從同步信息

	將數(shù)據(jù)還原至Server4節(jié)點(diǎn)：

	將備份的server2.sql通過(guò)scp命令拷貝至Server4節(jié)點(diǎn)。

	查看并記錄master status信息：

	在Server2節(jié)點(diǎn)，進(jìn)行數(shù)據(jù)全量備份：

	創(chuàng)建replica用于主從同步的用戶：

	重啟Server4數(shù)據(jù)庫(kù)

	Server4節(jié)點(diǎn)， 修改/etc/my.cnf:

	2.2.5 增加KeepAlived服務(wù)實(shí)現(xiàn)高可用

	確保新增的Server3和Server4節(jié)點(diǎn)安裝Keepalived服務(wù)。

	修改Server3節(jié)點(diǎn)配置

	
global_defs{
router_idvip3#機(jī)器標(biāo)識(shí)，一般設(shè)為hostname，故障發(fā)生時(shí)，郵件通知會(huì)使用到。
}
vrrp_instanceVI_1{#vrrp實(shí)例定義
stateBACKUP#lvs的狀態(tài)模式，MASTER代表主，BACKUP代表備份節(jié)點(diǎn)
interfaceens33#綁定對(duì)外訪問(wèn)的網(wǎng)卡
virtual_router_id111#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority98#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
advert_int1#master與backup節(jié)點(diǎn)同步檢查的時(shí)間間隔，單位是秒
authentication{#設(shè)置驗(yàn)證信息
auth_typePASS#有PASS和AH兩種
auth_pass6666#驗(yàn)證密碼，BACKUP密碼須相同
}
virtual_ipaddress{#KeepAlived虛擬的IP地址
192.168.116.150
}
}
virtual_server192.168.116.1503306{#配置虛擬服務(wù)器IP與訪問(wèn)端口
delay_loop6#健康檢查時(shí)間
persistence_timeout0#會(huì)話保持時(shí)間，這里要做測(cè)試，所以設(shè)為0，實(shí)際可根據(jù)session有效時(shí)間配置
protocolTCP#轉(zhuǎn)發(fā)協(xié)議類型，支持TCP和UDP
real_server192.168.116.1423306{#配置服務(wù)器節(jié)點(diǎn)VIP3
notify_down/usr/local/shell/mariadb.sh
weight1#設(shè)置權(quán)重，越大權(quán)重越高
TCP_CHECK{#r狀態(tài)監(jiān)測(cè)設(shè)置
connect_timeout10#超時(shí)配置，單位秒
retry3#重試次數(shù)
delay_before_retry3#重試間隔
connect_port3306#連接端口，和上面保持一致
}
}

}


	

	注意里面IP配置正確， 修改完成后重啟服務(wù)。

	創(chuàng)建關(guān)閉腳本mariadb.sh

	/usr/local/shell/mariadb.sh：

	
pkillkeepalived


	

	加入執(zhí)行權(quán)限：

	
chmoda+xmariadb.sh


	

	修改Server4節(jié)點(diǎn)配置

	
global_defs{
router_idvip4#機(jī)器標(biāo)識(shí)，一般設(shè)為hostname，故障發(fā)生時(shí)，郵件通知會(huì)使用到。
}
vrrp_instanceVI_1{#vrrp實(shí)例定義
stateBACKUP#lvs的狀態(tài)模式，MASTER代表主，BACKUP代表備份節(jié)點(diǎn)
interfaceens33#綁定對(duì)外訪問(wèn)的網(wǎng)卡
virtual_router_id112#虛擬路由標(biāo)示，同一個(gè)vrrp實(shí)例采用唯一標(biāo)示
priority98#優(yōu)先級(jí)，100代表最大優(yōu)先級(jí)，數(shù)字越大優(yōu)先級(jí)越高
advert_int1#master與backup節(jié)點(diǎn)同步檢查的時(shí)間間隔，單位是秒
authentication{#設(shè)置驗(yàn)證信息
auth_typePASS#有PASS和AH兩種
auth_pass6666#驗(yàn)證密碼，BACKUP密碼須相同
}
virtual_ipaddress{#KeepAlived虛擬的IP地址
192.168.116.151
}
}
virtual_server192.168.116.1513306{#配置虛擬服務(wù)器IP與訪問(wèn)端口
delay_loop6#健康檢查時(shí)間
persistence_timeout0#會(huì)話保持時(shí)間，這里要做測(cè)試，所以設(shè)為0，實(shí)際可根據(jù)session有效時(shí)間配置
protocolTCP#轉(zhuǎn)發(fā)協(xié)議類型，支持TCP和UDP
real_server192.168.116.1433306{#配置服務(wù)器節(jié)點(diǎn)VIP4
notify_down/usr/local/shell/mariadb.sh
weight1#設(shè)置權(quán)重，越大權(quán)重越高
TCP_CHECK{#r狀態(tài)監(jiān)測(cè)設(shè)置
connect_timeout10#超時(shí)配置，單位秒
retry3#重試次數(shù)
delay_before_retry3#重試間隔
connect_port3306#連接端口，和上面保持一致
}
}

}


	

	創(chuàng)建關(guān)閉腳本mariadb.sh

	/usr/local/shell/mariadb.sh：

	
pkillkeepalived


	

	給所有的用戶組加入執(zhí)行權(quán)限：

	
chmoda+xmariadb.sh


	

	修改完后重啟Keepalived服務(wù)。

	2.2.6 清理數(shù)據(jù)并驗(yàn)證

	通過(guò)應(yīng)用服務(wù)動(dòng)態(tài)擴(kuò)容接口做調(diào)整和驗(yàn)證

	在Server1節(jié)點(diǎn)清理數(shù)據(jù)

	根據(jù)取模規(guī)則， 保留accountNo為偶數(shù)的數(shù)據(jù)

	
deletefromt_trade_orderwhereaccountNo%2!=0


	

	在Server2節(jié)點(diǎn)清理數(shù)據(jù)

	根據(jù)取模規(guī)則， 保留accountNo為奇數(shù)的數(shù)據(jù)

	
deletefromt_trade_orderwhereaccountNo%2!=1


	

	基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

	3.keepalived高可用配置大全

	在Server1（192.168.116.140）中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.141',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000005',master_log_pos=3207,master_connect_retry=30;


	

	在Server2（192.168.116.141）中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.140',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000012',master_log_pos=1951,master_connect_retry=30;


	

	在Server3（192.168.116.142）中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.140',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000013',master_log_pos=2781,master_connect_retry=30;
QueryOK,0rowsaffected(0.01sec)


	

	在Server4（192.168.116.143）中執(zhí)行：

	
MariaDB[(none)]>changemastertomaster_host='192.168.116.141',master_user='replica',master_password='replica',master_port=3306,master_log_='mysql-bin.000005',master_log_pos=7358,master_connect_retry=30;
QueryOK,0rowsaffected(0.01sec)


	

	Server1和Server2雙主關(guān)系

	Server1: keepalived.conf

	vi /etc/keepalived/keepalived.conf

	
global_defs{
router_idvip1
}
vrrp_instanceVI_1{
stateBACKUP
interfaceens33
virtual_router_id111
priority100
advert_int1
authentication{
auth_typePASS
auth_pass6666
}
virtual_ipaddress{
192.168.116.150
}
}
virtual_server192.168.116.1503306{
delay_loop6
lb_algorr
lb_kindDR//NAT|DR|TUN
persistence_timeout0
protocolTCP
real_server192.168.116.1403306{
notify_down/usr/local/shell/mariadb.sh
weight1
TCP_CHECK{
connect_timeout10
retry3
delay_before_retry3
connect_port3306
}
}
}


	

	Server2:keepalived.conf

	vi /etc/keepalived/keepalived.conf

	
global_defs{
router_idvip2
}
vrrp_instanceVI_1{
stateBACKUP
interfaceens33
virtual_router_id111
priority98
advert_int1
authentication{
auth_typePASS
auth_pass6666
}
virtual_ipaddress{
192.168.116.150
}
}
virtual_server192.168.116.1503306{
delay_loop6
lb_algorr
lb_kindDR
persistence_timeout0
protocolTCP
real_server192.168.116.1413306{
notify_down/usr/local/shell/mariadb.sh
weight1
TCP_CHECK{
connect_timeout10
retry3
delay_before_retry3
connect_port3306
}
}
}


	

	新增數(shù)據(jù)庫(kù)VIP

	Server2:keepalived.conf

	vi /etc/keepalived/keepalived.conf

	
global_defs{
router_idvip2
}
vrrp_instanceVI_1{
stateBACKUP
interfaceens33
virtual_router_id112
priority100
advert_int1
authentication{
auth_typePASS
auth_pass6666
}
virtual_ipaddress{
192.168.116.151
}
}
virtual_server192.168.116.1513306{
delay_loop6
persistence_timeout0
protocolTCP
real_server192.168.116.1413306{
notify_down/usr/local/shell/mariadb.sh
weight1
TCP_CHECK{
connect_timeout10
retry3
delay_before_retry3
connect_port3306
}
}
}


	

	Server1和Server3雙主關(guān)系

	Server3: keepalived.conf

	vi /etc/keepalived/keepalived.conf

	
global_defs{
router_idvip3
}
vrrp_instanceVI_1{
stateBACKUP
interfaceens33
virtual_router_id111
priority98
advert_int1
authentication{
auth_typePASS
auth_pass6666
}
virtual_ipaddress{
192.168.116.150
}
}
virtual_server192.168.116.1503306{
delay_loop6
lb_algorr
lb_kindDR
persistence_timeout0
protocolTCP
real_server192.168.116.1423306{
notify_down/usr/local/shell/mariadb.sh
weight1
TCP_CHECK{
connect_timeout10
retry3
delay_before_retry3
connect_port3306
}
}
}


	

	Server2和Server4雙主關(guān)系

	Server4: keepalived.conf

	vi /etc/keepalived/keepalived.conf

	
global_defs{
router_idvip4
}
vrrp_instanceVI_1{
stateBACKUP
interfaceens33
virtual_router_id112
priority98
advert_int1
authentication{
auth_typePASS
auth_pass6666
}
virtual_ipaddress{
192.168.116.151
}
}
virtual_server192.168.116.1513306{
delay_loop6
lb_algorr
lb_kindDR
persistence_timeout0
protocolTCP
real_server192.168.116.1433306{
notify_down/usr/local/shell/mariadb.sh
weight1
TCP_CHECK{
connect_timeout10
retry3
delay_before_retry3
connect_port3306
}
}
}

	

	審核編輯：湯梓紅