mysql+mycat分片环境部署

Posted 屌丝大叔的笔记

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了mysql+mycat分片环境部署相关的知识，希望对你有一定的参考价值。

说明：

1、操作系统：64位CentOS Linux release 7.2.1511 (Core)

2、jdk版本：1.8.0_121

3、mysql版本: 5.7.17

4、两台mysql服务器：192.168.1.70（mycat将安装在这台机器上）和192.168.1.71

本文假设以上或者类似环境已经配置成功。

准备压缩文件

1、下载网址：http://www.mycat.io/

选择1.6版本，然后点击进入下载页面，如下图：

选择第一个，适合linux系统的

2、创建/soft目录：

进入192.168.1.70机器

[root@localhost soft]# mkdir /soft

利用WinSCP将下载好的tar包放入/soft目录

解压缩

解压

[root@localhost ~]# cd /soft

[root@localhost soft]# tar -zxvf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz

移动到/soft目录

[root@localhost soft]# mv mycat /usr/local/

配置环境变量

1、打开配置文件

[root@localhost bin]# vi /etc/profile

2、在文件末尾添加：

export MYCAT_HOME=/usr/local/mycat

export PATH=$PATH:$MYCAT_HOME/bin

保存并退出

3、使修改生效

[root@localhost bin]# source /etc/profile

4、测试是否生效

[root@localhost bin]# echo $MYCAT_HOME

配置主机名

[root@localhost bin]# vi /etc/hosts

拷贝以下代码到文件末尾：

192.168.1.70 server_1

192.168.1.71 server_2

保存并退出

忽略大小写

linux下部署安装mysql，表名大小写区分。

需要我们手动配置/etc/my.cnf，添加lower_case_table_names=1，使 linux 环境下 mysql 忽略表名大小写，否则使用 mycat 的时候会提示找不到。

 

因为之前配置了两台mysql服务器

192.168.1.70

192.168.1.71

所以两台都需要修改

[root@localhost soft]# vi /etc/my.cnf

将“lower_case_table_names=1”加入文件末尾，保存并退出

 

重启mysql服务

[root@localhost soft]# /etc/init.d/mysqld restart

配置schema.xml

[root@localhost conf]# vi schema.xml

将以下内容替换整个文件内容

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
    <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
        <table name="blog" primaryKey="id" dataNode="dn1,dn2" rule="mod-long" />
    </schema>
    
    <dataNode name="dn1" dataHost="server1" database="db1" />
    <dataNode name="dn2" dataHost="server2" database="db2" />
    
    <dataHost name="server1" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="server_1" url="192.168.1.70:3306" user="root" password="123456" />
    </dataHost>
    <dataHost name="server2" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="server_2" url="192.168.1.71:3306" user="root" password="123456" />
    </dataHost>
</mycat:schema>

保存并退出

配置rule.xml

因为我们就两个mysql节点，且分片规则使用的是：rule="mod-long"，所以需要修改此文件内容，将mod-long默认的3个节点修改成2个，不然mycat无法启动。

既然启动失败，那么在后面的连接mycat的步骤会报以下错误：

ERROR 2003 (HY000): Can\'t connect to MySQL server on \'192.168.1.70\' (111)

我曾在这里卡了一段时间，最终通过查看mycat的wrapper.log日志文件才找到原因的。

[root@localhost conf]# vi rule.xml

如下图：

----------------------------------------------------------------------------------

下面这段是日志文件里的错误信息，可以不看，写出来的原因是方便自己以后理解

