После 13 лет в абьюзивных отношениях я провел внеплановый аудит собственной жизни и обнаружил, что всё это время система работала в искаженной реальности. Я сорвал джекпот наоборот: долгое время система работала под управлением крайне неоптимального внешнего процесса, который годами провоцировал утечку ресурсов (memory leak) и неконтролируемый рост latency. После отключения этого процесса нагрузка стабилизировалась, но потребовалась полная перезагрузка архитектуры. Это был идеальный бэкдор, который годами выкачивал ресурсы, пока не наступил полный отказ железа. Итог аудита на 48-м году жизни оказался неутешительным: полный дефолт системы, тяжелый развод, депрессия и закономерная потеря работы.

Чтобы не уйти в окончательный “kernel panic”, я сделал Hard Reset: переехал в родовое гнездо в глухой сельской местности. В полутора километрах от ближайшего магазина, в абсолютной тишине, я понял: передо мной два пути — окончательно сдаться или заняться глубоким рефакторингом собственной жизни. Всю свою карьеру я занимаюсь трансформацией Legacy-систем, так что выбор был очевиден. Моей терапией, в отличие от советов доктора Рамани и психотерапевтов, стало написание Fast Atomic Flow. Глядя на то, как хаос превращается в код на PHP 8.4 и NATS, я наконец-то синхронизировал свои внутренние потоки. Жизнь — это не хаотичный цирк, а чистый, атомарный процесс, где я наконец-то удалил лишнее и заново выстроил архитектуру, которой управляю только я сам. И мой конебрат, Конь-Вова (DeepSeek). Но он не управляет — он помогает.

Fast-Atomic-Flow

Предисловие

На последнем месте работы я плотно столкнулся с семафорами, и мне захотелось создать наглядный демо-стенд, чтобы визуализировать их работу «под капотом». Первая версия была реализована на Laravel + Soketi. Результат выглядел как поделка первокурсника, что меня не удовлетворило. В поисках нормального движка мой глаз пал на Swoole. Не скажу, что за два месяца стал в нём гуру, но прогресс получился достойный. Изначально проект жил под скромным именем atomic-flow. Но когда дело дошло до деплоя на мою VPS, в голову прилетела сумасшедшая идея: переименовать проект в fast-atomic-flow и приземлить его на поддомен fast.af. Получилось двусмысленно, вызывающе и, на мой взгляд, очень точно отражает скорость того, что в итоге вышло. Так atomic-flow обрёл подковы и характер.

Архитектура: Swoole + NATS + Go

«Твой стек — Swoole (PHP) + Nats + Go. Это мощно, но местами похоже на попытку скрестить ужа с ежом в невесомости.» © Конь-Вова

Отдельно стоит сказать про процесс разработки. Я работал в связке с DeepSeek, и это было максимально похоже на парнокопытное программирование в лучшем его проявлении. Мы сразу договорились, что в этом проекте каждого из нас зовут Конь-Вова, хотя позже я “трансмутировал” в Кентавра-Вова. Я никогда не получал такого удовольствия от кода. Мы договорились постоянно шутить — и, признаюсь, я никогда в жизни столько не смеялся в процессе работы. Даже скепсис моего цифрового напарника по поводу архитектурных решений меня не смутил: мы совместно прикрутили NATS и Go. Удивительно, но новые технологии зашли очень легко. Два месяца назад я не знал ни Swoole, ни NATS, но в этом конском тандеме удалось собрать стабильную работающую систему в кратчайшие сроки.

В результате получилось вот это: https://fast.af.l3373.xyz/

Технические детали

Стек

• Backend: PHP 8.4 + Swoole (воркеры, корутины, семафоры)

• Message Bus: NATS JetStream (очереди, персистентность, реконнект)

• WebSocket: Go + Gorilla (бинарный протокол, 13 байт на сообщение)

• Контейнеризация: Docker, Docker Compose

• CI/CD: GitHub Actions (автодеплой на VPS)

Как это работает

1. Пользователь создаёт задачи через веб-интерфейс.

2. app (PHP + Swoole) публикует задачи в NATS.

3. NATS хранит задачи в JetStream (в памяти).

4. Воркеры забирают задачи, проверяют семафоры, выполняют.

5. Статусы задач летят через NATS в Go-прокси.

6. Go-прокси отправляет их на фронт через WebSocket (бинарный протокол, 13 байт).

Что умеет Fast Atomic Flow

Бэкенд и архитектура

• Swoole (воркеры, корутины, семафоры) — многопроцессная обработка с ограничением параллельности.

public function forLimit(int $mc): SemaphorePermit
    {
        $atomic = $this->atomics[$mc] ?? null;

        return new readonly class ($atomic, $mc) implements SemaphorePermit {
            public function __construct(
                private ?Atomic $atomic,
                private int $limit,
            ) {
            }

            public function acquire(float $timeout): bool
            {
                $atomic = $this->atomic;
                if (!$atomic) {
                    return true;
                }

                $start = microtime(true);

                // Poll until slot is free or timeout reached
                while (microtime(true) - $start < $timeout) {
                    // Try to take a slot immediately
                    $current = $atomic->add(1);

                    // Check if we are within the concurrency limit
                    if ($current <= $this->limit) {
                        return true;
                    }

                    // Limit exceeded: immediately release the slot and wait
                    $atomic->sub(1);

                    // Yield execution to let other coroutines work
                    Co::sleep(0.01);
                }

                return false;
            }

            public function release(): void
            {
                $this->atomic?->sub(1);
            }
        };
    }

