mysql代理、中间件技术

mysql代理、中间件技术

代理简介

名词
DB proxy 数据库中间件
功能
读写分离：读写分离导致处理速度迅速，一般情况下是主服务器进行写操作而从服务器进行读操作
负载均衡
支持数据的分片自动路由和聚合
本文主要围绕Mycat实现、且在完成MM-SS集群的条件下
实验步骤

1.配置五台虚拟机的域名解析（在之前完成的集群技术的条件下）

1. [root@mysql01 ~]# vim /etc/hosts
2. 192.168.70.33 master1
3. 192.168.70.34 master2
4. 192.168.70.35 slave1
5. 192.168.70.36 slave2
6. 192.168.70.37 mycat

复制代码

2.在mycat机器上准备好jdk
jdk官网下载地址

1. 根据上面提供的官方下载地址下载好解压
2. 解压
3. [root@mysql05 ~]# tar -zxf jdk-8u221-linux-x64.tar.gz -C /usr/local/
5. 软链接
6. [root@mysql05 ~]# ln -s /usr/local/jdk1.8.0_221 /usr/local/java
8. 配置环境变量
9. [root@mysql05 ~]# vim /etc/profile
10. JAVA_HOME=/usr/local/java
11. CLASSPATH=.:$JAVA_HOME/lib.tools.jar
12. PATH=$JAVA_HOME/bin:$PATH
13. export JAVA_HOME CLASSPATH PATH
15. [root@mysql05 ~]# source /etc/profile
16. [root@mysql05 ~]# which java
17. /usr/local/java/bin/java
19. [root@mysql05 ~]# java -version
20. java version "1.8.0_221"
21. Java(TM) SE Runtime Environment (build 1.8.0_221-b11)
22. Java HotSpot(TM) 64-Bit Server VM (build 25.221-b11, mixed mode)

复制代码

3.配置Mycat

1. [root@mysql05 ~]# wget http://dl.mycat.org.cn/1.6.7.1/Mycat-server-1.6.7.1-release-20200209222254-linux.tar.gz
3. 解压
4. [root@mysql05 ~]# tar -zxvf Mycat-server-1.6.7.6-release-20210730131311-linux.tar.gz -C /usr/local/
6. [root@mysql05 ~]# ls /usr/local/mycat/
7. bin  catlet  conf  lib  logs  version.txt

复制代码

3.1 配置mycat前端

1. 备份一下xml文件 以防我们修改错误
2. [root@mysql05 ~]# cp /usr/local/mycat/conf/server.xml .
4. [root@mysql05 ~]# vim /usr/local/mycat/conf/server.xml

复制代码

​        最下面 如下修改

3.2 配置mycat后端

1. 同样备份一下schema文件
2. [root@mysql05 ~]# cp /usr/local/mycat/conf/schema.xml .
3. [root@mysql05 ~]# vim /usr/local/mycat/conf/schema.xml

复制代码

balance为0：读写不分离
balance为1：读写分离
writeType=”0“，所有的写操作发送到配置的第一个writeHost，第一个挂了切到还生存的第二个writeHost，重新启动后以切换后的为准
writeType=”1“，均衡发送到两个服务器上
switchType='-1' 表示不自动切换
switchType='1'  默认值，表示根据延时自动切换
switchType='2'  根据MySQL主从同步的状态决定是否切换，心跳语句为show slave status

1. <?xml version="1.0"?>
2. <!DOCTYPE mycat:schema SYSTEM "schema.dtd">
3. <mycat:schema xmlns:mycat="http://io.mycat/">
5.         <schema name="mycatDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
6.         </schema>
7.         <dataNode name="dn1" dataHost="localhost1" database="mycatDB" />
8.         <dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
9.                           writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
10.                 <heartbeat>select user()</heartbeat>
11.                 <writeHost host="master1" url="master1:3306" user="mycatproxy"
12.                                    password="Xuxin_0709">
13.                         <readHost host="slave1" url="slave1:3306" user="mycatproxy" password="Xuxin_0709" />
14.                         <readHost host="slave2" url="slave2:3306" user="mycatproxy" password="Xuxin_0709" />
15.                 </writeHost>
17.                 <writeHost host="master2" url="master2:3306" user="mycatproxy"
18.                                    password="Xuxin_0709">
19.                         <readHost host="slave1" url="slave1:3306" user="mycatproxy" password="Xuxin_0709" />
20.                         <readHost host="slave2" url="slave2:3306" user="mycatproxy" password="Xuxin_0709" />
21.                 </writeHost>
22.         </dataHost>
23. </mycat:schema>

