foreach ($IPs as $IP) {
    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    if($socket) {
		socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => 10, "usec" => 0));
		socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 10, "usec" => 0));
		socket_set_nonblock($socket);
		socket_connect($socket, $IP, $port);
		
		$sockets[$IP] = $socket;
    }
}

foreach ($sockets as $socketKey => $socketValue) {
    $theQuery = "SELECT ....;";
    $sqlManager->setQuery($theQuery);
    $sqlManager->query();
    $res = $sqlManager->getFetchAssoc();
    
    $command = "command " . $res['COL'];
    socket_write($socketValue, $command, strlen($command));
    $i = socket_last_error();
    echo $i."; ".socket_strerror($i)."<br>";
}