Mikrotik API с PHP

@juanmesa Пожалуйста, пиши по-английски. Я не понимаю… Испанский, как я полагаю. В любом случае, посмотрев лог, думаю, понял в чём у тебя проблема. Наверное, у тебя в коде что-то типа: $API->comm('/ip route rule add src-address=10.1.0.99 action=unreachable'); или может быть $API->write('/ip route rule add src-address=10.1.0.99 action=unreachable', false); В любом случае, с классом Дениса так делать нельзя. Судя по логу, раньше в твоём коде ты это делаешь правильно. Удали все части кода, которые похожи на приведённые примеры, и используй тот вариант, который работал раньше.

@P3T3R Есть несколько способов подойти к решению, всё зависит от того, где вы хотите сосредоточить основную нагрузку — на роутере, веб-сервере или сервере базы данных? Есть ли проблемы с памятью где-то? Как выглядит таблица в БД? Мы вообще про ARP-лист говорим? Предположу, что память на веб-сервере не самый большой вопрос (хотя она всё равно ограничена, пусть даже искусственно через php.ini), и что сетевые соединения с роутером дороже, чем с сервером базы данных, как это обычно и бывает (особенно если БД работает на той же машине, что и веб-сервер). Также предполагаю следующую структуру таблицы БД:

CREATE TABLE `arp` (
 `ip` varchar(15) NOT NULL,
 `mac` char(17) NOT NULL,
 PRIMARY KEY (`ip`,`mac`)
) ENGINE=InnoDB

Сначала сделайте один запрос на вывод к роутеру, чтобы получить все записи. Затем для каждой записи из списка проверьте, есть ли она в базе, просто сделав запрос и посмотрев, есть ли результат. Если записи нет — добавьте её ID в список для удаления. Если есть — добавьте пару IP/MAC в строку, которая позже сформирует SQL-запрос. После обработки всех записей сделайте один запрос на удаление к роутеру со всеми собранными ID, выполните SQL-запрос, который вернёт все записи, кроме тех, что собраны, и отправьте запрос на добавление каждой из них.

Если не возражаете, приведу пример на своём клиенте, но вы можете переписать это на класс Дениса, если нужно:

<?php
namespace PEAR2\Net\RouterOS;
require_once 'PEAR2/Net/RouterOS/Autoload.php';

//Подключаемся и к роутеру, и к MySQL.
$client = new Client('10.30.99.31', 'admin', 'password');
$mysqli = new \mysqli('127.0.0.1', 'root', '', 'db');

//Для скорости используем подготовленные выражения.
$selectStatement = array(
 'stmt' => $mysqli->prepare('SELECT `ip`, `mac` FROM `arp` WHERE `ip`= ? AND `mac` = ?'),
 'params' => array('ip' => null, 'mac' => null)
);
$selectStatement->bind_param('ss', $selectStatement['params']['ip'], $selectStatement['params']['mac']);

//Переменные для дальнейшего использования.
$removalIDs = '';
$finalSelectQueryFilters = array();

//Делаем запрос, который вернёт все записи ARP... без комментариев.
$printRequest = new Request('/ip arp print .proplist=.id,address,mac-address');
$printRequest->setTag('p');

//Определяем, что делать с каждой записью. Такой подход минимизирует потребление памяти на этом этапе.
$client->sendAsync($printRequest,
 function ($response) use ($mysqli, &$selectStatement, &$removalIDs, &$finalSelectQueryFilters) {
   if ($response->getType() === Response::TYPE_DATA) {
     $selectStatement['params']['ip'] = $response->getArgument('address');
     $selectStatement['params']['mac'] = $response->getArgument('mac-address');
     $selectStatement['stmt']->execute();
     if ($selectStatement['stmt']->get_result()->num_rows) {
       $finalSelectQueryFilters[] =
         "(`ip` = '" . $mysqli->real_escape_string($response->getArgument('address')) .
         "' AND `mac` = '" . $mysqli->real_escape_string($response->getArgument('mac-address')) .
         "')";
     } else {
       $removalIDs .= $response->getArgument('.id') . ',';
     }
   }
 }
);
$client->loop();

