mycat實現讀寫分離（一）

本文轉載自查看原文 2018-09-11 20:50 3267 mycat/ mysql/ 數據庫/ 讀寫分離

1、實現讀寫分離的方式

　　1.1 應用層實現

　　　　比如使用SpringJDBC/myBatis/Hibernate訪問數據庫時配置多數據源，這些組件會通過算法把請求分流到不同的數據源，本文不做過多說明。

　　1.2 代理實現

　　　　這種方式是在應用層和數據庫集群之間添加一個代理服務，應用層訪問代理，代理根據請求類型(讀/寫)自動分流到不同的數據庫服務器。各種分布式數據庫中間件應運而生，比如Amoeba、Atlas、Cobar、Mycat、Mysql-proxy等，Mycat繼承並發揚了

　　　　Cobar，是相對成熟開源社區較為活躍的一款數據庫中間件。

2、mycat讀寫分離配置

　　2.1 下載mycat

　　　　2016年，mycat發布了1.5版本，這是目前為止比較穩定的版本。生產環境官方還是建議使用1.5，但是本文搭建實驗環境選擇了較新的mycat1.6。下載地址：https://github.com/MyCATApache/Mycat-download

　　2.2 安裝mycat

　　　　將下載的Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz上傳至mycat服務器，執行tar -zxvf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz,解壓后如圖得到mycat根目錄。

　　　　mycat目錄結構：

　　　　bin mycat命令，啟動、重啟、停止等命令

　　　　catlet mycat的擴展功能

conf mycat相關配置文件所在目錄

　　　　lib mycat引用的jar包，mycat是Java開發的，(上述服務器中已經配置好jdk)

　　　　logs mycat日志文件所在目錄主要mycat.pid、mycat.log、wrapper.log

　　2.3 配置文件說明

　　　詳細標簽配置解釋請參照官方解釋：http://www.mycat.io/document/mycat-definitive-guide.pdf

　　2.4 實現讀寫分離的兩種方式

　　　　2.4.1 方式一：

master-slave模式
項目	mycat	MySQL-master	MySQL-master-standby	MySQL-slave
IP	192.168.153.129	192.168.153.130	192.168.153.133	192.168.153.131
PORT	8066\9066	3306	3306	3306

　　　　配置文件：server.xml　

  1 <?xml version="1.0" encoding="UTF-8"?>
  2 <!-- - - Licensed under the Apache License, Version 2.0 (the "License"); 
  3     - you may not use this file except in compliance with the License. - You 
  4     may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 
  5     - - Unless required by applicable law or agreed to in writing, software - 
  6     distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT 
  7     WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the 
  8     License for the specific language governing permissions and - limitations 
  9     under the License. -->
 10 <!DOCTYPE mycat:server SYSTEM "server.dtd">
 11 <mycat:server xmlns:mycat="http://io.mycat/">
 12     <system>
 13     <property name="useSqlStat">0</property>  <!-- 1為開啟實時統計、0為關閉 -->
 14     <property name="useGlobleTableCheck">0</property>  <!-- 1為開啟全加班一致性檢測、0為關閉 -->
 15 
 16         <property name="sequnceHandlerType">2</property>
 17       <!--  <property name="useCompression">1</property>--> <!--1為開啟mysql壓縮協議-->
 18         <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--設置模擬的MySQL版本號-->
 19     <!-- <property name="processorBufferChunk">40960</property> -->
 20     <!-- 
 21     <property name="processors">1</property> 
 22     <property name="processorExecutor">32</property> 
 23      -->
 24         <!--默認為type 0: DirectByteBufferPool | type 1 ByteBufferArena-->
 25         <property name="processorBufferPoolType">0</property>
 26         <!--默認是65535 64K 用於sql解析時最大文本長度 -->
 27         <!--<property name="maxStringLiteralLength">65535</property>-->
 28         <!--<property name="sequnceHandlerType">0</property>-->
 29         <!--<property name="backSocketNoDelay">1</property>-->
 30         <!--<property name="frontSocketNoDelay">1</property>-->
 31         <!--<property name="processorExecutor">16</property>-->
 32         <!--
 33             <property name="serverPort">8066</property> <property name="managerPort">9066</property> 
 34             <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> 
 35             <property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> -->
 36         <!--分布式事務開關，0為不過濾分布式事務，1為過濾分布式事務（如果分布式事務內只涉及全局表，則不過濾），2為不過濾分布式事務,但是記錄分布式事務日志-->
 37         <property name="handleDistributedTransactions">0</property>
 38         
 39             <!--
 40             off heap for merge/order/group/limit      1開啟   0關閉
 41         -->
 42         <property name="useOffHeapForMerge">1</property>
 43 
 44         <!--
 45             單位為m
 46         -->
 47         <property name="memoryPageSize">1m</property>
 48 
 49         <!--
 50             單位為k
 51         -->
 52         <property name="spillsFileBufferSize">1k</property>
 53 
 54         <property name="useStreamOutput">0</property>
 55 
 56         <!--
 57             單位為m
 58         -->
 59         <property name="systemReserveMemorySize">384m</property>
 60 
 61 
 62         <!--是否采用zookeeper協調切換  -->
 63         <property name="useZKSwitch">true</property>
 64 
 65 
 66     </system>
 67     
 68     <!-- 全局SQL防火牆設置 -->
 69     <!-- 
 70     <firewall> 
 71        <whitehost>
 72           <host host="127.0.0.1" user="mycat"/>
 73           <host host="127.0.0.2" user="mycat"/>
 74        </whitehost>
 75        <blacklist check="false">
 76        </blacklist>
 77     </firewall>
 78     -->
 79     
 80     <user name="root">
 81         <property name="password">mysql</property>
 82         <property name="schemas">testdb</property>
 83         <property name="readOnly">false</property>
 84         
 85         <!-- 表級 DML 權限設置 -->
 86         <!--         
 87         <privileges check="false">
 88             <schema name="TESTDB" dml="0110" >
 89                 <table name="tb01" dml="0000"></table>
 90                 <table name="tb02" dml="1111"></table>
 91             </schema>
 92         </privileges>        
 93          -->
 94     </user>
 95 
 96     <!--
 97     <user name="user">
 98         <property name="password">user</property>
 99         <property name="schemas">TESTDB</property>
