PHP: полный мануал с примерами, функциями и ООП

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-first-log', 'Включить счётчик журнала и открыть заявку', ['Заявка', 'Состояние', 'Записи драйвера'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-101','state'=>'готова','note'=>'учебная заметка']);
        $logger=new SafeTally();
        $found=withLogs($logger,fn()=>readTicket(freshObserverManager($uri),$namespace,'O-101'));
        $ticket=$found[0] ?? [];
        $checks['ticket_read'] = $ticket===['_id'=>'O-101','state'=>'готова'];
        $checks['driver_called_logger'] = $logger->total()>0;
        $checks['known_levels'] = count($logger->levels)===6 && $logger->unknown===0;
        $rows=[[$ticket['_id'],$ticket['state'],$logger->total()>0?'получены':'пока пусто']];
        return [$rows,$checks,'O-101 готова. Счётчик получил записи расширения.',
            array_combine(['ERROR','CRITICAL','WARNING','MESSAGE','INFO','DEBUG'],$logger->levels)];
    }
);

O-101 готова. Счётчик получил записи расширения.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-severity-filter', 'Отделить предупреждения от обычного потока', ['Уровень или заявка', 'Куда попадает результат'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-102','state'=>'собрана']);
        $logger=new SafeTally();
        $ticket=withLogs($logger,fn()=>readTicket(freshObserverManager($uri),$namespace,'O-102'))[0];
        $levels=[Mon\LogSubscriber::LEVEL_ERROR,Mon\LogSubscriber::LEVEL_CRITICAL,Mon\LogSubscriber::LEVEL_WARNING,
            Mon\LogSubscriber::LEVEL_MESSAGE,Mon\LogSubscriber::LEVEL_INFO,Mon\LogSubscriber::LEVEL_DEBUG];
        $urgent=$logger->priorityCount();
        $routine=array_sum(array_slice($logger->levels,3));
        $checks['driver_enumeration'] = $levels===[0,1,2,3,4,5];
        $checks['partition_complete'] = $urgent+$routine===$logger->total() && $logger->total()>0;
        $checks['ticket_visible'] = $ticket['state']==='собрана';
        $rows=[['0–2','Разбор предупреждений'],['3–5','Диагностика'],[$ticket['_id'],$ticket['state']]];
        return [$rows,$checks,'O-102 собрана. Сообщения распределены по двум очередям.',
            ['Получено уровней 0–2'=>$urgent,'Получено уровней 3–5'=>$routine]];
    }
);

O-102 собрана. Сообщения распределены по двум очередям.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-subscribe-window', 'Закрыть окно сбора между двумя заданиями', ['Задание', 'Состояние', 'Временный приёмник'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertMany([['_id'=>'O-201','state'=>'принята'],['_id'=>'O-202','state'=>'отгружена']]);
        $window=new SafeTally();
        $control=new SafeTally();
        Mon\addSubscriber($control);
        try {
            Mon\addSubscriber($window);
            Mon\addSubscriber($window);
            $oldW=$window->total();
            $oldC=$control->total();
            $first=readTicket(freshObserverManager($uri),$namespace,'O-201')[0];
            $bothW=$window->total()-$oldW;
            $bothC=$control->total()-$oldC;
            Mon\removeSubscriber($window);
            Mon\removeSubscriber($window);
            $closed=$window->total();
            $stillOpen=$control->total();
            $second=readTicket(freshObserverManager($uri),$namespace,'O-202')[0];
            $checks['one_delivery_per_registration'] = $bothW>0 && $bothW===$bothC;
            $checks['closed_window'] = $closed===$window->total() && $control->total()>$stillOpen;
        } finally {
            Mon\removeSubscriber($window);
            Mon\removeSubscriber($control);
        }
        $checks['two_reads'] = $first['state']==='принята' && $second['state']==='отгружена';
        $rows=[[$first['_id'],$first['state'],'окно открыто'],[$second['_id'],$second['state'],'окно закрыто']];
        return [$rows,$checks,'Окно диагностики O-201 закрыто до чтения O-202.',
            ['События за первое окно'=>$bothW,'События контрольного приёмника за второе окно'=>$control->total()-$stillOpen]];
    }
);

