Mysql Fabric高可用集群分片功能测试

一、MySQL Fabric高可用集群中一台数据库崩溃了，不影响数据的完整性

1.测试前准备

a）   查看group_id-1集群组的服务器状态

mysqlfabric group lookup_servers group_id-1

返回结果：

Command :
{ success = True
  return = [{‘status‘: ‘PRIMARY‘, ‘server_uuid‘: ‘7a45f71d-7934-11e4-9e8c-782bcb74823a‘, ‘mode‘: ‘READ_WRITE‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.71:3306‘}, {‘status‘: ‘SECONDARY‘, ‘server_uuid‘: ‘9cf162ca-7934-11e4-9e8d-782bcb1b6b98‘, ‘mode‘: ‘READ_ONLY‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.76:3306‘}, {‘status‘: ‘SECONDARY‘, ‘server_uuid‘: ‘ae94200b-7932-11e4-9e81-a4badb30e16b‘, ‘mode‘: ‘READ_ONLY‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.70:3306‘}]
  activities =
}

此时primary机为机器：192.168.1.71：3306，group_id-1集群组正常

b）   查看group_id-1集群组中的数据

mysql -P 3306 -h 192.168.1.76 -u root -e "select * from test.subscribers"
mysql -P 3306 -h 192.168.1.71 -u root -e "select * from test.subscribers"
mysql -P 3306 -h 192.168.1.70 -u root -e "select * from test.subscribers"

返回结果如下：

+--------+------------+-----------+

| sub_no | first_name | last_name |

+--------+------------+-----------+

| 500 | Billy | Joel |

| 1500 | Arthur | Askey |

| 5000 | Billy | Fish |

| 17542 | Bobby | Ball |

| 22 | Billy | Bob |

| 8372 | Banana | Man |

| 93846 | Bill | Ben |

| 15050 | John | Smith |

+--------+------------+-----------+

c）   利用python接口查看数据库test的数据表subscribers分片后的全部数据

python read_table_ha.py

返回结果如下：

(u‘Billy‘, u‘Bob‘)

(u‘Billy‘, u‘Fish‘)

(u‘Billy‘, u‘Joel‘)

(u‘Arthur‘, u‘Askey‘)

(u‘Banana‘, u‘Man‘)

(u‘Billy‘, u‘Fish‘)

(u‘Bill‘, u‘Ben‘)

(u‘Jimmy‘, u‘White‘)

(u‘John‘, u‘Smith‘)

(u‘Bobby‘, u‘Ball‘)

2.开始测试

a）  激活故障自动切换

即使Fabric选出了master角色，但当这个master角色宕机时，fanric不会自动将secondary角色切换为master角色，所以需要将HA集群组的配置改为自动切换角色

mysqlfabric group activate group_id-1

b）  停止group_id-1组中的master角色，即数据库实例192.168.1.71：3306，再查看fabric的状态

mysqlfabric group lookup_servers group_id-1

返回结果：

Command :
{ success = True
  return = [{‘status‘: ‘FAULTY‘, ‘server_uuid‘: ‘7a45f71d-7934-11e4-9e8c-782bcb74823a‘, ‘mode‘: ‘READ_WRITE‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.71:3306‘}, {‘status‘: ‘SECONDARY‘, ‘server_uuid‘: ‘9cf162ca-7934-11e4-9e8d-782bcb1b6b98‘, ‘mode‘: ‘READ_ONLY‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.76:3306‘}, {‘status‘: ‘PRIMARY‘, ‘server_uuid‘: ‘ae94200b-7932-11e4-9e81-a4badb30e16b‘, ‘mode‘: ‘READ_WRITE‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.70:3306‘}]
  activities =
}

其中，数据库实例192.168.1.71:3306的状态为FAULTY，mysql fabric自动检测到了HA组的故障，并自动选举了slave角色为primary角色

c）    查看group_id-1集群组中的数据

