Баланс

<?
/**
* Устанавливает соединение с наименее нагруженным сервером из списка
* @param array $connections список соединений
* @param int $permission типа прав
*/
function connectFree ($connections, $permission = DB_R) {
   if(! is_array($connections)) throw new Exception('connectFree: передан некорректный массив соединений');

   $statuses = array();                 // Массив всех состояний
   $pool = array();                     // Массив для случайного выбора одного из нескольких равнозначных соединений
   $newConnections = array();           // Список установленных соединений
   $minLoad = 0;                        // Показатель минимальной нагруженности
   $avName = '';                        // Название подключения к серверу с минимальной нагрузкой
   $report = '';                        // Отчёт

   $cachePref = 'db_cStat_';            // Префикс ключа memcached
   $cacheTime = 35;                     // Время на которое кешируется состояние подключения
   $cache = Box:: getInstanceOf('CacheMC');   // Кеш

   // Перебор всех предложенных соединений
   foreach($connections as $conName) {
      /**
       * Проверяем закешированный статус соединения 
       */
      $cacheKey = $cachePref . $conName;
      $status = $cache->smartGet($cacheKey);

      // Если закешированного состояния нет
      if(!$status) {
         // Если нужное соединение ещё не открыто
         if(empty($this->connections[$conName])) {
            try {
               $connection = $this->connect($conName);
               $newConnections[] = $conName;
            } catch (Exception $e) {
               err('При проверке свободных серверов произошла ошибка подключения ' . $conName);
               $report .= $conName . ': ошибка подключения' . '; ';

               continue;
            }
         } else {
            $connection = $this->connections[$conName];
         }

         // Если это слейв, проверяем статус репликации
         if(! empty($this->conParams[$conName]['slave']) && !$this->checkSlave($connection)) {
            $report .= $conName . ': слейв не прошёл проверку' . '; ';;
            $status = -2;
            $statuses[$conName] = $status;
         }

         // Проверка загруженности сервера по количеству работающих тредов
         // (пока я не придумал другого способа, но и этот довольно толков и информативен)
         if(!$status) {
            $status = $this->query('show status like \'Threads_running\'', $connection);

            // Вынимаем закопанное значение
            if($status && $status->rowCount()) $status = $status->fetchAll();
            if(! empty($status[0]['Value'])) $status = $status[0]['Value']; else $status = -1;
         }

         // Сохренение значения в кеш
         $cache->smartSet($cacheKey, $status, $cacheTime);
      }

      // Обработка состояния
      if($status) {
         // Поиск минимального значения
         if((!$minLoad && $status >= 0) || ($status > 0 && $status < $minLoad)) {
            $minLoad = $status;
            $avName = $conName;
         }

         $statuses[$conName] = $status;
         $report .= $conName . ': ' . $status . '; ';
      }
   }

   // Если в итоге пусто
   if(! count($statuses)) throw new Exception('connectFree: не удалось найти ни одного доступного соединения');

   // Выбор равнозначных соединений
   foreach($connections as $conName) {
      if($statuses[$conName] == $minLoad) $pool[] = $conName;
   }

   // Если соединений несколько, выбираем одно случайно
   if(count($pool) > 1) {
      shuffle($pool);
      $avName = $pool[0];
   }

   // Отключиться от всех серверов, к которым производилось подключение, кроме самого доступного
   foreach($newConnections as $cName) {
      if($cName != $avName) $this->disconnect($cName);
   }

   // Подключиться к выбранному соединению
   if(empty($this->connections[$avName])) {
      $this->connect($avName);
   }

   // Установка соединений в зависимости от запрошенных прав
   if($permission == DB_R) {
      if($this->conNameRead != $avName) $this->init($avName);
   } else {
      if($this->conNameWrite != $avName) $this->init(null, $avName);
   }

   // В отладку
   $report .= 'результат: ' . $avName;
   debug($report, 'Db:: connectFree');
}
?>