Окно диагностики O-201 закрыто до чтения O-202.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-client-scope', 'Определить, какому клиенту принадлежит наблюдение', ['Клиент', 'Номер', 'Состояние', 'Подписка на изменения'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertMany([['_id'=>'O-301','state'=>'выдана'],['_id'=>'O-302','state'=>'упакована']]);
        $logger=new SafeTally();
        $scope=new ChangeObserver();
        [$a,$b,$changes,$more]=withLogs($logger,function() use ($logger,$scope,$uri,$namespace) {
            $left=freshObserverManager($uri);
            return observeChanges($left,$scope,function() use ($left,$logger,$scope,$uri,$namespace) {
                $a=readTicket($left,$namespace,'O-301')[0];
                $changes=$scope->nodeChanges+$scope->fleetChanges;
                $old=$logger->total();
                $b=readTicket(freshObserverManager($uri),$namespace,'O-302')[0];
                return [$a,$b,$changes,$logger->total()-$old];
            });
        });
        $rejected=false;
        $another=freshObserverManager($uri);
        try { $another->addSubscriber($logger); }
        catch (MongoDB\Driver\Exception\InvalidArgumentException $expected) { $rejected=true; }
        $checks['only_left_observed'] = $changes>0 && $scope->nodeChanges+$scope->fleetChanges===$changes;
        $checks['global_observed_second_window'] = $more>0;
        $checks['local_logger_rejected'] = $rejected;
        $checks['business_values'] = $a['state']==='выдана' && $b['state']==='упакована';
        $rows=[['Клиент А',$a['_id'],$a['state'],'SDAM подключён'],['Клиент Б',$b['_id'],$b['state'],'SDAM не подключён']];
        return [$rows,$checks,'Оба клиента прочли заявки. Адресный наблюдатель видел клиента А.',
            ['Изменений у клиента А'=>$changes,'Глобальных сообщений за второе окно'=>$more]];
    }
);

Оба клиента прочли заявки. Адресный наблюдатель видел клиента А.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-node-and-fleet', 'Прочитать две строки паспорта подключения', ['Что описываем', 'Что обнаружено'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-401','state'=>'в пути']);
        $reader=freshObserverManager($uri);
        $events=new ChangeObserver();
        $ticket=observeChanges($reader,$events,fn()=>readTicket($reader,$namespace,'O-401'))[0];
        $node=$events->node;
        $fleet=$events->fleet;
        $checks['known_local_node'] = $node['local'] && $node['to']===ServerDescription::TYPE_STANDALONE;
        $checks['single_topology'] = $fleet['to']===TopologyDescription::TYPE_SINGLE && $fleet['servers']===1;
        $checks['event_access_paths_agree'] = $node['properties_agree'] && $fleet['properties_agree'];
        $checks['snapshots_related'] = $events->sameGroup();
        $checks['latency_is_optional'] = $node['valid_rtt'];
        $checks['ticket_verified'] = $ticket['state']==='в пути';
        $rows=[['Узел',$node['to']],['Топология',$fleet['to']],[$ticket['_id'],$ticket['state']]];
        return [$rows,$checks,'Узел Standalone, топология Single. O-401 в пути.',
            ['Известно узлов'=>$fleet['servers'],'RTT измерения, мс'=>$node['rtt_ms']]];
    }
);

Узел Standalone, топология Single. O-401 в пути.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-absent-ticket', 'Отличить пустую карточку от недоступной базы', ['Введённый номер', 'Совпадений', 'Что показать'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-501','state'=>'передана курьеру']);
        $reader=freshObserverManager($uri);
        $events=new ChangeObserver();
        [$missing,$present]=observeChanges($reader,$events,function() use ($reader,$namespace) {
            return [readTicket($reader,$namespace,'O-509'),readTicket($reader,$namespace,'O-501')];
        });
        $checks['route_discovered'] = $events->fleet['readable']===true;
        $checks['missing_completed'] = $missing===[];
        $checks['control_ticket_valid'] = count($present)===1 && $present[0]['state']==='передана курьеру';
        $rows=[['O-509',count($missing),$missing===[]?'Сверить номер':'Открыть карточку'],
            [$present[0]['_id'],count($present),$present[0]['state']]];
        return [$rows,$checks,'O-509 не найдена. Контрольная O-501 передана курьеру.',
            ['Успешные проверки узла'=>$events->heartbeatOK,'Изменения топологии'=>$events->fleetChanges]];
    }
);

