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

HAProxy的代理檢測

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

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

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

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

# telnet 127.0.0.1 6789
Trying 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ù)器上，有兩個復(fù)制正在運(yùn)行（192.168.10.2和192.168.10.3），應(yīng)用的讀請求在3307端口，你需要在HAProxy中配置一個前端和后端，像這樣：
 

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

時延1
  

時延2
  

結(jié)論

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

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

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

最新評論