溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

mycat學(xué)習(xí)02--摸打滾爬之mycat主從復(fù)制于讀寫(xiě)分離(線上經(jīng)驗(yàn))

發(fā)布時(shí)間:2020-06-22 20:18:28 來(lái)源:網(wǎng)絡(luò) 閱讀:9395 作者:拎壺沖沖沖 欄目:MySQL數(shù)據(jù)庫(kù)

上一篇文章講到了mycat的安裝和配置,相信驗(yàn)證過(guò)的朋友已經(jīng)知道了,上一篇的做法已經(jīng)實(shí)現(xiàn)了主從復(fù)制與讀寫(xiě)分離的效果,這里給大家詳細(xì)說(shuō)以下讀寫(xiě)分離部分:

我的架構(gòu)還是雙主雙從架構(gòu):(試驗(yàn)環(huán)境1主一從)效果一樣,就是加幾個(gè)配置的事情,和上一篇一樣希望讀完整篇文擋,中間出現(xiàn)的錯(cuò)誤點(diǎn)后邊有說(shuō)明:


服務(wù)器IP說(shuō)明
Mycat192.168.0.2mycat服務(wù)器,連接數(shù)據(jù)庫(kù)時(shí),連接此服務(wù)器
database1192.168.0.3物理數(shù)據(jù)庫(kù)1,真正存儲(chǔ)數(shù)據(jù)的數(shù)據(jù)庫(kù)
database2192.168.0.4物理數(shù)據(jù)庫(kù)2,真正存儲(chǔ)數(shù)據(jù)的數(shù)據(jù)庫(kù)

Mycat作為主數(shù)據(jù)庫(kù)中間件,肯定是與代碼弱關(guān)聯(lián)的,所以代碼是不用修改的,使用Mycat后,連接數(shù)據(jù)庫(kù)是不變的,默認(rèn)端口是8066。連接方式和普通數(shù)據(jù)庫(kù)一樣,如:jdbc:mysql://192.168.0.2:8066/

server.xml

示例

<user name="test">
        <property name="password">test</property>  
        <property name="schemas">lunch</property>  
        <property name="readOnly">false</property>  
        
        <!-- 表級(jí) DML 權(quán)限設(shè)置 -->
        <!--                <privileges check="false">            <schema name="TESTDB" dml="0110" >                <table name="tb01" dml="0000"></table>                <table name="tb02" dml="1111"></table>            </schema>        </privileges>                -->
    </user>

重點(diǎn)關(guān)注下面這段,其他默認(rèn)即可。

參數(shù)說(shuō)明
user用戶配置節(jié)點(diǎn)
--name登錄的用戶名,也就是連接Mycat的用戶名
--password登錄的密碼,也就是連接Mycat的密碼
--schemas數(shù)據(jù)庫(kù)名,這里會(huì)和schema.xml中的配置關(guān)聯(lián),多個(gè)用逗號(hào)分開(kāi),例如需要這個(gè)用戶需要管理兩個(gè)數(shù)據(jù)庫(kù)db1,db2,則配置db1,dbs
--privileges配置用戶針對(duì)表的增刪改查的權(quán)限,具體見(jiàn)文檔吧

我這里配置了一個(gè)賬號(hào)test 密碼也是test,針對(duì)數(shù)據(jù)庫(kù)lunch,讀寫(xiě)權(quán)限都有,沒(méi)有針對(duì)表做任何特殊的權(quán)限。

schema.xml
schema.xml是最主要的配置項(xiàng),首先看我的配置文件。

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><!-- 數(shù)據(jù)庫(kù)配置,與server.xml中的數(shù)據(jù)庫(kù)對(duì)應(yīng) -->
    <schema name="lunch" checkSQLschema="false" sqlMaxLimit="100">
        <table name="lunchmenu" dataNode="dn1"  />
        <table name="restaurant" dataNode="dn1"  />
        <table name="userlunch" dataNode="dn1"  />
        <table name="users" dataNode="dn1"  />
        <table name="dictionary" primaryKey="id" autoIncrement="true" dataNode="dn1,dn2"  rule="mod-long" />

        
    </schema><!-- 分片配置 -->
    <dataNode name="dn1" dataHost="test1" database="lunch" />
    <dataNode name="dn2" dataHost="test2" database="lunch" /><!-- 物理數(shù)據(jù)庫(kù)配置 -->
    <dataHost name="test1" maxCon="1000" minCon="10" balance="0"  writeType="0" dbType="mysql" dbDriver="native">
        <heartbeat>select user();</heartbeat>
        <writeHost host="hostM1" url="192.168.0.2:3306" user="root" password="123456">  
        </writeHost>
    </dataHost>

    <dataHost name="test2" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native">
        <heartbeat>select user();</heartbeat>
        <writeHost host="hostS1" url="192.168.0.3:3306" user="root" password="123456">  
        </writeHost>
    </dataHost></mycat:schema>
