本文實例講述了PHP實現負載均衡的加權輪詢方法。分享給大家供大家參考，具體如下：
1. 負載均衡算法有哪些？
2.如何用PHP實現加權輪詢？
實現思路：
通過傳入不同的用戶id，然后給他們分配不同的主機。
首先，需要一個接收用戶id的數組。
其次，需要一個存主機的數組，這些主機有不同的權重。這里的權重可以這么考慮：
假設有abc三臺主機，權重分別為3，1，1，那么a的占比為0.6，b和c的占比各為0.2。
直接遍歷主機的數組，假如用戶來了100個人，到a的時候，a的占比是0.6，就從用戶數組里隨機取60個人分給a；輪到b時，b的占比是0.2，就從用戶數組里隨機取20人；同理，c20人，這樣就完成了100個請求的轉發。
可是真實場景不是固定一批用戶，而是持續不斷的用戶請求，由于轉發非常快，當來的新用戶非常少時，每次從用戶隊列中取完、轉發后立馬去用戶隊列中取，很有可能每次只取2條，造成請求全部給了a，b和c一直沒有的情況。這時候可以考慮按照不同策略從用戶隊列中取數據。假設以前5ms就處理完一次轉發，則現在定義兩種策略，如果用戶隊列中有100個用戶時，就取出來，按著主機占比進行轉發，如果用戶隊列中不足100人，但是當前時間和上一次取值時間相差10ms，就取出來進行轉發，這樣就可以累積5ms，而這5ms里隊列中又會多一些用戶請求，這樣就不會把所有請求都分給一臺機器了。
代碼：
<?php// php實現負載均衡的加權輪詢（WRR）class WRR { // 每次取100人 const num = 100; // 上次取值時間，秒級時間戳 public $last_time; // 權重 machine=>weight public $machines = array( 'a' => 3, // 0.6 'b' => 1, // 0.2 'c' => 1 // 0.2 ); // 占比 public $proportion = array(); // 用戶隊列 public static $user_ids = array(); public function __construct() { // 各機器的占比 $total = 0; foreach ($this->machines as $machine => $weight) { $total += $weight; } $this->proportion['a'] = $this->machines['a'] / $total; $this->proportion['b'] = $this->machines['b'] / $total; $this->proportion['c'] = $this->machines['c'] / $total; } public function getUsers() { // 用戶人數 $cnt = count(self::$user_ids); $a_num = 0; $b_num = 0; $c_num = 0; if ($cnt >= self::num) { // 隊列超過100人 $a_num = round(self::num * $this->proportion['a']); $b_num = round(self::num * $this->proportion['b']); $c_num = $cnt - $a_num - $b_num; } else { // 隊列不足100人 $last_time = $this->last_time; // 上次訪問時間 while (true) { $current_time = $this->getMillisecond(); if (($current_time - $last_time) >= 10) { // 當前時間和上一次取值時間超過10ms $a_num = round($cnt * $this->proportion['a']); $b_num = round($cnt * $this->proportion['b']); $c_num = $cnt - $a_num - $b_num; $this->last_time = self::getMillisecond(); // 更新訪問時間 break; } } } $a = array_splice(self::$user_ids, 0, $a_num); $b = array_splice(self::$user_ids, 0, $b_num); $c = array_splice(self::$user_ids, 0, $c_num); return array( 'a' => $a, 'b' => $b, 'c' => $c ); } // 獲取毫秒級時間戳 public function getMillisecond() { list($t1, $t2) = explode(" ", microtime()); return (float)sprintf('%.0f', (floatval($t1) + floatval($t2)) * 1000); }}// 測試$wrr = new WRR();for ($i = 0; $i < 3; $i++) {// 模擬持續不斷的用戶請求 $random = rand(10, 120); $user_ids = range(1, $random); WRR::$user_ids = $user_ids; $users = $wrr->getUsers(); print_r($users);}真實的算法比這個復雜多了，它需要考慮一點，就是來過的用戶要保持原來分配的機器，除非原來的機器掛了。這樣做的原因是緩存。很多基于內存的緩存，都是基于用戶級別的，所以相同的用戶保持同一臺機器，有助于提升性能。
希望本文所述對大家PHP程序設計有所幫助。
新聞熱點
疑難解答
圖片精選