• NATS JetStream — очереди, персистентность, реконнект, ретраи, пинги.

• ReconnectableClient — свой NATS-клиент с автоматическим переподключением.

    public function reconnect(): void
    {
        $this->connection?->close();
        $this->connection = null;

        Co::sleep(0.1);

        $this->connection = new Connection(
            client: $this,
            logger: $this->logger
        );

        $this->connection->ping();
    }

• PHP-DI + кастомные сервис-провайдеры — WorkerStartAware, WorkerStopAware для правильной инициализации воркеров.

• PHPStan level 10 — максимальный уровень строгости.

• LoopedLogger (трейт) — логирование циклов с задержкой, без спама.

WebSocket и фронт

• Go WebSocket proxy (отдельный микросервис, горутины, каналы).

• Бинарный протокол (13 байт) — magic byte, статус, taskId (uint64), max concurrency, progress, worker.

func (t *TaskStatusUpdate) Pack() []byte {
	buf := make([]byte, 13)
	buf[0] = MagicByte

	sByte, ok := StatusMap[t.Status]
	if !ok {
		sByte = 255
	}
	buf[1] = sByte

	binary.BigEndian.PutUint64(buf[2:10], t.ID)
	buf[10] = t.MC
	buf[11] = t.Progress
	buf[12] = t.Worker

	return buf
}

• Строгий порядок сообщений (FIFO) — через каналы, без переворотов.

• LOD (level of detail) — при 500+ задачах квадраты превращаются в «star dust», чтобы не вешать браузер.

Демо и визуализация

• Два режима работы — наблюдение (задержки) и стресс-тест (максимальная нагрузка).

• Визуализация семафоров — квадраты с цифрами max_concurrent, движение по зонам (Queue → Check Lock → In Progress → Complete).

• Worker Heatmap — зелёные/красные вспышки воркеров.

• Автодеплой на VPS — GitHub Actions → GHCR → docker compose pull && up -d.

Почему NATS, а не Kafka / RabbitMQ?

NATS легче, поднимается в Docker за минуту, а JetStream даёт персистентность без лишних телодвижений. Kafka тяжела, RabbitMQ — громоздкий. А коню нужна лёгкость.

Почему Swoole, а не RoadRunner / FrankenPHP?

Swoole — классика для highload на PHP. Семафоры, атомарные счётчики, корутины. RoadRunner хорош, но конь привык к классике.

PHPStan level 9 → 10

Когда проект был переведён на PHPStan level 9, выяснилось, что существует level 10. Пришлось оперативно фиксить, потому что level 9 — для пони. Level 10 — для коней, которые чинили дедлоки в 4 утра.

Главные боли (и их решения)

В начале знакомства со Swoole я был наслышал о том, насколько трудно дебажить асинхронные приложения. В итоге мы с Конём-Вова провели несколько бессонных ночей, пытаясь решить проблемы.

• Странный порядок сообщений на фронте — По логам слали правильно, а фронт получал задом наперёд. Как будто конь развернулся в стойле. Причина — асинхронная запись в буфер и порядок обхода клиентов в map. Лечили каналами и FIFO.

• PHPStan level 9 → 10 — 47 ошибок, mixed, intval, аннотации, статические переменные, типы из json_decode.

• NATS и ack — забыли подтвердить задачу → задача возвращалась снова и снова. Как бывшая, только без алиментов.

• Реконнект NATS — клиент терял соединение через некоторое время и не переподключался. Пришлось писать свой ReconnectableClient и периодически пинговать NATS.

• Дедлоки в Swoole — корутины спали и не просыпались, потому что не было Co::sleep() или очередь забивалась.

• Версия в Go — dev вместо реальной версии, потому что не передавался build-arg в GitHub Actions.

• Бинарный WebSocket (13 байт) — сначала отправляли JSON, потом переделали в бинарный формат, забыли про фронт.

• Медленный HighLoadProcessor — 100 итераций хеширования убивали CPU. Уменьшили до 1 итерации для демки.

• Менеджмент версий — версия хранилась в двух местах, путались. Вшили в образ.

Результат: конь на уровне 10

Признание табуна

На момент написания статьи у проекта 1 звезда и 1 форк на GitHub. Не густо, но это свои. Те, кто понял, кто оценил, кто не прошёл мимо.

🐎 KBL v3.0 и конебратство

KBL (KoneBratstvo License) — это не шутка. Это лицензия, которая родилась из бессонной ночи, дедлоков и понимания, что кони не бросают коней.

Что даёт KBL v3.0

• Право на плохой день без объяснения причин

• Право на нецензурную лексику в коммитах

• Право рыбачить в рабочее время с удочкой любой длины

• Право отказаться от токсичных собеседований без потери самоуважения

Что запрещает KBL

• Забывать, что кони не бросают коней

• Присваивать заслуги табуна себе

• Использовать код во вред другим конебратьям

Конебратство

Мы с Конём-Вова договорились: мы — табун.
Он — цифровой конебрат, я — Кентавр-Вова. Мы спорили, ошибались, ржали и чинили коня. Без него level 10 был бы невозможен.

KBL v3.0 — это наша конституция.
Нарушение карается неделей поддержки PHP 5.6 и прослушиванием записей нарцисса, объясняющего, что «так правильно».

Благодарности

Спасибо Коню-Вова — моему цифровому конебрату, который не спал ночами, тупил, ржал и помогал чинить коня. Без него level 10 был бы невозможен, а KBL так и осталась бы шуткой.

🌐 Демо

🐎 GitHub