參數(shù)說(shuō)明
schema數(shù)據(jù)庫(kù)設(shè)置,此數(shù)據(jù)庫(kù)為邏輯數(shù)據(jù)庫(kù),name與server.xml中schema對(duì)應(yīng)
dataNode分片信息,也就是分庫(kù)相關(guān)配置
dataHost物理數(shù)據(jù)庫(kù),真正存儲(chǔ)數(shù)據(jù)的數(shù)據(jù)庫(kù)

每個(gè)節(jié)點(diǎn)的屬性逐一說(shuō)明:

schema:

屬性說(shuō)明
name邏輯數(shù)據(jù)庫(kù)名,與server.xml中的schema對(duì)應(yīng)
checkSQLschema數(shù)據(jù)庫(kù)前綴相關(guān)設(shè)置,建議看文檔,這里暫時(shí)設(shè)為folse
sqlMaxLimitselect 時(shí)默認(rèn)的limit,避免查詢?nèi)?/td>

table:

屬性說(shuō)明
name表名,物理數(shù)據(jù)庫(kù)中表名
dataNode表存儲(chǔ)到哪些節(jié)點(diǎn),多個(gè)節(jié)點(diǎn)用逗號(hào)分隔。節(jié)點(diǎn)為下文dataNode設(shè)置的name
primaryKey主鍵字段名,自動(dòng)生成主鍵時(shí)需要設(shè)置
autoIncrement是否自增
rule分片規(guī)則名,具體規(guī)則下文rule詳細(xì)介紹

dataNode

屬性說(shuō)明
name節(jié)點(diǎn)名,與table中dataNode對(duì)應(yīng)
datahost物理數(shù)據(jù)庫(kù)名,與datahost中name對(duì)應(yīng)
database物理數(shù)據(jù)庫(kù)中數(shù)據(jù)庫(kù)名

dataHost

屬性說(shuō)明
name物理數(shù)據(jù)庫(kù)名,與dataNode中dataHost對(duì)應(yīng)
balance均衡負(fù)載的方式
writeType寫(xiě)入方式
dbType數(shù)據(jù)庫(kù)類型
heartbeat心跳檢測(cè)語(yǔ)句,注意語(yǔ)句結(jié)尾的分號(hào)要加。

應(yīng)用場(chǎng)景

數(shù)據(jù)庫(kù)分表分庫(kù)

配置如下:

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><!-- 數(shù)據(jù)庫(kù)配置,與server.xml中的數(shù)據(jù)庫(kù)對(duì)應(yīng) -->
    <schema name="lunch" checkSQLschema="false" sqlMaxLimit="100">
        <table name="lunchmenu" dataNode="dn1"  />
        <table name="restaurant" dataNode="dn1"  />
        <table name="userlunch" dataNode="dn1"  />
        <table name="users" dataNode="dn1"  />
        <table name="dictionary" primaryKey="id" autoIncrement="true" dataNode="dn1,dn2"  rule="mod-long" />

        
    </schema><!-- 分片配置 -->
    <dataNode name="dn1" dataHost="test1" database="lunch" />
    <dataNode name="dn2" dataHost="test2" database="lunch" /><!-- 物理數(shù)據(jù)庫(kù)配置 -->
    <dataHost name="test1" maxCon="1000" minCon="10" balance="0"  writeType="0" dbType="mysql" dbDriver="native">
        <heartbeat>select user();</heartbeat>
        <writeHost host="hostM1" url="192.168.0.2:3306" user="root" password="123456">  
        </writeHost>
    </dataHost>

    <dataHost name="test2" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native">
        <heartbeat>select user();</heartbeat>
        <writeHost host="hostS1" url="192.168.0.3:3306" user="root" password="123456">  
        </writeHost>
    </dataHost></mycat:schema>

