搜索
首页数据库mysql教程MySQL Proxy 实现MySQLDB 读写分离

一、简述

MySQL Proxy是一个处于你的client端和MySQL server端之间的简单程序,它可以监测、分析或改变它们的通信。它使用灵活,没有限制,常见的用途包括:负载平衡,故障、查询分析,查询过滤和修改等等。

MySQL Proxy就是这么一个中间层代理,简单的说,MySQL Proxy就是一个连接池,负责将前台应用的连接请求转发给后台的数据库,并且通过使用lua脚本,可以实现复杂的连接控制和过滤,从而实现读写分离和负 载平衡。对于应用来说,MySQL Proxy是完全透明的,应用则只需要连接到MySQL Proxy的监听端口即可。当然,这样proxy机器可能成为单点失效,但完全可以使用多个proxy机器做为冗余,在应用服务器的连接池配置中配置到多 个proxy的连接参数即可。

MySQL Proxy更强大的一项功能是实现“读写分离”,基本原理是让主数据库处理事务性查询,让从库处理SELECT查询。数据库复制被用来把事务性查询导致的变更同步到集群中的从库。

二、对MariaDB做主从复制

关于如何对MariaDB做主从复制,请移步本人博客MariaDB 主从复制 

三、安装

   1.可以通过rpm安装,其会提供配置文件及服务脚本,但是没有读写分享脚本

 2.通过编译安装

①、源码安装时,MySQL proxy的依赖关系:    

           libevent 1.x or higher (1.3b or later is preferred).

           lua 5.1.x or higher.

           glib2 2.6.0 or higher.

           pkg-config.

           libtool 1.5 or higher.

           MySQL 5.0.x or higher developer files.

       ②、下载源码包,编译安装

# tar zxf mysql-proxy-0.8.2.tar.gz# cd mysql-proxy-0.8.2# ./configure# make# make check如果管理员有密码,上面的步骤则需要使用如下格式进行:# MYSQL_PASSWORD=root_pwd make check# make install默认情况下, mysql-proxy安装在/usr/local/sbin/mysql-proxy,而Lua示例脚本安装在/usr/local/share目录中。

3.通过通用二进制格式安装

①、下载解压。这里的系统平台为rhel6.5 64位系统

[root@httpweb ~]# wget http://mirror.sohu.com/mysql/MySQL-Proxy/mysql-proxy-0.8.4-linux-el6-x86-64bit.tar.gz[root@httpweb ~]# tar xf mysql-proxy-0.8.4-linux-el6-x86-64bit.tar.gz[root@httpweb ~]# mv mysql-proxy-0.8.4-linux-el6-x86-64bit /usr/local/mysql-proxy

②、添加代理用户

[root@httpweb mysql-proxy]# useradd mysql-proxy

 ③、为mysql-proxy提供SysV服务脚本

#!/bin/bash## mysql-proxy This script starts and stops the mysql-proxy daemon## chkconfig: - 78 30# processname: mysql-proxy# description: mysql-proxy is a proxy daemon for mysql# Source function library.. /etc/rc.d/init.d/functionsprog="/usr/local/mysql-proxy/bin/mysql-proxy"# Source networking configuration.if [ -f /etc/sysconfig/network ]; then	. /etc/sysconfig/networkfi# Check that networking is up.[ ${NETWORKING} = "no" ] && exit 0# Set default mysql-proxy configuration.ADMIN_USER="admin"ADMIN_PASSWD="admin"ADMIN_LUA_SCRIPT="/usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua"PROXY_OPTIONS="--daemon"PROXY_PID=/var/run/mysql-proxy.pidPROXY_USER="mysql-proxy"# Source mysql-proxy configuration.if [ -f /etc/sysconfig/mysql-proxy ]; then	. /etc/sysconfig/mysql-proxyfiRETVAL=0start() {	echo -n $"Starting $prog: "	daemon $prog $PROXY_OPTIONS --pid-file=$PROXY_PID --proxy-address="$PROXY_ADDRESS" --user=$PROXY_USER --admin-username="$ADMIN_USER" --admin-lua-script="$ADMIN_LUA_SCRIPT" --admin-password="$ADMIN_PASSWORD"	RETVAL=$?	echo	if [ $RETVAL -eq 0 ]; then		touch /var/lock/subsys/mysql-proxy	fi}stop() {	echo -n $"Stopping $prog: "	killproc -p $PROXY_PID -d 3 $prog	RETVAL=$?	echo	if [ $RETVAL -eq 0 ]; then		rm -f /var/lock/subsys/mysql-proxy		rm -f $PROXY_PID	fi}# See how we were called.case "$1" in	start)		start		;;	stop)		stop		;;	restart)		stop		start		;;	condrestart|try-restart)		if status -p $PROXY_PIDFILE $prog >&/dev/null; then			stop			start		fi		;;	status)		status -p $PROXY_PID $prog		;;	*)		echo "Usage: $0 {start|stop|restart|reload|status|condrestart|try-restart}"		RETVAL=1		;;esacexit $RETVAL

将上述内容保存为/etc/init.d/mysql-proxy,给予执行权限,而后添加至服务列表

[root@httpweb mysql-proxy]# vi /etc/init.d/mysql-proxy[root@httpweb mysql-proxy]# chmod +x /etc/init.d/mysql-proxy[root@httpweb mysql-proxy]# chkconfig --add mysql-proxy

④、为服务脚本提供配置文件/etc/sysconfig/mysql-proxy

#Options for mysql-proxyADMIN_USER="firefox"ADMIN_PASSWORD="firefox"ADMIN_ADDRESS=""ADMIN_LUA_SCRIPT="/usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua"PROXY_ADDRESS=""PROXY_USER="mysql-proxy"PROXY_OPTIONS="--daemon --log-level=info --log-use-syslog --plugins=proxy --plugins=admin --proxy-backend-addresses=192.168.1.200:3306 --proxy-read-only-backend-addresses=192.168.1.202:3306 --proxy-lua-script=/usr/local/mysql-proxy/share/doc/mysql-proxy/rw-splitting.lua"其中的proxy-backend-addresses选项和proxy-read-only-backend-addresses选项均可重复使用多次,以实现指定多个读写服务器或只读服务器。

⑤、mysql-proxy的配置选项

mysql-proxy的配置选项大致可分为帮助选项、管理选项、代理选项及应用程序选项几类,下面一起去介绍它们。	--help	--help-admin	--help-proxy	--help-all ———— 以上四个选项均用于获取帮助信息;	--proxy-address=host:port ———— 代理服务监听的地址和端口;	--admin-address=host:port ———— 管理模块监听的地址和端口;	--proxy-backend-addresses=host:port ———— 后端mysql服务器的地址和端口;	--proxy-read-only-backend-addresses=host:port ———— 后端只读mysql服务器的地址和端口;	--proxy-lua-script=file_name ———— 完成mysql代理功能的Lua脚本;	--daemon ———— 以守护进程模式启动mysql-proxy;	--keepalive ———— 在mysql-proxy崩溃时尝试重启之;	--log-file=/path/to/log_file_name ———— 日志文件名称;	--log-level=level ———— 日志级别;	--log-use-syslog ———— 基于syslog记录日志;	--plugins=plugin,.. ———— 在mysql-proxy启动时加载的插件;	--user=user_name ———— 运行mysql-proxy进程的用户;	--defaults-file=/path/to/conf_file_name ———— 默认使用的配置文件路径;其配置段使用[mysql-proxy]标识;	--proxy-skip-profiling ———— 禁用profile;	--pid-file=/path/to/pid_file_name ———— 进程文件名; 

⑥、提供admin.lua文件,将其保存至/usr/local/mysql-proxy/share/mysql-proxy/中

--[[ $%BEGINLICENSE%$ Copyright (c) 2007, 2012, Oracle and/or its affiliates. All rights reserved. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; version 2 of the License. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301USA $%ENDLICENSE%$ --]]function set_error(errmsg)	proxy.response = {		type = proxy.MYSQLD_PACKET_ERR,		errmsg = errmsg or "error"	}endfunction read_query(packet)	if packet:byte() ~= proxy.COM_QUERY then		set_error("[admin] we only handle text-based queries (COM_QUERY)")		return proxy.PROXY_SEND_RESULT	end	local query = packet:sub(2)	local rows = { }	local fields = { }	if query:lower() == "select * from backends" then		fields = {			{ name = "backend_ndx",			type = proxy.MYSQL_TYPE_LONG },			{ name = "address",			type = proxy.MYSQL_TYPE_STRING },			{ name = "state",			type = proxy.MYSQL_TYPE_STRING },			{ name = "type",			type = proxy.MYSQL_TYPE_STRING },			{ name = "uuid",			type = proxy.MYSQL_TYPE_STRING },			{ name = "connected_clients",			type = proxy.MYSQL_TYPE_LONG },		}		for i = 1, #proxy.global.backends do			local states = {				"unknown",				"up",				"down"			}			local types = {				"unknown",				"rw",				"ro"			}			local b = proxy.global.backends[i]			rows[#rows + 1] = {				i,				b.dst.name,	-- configured backend address				states[b.state + 1], -- the C-id is pushed down starting at 0				types[b.type + 1], -- the C-id is pushed down starting at 0				b.uuid,	-- the MySQL Server's UUID if it is managed				b.connected_clients-- currently connected clients			}		end	elseif query:lower() == "select * from help" then		fields = {			{ name = "command",			type = proxy.MYSQL_TYPE_STRING },			{ name = "description",			type = proxy.MYSQL_TYPE_STRING },		}		rows[#rows + 1] = { "SELECT * FROM help", "shows this help" }		rows[#rows + 1] = { "SELECT * FROM backends", "lists the backends and their state" }	else		set_error("use 'SELECT * FROM help' to see the supported commands")		return proxy.PROXY_SEND_RESULT	end	proxy.response = {		type = proxy.MYSQLD_PACKET_OK,		resultset = {			fields = fields,			rows = rows		}	}	return proxy.PROXY_SEND_RESULTend

 ⑦、测试

启动服务;

service mysql-proxy start

管理功能测试      

wKiom1NOlV_BSlwLAABNBtSUtm0691.jpg

可以看到4041端口和3306端口以及处于监听状态

我们在主服务器上授予201数据库写的权限

MariaDB [(none)]>grant all on *.* to 'firefox'@'192.168.1.201' identified by 'firefox';MariaDB [(none)]> flush privileges;[root@httpweb mysql-proxy]# mysql -ufirefox -pfirefox -h192.168.1.201 --port=3306我们可以看到我们在mysql-proxy的可以登录数据库了

查看是否配置成功   

[root@httpweb ~]# mysql -ufirefox -pfirefox -h192.168.1.201 --port=4041Welcome to the MySQL monitor.Commands end with ; or /g.Your MySQL connection id is 1Server version: 5.0.99-agent-adminCopyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved.Oracle is a registered trademark of Oracle Corporation and/or itsaffiliates. Other names may be trademarks of their respectiveowners.mysql> select * from backends;+-------------+--------------------+---------+------+------+-------------------+| backend_ndx | address| state | type | uuid | connected_clients |+-------------+--------------------+---------+------+------+-------------------+| 1 | 192.168.1.200:3306 | up| rw | NULL | 0 || 2 | 192.168.1.202:3306 | up| ro | NULL | 0 |+-------------+--------------------+---------+------+------+-------------------+

我们的程序就可以实现真正意义上的读写分离了,大功告成,由于本人水平有限,请各位大神多多批评指正

声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
ace-guard client exe是什么程序ace-guard client exe是什么程序Sep 22, 2021 pm 06:07 PM

ace-guard client exe是腾讯代理游戏的反作弊程序,是ewido的守护进程,保护“ewido.exe”进程不被恶意软件关闭;使用它可以检测游戏用户是否有开挂行为,可自动进行封号处理。

修复: 操作员拒绝 Windows 任务计划程序中的请求错误修复: 操作员拒绝 Windows 任务计划程序中的请求错误Aug 01, 2023 pm 08:43 PM

要自动化任务和管理多个系统,任务计划软件是您武器库中的宝贵工具,尤其是对于系统管理员而言。Windows任务计划程序完美地完成了这项工作,但最近许多人报告说操作员拒绝了请求错误。该问题存在于操作系统的所有迭代中,即使已经广泛报告和涵盖,也没有有效的解决方案。继续阅读以找到真正对其他人有用的内容!操作员或管理员拒绝了任务计划程序0x800710e0中的请求是什么?任务计划程序允许在没有用户输入的情况下自动执行各种任务和应用程序。您可以使用它来安排和组织特定应用程序、配置自动通知、帮助传递消息等。它

如何在Windows 10和11上按面部对照片进行排序如何在Windows 10和11上按面部对照片进行排序Aug 08, 2023 pm 10:41 PM

Windows的操作随着每个版本而变得越来越好,具有诱人的功能来改善用户体验。用户希望在Windows10和11上探索的一项功能是能够按面部对照片进行排序。此功能允许您通过面部识别对朋友和家人的照片进行分组。听起来很有趣,对吧?继续阅读如何了解如何利用该功能。我可以在Windows上按面孔对照片进行分组吗?是的,您可以使用“照片”应用在Windows10和11上按人脸对图片进行分组。但是,此功能在照片应用程序版本上不可用。此外,您可以使用“人脉”选项卡将这些照片链接到联系人。因此,使用此功能可以

如何自动切换特定应用程序的iPhone方向锁定如何自动切换特定应用程序的iPhone方向锁定Jun 06, 2023 am 08:22 AM

在iOS中,当您将iPhone从纵向旋转到横向时,许多App会显示不同的视图。根据应用程序及其使用方式,这种行为并不总是可取的,这就是Apple在“控制中心”中包含方向锁定选项的原因。但是,某些应用程序在禁用方向锁定的情况下工作得更有用-想想YouTube或照片应用程序,将设备旋转到横向可以提供更好的全屏观看体验。如果您倾向于保持锁定状态,则必须在每次打开这些类型的应用程序时在“控制中心”中禁用它以获得全屏体验。然后,当您关闭应用程序时,您必须记住重新打开方向锁定,这并不理想。幸运的是,您可以创

microsoft visual c++可以卸载吗?microsoft visual c++可以卸载吗?Sep 14, 2022 am 11:36 AM

“microsoft visual c++”是可以卸载的,但是不建议卸载;“microsoft visua”这些都是一些微软的组件,里面包括一些“C++”标准库、原始数据库等相关信息,很多软件尤其是游戏中需要“microsoft visual c++”中的环境组件,如果缺少了“C++”标准库的支持,可能会造成软件的无法运行。

卸载程序的文件名是什么卸载程序的文件名是什么Oct 21, 2022 pm 02:05 PM

卸载程序的文件名是“uninstall.exe”或“uninst.exe”,是用以协助使用者将软件自电脑中删除的一种电脑软件。使用方法:1、在文件资源管理器中挖掘并导航到应用程序EXE文件所在的文件路径;2、通过文件路径打开应用程序的安装目录,找到“uninstall.exe”文件;3、双击卸载文件“uninstall.exe”即可开始程序删除过程。

如何从Microsoft商店快速卸载应用如何从Microsoft商店快速卸载应用Jul 12, 2023 pm 09:25 PM

Microsoft应用商店是内置存储库,用户可以在其中下载、更新和卸载适用于Windows操作系统的应用。可悲的是,许多用户不知道如何在MicrosoftStore上卸载应用程序。因此,本文将带您了解如何快速从Microsoft商店卸载应用程序。或者,如果您的Windows11PC上缺少Microsoft应用商店应用程序,我们提供了有关下载和安装应用商店应用程序的详细指南。是否可以直接从Microsoft应用商店卸载应用?否,Microsoft应用商店不提供直接从平台卸载应用的选项。您只能通过平

C语言中的身份矩阵程序C语言中的身份矩阵程序Aug 30, 2023 am 10:45 AM

给定一个方阵M[r][c],其中“r”是一定数量的行,“c”是列,使得r=c,我们必须检查“M”是否是单位矩阵。恒等矩阵恒等矩阵也称为大小为nxn方阵的单位矩阵,其中对角元素的整数值为1,非对角元素的整数值为0就像下面给定的示例-$$I1=\begin{bmatrix}1\end{bmatrix},\I2=\begin{bmatrix}1&0\0&1\end{bmatrix},\I3=\begin{bmatrix}1&0&0\0&1&0\0&

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
3 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
3 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
3 周前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解锁Myrise中的所有内容
3 周前By尊渡假赌尊渡假赌尊渡假赌

热工具

EditPlus 中文破解版

EditPlus 中文破解版

体积小,语法高亮,不支持代码提示功能

安全考试浏览器

安全考试浏览器

Safe Exam Browser是一个安全的浏览器环境,用于安全地进行在线考试。该软件将任何计算机变成一个安全的工作站。它控制对任何实用工具的访问,并防止学生使用未经授权的资源。

mPDF

mPDF

mPDF是一个PHP库,可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件,并处理不同的语言。与原始脚本如HTML2FPDF相比,它的速度较慢,并且在使用Unicode字体时生成的文件较大,但支持CSS样式等,并进行了大量增强。支持几乎所有语言,包括RTL(阿拉伯语和希伯来语)和CJK(中日韩)。支持嵌套的块级元素(如P、DIV),

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

螳螂BT

螳螂BT

Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。