在MySQL世界里，HAProxy 通常來(lái)作為軟件負(fù)載均衡器使用。彼得.博羅什在過(guò)去的郵件中解釋了如何使用percona xtradb集群(pxc)來(lái)對(duì)其設(shè)置。所以它只發(fā)送查詢到可應(yīng)用的節(jié)點(diǎn)。同樣的方法可用于常規(guī)主從設(shè)置來(lái)讀取負(fù)載并分散到多個(gè)從節(jié)點(diǎn)。不過(guò)，使用MySQL復(fù)制，另一個(gè)因素開始發(fā)揮作用：復(fù)制延遲。在這種情況下，被提及到的 Percona xtraDB 集群以及我們提出只返回“向上”或者“向下”的檢查方法行不通。我們將希望依賴其復(fù)制延遲來(lái)調(diào)整內(nèi)部Haproxy的一個(gè)權(quán)重。這就是我們要做的在這篇文章中使用HAProxy 1.5。

HAProxy的代理檢測(cè)

HAProxy 1.5運(yùn)行我們運(yùn)行一個(gè)代理檢測(cè)，這是一項(xiàng)可以添加到常規(guī)健康檢測(cè)項(xiàng)的檢測(cè)。代理檢測(cè)的好處是返回值可以是‘up'或 ‘down'，但也可以是個(gè)權(quán)重值。

代理是什么呢？它是一個(gè)簡(jiǎn)單的可以訪問(wèn)給定端口上TCP連接的程。所以，如果我們要在一臺(tái)MySQL服務(wù)器上運(yùn)行代理，這需要：

•     如果不運(yùn)行復(fù)制的話確保服務(wù)在HAProxy上是停止的
•     如果復(fù)制延遲小于10s，設(shè)置weight為100%
•     如果延遲大于等于10s，小于50s，設(shè)置weight為50%
•     在其他情況下設(shè)置weight為5%

我們可以使用這樣一個(gè)腳本:
 

$ 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發(fā)出連接到運(yùn)行在3306端口上的MySQL實(shí)例，這樣運(yùn)行：
 

$ php agent.php 6789 3306

你還需要指定MySQL用戶：
 

mysql> GRANT REPLICATION CLIENT ON *.* TO 'haproxy'@'127.0.0.1' IDENTIFIED BY 'haproxy_pwd';

代理啟動(dòng)后，你可以檢測(cè)一下它是否正常運(yùn)行：
 

# telnet 127.0.0.1 6789Trying 127.0.0.1...Connected to 127.0.0.1.Escape character is '^]'.up 100%Connection closed by foreign host.

假設(shè)它運(yùn)行在本地的應(yīng)用服務(wù)器上，有兩個(gè)復(fù)制正在運(yùn)行（192.168.10.2和192.168.10.3），應(yīng)用的讀請(qǐng)求在3307端口，你需要在HAProxy中配置一個(gè)前端和后端，像這樣：
 

現(xiàn)在所有的都準(zhǔn)備好了，現(xiàn)在讓我們看看怎么使用HAProxy來(lái)動(dòng)態(tài)的改變重滯服務(wù)器，代碼如下：
  

時(shí)延1
  

時(shí)延2
  

結(jié)論

在HAProxy 1.5中代理檢查是一個(gè)很好的新增功能。 在上面的設(shè)置中是簡(jiǎn)單的: 舉例來(lái)說(shuō)， 如果 HAProxy 連接代理失敗，它就不會(huì)被標(biāo)記。 推薦與代理檢查一起，保持常規(guī)的健康度檢查。

細(xì)心的讀取者們（reads）將會(huì)注意到這個(gè)配置，如果在所有節(jié)點(diǎn)上都被復(fù)制， HAProxy將會(huì)停止發(fā)送給讀取者. 這可能不是最好的解決方案。但可能的選項(xiàng)是：停止代理并標(biāo)記服務(wù)器為UP，使用狀態(tài)套接字（socket）或者添加主節(jié)點(diǎn)作為備份服務(wù)器。

最后一點(diǎn)，使用Percona工具集的pt-heartbeat替代Seconds_Behind_Master，您可以編輯代理的代碼，可以對(duì)復(fù)制的延遲進(jìn)行測(cè)量 。