复制代码

4.配置mysql群
M-M-S-S 准备Mycat连接的用户及权限 (这里不要填详细ip 填域名mycat！)

1. 在master1上
2. mysql> create user 'mycatproxy'@'mycat' identified by 'Xuxin_0709';
4. mysql> grant all privileges on *.* to 'mycatproxy'@'mycat';
6. mysql> flush privileges;

复制代码

5.启动Mycat

1. [root@mysql05 ~]# /usr/local/mycat/bin/mycat start
2. Starting Mycat-server...
4. 查看日志 看是否存在错误
5. [root@mysql05 logs]# tail -f /usr/local/mycat/logs/wrapper.log
7. 如果看到如下错误
8. Startup failed: Timed out waiting for a signal from the JVM.
9. JVM did not exit on request, terminated
10. 可以试试编辑wrapper.conf文件
11. vim /usr/local/mycat/conf/wrapper.conf
12. 添加如下语句，增加启动时间
13. wrapper.startup.timeout=300
15. 日志无异常的话查看端口 8066 表示已经成功启动mycat了
16. [root@mysql05 ~]# netstat -tunlp
17. Active Internet connections (only servers)
18. Proto Recv-Q Send-Q Local Address           Foreign Address         State       PID/Program name   
19. tcp        0      0 0.0.0.0:22              0.0.0.0:*               LISTEN      949/sshd            
20. tcp        0      0 127.0.0.1:25            0.0.0.0:*               LISTEN      1366/master         
21. tcp        0      0 127.0.0.1:32000         0.0.0.0:*               LISTEN      10085/java         
22. tcp6       0      0 :::8066                 :::*                    LISTEN      10085/java         
23. tcp6       0      0 :::33060                :::*                    LISTEN      1004/mysqld         
24. tcp6       0      0 :::9066                 :::*                    LISTEN      10085/java         
25. tcp6       0      0 :::3306                 :::*                    LISTEN      1004/mysqld         
26. tcp6       0      0 :::40747                :::*                    LISTEN      10085/java         
27. tcp6       0      0 :::22                   :::*                    LISTEN      949/sshd            
28. tcp6       0      0 ::1:25                  :::*                    LISTEN      1366/master         
29. tcp6       0      0 :::37215                :::*                    LISTEN      10085/java         
30. tcp6       0      0 :::1984                 :::*                    LISTEN      10085/java         
31. udp        0      0 127.0.0.1:323           0.0.0.0:*                           672/chronyd         
32. udp        0      0 0.0.0.0:68              0.0.0.0:*                           746/dhclient        
33. udp6       0      0 ::1:323                 :::*                                672/chronyd         

复制代码

6.安装mariadb（mysql客户端）
注意:如果已经安装mysql服务端 可以不安装mariadb 关闭mysql服务端即可。

1. yum install mariadb -y

复制代码

7.登录mycat账号

1. [root@mysql05 ~]# mysql -hmycat -uroot -p'Xuxin_0709' -P8066;
3. mysql> show databases;  //虚拟的数据库 先不要在此数据库做任何操作！
4. +----------+
5. | DATABASE |
6. +----------+
7. | mycatDB  |
8. +----------+
9. 1 row in set (0.02 sec)

复制代码

8.先去集群创建mycatDB和表(master1)

1. mysql> create database mycatDB;
3. mysql> create table mycatDB.t1(id int(10));
5. mysql> insert into mycatDB.t1 values(1);

复制代码

9.再回到mycat机器 （如果执行sql语句卡住，试着检查授权问题，配置文件是否正确）

1. MySQL [(none)]> use mycatDB;
2. Reading table information for completion of table and column names
3. You can turn off this feature to get a quicker startup with -A
5. Database changed
6. MySQL [mycatDB]> select * from mycatDB.t1;
7. +------+
8. | id   |
9. +------+
10. |    1 |
11. +------+
12. 1 row in set (0.00 sec)

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！