STATUS | wrapper  | 2017/08/19 20:13:36 | TERM trapped.  Shutting down.
STATUS | wrapper  | 2017/08/19 20:13:37 | <-- Wrapper Stopped
STATUS | wrapper  | 2017/08/19 20:13:41 | --> Wrapper Started as Daemon
STATUS | wrapper  | 2017/08/19 20:13:41 | Launching a JVM...
INFO   | jvm 1    | 2017/08/19 20:13:41 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=64M; support was removed in 8.0
INFO   | jvm 1    | 2017/08/19 20:13:41 | Wrapper (Version 3.2.3) http://wrapper.tanukisoftware.org
INFO   | jvm 1    | 2017/08/19 20:13:41 |   Copyright 1999-2006 Tanuki Software, Inc.  All Rights Reserved.
INFO   | jvm 1    | 2017/08/19 20:13:41 | 
INFO   | jvm 1    | 2017/08/19 20:13:42 | 
INFO   | jvm 1    | 2017/08/19 20:13:42 | WrapperSimpleApp: Encountered an error running main: java.lang.ExceptionInInitializerError
INFO   | jvm 1    | 2017/08/19 20:13:42 | java.lang.ExceptionInInitializerError
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.MycatStartup.main(MycatStartup.java:53)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at java.lang.reflect.Method.invoke(Method.java:498)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at org.tanukisoftware.wrapper.WrapperSimpleApp.run(WrapperSimpleApp.java:240)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at java.lang.Thread.run(Thread.java:745)
INFO   | jvm 1    | 2017/08/19 20:13:42 | Caused by: io.mycat.config.util.ConfigException: Illegal table conf : table [ BLOG ] rule function [ mod-long ] partition size : 3 > table datanode size : 2, please make sure table datanode size = function partition size
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.checkRuleSuitTable(XMLSchemaLoader.java:563)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.loadTables(XMLSchemaLoader.java:396)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.loadSchemas(XMLSchemaLoader.java:173)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.load(XMLSchemaLoader.java:122)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.<init>(XMLSchemaLoader.java:83)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.loader.xml.XMLSchemaLoader.<init>(XMLSchemaLoader.java:87)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.ConfigInitializer.<init>(ConfigInitializer.java:74)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.config.MycatConfig.<init>(MycatConfig.java:72)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.MycatServer.<init>(MycatServer.java:144)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     at io.mycat.MycatServer.<clinit>(MycatServer.java:96)
INFO   | jvm 1    | 2017/08/19 20:13:42 |     ... 7 more
STATUS | wrapper  | 2017/08/19 20:13:44 | <-- Wrapper Stopped
View Code 

创建数据库

192.168.1.70对应的mysql服务器创建数据库：db1

[root@localhost soft]# /usr/local/mysql/bin/mysql -uroot -p123456

mysql> create database db1;

----------------------------------------------------------------------------------

192.168.1.71对应的mysql服务器创建数据库：db2

[root@localhost soft]# /usr/local/mysql/bin/mysql -uroot -p123456

mysql> create database db2;

启动mycat

[root@localhost ~]# mycat start

连接mycat

[root@localhost mycat]# /usr/local/mysql/bin/mysql -u root -p -P 8066 -h 192.168.1.70

如上图，表示逻辑数据库连接成功

说明：这里连接的就是逻辑数据库了

测试

1、 建表

选择逻辑数据库

mysql> use TESTDB;
CREATE TABLE blog ( 
　　id int(11) NOT NULL,
　　title varchar(20) NOT NULL, 
　　author varchar(30), 
　　PRIMARY KEY (id) 
) ENGINE=MyISAM DEFAULT CHARSET=utf8;

执行完上面的sql语句，会看到

192.168.1.70 db1下有了blog表

192.168.1.71 db2下也有了blog表

2、插入数据

insert into blog(id,title) values(1,\'test\');
insert into blog(id,title) values(2,\'test\');
insert into blog(id,title) values(3,\'test\');
insert into blog(id,title) values(4,\'test\');
insert into blog(id,title) values(5,\'test\');
insert into blog(id,title) values(6,\'test\');
insert into blog(id,title) values(7,\'test\');
insert into blog(id,title) values(8,\'test\');
insert into blog(id,title) values(9,\'test\');
insert into blog(id,title) values(10,\'test\');
insert into blog(id,title) values(11,\'test\');
insert into blog(id,title) values(12,\'test\');
insert into blog(id,title) values(13,\'test\');
insert into blog(id,title) values(14,\'test\');

3、查询

Select * from blog;

分别在server_1和server_2上执行查询语句

server_1返回的结果是：

server_2返回的结果是：

如果查询TESTDB逻辑数据库的话，出现的结果是：

好，到此大功告成，作为入门篇非常简单。

远程连接mycat

开启端口8066

[root@localhost ~]# firewall-cmd --zone=public --add-port=8066/tcp --permanent

重启防火墙

[root@localhost ~]# firewall-cmd –reload

Navicat for MySQL连接

参考文献：

http://blog.csdn.net/testcs_dn/article/details/51438216  这篇主要参考环境配置

http://maosheng.iteye.com/blog/2306937 这篇文章主要参考它的简单配置schema.xml

http://www.jb51.net/article/114290.htm 这篇文章主要参考它的简单配置schema.xml

以上是关于mysql+mycat分片环境部署的主要内容，如果未能解决你的问题，请参考以下文章

MySQL 部署分布式架构 MyCAT

MyCat 学习笔记 第十一篇.数据分片 之 分片事务处理

MyCat - 使用篇

MySQL(19) Mycat分片(分库分表)配置

MyCat 学习笔记 第十三篇.数据分片 之 通过HINT执行存储过程

mycat教程 —— mycat使用教程及分片方法案例