DeFiBus (Decentralized Financial Message Bus) — Распределённая финансовая шина сообщений

DeFiBus = RPC + MQ — это безопасная и контролируемая распределённая финансовая шина сообщений, созданная на основе открытого исходного кода. DeFiBus предоставляет не только синхронные вызовы RPC, но и асинхронные уведомления о событиях MQ, а также обычные услуги вызова и режимы обмена сообщениями, такие как широковещательная рассылка событий и групповая рассылка. Кроме того, DeFiBus повышает доступность в распределённых сценариях, таких как мультицентровая работа, локальное обслуживание и постепенное развёртывание.

Усиление отказоустойчивости в отношении сбоев оборудования делает шину сообщений более стабильной и надёжной, обеспечивая 7x24-часовое обслуживание для бизнеса.

Распределённая архитектура

DCN: Data Center Node (узел центра обработки данных).

Архитектура системы

Основные компоненты (модули) DeFiBus включают:

• Broker: обеспечивает функции хранения сообщений с помощью облегчённых механизмов тем и очередей. Брокер периодически сообщает информацию о темах в NameServer, и все экземпляры брокера в кластере должны поддерживать согласованность, чтобы избежать несогласованности информации о маршрутизации.
• NameServer: предоставляет обнаружение и маршрутизацию тем. Каждый NameServer принимает сообщения о темах от брокеров и поддерживает информацию о маршрутизации тем для запросов клиентов.
• GSL (Global Service Location): сервис глобального местоположения предоставляет маршрутизацию на уровне сервисов. Сервисы могут быть развёрнуты в разных регионах (например, разные центры обработки данных, логические разделы и т. д.), и клиентам не нужно заботиться о регионе развёртывания сервисов при запросе конкретных сервисов. GSL может автоматически определять конкретные сервисы и возвращать информацию о сервисах клиентам.
• EventMesh: сервисный прокси предоставляет доступ через TCP/HTTP и позволяет клиентам на других языках программирования, таким как C, GO, Python и другим, подключаться в соответствии с протоколом.
• ConfigCenter (CC): центр конфигурации предоставляет доступ через HTTP, например, адресацию Namesrv и другие конфигурации.
• ACL: служба контроля доступа, управление доступом на уровне тем, поддержка чёрных и белых списков.
• SGS (Service Government System): система управления сервисами, используется для управления сервисами, запросами сервисов, ответами сервисов, маршрутизацией сервисов, ACL и другими процессами и данными.

Список функций:

• RPC-вызовы: «запрос-ответ», поддерживают синхронный вызов между системами.
• Публикация и подписка на сообщения.
• Постепенное развёртывание: постепенная публикация сервисов.
• Механизм разрыва цепи: управление отказами на уровне приложений.
• Управление потоком: ограничение потока на уровне очередей.
• Локальное обслуживание: запросы и ответы на обслуживание выполняются локально, уменьшая количество вызовов между регионами.
• Мультиактивность приложений: мультицентровое мультиактивное развёртывание приложений.
• Динамическая регулировка очередей: динамическая адаптация количества очередей в зависимости от количества экземпляров приложения.
• Таблица контроля доступа: оптимизация ситуации повторного потребления при балансировке нагрузки.
• Отказоустойчивость: изоляция отказов и ошибок.
• Сервисный прокси: облачный мультиязычный прокси EventMesh.
• Управление сервисами: управление метаданными сервисов (ожидается открытый исходный код).
• Маршрутизация и определение местоположения сервисов: динамическая маршрутизация и определение местоположения (ожидается открытый исходный код).
• Плавное обновление: плавное обновление, плавное расширение (ожидается открытый исходный код).

Быстрый старт

Процесс установки и развёртывания DeFiBus см. в «Руководстве по использованию DeFiBus». Примеры модулей предоставляют лучшие практики: defibus-examples.

Лицензия

DeFiBus лицензируется под Apache License.

Мы выражаем огромную благодарность следующим проектам за их вклад в открытый исходный код:

• RocketMQ;
• Netty.

Динамика

Сводная информация о динамике и новостях доступна на Wiki.

Контакты

Группа WeChat/QQ: