Что это такое?
Sogou C++ Workflow — промышленный C++-движок для асинхронного сетевого взаимодействия и параллельных вычислений. Компания Sogou использует его внутри для поиска, облачного метода ввода и рекламных сервисов, а он обрабатывает миллиарды запросов в день.
Sogou C++ Workflow — промышленный C++-движок для асинхронного сетевого взаимодействия и параллельных вычислений. Компания Sogou использует его внутри для поиска, облачного метода ввода и рекламных сервисов, а он обрабатывает миллиарды запросов в день.Это фреймворк или просто сетевая библиотека?Это полноценный фреймворк для асинхронного программирования. Помимо многопротокольной клиент-серверной библиотеки (HTTP, Redis, MySQL, Kafka), он позволяет создавать собственные протоколы, свою RPC-систему и произвольные рабочие процессы на основе DAG, которые сочетают сетевые операции и вычисления.
Это полноценный фреймворк для асинхронного программирования. Помимо многопротокольной клиент-серверной библиотеки (HTTP, Redis, MySQL, Kafka), он позволяет создавать собственные протоколы, свою RPC-систему и произвольные рабочие процессы на основе DAG, которые сочетают сетевые операции и вычисления.Как добавить это в мой проект?Установите готовые пакеты через apt-get в Debian/Ubuntu или dnf в Fedora, соберите проект с помощью xmake или скомпилируйте из исходников через make, а затем следуйте руководствам (например, примеру клиента 'wget'), чтобы написать свою первую задачу.
Установите готовые пакеты через apt-get в Debian/Ubuntu или dnf в Fedora, соберите проект с помощью xmake или скомпилируйте из исходников через make, а затем следуйте руководствам (например, примеру клиента 'wget'), чтобы написать свою первую задачу.Что нужно для сборки?Компилятор с поддержкой C++11 и OpenSSL 1.1+ (BoringSSL тоже подходит). Зависимостей от boost или asio нет, однако для протокола Kafka нужны библиотеки сжатия lz4, zstd и snappy.
Компилятор с поддержкой C++11 и OpenSSL 1.1+ (BoringSSL тоже подходит). Зависимостей от boost или asio нет, однако для протокола Kafka нужны библиотеки сжатия lz4, zstd и snappy.Версия для Windows не отстаёт от Linux?Поддержка Windows поставляется в отдельной ветке и использует IOCP вместо реализации для Linux на основе epoll, однако пользовательские интерфейсы полностью идентичны версии для Linux.
Поддержка Windows поставляется в отдельной ветке и использует IOCP вместо реализации для Linux на основе epoll, однако пользовательские интерфейсы полностью идентичны версии для Linux.На каких платформах и процессорах это работает?Работает на Linux, macOS, Windows и Android, на 32- и 64-битных x86, на ARM как с порядком байтов big-endian, так и little-endian, а также на процессорах Loongson.
Работает на Linux, macOS, Windows и Android, на 32- и 64-битных x86, на ARM как с порядком байтов big-endian, так и little-endian, а также на процессорах Loongson.Как Workflow связан с srpc?srpc — это отдельная RPC-система с открытым исходным кодом, построенная на основе Workflow; она добавляет поддержку протоколов srpc, brpc, trpc и thrift.
srpc — это отдельная RPC-система с открытым исходным кодом, построенная на основе Workflow; она добавляет поддержку протоколов srpc, brpc, trpc и thrift.Могут ли воркфлоу быть сложнее простых последовательных и параллельных цепочек?Да: помимо обычных последовательных и параллельных структур фреймворк поддерживает произвольные топологии задач в виде DAG (направленного ациклического графа).
Да: помимо обычных последовательных и параллельных структур фреймворк поддерживает произвольные топологии задач в виде DAG (направленного ациклического графа).Какие клиенты есть из коробки?В комплекте есть готовые асинхронные клиенты для HTTP, Redis, MySQL (а также MariaDB и TiDB) и Kafka, поэтому писать собственный код протокола для них не нужно.
В комплекте есть готовые асинхронные клиенты для HTTP, Redis, MySQL (а также MariaDB и TiDB) и Kafka, поэтому писать собственный код протокола для них не нужно.Как в асинхронном коде с колбэками избегается утечка памяти?Время жизни каждой задачи длится от создания до завершения колбэка, после чего она автоматически освобождается; ненужные задачи нужно освобождать вызовом dismiss(). Архитектура намеренно не использует std::shared_ptr, отдавая предпочтение колбэкам на основе std::function.
Время жизни каждой задачи длится от создания до завершения колбэка, после чего она автоматически освобождается; ненужные задачи нужно освобождать вызовом dismiss(). Архитектура намеренно не использует std::shared_ptr, отдавая предпочтение колбэкам на основе std::function.Which topics is it in?consul, dag, service-discovery, load-balancer, kafka, dns, concurrency, async, microservices, mysql, redis, http
consul, dag, service-discovery, load-balancer, kafka, dns, concurrency, async, microservices, mysql, redis, http