100         <property name="readOnly">true</property>
101     </user>
102     -->
103 
104 </mycat:server>

　　　　配置文件：schema.xml

 1 <?xml version="1.0" encoding="utf-8"?>
 2 <!DOCTYPE mycat:schema SYSTEM "schema.dtd">
 3 
 4 <mycat:schema xmlns:mycat="http://io.mycat/">  
 5   <!-- 數據庫配置，與server.xml中的數據庫對應 -->  
 6   <schema name="testdb" checkSQLschema="true" sqlMaxLimit="100"> 
 7     <table name="travel_record" primaryKey="id" autoIncrement="true" dataNode="dn1"/> 
 8   </schema>  
 9   <!-- 分片配置 -->  
10  
11   <dataNode name="dn1" dataHost="host1" database="testdb"/>  
12   <!--
13   <dataNode name="dn2" dataHost="host2" database="testdb"/>  
14   <dataNode name="dn3" dataHost="host3" database="testdb"/>  
15   -->
16   <!-- 物理數據庫配置 -->  
17   <dataHost name="host1" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native"> 
18     <heartbeat>select user();</heartbeat>  
19     <writeHost host="M1" url="192.168.153.130:3306" user="root" password="mysql">
20        <readHost host="S1" url="192.168.153.131:3306" user="root" password="mysql"/>
21     </writeHost> 
22     <writeHost host="M2" url="192.168.153.133:3306" user="root" password="mysql"/>
23   </dataHost>
24   <!--  
25   <dataHost name="host2" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native"> 
26     <heartbeat>select user();</heartbeat>  
27     <writeHost host="M2" url="192.168.153.131:3306" user="root" password="mysql"/> 
28   </dataHost>  
29   <dataHost name="host3" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native"> 
30     <heartbeat>select user();</heartbeat>  
31     <writeHost host="M3" url="192.168.153.133:3306" user="root" password="mysql"/> 
32   </dataHost>
33   --> 
34 </mycat:schema>

　在啟動mycat之前分別在130、131、133mysq服務中創建數據庫，測試表：

 1 --創建數據庫
 2 create database testdb；
 3 --使用當前庫
 4 use testdb;
 5 --創建測試表travel_record
 6 CREATE TABLE IF NOT EXISTS `travel_record`(
 7    `id` INT(11) NOT NULL AUTO_INCREMENT,
 8    `org_code` VARCHAR(20) NOT NULL,
 9    `org_name` VARCHAR(20) DEFAULT NULL,
10    PRIMARY KEY ( `id` )
11 )ENGINE=InnoDB DEFAULT CHARSET=utf8;