//$removalIDs и $finalSelectQueryFilters теперь заполнены. Используем их.

//Удаляем все записи, которых нет в базе.
$removeRequest = new Request('/ip arp remove');
$removeRequest->setArgument('numbers', rtrim($removalIDs, ','));
$client->sendSync($removeRequest);

//Получаем все записи, которые есть в базе, но отсутствуют в роутере.
$finalSelectResult = $mysqli->query('SELECT `ip`, `mac` FROM `arp` WHERE NOT (' . implode(' OR ', $finalSelectQueryFilters) . ')');

//Добавляем их в роутер.
$addRequest = new Request('/ip arp add');
for ($i = 0; $row = $finalSelectResult->fetch_assoc(); ++$i) {
 $client->sendAsync(
   $addRequest
     ->setArgument('address', $row['ip'])
     ->setArgument('mac-address', $row['mac'])
     ->setTag($i)
 );
}
$client->loop();

Кстати, всё было бы гораздо проще, если вы просто добавляли записи в роутер одновременно с добавлением в базу, и удаляли из роутера при удалении из базы.

По поводу того, что у вас несколько роутеров — пример в моём втором посте: в принципе, просто создайте новый объект Client для каждого роутера. Что касается access-list… извиняюсь, я раньше не заметил, что вы хотите работать только с MAC-адресами (я отвлёкся на то, что в вашей базе данных есть ещё и IP, поэтому сначала подумал про ARP). В базе данных указано, в каком роутере находится пользователь? Эти данные отличаются для каждого роутера или пользователь может подключаться с любого? Предположу, что данные разные для каждого роутера (имена пользователей могут повторяться, если они на разных роутерах), и что база это отслеживает с помощью отдельной таблицы с данными роутеров. Тогда схема может выглядеть примерно так:

SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0;
SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0;
SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='TRADITIONAL';

-- -----------------------------------------------------
-- Таблица `routers`
-- -----------------------------------------------------
CREATE TABLE IF NOT EXISTS `routers` (
 `routerID` INT(11) NOT NULL AUTO_INCREMENT,
 `ip` VARCHAR(15) NOT NULL,
 `username` VARCHAR(255) NOT NULL,
 `password` VARCHAR(255) NOT NULL,
 PRIMARY KEY (`routerID`)
)
ENGINE=InnoDB
DEFAULT CHARSET=utf8;

SHOW WARNINGS;

-- -----------------------------------------------------
-- Таблица `clients`
-- -----------------------------------------------------
CREATE TABLE IF NOT EXISTS `clients` (
 `ip` VARCHAR(15) NOT NULL,
 `mac` CHAR(17) NOT NULL,
 `routerID` INT(11) NOT NULL,
 `username` VARCHAR(255) NULL DEFAULT NULL,
 PRIMARY KEY (`ip`, `mac`, `routerID`),
 INDEX `fk_clients_routers` (`routerID` ASC),
 CONSTRAINT `fk_clients_routers`
   FOREIGN KEY (`routerID`)
   REFERENCES `router`.`routers` (`routerID`)
   ON DELETE NO ACTION
   ON UPDATE CASCADE
)
ENGINE=InnoDB
DEFAULT CHARSET=utf8;

SHOW WARNINGS;

SET SQL_MODE=@OLD_SQL_MODE;
SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS;
SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS;

Теперь, поскольку структура кода начинала сходить с ума, я выделил большую часть прежнего кода в отдельный класс. Думаю, мог бы сделать это и лучше, но сейчас главная задача — привести в порядок то, что раньше было анонимной функцией. Остальная часть кода практически не изменилась, за исключением всего, что связано с IP:

<?php
namespace PEAR2\Net\RouterOS;
require_once 'PEAR2/Net/RouterOS/Autoload.php';