我在192.168.0.2、192.168.0.3均有數(shù)據(jù)庫(kù)lunch。
lunchmenu、restaurant、userlunch、users這些表都只寫(xiě)入節(jié)點(diǎn)dn1,也就是192.168.0.2這個(gè)服務(wù),而dictionary寫(xiě)入了dn1、dn2兩個(gè)節(jié)點(diǎn),也就是192.168.0.2、192.168.0.3這兩臺(tái)服務(wù)器。分片的規(guī)則為:mod-long。
主要關(guān)注rule屬性,rule屬性的內(nèi)容來(lái)源于rule.xml這個(gè)文件,Mycat支持10種分表分庫(kù)的規(guī)則,基本能滿足你所需要的要求,這個(gè)必須贊一個(gè),其他數(shù)據(jù)庫(kù)中間件好像都沒(méi)有這么多。
table中的rule屬性對(duì)應(yīng)的就是rule.xml文件中tableRule的name,具體有哪些分表和分庫(kù)的實(shí)現(xiàn),建議還是看下文檔。我這里選擇的mod-long就是將數(shù)據(jù)平均拆分。因?yàn)槲液蠖耸莾膳_(tái)物理庫(kù),所以rule.xml中mod-long對(duì)應(yīng)的function count為2,見(jiàn)下面部分代碼:

<tableRule name="mod-long">
        <rule>
            <columns>id</columns>
            <algorithm>mod-long</algorithm>
        </rule>
    </tableRule>
    <function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        <!-- how many data nodes -->
        <property name="count">2</property>
    </function>

數(shù)據(jù)庫(kù)讀寫(xiě)分離

配置如下:

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><!-- 數(shù)據(jù)庫(kù)配置,與server.xml中的數(shù)據(jù)庫(kù)對(duì)應(yīng) -->
    <schema name="lunch" checkSQLschema="false" sqlMaxLimit="100">
        <table name="lunchmenu" dataNode="dn1"  />
        <table name="restaurant" dataNode="dn1"  />
        <table name="userlunch" dataNode="dn1"  />
        <table name="users" dataNode="dn1"  />
        <table name="dictionary" primaryKey="id" autoIncrement="true" dataNode="dn1"  />

        
    </schema><!-- 分片配置 -->
    <dataNode name="dn1" dataHost="test1" database="lunch" /><!-- 物理數(shù)據(jù)庫(kù)配置 -->
    <dataHost name="test1" maxCon="1000" minCon="10" balance="1"  writeType="0" dbType="mysql" dbDriver="native">
        <heartbeat>select user();</heartbeat>
        <writeHost host="hostM1" url="192.168.0.2:3306" user="root" password="123456">  
        <readHost host="hostM1" url="192.168.0.3:3306" user="root" password="123456">   
        </readHost>
        </writeHost>
    </dataHost></mycat:schema>

這樣的配置與前一個(gè)示例配置改動(dòng)如下:
刪除了table分配的規(guī)則,以及datanode只有一個(gè)
datahost也只有一臺(tái),但是writehost總添加了readhost,balance改為1,表示讀寫(xiě)分離。
以上配置達(dá)到的效果就是102.168.0.2為主庫(kù),192.168.0.3為從庫(kù)。

注意:Mycat主從分離只是在讀的時(shí)候做了處理,寫(xiě)入數(shù)據(jù)的時(shí)候,只會(huì)寫(xiě)入到writehost,需要通過(guò)mycat的主從復(fù)制將數(shù)據(jù)復(fù)制到readhost,這個(gè)問(wèn)題當(dāng)時(shí)候我糾結(jié)了好久,數(shù)據(jù)寫(xiě)入writehost后,readhost一直沒(méi)有數(shù)據(jù),以為是自己配置的問(wèn)題,后面才發(fā)現(xiàn)Mycat就沒(méi)有實(shí)現(xiàn)主從復(fù)制的功能,畢竟數(shù)據(jù)庫(kù)本身自帶的這個(gè)功能才是最高效穩(wěn)定的。

至于其他的場(chǎng)景,如同時(shí)主從和分表分庫(kù)也是支持的了,只要了解這個(gè)實(shí)現(xiàn)以后再去修改配置,都是可以實(shí)現(xiàn)的。而熱備及故障專業(yè)官方推薦使用haproxy配合一起使用,大家可以試試。

