какая польза от Kafka в микросервисах

Когда серверная система взаимодействует с микросервисами: позвольте данным течь

Представьте себе такой сценарий: вы отлаживаете линию по производству роботизированного оружия. Шесть серводвигателей должны работать вместе, каждый из которых получает инструкции по положению в режиме реального времени и передает данные о температуре и скорости обратно в центр управления. Внезапно данные обратной связи одного мотора запаздывали, и вся последовательность действий начала отставать — точно так же, как в танце, который должен был быть плавным, кто-то замедлил ритм, и в команде царил хаос.

В мире машин и автоматизации мы знаем, что надежный поток данных в режиме реального времени является источником жизненной силы. Задержка сигнала может привести к смещению сборки; потеря инструкции может даже вызвать коллизию оборудования. Это строгое требование к оперативности и порядку данных на самом деле удивительно похоже на проблемы, с которыми сталкиваются «микросервисы» в современной архитектуре программного обеспечения.

Где застревает «танец данных» микросервисов?

Программное приложение, которое изначально было интегрировано в единое целое, было разделено на несколько независимых небольших сервисов, таких как управление пользователями, обработка заказов и инвентаризация. Они выполняют свои обязанности и проявляют гибкость. Но возникают проблемы: Сервис А генерирует новый заказ, Сервис Б должен обновить запасы, а Сервис С должен уведомить логистику. Откуда они знают, что «событие» произошло? Традиционный подход заключается в прямом вызове друг друга, как если бы все двигатели были жестко соединены вместе. Когда определенная служба занята или выходит из строя, вся цепочка ожидает, блокируется или даже разрушается.

Это подводит нас к сути того, о чем нам нужно поговорить: событийно-ориентированной архитектуре и одному из ее ключевых игроков. Он функционирует как высокоинтеллектуальный, бесконечный нервный центр.

Это не простая очередь сообщений, а основа журнала событий.

Возможно, более интуитивно понятно думать об этом как о постоянно записываемом «глобальном журнале событий». Любой микросервис (например, «Заказ успешно создан») может легко опубликовать запись о событии в этом журнале журнала, например: «Идентификатор события: 107, Тип: Новый заказ, Содержание: Номер заказа XXX, Время: 14:00». Оно не спрашивает почему, оно лишь отвечает за то, чтобы всё аккуратно и настойчиво записывать.

Все другие службы, которые заботятся об этом (например, службы инвентаризации, службы ведения журналов, службы анализа), могут подписаться на этот журнал в любое время. Они могут читать с начала или продолжать с того места, на котором остановились, самостоятельно переваривая эти события в своем собственном темпе, не нарушая «службу заказов», сгенерировавшую событие. Когда служба инвентаризации считывает событие нового заказа, она вычитает запасы; когда служба анализа его считывает, она обновляет статистику продаж.

Это приносит несколько обнадеживающих преимуществ, особенно в соответствии с нашим инженерным мышлением:

1. Развязка и устойчивость:Издатели и подписчики не знают друг друга. Даже если служба инвентаризации временно обновляется и поддерживается, события заказов по-прежнему будут постоянно регистрироваться в журнале. Когда служба инвентаризации возобновит работу, она сможет спокойно справиться с накопившейся работой без потери данных. Система подобна буферной пружине и больше не является хрупкой.
2. Последовательность и прослеживаемость:Каждое мероприятие имеет строгую последовательность. Это крайне важно при работе с бизнес-процессами со строгими причинно-следственными связями, такими как «платеж-отгрузка». Вы можете четко отслеживать полный контекст события, что облегчает отладку и аудит.
3. В реальном времени против асинхронного:Данные передаются почти в реальном времени, но обработка является асинхронной. Службе не нужно ждать ответа, и она может продолжить обработку следующего запроса, при этом пропускная способность, естественно, значительно улучшится.

Что нас волнует, когда мы выбираем такой «нервный центр»?

Как и при выборе сервосистемы для прецизионного оборудования, мы будем учитывать ее частоту срабатывания, точность управления и стабильность работы. В мире программного обеспечения аналогичные соображения таковы:

• Высокая пропускная способность и низкая задержка:Сможет ли он справиться с огромным потоком событий, сохраняя при этом миллисекундную скорость доставки?
• Долговечность и надежность:Данные хранятся надежно и никогда не теряются даже при перезапуске сервера?
• Горизонтальная масштабируемость:Когда бизнес растет, можно ли плавно расширить мощности за счет простого добавления машин вместо замены всей системы?

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

простая мысль

Если вы планируете сложную систему, состоящую из множества независимых служб, вы можете также спросить себя: постоянно ли мои службы «звонят» друг другу, чтобы подгонять друг друга, из-за чего линия часто оказывается занятой или без ответа; или они все привыкли публиковать и получать информацию с общей "доски объявлений", и каждый работает неторопливо?

Последняя модель является одним из ключей к тому, чтобы позволить микросервисной архитектуре по-настоящему раскрыть свою мощь. Это не только решает технические проблемы, но и меняет философию совместной работы с данными. В эту эпоху, когда данные имеют ценность, обеспечение эффективной и безошибочной доставки информационного потока является краеугольным камнем для того, чтобы любая сложная система — будь то механическая линия или программный кластер — стала зрелой и надежной.

Основанная в 2005 году,мощностьбыла посвящена профессиональному производителю компактных приводов со штаб-квартирой в Дунгуане, провинция Гуандун, Китай. Используя инновации в технологии модульных приводов,мощностьобъединяет высокопроизводительные двигатели, прецизионные редукторы и многопротокольные системы управления, обеспечивая эффективные и индивидуальные решения для интеллектуальных систем привода. Kpower предоставила профессиональные решения в области приводных систем более чем 500 корпоративным клиентам по всему миру, предлагая продукты, охватывающие различные области, такие как системы «умный дом», автоматическая электроника, робототехника, точное земледелие, дроны и промышленная автоматизация.