mysql -P 3306 -h 192.168.1.76 -u root -e "select * from test.subscribers"
mysql -P 3306 -h 192.168.1.70 -u root -e "select * from test.subscribers"

返回结果：

+--------+------------+-----------+

| sub_no | first_name | last_name |

+--------+------------+-----------+

| 500 | Billy | Joel |

| 1500 | Arthur | Askey |

| 5000 | Billy | Fish |

| 17542 | Bobby | Ball |

| 22 | Billy | Bob |

| 8372 | Banana | Man |

| 93846 | Bill | Ben |

| 15050 | John | Smith |

+--------+------------+-----------+

d）    利用python接口查看数据库test的数据表subscribers分片后的全部数据

python read_table_ha.py

返回结果：

(u‘Billy‘, u‘Bob‘)

(u‘Billy‘, u‘Fish‘)

(u‘Billy‘, u‘Joel‘)

(u‘Arthur‘, u‘Askey‘)

(u‘Banana‘, u‘Man‘)

(u‘Billy‘, u‘Fish‘)

(u‘Bill‘, u‘Ben‘)

(u‘Jimmy‘, u‘White‘)

(u‘John‘, u‘Smith‘)

(u‘Bobby‘, u‘Ball‘)

结论：由以上测试返回数据表明，当HA组（group_id-1）中的master角色崩溃，mysql fabric会自动选举一个slave角色为master，并可正常查询原来的数据，因此当mysql fabric高可用集群中某一台数据库崩溃掉，并不影响数据的完整性

PS：手工恢复FAULT状态的数据库实例

mysql fabric高可用集群中的服务器状态有四种：primary、secondary、faulty、spare

关闭primary，primary不能从组中移除，需要使用mysqlfabric group demote group_id-1来关闭组中的primary，不会重新选举一个新的master，同时也不会关闭故障检测

a）    当其中的一个数据库实例崩溃，可以将这个数据库实例从组中删除，启动这个数据库实例后再重新添加，例如：

mysqlfabric group remove group_id-1 7a45f71d-7934-11e4-9e8c-782bcb74823a
mysqlfabric group add group_id-1 192.168.1.71:3306
mysqlfabric group lookup_servers group_id-1

返回结果：

Command :
{ success = True
  return = [{‘status‘: ‘SECONDARY‘, ‘server_uuid‘: ‘7a45f71d-7934-11e4-9e8c-782bcb74823a‘, ‘mode‘: ‘READ_ONLY‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.71:3306‘}, {‘status‘: ‘SECONDARY‘, ‘server_uuid‘: ‘9cf162ca-7934-11e4-9e8d-782bcb1b6b98‘, ‘mode‘: ‘READ_ONLY‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.76:3306‘}, {‘status‘: ‘PRIMARY‘, ‘server_uuid‘: ‘ae94200b-7932-11e4-9e81-a4badb30e16b‘, ‘mode‘: ‘READ_WRITE‘, ‘weight‘: 1.0, ‘address‘: ‘192.168.1.70:3306‘}]
  activities =
}

b）    当HA组中全部的服务器宕机，实例重启后，fabric的状态不会自动恢复，需要先执行命令：mysqlfabric group demote group_id-1，因为不能直接修改server的状态由faulty为secondary，需要将状态修改为spare，在改为secondary，如下：

mysqlfabric group demote group_id-1
mysqlfabric group deactivate group_id-1
mysqlfabric server set_status 7a45f71d-7934-11e4-9e8c-782bcb74823a spare
mysqlfabric server set_status 7a45f71d-7934-11e4-9e8c-782bcb74823a secondary

###当所有的数据库实例都为secondary状态时，可选举master角色，命令如下：

mysqlfabric group promote group_id-1

二、MySQL Fabric高可用集群存储均衡

1.测试前准备

a）    测试脚本

cat test_add_subs_shards.py
import mysql.connector
from mysql.connector import fabric
import math
def add_subscriber(conn, sub_no, first_name, last_name):
    conn.set_property(tables=["test.subscribers"], key=sub_no,         mode=fabric.MODE_READWRITE)
    cur = conn.cursor()
    cur.execute(
        "INSERT INTO subscribers VALUES (%s, %s, %s)",
        (sub_no, first_name, last_name)
        )