// Подключение к MySQL.
$mysqli = new \mysqli('127.0.0.1', 'root', '', 'db');

class ResponseProcessor {
   protected $mysqli;
   protected $stmt;
   protected $params = array('routerID' => null, 'mac' => null);
   protected $removalIDs = '';
   protected $existingMACs = '';

   public function __construct(\mysqli $mysqli) {
       $this->mysqli = $mysqli;
       $this->stmt = $mysqli->prepare('SELECT `mac` FROM `clients` WHERE `routerID` = ? AND `mac` = ?');
       $this->stmt->bind_param('is', $this->params['routerID'], $this->params['mac']);
   }

   public function setRouterID($id) {
       $this->params['routerID'] = (int)$id;
       $this->removalIDs = $this->existingMACs = '';
   }

   public function process(Response $response) {
       if ($response->getType() === Response::TYPE_DATA) {
           $this->params['mac'] = $response->getArgument('mac-address');
           $this->stmt->execute();
           if ($this->stmt->get_result()->num_rows) {
               $this->existingMACs .= "'" . $this->mysqli->real_escape_string($response->getArgument('mac-address')) . "',";
           } else {
               $this->removalIDs .= $response->getArgument('.id') . ',';
           }
       }
   }

   public function getRemovalIDs() {
       return rtrim($this->removalIDs, ',');
   }

   public function getAllNotInRouter() {
       return $this->mysqli->query('SELECT `mac` FROM `clients` WHERE `routerID` = ' . $this->params['routerID'] . ' AND `mac` NOT IN (' . rtrim($this->existingMACs, ',') . ')');
   }
}

$printRequest = new Request('/interface wireless access-list print .proplist=.id,mac-address');
$printRequest->setTag('p');

$removeRequest = new Request('/interface wireless access-list remove');
$addRequest = new Request('/interface wireless access-list add');

$processor = new ResponseProcessor($mysqli);
$routers = $mysqli->query('SELECT `routerID`, `ip`, `username`, `password` FROM `routers`');
while ($router = $routers->fetch_assoc()) {
   $client = new Client($router['ip'], $router['username'], $router['password']);
   $processor->setRouterID($router['routerID']);

   // Определяем, что делать с каждой записью. Такой подход позволяет минимизировать потребление памяти на этом этапе.
   $client->sendAsync($printRequest, array($processor, 'process'));
   $client->loop();

   // Удаляем все записи, которых нет в базе.
   $client->sendSync($removeRequest->setArgument('numbers', $processor->getRemovalIDs()));

   // Получаем все записи, которые есть в базе, но отсутствуют в роутере.
   $finalSelectResult = $processor->getAllNotInRouter();

   // Добавляем все такие записи в роутеры.
   for ($i = 0; $row = $finalSelectResult->fetch_assoc(); ++$i) {
       $client->sendAsync(
           $addRequest
               ->setArgument('mac-address', $row['mac'])
               ->setTag($i)
       );
   }
   $client->loop();
}

Обратите внимание, что в итоге каждый MAC-адрес добавляется на “все” беспроводные интерфейсы, а не на конкретный. Если хотите назначать конкретный интерфейс, нужно либо хранить интерфейс в базе вместе с MAC-адресом, либо использовать что-то вроде функции PEAR Net_IPv4::ipInNetwork(), чтобы автоматически определить интерфейс, исходя из IP пользователя и сетевых адресов AP на текущем роутере. Первый вариант требует больше места в базе (2000 пользователей минимум по 5 байт на пользователя — это минимум 10 Кб, и рост зависит от длины имен интерфейсов), а второй — занимает некоторое время (каждую добавляемую запись нужно проверить, а перед этим сделать дополнительный запрос для получения всех сетевых адресов AP; в среднем это несколько миллисекунд накладных расходов, в худшем случае полсекунды, при условии, что сеть в порядке и количество записей умеренное). Что бы вы предпочли пожертвовать?