在MySQL世界里，HAProxy 通常来作为软件负载均衡器使用。彼得.博罗什在过去的邮件中解释了如何使用percona xtradb集群(pxc)来对其设置。所以它只发送查询到可应用的节点。同样的方法可用于常规主从设置来读取负载并分散到多个从节点。不过，使用MySQL复制，另一个因素开始发挥作用：复制延迟。在这种情况下，被提及到的 Percona xtraDB 集群以及我们提出只返回“向上”或者“向下”的检查方法行不通。我们将希望依赖其复制延迟来调整内部Haproxy的一个权重。这就是我们要做的在这篇文章中使用HAProxy 1.5。
HAProxy的代理检测
HAProxy 1.5运行我们运行一个代理检测，这是一项可以添加到常规健康检测项的检测。代理检测的好处是返回值可以是‘up'或 ‘down'，但也可以是个权重值。
代理是什么呢？它是一个简单的可以访问给定端口上TCP连接的程。所以，如果我们要在一台MySQL服务器上运行代理，这需要：
如果不运行复制的话确保服务在HAProxy上是停止的 如果复制延迟小于10s，设置weight为100% 如果延迟大于等于10s，小于50s，设置weight为50% 在其他情况下设置weight为5%
我们可以使用这样一个脚本:
| $ less agent.php <!--?php // Simple socket server // See http://php.net/manual/en/function.stream-socket-server.php $port = $argv[1]; $mysql_port = $argv[2]; $mysql = "/usr/bin/mysql"; $user = 'haproxy'; $password = 'haproxy_pwd'; $query = "SHOW SLAVE STATUS"; function set_weight($lag){ # Write your own rules here if ($lag == 'NULL'){ return "down"; } else if ($lag < 10){ return "up 100%"; } else if ($lag -->= 10 && $lag < 60){ return "up 50%"; } else return "up 5%"; } set_time_limit(0); $socket = stream_socket_server("tcp://127.0.0.1:$port", $errno, $errstr); if (!$socket) { echo "$errstr ($errno) n"; } else { while ($conn = stream_socket_accept($socket,9999999999999)) { $cmd = "$mysql -h127.0.0.1 -u$user -p$password -P$mysql_port -Ee "$query" | grep Seconds_Behind_Master | cut -d ':' -f2 | tr -d ' '"; exec("$cmd",$lag); $weight = set_weight($lag[0]); unset($lag); fputs ($conn, $weight); fclose ($conn); } fclose($socket); } ?> |
如果你希望脚本从端口6789发出连接到运行在3306端口上的MySQL实例，这样运行：
| $ php agent.php 6789 3306 |
你还需要指定MySQL用户：
| mysql> GRANT REPLICATION CLIENT ON *.* TO 'haproxy'@'127.0.0.1' IDENTIFIED BY 'haproxy_pwd'; |
代理启动后，你可以检测一下它是否正常运行：