conn = mysql.connector.connect(
    fabric={"host" : "localhost", "port" : 32274, "username": "admin",         "password" : "admin"},
    user="root", database="test", password="",
    autocommit=True
)
conn.set_property(tables=["test.subscribers"], scope=fabric.SCOPE_LOCAL)
for num in range(10):
    add_subscriber(conn, "%s" % num, "k%s" % num, "kw%s" % num)

2.开始hash分片测试

a）插入10条记录，当group_id-1组的三台服务器正常，group_id-2组只有一台服务器正常运作时，

group_id-1组的数据如下：

group_id-2组的数据如下：

b）    测试插入1万条记录，group_id-1组和group_id-2组都有三台服务器正常运作

分片后，group_id-1组插入的数据行数如下：

mysql -P 3306 -h 192.168.1.70 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 7138 |

+----------+

分片后，group_id-2组插入的数据行数如下：

mysql -P 3309 -h 192.168.1.76 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 2903 |

+----------+

c）     测试插入10万条记录，group_id-1组和group_id-2组都有三台服务器正常运作

分片后，group_id-1组插入的数据行数如下：

mysql -P 3306 -h 192.168.1.70 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 78719 |

+----------+

分片后，group_id-2组插入的数据行数如下：

mysql -P 3309 -h 192.168.1.76 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 31321 |

+----------+

d）    测试插入100万条记录，group_id-1组和group_id-2组都有三台服务器正常运作

分片后，group_id-1组插入的数据行数如下：

mysql -P 3306 -h 192.168.1.70 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 794287 |

+----------+

分片后，group_id-2组插入的数据行数如下：

mysql -P 3309 -h 192.168.1.76 -u root -e "select count(*) from test.subscribers"

返回结果：

+----------+

| count(*) |

+----------+

| 315752 |

+----------+

添加一个新HA组（group_id-3），对HA组（group_id-1）进行分片，操作如下：

a）    在机器：192.168.1.71 192.168.1.76 192.168.1.230上各起一个数据库实例，添加为组group_id-3

mysqlfabric group add group_id-3 192.168.1.71:3313
mysqlfabric group add group_id-3 192.168.1.76:3315
mysqlfabric group add group_id-3 192.168.1.230:3317

选举primary角色

mysqlfabric group promote group_id-3

b）    重置HA组group_id-3所有的数据库实例

mysql -P 3313 -h 192.168.1.71 -u root -e "reset master"
mysql -P 3315 -h 192.168.1.76 -u root -e "reset master"
mysql -P 3317 -h 192.168.1.230 -u root -e "reset master"

c）    查看HA组（group_id-1）的shard_id值，在储存机查看fabric数据库

mysql -h 127.0.0.1 -P3306 -u root -e ‘select * from fabric.shards‘

返回结果：

+----------+------------+---------+

| shard_id | group_id | state |

+----------+------------+---------+

| 4 | group_id-1 | ENABLED |

| 5 | group_id-2 | ENABLED |

+----------+------------+---------+

d）    对HA组（group_id-1）进行分片分离，将

mysqlfabric sharding split_shard 4 group_id-3

ps：如果这里执行分片不成功，错误如下：

Last_IO_Error: Got fatal error 1236 from master when reading data from binary log: ‘could not find next log; the first event ‘‘ at 4, the last event read from ‘./binlog.000003‘ at 621, the last byte read from ‘./binlog.000003‘ at 621.‘

解决方法：

将master角色的数据dump出来，如下：

mysqldump -h 192.168.1.76 -u root -P3315 --all-databases --flush-privileges --single-transaction --flush-logs --triggers --routines --events --hex-blob >/data/database/full_backup_master.sql

停掉slave机

