.netcore微服务-Mycat

时间 2019-11-10

标签 netcore 微服 mycat 繁體版

原文原文链接

1、前言

1.1 分布式数据库

随着IT行业的迅猛发展，行业应用系统的数据规模呈现爆炸式增加，对数据库的数据处理能力要求愈来愈高，分布式数据库正是所以应运而生。java

分布式数据库特色包括：mysql

透明性：用户没必要关心后台数据库的具体实现web

扩展性：可以根据系统压力状况进行扩展sql

可靠性：若是其中一台服务器宕机，备用服务器可以自动切换继续提供服务数据库

高性能：windows

1.2 Mycat介绍

Mycat（http://www.mycat.io/）是一个支持mysql、sql server等数据库集群化部署的中间件。它由Amoeba和cobar发展而来。服务器

2、负载均衡

3、测试环境

服务器负载均衡	Mycattcp	Mysql-master分布式	Mysql-slave	Mysql-master-standby	Mysql-master-standby
IP	127.0.0.1	10.3.30.161	10.3.30.238	120.77.80.215	10.3.6.84
Port	8066/9066	3306	3306	3306	3306
Account	root 123456	test 123456	test 123456	test 123456	test 123456

4、测试脚本

CREATE TABLE `employee` (

`ID` int(11) NOT NULL,

`NAME` varchar(100) default NULL,

`SHARDING_ID` int(11) NOT NULL,

PRIMARY KEY (`ID`)

)

INSERT INTO employee(ID,NAME,SHARDING_ID) VALUES ('6', 'amos', '10000');

5、软件安装

首先安装mycat-server、mycat-eye、zookeeper和navicat for mysql

6、服务启动

6.1 启动mycat

6.1.1安装java环境

一、安装jdk

二、配置环境变量

JAVA_HOME=C:\Program Files\Java\jdk1.8.0_131

CLASSPATH=.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar;

Path =%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;

6.1.2启动mycat服务

在windows8操做系统上启动mycat服务，命令以下

cmd

cd /d D:\EC-OFC\Java\Mycat\Mycat-server-1.6\mycat\bin

startup_nowrap.bat

6.1.3链接mycat

6.1.3.1navicat链接

使用navicat链接mycat，默认端口为8066，密码123456

6.1.3.2DOS连接

cmd

cd /d C:\Program Files\MySQL\MySQL Server 5.7\bin

mysql -uroot -p123456 -P8066

注意：若是须要使用如show @@datasource命令时，须要链接9066端口而不是8066

6.2 启动zookeeper

D:\EC-OFC\开发工具\zookeeper-3.4.10\bin\zkServer.bat

6.3 启动mycat-eye

D:\EC-OFC\Java\Mycat\mycat-web\start.bat

7、写集群

7.1 拓扑图

7.2 配置文件

<?xml version="1.0"?>
<!DOCTYPEmycat:schemaSYSTEM"schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

    <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
        <table name="employee" primaryKey="ID" dataNode="dn1,dn2"/>
    </schema>
    <dataNode name="dn1" dataHost="host1" database="db1"/>
    <dataNode name="dn2" dataHost="host2" database="db1"/>
    <dataHost name="host1" maxCon="1000" minCon="10" balance="1"
              writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="hostM1" url="120.77.80.215:3306" user="test" password="123456">
        </writeHost>
    </dataHost>
    <dataHost name="host2" maxCon="1000" minCon="10" balance="1"
              writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="hostM2" url="10.3.30.238:3306" user="test" password="123456">
        </writeHost>
    </dataHost>
</mycat:schema>

8、主从配置

8.1 业务要求

Master挂掉时，Slave还能提供读服务。

8.2 配置步骤

注意每台mysql服务器的server-id必须惟一

第一步：

在10.3.30.161中建立一个10.3.30.238主机中能够登陆的MySQL用户

用户：mysql238

密码：123456

mysql>GRANT REPLICATION SLAVE ON *.* TO ‘mysql238’@’10.3.30.238’ IDENTIFIED BY ‘123456’;

mysql>FLUSH PRIVILEGES;

第二步：

须要先在C:\ProgramData\MySQL\MySQL Server 5.7\my.ini文件中添加log-bin=mysql-bin

查看10.3.30.161MySQL服务器二进制文件名与位置

mysql>SHOW MASTER STATUS;

第三步：

告知二进制文件名与位置

在10.3.30.238中执行：

mysql>CHANGE MASTER TO

MASTER_HOST='10.3.30.161',

MASTER_USER='mysql238',

MASTER_PASSWORD='123456',

MASTER_LOG_FILE='mybin.000001',

MASTER_LOG_POS=154;

完成主从复制配置

8.3 验证配置

在10.3.30.238中

mysql> START SLAVE; #开启复制

mysql>SHOW SLAVE STATUS\G #查看主从复制是否配置成功

当看到Slave_IO_Running: YES、Slave_SQL_Running: YES才代表状态正常

8.4 配置文件

switchType='-1'意味着当主挂掉的时候，不进行自动切换，即hostS1并不会被提高为主，仍只提供读的功能。这就避免了将数据写进slave的可能性，单纯的MySQL主从集群并不容许将数据写进slave中，除非配置的是双master。

<mycat:schema xmlns:mycat="http://io.mycat/">
    <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
        <table name="employee" primaryKey="ID" dataNode="dn1"/>
    </schema>
    <dataNode name="dn1" dataHost="host1" database="db1"/>
    <dataHost name="host1" maxCon="1000" minCon="10" balance="1"
              writeType="0" dbType="mysql" dbDriver="native" switchType="-1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="hostM1" url="10.3.30.161:3306" user="test" password="123456">
            <readHost host="hostR1" url="120.77.80.215:3306" user="test" password="123456"/>
        </writeHost>
        <writeHost host="hostS1" url="10.3.30.238:3306" user="test" password="123456">
        </writeHost>
    </dataHost>
</mycat:schema>

9、Haproxy配置

9.1 拓扑图

9.2 配置文件

此处为haproxy配置文件

#

global
maxconn 1500
nbproc 1
daemon

defaults
        mode tcp
        retries 3
        option abortonclose
        maxconn 32000
        timeout connect 300000ms
        timeout client 300000ms
        timeout server 300000ms
        log 127.0.0.1   local0 err

listen admin_stats
        bind :48800
        stats uri /admin-status
        stats auth admin:admin
        mode http
        option httplog
listen mycat_servers
        bind :3307 ## 绑定端口
        mode tcp
        option tcplog
        #balance source
        server server238 10.3.30.238:8066 check port 8066 weight 1 check
        server server84 10.3.6.84:8066 check port 8066 weight 1 check
mysql客户端或者应用程序能够经过如上配置的127.0.0.1:3307端口连接haproxy实现连接mycat集群的目的。

10、注意事项

一、主主复制配置文件中auto_increment_increment和auto_increment_offset只能保证主键不重复，却不能保证主键有序。

二、当配置完成Slave_IO_Running、Slave_SQL_Running不全为YES时，show slave status\G信息中有错误提示，可根据错误提示进行更正。

三、Slave_IO_Running、Slave_SQL_Running不全为YES时，大多数问题都是数据不统一致使。

常见出错点：

一、两台数据库都存在db数据库，而第一台MySQL db中有tab1，第二台MySQL db中没有tab1，那确定不能成功。

二、已经获取了数据的二进制日志名和位置，又进行了数据操做，致使POS发生变动。在配置CHANGE MASTER时仍是用到以前的POS。

三、stop slave后，数据变动，再start slave。出错。

终极更正法：从新执行一遍CHANGE MASTER就行了。