基于pxc5.7的mysql集群 mysql集群架构部署方案
yuyutoo 2024-11-08 15:40 4 浏览 0 评论
pxc集群的最大优点是高一致性,每一个节点都可以读写。因为是高一致,当向一个节点写入数据时,必须要所有节点都成功,才返回成功状态,所以,写入的性能比单一节点的数据库和主从集群的数据库略差,但对于需要高一致要求的数据,可以保证数据的安全。
注意这儿使用的是 pxc:5.7版本。此版本集群之间节点互相认证不需要证书,后面有pxc8.0基于证书的集群。
集群应该安装到多台真实的宿主机上,如果是在一台宿主上安装多个容器的集群,这种形式只能用于学习。
在多台真机上安装mysql集群时,为保证相互的通讯,可以使用--network=host宿主机网络模式,也可以先创建一个docker swarm集群,实现通过ingress在多宿主机容器之间通讯。
步1、下载镜像
下载地址:https://hub.docker.com/r/percona/percona-xtradb-cluster。
# docker pull percona/percona-xtradb-cluster:5.7
步2、创建一个独立的网络给pxc集群使用
$ docker network create -d bridge --attachable pxc-net
步3、创建三个数据卷
如果不创建数据卷,在后面启动时,也可以使用-v指定影射目录:
步4、创建三个pxc容器
参数说明:
- CLUSTER_NAME集群之间需要有相同的集群名称。
- CLUSTER_JOIN后启动的PXC目标节点的名称。默认第一个启动的PXC容器,会先创建一个PXC集群并等待后续节点加入。
- 也可以直接使用docker-compose.yml创建,效果相同。
第一个:
#!/bin/bash
docker run --name node1 -d \
-p 3301:3306 \
-v v1:/var/lib/mysql \
-e MYSQL_ROOT_PASSWORD=123456 \
-e CLUSTER_NAME=PXC \
-e XTRABACKUP_PASSWORD=123456 \
--privileged \
--network pxc-net \
percona/percona-xtradb-cluster:5.7 \
--character-set-server=utf8 --collation-server=utf8_generic_ci
第二个,注意添加join语句:
#!/bin/bash
docker run --name node2 -d \
-p 3302:3306 \
-v v2:/var/lib/mysql \
-e MYSQL_ROOT_PASSWORD=123456 \
-e CLUSTER_NAME=PXC \
-e XTRABACKUP_PASSWORD=123456 \
-e CLUSTER_JOIN=node1 \
--privileged \
--network pxc-net \
percona/percona-xtradb-cluster:5.7 \
--character-set-server=utf8 --collation-server=utf8_generic_ci
第三个,注意添加join语句:
#!/bin/bash
docker run --name node3 -di \
-p 3303:3306 \
-v v3:/var/lib/mysql \
-e MYSQL_ROOT_PASSWORD=123456 \
-e CLUSTER_NAME=PXC \
-e XTRABACKUP_PASSWORD=123456 \
-e CLUSTER_JOIN=node1 \
--privileged \
--network pxc-net \
percona/percona-xtradb-cluster:5.7 \
--character-set-server=utf8 --collation-server=utf8_generic_ci
步5、验证集群
分别通过MySql Client连接三台不同的主机,并创建数据库,创建数据表、写入数据,分别查询其他几台主机上的数据内容,如果数据已经同步,说明集群已经可以工作了:
步6、配置MySql集群的负载均衡
这儿我们使用haproxy给mysql集群做负载均衡
下载haproxy
下载地址:https://hub.docker.com/_/haproxy
docker pull haproxy
2、创建haproxy的配置文件
在任意目录下,创建一个haproxy.cfg配置文件,内容如下 :
注意,每一行如果最前面有空格,请使用4个空格,行内空格使用1个空格即可。
global
#工作目录,需要与创建容器指定的目录相同
# chroot /usr/local/etc/haproxy
#日志文件
log 127.0.0.1 local5 info
#守护进程
daemon
defaults
log global
mode http
#日志格式
option httplog
#日志中不记录负载均衡的心跳检测记录
option dontlognull
#连接超时时间毫秒
timeout connect 5000
#客户端超时
timeout client 50000
#服务器超时
timeout server 50000
#監控界面
listen admin_stats
bind 0.0.0.0:8888
mode http
stats uri /dbs_monitor
#统计报告
stats realm global\statistics
#登录账户
stats auth admin:admin
#数据负载均衡
listen proxy-mysql
#访问的ip:port
bind 0.0.0.0:3306
mode tcp
#负载均衡算法
balance roundrobin
#日志格式
option tcplog
#在mysql中创建一个没有权限的haproxy用户密码为空
#haproxy使用这个账户对mysql进行监控
option mysql-check user haproxy
server MySQL_1 node1:3306 check weight 1 maxconn 2000
server MySQL_2 node2:3306 check weight 1 maxconn 2000
server MySQL_3 node3:3306 check weight 2 maxconn 2000
option tcpka
3、创建haproxy用户
在pxc数据库上,创建haproxy用户,密码必须为空,此用户用于haproxy对mysql进行健康检查,不用授权任何权限。 登录pxc集群的任何节点,执行创建即可:
mysql> create user 'haproxy'@'%' identified by “”;
启动haproxy
8888为监控界面端口,3306为数据库端口。
-v ~/a 为包含有haproxy.cfg的配置文件的目录。
#!/bin/bash
docker run --name haproxy -d \
-p 8888:8888 -p 3306:3306 \
-v ~/a:/usr/local/etc/haproxy \
--privileged \
--network pxc-net \
haproxy
访问8888端口
地址:http://192.168.56.61:8888/dbs_monitor
测试连接
使用mysql client访3306(haproxy代理的mysql的端口)。
# mysql -uroot -p123456 -h192.168.56.61 -P3306
MYSQL>
或使用MySQLClient UI(任何可以连接mysql的ui)都可以通过haproxy 3306端口操作mysql.
连接成功:
步7、停止主节点重新启动
处理两个地方:
1: 修改主节点数据目录下grastate.dat文件,将safe_to_bootstrap修改为1。
2:添加CLUSTER_JOIN参数等于任何一个正在运行的mysql服务。
启动参数添加:
-e CLUSTER_JOIN=mysql-node2
然后再重新启动即可,启动后查询集群的状态:
show status like ‘wsrep_%’,如果显示3台服务器,就可以了:
关于safe_to_bootstrap值的说明:
一般下情况,在集群中,只会有一个pxc节点的safe_to_bootstrap值为1,即为初始化创建集群的节点,pxc集群创建成且其他节点加入成功后,任何的节点都可以执行读写,数据之间互相同步。
如果三台主机依次关闭,则最后一台关闭的主机safe_to_bootstrap的值为1,即此主机拥有最新的数据,启动时,应该先启动这个节点。
如果三台主机,同时关闭,则有可能三台主机的safe_to_bootstrap的值都是0,则只需要任何一台的safe_to_bootstrap=1,后先启动这台主机,再其他其他主机,就可以成功启动集群。
相关推荐
- 全局和隐式 using 指令详解(全局命令)
-
1.什么是全局和隐式using?在.NET6及更高版本中,Microsoft引入了...
- 请停止微服务,做好单体的模块化才是王道:Spring Modulith介绍
-
1、介绍模块化单体是一种架构风格,代码是根据模块的概念构成的。对于许多组织而言,模块化单体可能是一个很好的选择。它有助于保持一定程度的独立性,这有助于我们在需要的时候轻松过渡到微服务架构。Spri...
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
-
我是一位多年后端经验的工程师,其中前几年用ASP.NET...
- .NET AOT 详解(.net 6 aot)
-
简介AOT(Ahead-Of-TimeCompilation)是一种将代码直接编译为机器码的技术,与传统的...
- 一款基于Yii2开发的免费商城系统(一款基于yii2开发的免费商城系统是什么)
-
哈喽,我是老鱼,一名致力于在技术道路上的终身学习者、实践者、分享者!...
- asar归档解包(游戏arc文件解包)
-
要学习Electron逆向,首先要有一个Electron开发的程序的发布的包,这里就以其官方的electron-quick-start作为例子来进行一下逆向的过程。...
- 在PyCharm 中免费集成Amazon CodeWhisperer
-
CodeWhisperer是Amazon发布的一款免费的AI编程辅助小工具,可在你的集成开发环境(IDE)中生成实时单行或全函数代码建议,帮助你快速构建软件。简单来说,AmazonCodeWhi...
- 2014年最优秀JavaScript编辑器大盘点
-
1.WebstormWebStorm是一种轻量级的、功能强大的IDE,为Node.js复杂的客户端开发和服务器端开发提供完美的解决方案。WebStorm的智能代码编辑器支持JavaScript,...
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
-
项目简介:基于JS的超轻量级聊天软件。前端:vue、iview、electron实现的PC桌面版聊天程序,主要适用于私有云项目内部聊天,企业内部管理通讯等功能,主要通讯协议websocket。支持...
- JetBrains Toolbox推出全新产品订阅授权模式
-
捷克知名软件开发公司JetBrains最为人所熟知的产品是Java编程语言开发撰写时所用的集成开发环境IntelliJIDEA,相信很多开发者都有所了解。而近期自2015年11月2日起,JetBr...
- idea最新激活jetbrains-agent.jar包,亲测有效
-
这里分享一个2019.3.3版本的jetbrains-agent.jar,亲测有效,在网上找了很多都不能使用,终于找到一个可以使用的了,这里分享一下具体激活步骤,此方法适用于Jebrains家所有产品...
- CountDownTimer的理解(countdowntomars)
-
CountDownTimer是android开发常用的计时类,按照注释中的说明使用方法如下:kotlin:object:CountDownTimer(30000,1000){...
- 反射为什么性能会很慢?(反射时为什么会越来越长)
-
1.背景前段时间维护一个5、6年前的项目,项目总是在某些功能使用上不尽人意,性能上总是差一些,仔细过了一下代码发现使用了不少封装好的工具类,工具类里面用了好多的反射,反射会影响到执行效率吗?盲猜了一...
- btrace 开源!基于 Systrace 高性能 Trace 工具
-
介绍btrace(又名RheaTrace)是抖音基础技术团队自研的一款高性能AndroidTrace工具,它基于Systrace实现,并针对Systrace不足之处加以改进,核心改进...
你 发表评论:
欢迎- 一周热门
- 最近发表
-
- .NET 奇葩问题调试经历之3——使用了grpc通讯类库后,内存一直增长......
- 全局和隐式 using 指令详解(全局命令)
- 请停止微服务,做好单体的模块化才是王道:Spring Modulith介绍
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
- .NET AOT 详解(.net 6 aot)
- 一款基于Yii2开发的免费商城系统(一款基于yii2开发的免费商城系统是什么)
- asar归档解包(游戏arc文件解包)
- 在PyCharm 中免费集成Amazon CodeWhisperer
- 2014年最优秀JavaScript编辑器大盘点
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)