mysql -P 3317 -h 192.168.1.230 -u root -e "stop slave"
mysql -P 3317 -h 192.168.1.230 -u root -e "reset master"
mysql -P 3317 -h 192.168.1.230 -u root </data/full_backup_master.sql
mysql -P 3317 -h 192.168.1.230 -u root -e "start slave"

再次执行分片，会报以下错误：

Procedure :
{ uuid = 4da230c2-31c3-4242-bd88-ccafd51bfac1,
  finished = True,
  success = False,
  return = BackupError: (‘Error while restoring the backup using the mysql client\n, %s‘, "ERROR 1840 (HY000) at line 24 in file: ‘MySQL_192.168.1.76_3306.sql‘: @@GLOBAL.GTID_PURGED can only be set when @@GLOBAL.GTID_EXECUTED is empty.\n"),
  activities =
}

解决方法：

在HA组（group_id-3）的全部数据库实例上执行“reset master”，再分片即可

e)    现在HA组有group_id-1、group_id-2、group_id-3，尝试插入100条记录

group_id-1的插入的数据行数有：

mysql -P 3306 -h 192.168.1.70 -u root -e "select count(*) from test.subscribers where sub_no between 20000 and 20100"

返回结果：

+----------+

| count(*) |

+----------+

| 70 |

+----------+

group_id-2、group_id-3的插入的数据行数有：

mysql -P 3309 -h 192.168.1.76 -u root -e "select count(*) from test.subscribers where sub_no between 20000 and 20100"
mysql -P 3313 -h 192.168.1.230 -u root -e "select count(*) from test.subscribers where sub_no between 20000 and 20100"

返回结果：

+----------+

| count(*) |

+----------+

| 30 |

+----------+

用select语句可知，HA组group_id-2、group_id-3插入的数据是一样的

3.hash分片测试结论

在插入1万条记录时，HA组（group_id-1）插入了7138条记录，HA组（group_id-2）插入了2903条记录

在插入10万条记录时，HA组（group_id-1）插入了78719条记录，HA组（group_id-2）插入了31321条记录

在插入100万条记录时，HA组（group_id-1）插入了794287条记录，HA组（group_id-2）插入了315752条记录

因此，对mysql fabric高集群进行hash分片后，分片比例为7:3，负载并不是十分均衡

三、调查PHP、Erlang等语言如何连接MySQL Fabric

目前Fabric提供了Php, Java, Python三大类的API，大家可以通过编程的方式来操作Fabric。

python脚本如上面所示

Connector/Python:http://dev.mysql.com/doc/mysql-utilities/1.5/en/connector-python-fabric.html

Connector/J:http://dev.mysql.com/doc/mysql-utilities/1.5/en/connector-j-fabric.html

Connector:http://php.net/manual/zh/book.mysqlnd-ms.php

时间： 2024-10-07 07:27:46

Mysql Fabric高可用集群分片功能测试的相关文章

CoroSync + Drbd + MySQL 实现MySQL的高可用集群

Corosync + DRBD + MySQL 构建高可用MySQL集群 节点规划: node1.huhu.com172.16.100.103 node2.huhu.com172.16.100.104 资源名称规划 资源名称:可以是除了空白字符外的任意ACSII码字符 DRBD设备:在双节点上,此DRBD设备文件,一般为/dev/drbdN,主设备号147 磁盘:在双方节点上,各自提供存储设备 网络配置:双方数据同步所使用的网络属性 DRBD从Linux内核2.6.33起已经整合进内核 1.配置

基于keepalived搭建MySQL的高可用集群

http://www.cnblogs.com/ivictor/p/5522383.html 基于keepalived搭建MySQL的高可用集群 MySQL的高可用方案一般有如下几种: keepalived+双主,MHA,MMM,Heartbeat+DRBD,PXC,Galera Cluster 比较常用的是keepalived+双主,MHA和PXC. 对于小公司,一般推荐使用keepalived+双主,简单. 下面来部署一下 配置环境: 角色                          

使用drbd结合corosync实现mysql的高可用集群服务