O-509 не найдена. Контрольная O-501 передана курьеру.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-write-receipt', 'Объяснить отказ вставки при доступном узле', ['Проверка', 'Фактическое значение'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-601','state'=>'принята']);
        $reader=freshObserverManager($uri);
        $events=new ChangeObserver();
        [$code,$ticket]=observeChanges($reader,$events,function() use ($reader,$namespace) {
            $batch=new BulkWrite();
            $batch->insert(['_id'=>'O-601','state'=>'новая']);
            $code=null;
            try { $reader->executeBulkWrite($namespace,$batch); }
            catch (MongoDB\Driver\Exception\BulkWriteException $error) {
                $issues=$error->getWriteResult()->getWriteErrors();
                $code=isset($issues[0]) ? $issues[0]->getCode() : null;
                if ($code!==11000) { throw $error; }
            }
            return [$code,readTicket($reader,$namespace,'O-601')[0]];
        });
        $writable=$events->fleet['writable'];
        $checks['route_to_writer'] = $writable===true;
        $checks['id_conflict'] = $code===11000;
        $checks['old_state_preserved'] = $ticket['state']==='принята' && $orders->countDocuments([])===1;
        $rows=[['Есть узел для записи',$writable],['Код элемента',$code],[$ticket['_id'],$ticket['state']]];
        return [$rows,$checks,'O-601 уже зарегистрирована. Сохранённое состояние — принята.',
            ['Сохранено документов'=>(int)$orders->countDocuments([])]];
    }
);

O-601 уже зарегистрирована. Сохранённое состояние — принята.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/observability-lab.php';
use MongoDB\Collection;
use MongoDB\Driver\{Manager, Query, BulkWrite, ServerDescription, TopologyDescription};
use MongoDB\Driver\Monitoring as Mon;

runObserverLesson('mongodb135-observe-probe-decision', 'Выбрать сообщение оператору при отказе соединения', ['Куда обратились', 'Что известно', 'Сообщение или действие'],
    function (Collection $orders,string $uri,string $namespace): array {
        $orders->insertOne(['_id'=>'O-701','state'=>'ожидает выдачи']);
        $socket=stream_socket_server('tcp://127.0.0.1:0',$errno,$errstr,STREAM_SERVER_BIND);
        if ($socket===false) { throw new RuntimeException('Cannot reserve private probe port'); }
        $failed=new ChangeObserver();
        $timedOut=false;
        try {
            $endpoint=stream_socket_get_name($socket,false);
            if (!is_string($endpoint) || !preg_match('/^127\.0\.0\.1:[0-9]+$/D',$endpoint)) {
                throw new RuntimeException('Expected owned loopback socket');
            }
            $bad=freshObserverManager('mongodb://'.$endpoint.'/?directConnection=true&retryWrites=false');
            try { observeChanges($bad,$failed,fn()=>readTicket($bad,$namespace,'O-701')); }
            catch (MongoDB\Driver\Exception\ConnectionTimeoutException $expected) { $timedOut=true; }
        } finally { fclose($socket); }
        $working=new ChangeObserver();
        $reader=freshObserverManager($uri);
        $known=observeChanges($reader,$working,fn()=>readTicket($reader,$namespace,'O-701'));
        $checks['unavailable_is_not_empty'] = $timedOut && $failed->heartbeatFailures>0;
        $checks['working_route'] = $working->fleet['readable'] && $working->heartbeatOK>0;
        $checks['known_document'] = count($known)===1 && $known[0]['state']==='ожидает выдачи';
        $rows=[['Учебная недоступная точка',$timedOut?'Чтение не выполнено':'Чтение выполнено','Проверить подключение'],
            ['Рабочая точка',$known[0]['_id'],$known[0]['state']]];
        return [$rows,$checks,'Первое чтение не выполнено. Рабочая база вернула O-701 — ожидает выдачи.',
            ['Неудачные проверки первой точки'=>$failed->heartbeatFailures,'Успешные проверки рабочей точки'=>$working->heartbeatOK]];
    }
);

Первое чтение не выполнено. Рабочая база вернула O-701 — ожидает выдачи.

CLI-программа подключается к учебной базе, сопоставляет живые наблюдения с данными заявки и записывает result.html и result.json.