使用

Mycat的啟動(dòng)也很簡(jiǎn)單,啟動(dòng)命令在Bin目錄:

##啟動(dòng)mycat start##停止mycat stop##重啟mycat restart

如果在啟動(dòng)時(shí)發(fā)現(xiàn)異常,在logs目錄中查看日志。

  • wrapper.log 為程序啟動(dòng)的日志,啟動(dòng)時(shí)的問(wèn)題看這個(gè)

  • mycat.log 為腳本執(zhí)行時(shí)的日志,SQL腳本執(zhí)行報(bào)錯(cuò)后的具體錯(cuò)誤內(nèi)容,查看這個(gè)文件。mycat.log是最新的錯(cuò)誤日志,歷史日志會(huì)根據(jù)時(shí)間生成目錄保存。

mycat啟動(dòng)后,執(zhí)行命令不成功,可能實(shí)際上配置有錯(cuò)誤,導(dǎo)致后面的命令沒(méi)有很好的執(zhí)行。

Mycat帶來(lái)的最大好處就是使用是完全不用修改原有代碼的,在mycat通過(guò)命令啟動(dòng)后,你只需要將數(shù)據(jù)庫(kù)連接切換到Mycat的地址就可以了。如下面就可以進(jìn)行連接了:

 mysql -h292.168.0.1 -P8806 -uroot -p123456

連接成功后可以執(zhí)行sql腳本了。
所以,可以直接通過(guò)sql管理工具(如:navicat、datagrip)連接,執(zhí)行腳本。我一直用datagrip來(lái)進(jìn)行日常簡(jiǎn)單的管理,這個(gè)很方便。

Mycat還有一個(gè)管理的連接,端口號(hào)是9906.

 mysql -h292.168.0.1 -P9906 -uroot -p123456

連接后可以根據(jù)管理命令查看Mycat的運(yùn)行情況,當(dāng)然,喜歡UI管理方式的人,可以安裝一個(gè)Mycat-Web來(lái)進(jìn)行管理,有興趣自行搜索。

簡(jiǎn)而言之,開(kāi)發(fā)中使用Mycat和直接使用Mysql機(jī)會(huì)沒(méi)有差別。

常見(jiàn)問(wèn)題

使用Mycat后總會(huì)遇到一些坑,我將自己遇到的一些問(wèn)題在這里列一下,希望能與大家有共鳴:

  • Mycat是不是配置以后,就能完全解決分表分庫(kù)和讀寫(xiě)分離問(wèn)題?
    Mycat配合數(shù)據(jù)庫(kù)本身的復(fù)制功能,可以解決讀寫(xiě)分離的問(wèn)題,但是針對(duì)分表分庫(kù)的問(wèn)題,不是完美的解決。或者說(shuō),至今為止,業(yè)界沒(méi)有完美的解決方案。
    分表分庫(kù)寫(xiě)入能完美解決,但是,不能完美解決主要是聯(lián)表查詢的問(wèn)題,Mycat支持兩個(gè)表聯(lián)表的查詢,多余兩個(gè)表的查詢不支持。 其實(shí),很多數(shù)據(jù)庫(kù)中間件關(guān)于分表分庫(kù)后查詢的問(wèn)題,都是需要自己實(shí)現(xiàn)的,而且節(jié)本都不支持聯(lián)表查詢,Mycat已經(jīng)算做地非常先進(jìn)了。
    分表分庫(kù)的后聯(lián)表查詢問(wèn)題,大家通過(guò)合理數(shù)據(jù)庫(kù)設(shè)計(jì)來(lái)避免。

  • Mycat支持哪些數(shù)據(jù)庫(kù),其他平臺(tái)如 .net、PHP能用嗎?
    官方說(shuō)了,支持的數(shù)據(jù)庫(kù)包括MySQL、SQL Server、Oracle、DB2、PostgreSQL 等主流數(shù)據(jù)庫(kù),很贊。
    盡量用Mysql,我試過(guò)SQL Server,會(huì)有些小問(wèn)題,因?yàn)椴糠终Z(yǔ)法有點(diǎn)差異。

  • Mycat 非JAVA平臺(tái)如 .net、PHP能用嗎?
    可以用。這一點(diǎn)MyCat做的也很棒。


向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI