基于mysql-proxy实现读写分离的启动脚本

Posted 2020-08-02

#!/bin/bash
#
#chkconfig: 2345 94 06
#
. /etc/rc.d/init.d/functions

#加载脚本配置文件，提供变量值
if [ -e /usr/mysql-proxy.conf ] ; then
	. /usr/mysql-proxy.conf
fi

#查看是否安装mysql-proxy软件
if ! `cd /usr/local/mysql-proxy > /dev/null` ; then
		tar xf /root/$VER -C /usr/local/
		ln -s /usr/local/mysql-proxy-0.8.5-linux-glibc2.3-x86-32bit /usr/local/mysql-proxy
	fi

start() {
	/usr/local/mysql-proxy/bin/mysql-proxy --daemon --log-level=$LOGLEVEL --log-file="$LOGFILE" --plugins=‘proxy‘ --proxy-backend-addresses="$MASTERADDR" --proxy-read-only-backend-addresses="$SLAVEADDR" --proxy-lua-script=‘$PROXYLUA‘ --plugins=‘admin‘ --admin-username="$ADMINUSER" --admin-password="$PASSWD" --admin-lua-script="$ADMINLUA"
}

stop() {
	killall mysql-proxy
}

#查看代理运行状态时，需保证本机装有mysql客户端程序
status() {
	mysql -u$ADMINUSER -h$PROXYADDR -p$PASSWD --port=$ADMINPORT -e"select * from backends"
}

test() {
	if `netstat -ntpl | grep ‘mysql-proxy‘ > /dev/null` ; then
		STAT=OK
	else
		STAT=FAULT
	fi
}
case $1 in
	start)
		start
		test
		echo "Start mysql-proxy...[$STAT]"
	;;
	stop)
		stop
		echo "stop mysql-proxy...[OK]"
	;;
	restart)
		stop
		echo "stop mysql-proxy...[OK]"
		start
		test
		echo "Start mysql-proxy...[$STAT]"
	;;
	status)
		status
	;;
	*|help)
		echo "Usage:$0 {start|stop|restart|status|help]"
	;;
esac

需要加载的配置文件，提供变量值

VER="mysql-proxy-0.8.5-linux-glibc2.3-x86-32bit.tar.gz"

LOGLEVEL="info"

LOGFILE="/var/log/mysql-proxy.log"

MASTERADDR="192.168.1.51:3306"

SLAVEADDR="192.168.1.53:3306"

PROXYLUA="/usr/local/mysql-proxy/share/doc/mysql-proxy/rm-splitting.lua"

ADMINUSER="admin"

PASSWD="admin"

ADMINLUA="/usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua"

PROXYADDR=‘192.168.1.54‘

PROXYPORT=4040

ADMINPORT=4041

admin.lua脚本

function set_error(errmsg)

proxy.response = {

type = proxy.MYSQLD_PACKET_ERR,

errmsg = errmsg or "error"

}

end

 

function 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_RESULT

end