DRBD:Distributed Replicated Block Dvice 分布式复制块设备,它可以将两个主机的硬盘或者分区做成镜像设备,类似于RAID1的原理,只不过它会将主节点的数据主动通过网络同步到从节点做成镜像,当主节点发生故障,让从节点成为主节点,因为是镜像设备,所以数据不会丢失.corosync在这里的作用就是将drbd通过pacemaker做成高可用服务的资源,以便于主从节点间的自动切换.drbd由于使用各节点之间自身的硬盘设备,因此对于需要共享存储的场景不失为一种节约成本的解

【mysql】高可用集群之MMM

一.复制的常用拓扑结构 复制的体系结构有以下一些基本原则: (1)    每个slave只能有一个master: (2)    每个slave只能有一个唯一的服务器ID: (3)    每个master可以有很多slave: (4)    如果你设置log_slave_updates,slave可以是其它slave的master,从而扩散master的更新. MySQL不支持多主服务器复制(Multimaster Replication)——即一个slave可以有多个master.但是,通过一些

Mysql MHA高可用集群架构

记得之前发过一篇文章,名字叫<浅析MySQL高可用架构>,之后一直有很多小伙伴在公众号后台或其它渠道问我,何时有相关的深入配置管理文章出来,因此,民工哥,也将对前面的各类架构逐一进行整理,然后发布出来.那么今天将来发布的MHA的架构整体规划与配置操作. 简单介绍MHA(Master High Availability)目前在MySQL高可用方面是一个相对成熟的解决方案,作为MySQL高可用性环境下故障切换和主从提升的高可用软件.在MySQL故障切换过程中,MHA能做到在0~30秒之内自动完成数

Corosync+Pacemaker+DRBD+MySQL实现MySQL的高可用集群

一.Corosync概述 1.什么是AIS和OpenAIS? AIS是应用接口规范,是用来定义应用程序接口(API)的开放性规范的集合,这些应用程序作为中间件为应用服务提供一种开放.高移植性的程序接口.是在实现高可用应用过程中是亟需的.服务可用性论坛(SA Forum)是一个开放性论坛,它开发并发布这些免费规范.使用AIS规范的应用程序接口(API),可以减少应用程序的复杂性和缩短应用程序的开发时间,这些规范的主要目的就是为了提高中间组件可移植性和应用程序的高可用性. OpenAIS是基于SA

各种报错，搭建Mysql MHA高可用集群时踩的各种坑

mha下载地址,需要翻墙 https://code.google.com/p/mysql-master-ha/ 管理软件 mha4mysql-manager-0.52-0.noarch.rpm 节点软件 mha4mysql-node-0.52-0.noarch.rpm 环境介绍 Centos6.7 X64 192.168.30.210 monitor 192.168.30.211 db1 (master) 192.168.30.212 db2  (备master) 192.168.30.213 

heatbeat-gui实现基于nfs的mysql高可用集群

一.简述HA高可用集群 高可用集群就是当集群中的一个节点发生各种软硬件及人为故障时,集群中的其他节点能够自动接管故障节点的资源并向外提供服务.以实现减少业务中断时间,为用户提供更可靠,更高效的服务. 二.基于nfs实现mysql的高可用集群配置 环境准备接上文 heartbeat-gui部署 实验环境: nfs server准备 1.在nfs server准备LVM存储空间 [[email protected] ~]# fdisk /dev/sdb Device contains neither

企业主流MySQL高可用集群架构三部曲之PXC

前段时间,老张给大家介绍了企业中主流MySQL高可用集群架构三部曲中的前两部,有不了解的同学可以去访问我之前的博客内容. 第一部曲直通车>> 企业中MySQL主流高可用架构实战三部曲之MHA 第二部曲直通车>>企业中MySQL高可用集群架构三部曲之MM+keepalived 独家新课程上线>>MySQL体系结构深入剖析及实战DBA视频课程 今儿给大家介绍最后一部曲,是percona公司的percona xtraDB cluster.简称PXC.它是基于GaLera协议的