Брокеры

Нормативная версия документации - английская

Эта страница переведена с английского языковой моделью. При любом расхождении верен английский оригинал.

Обработчики, роутеры, кодеки и middleware не зависят от брокера. Перевести сервис на другой брокер вы можете, изменив одну строку в with_broker.

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

У каждого крейта брокера свой сайт документации: ссылки собраны в столбце «Документация» и в меню Брокеры.

Брокер	Крейт	Транспорт	Документация
Memory	ruststream (фича memory)	очередь внутри процесса, без внешнего сервиса	этот сайт
NATS	ruststream-nats	Core NATS и JetStream	powersemmi.github.io/ruststream-nats
Redis	ruststream-fred	Redis Streams (standalone, кластер, sentinel)	powersemmi.github.io/ruststream-fred
RabbitMQ	ruststream-lapin	AMQP 0.9.1 (очереди, обменники, подтверждения издателя, direct reply-to)	powersemmi.github.io/ruststream-lapin
Kafka	ruststream-rdkafka	Apache Kafka (группы консьюмеров, отслеживаемая фиксация смещений, транзакции, конвейеры exactly-once)	powersemmi.github.io/ruststream-rdkafka
AMQP 1.0	ruststream-amqp	ActiveMQ Artemis, RabbitMQ 4.x, Azure Service Bus и остальное семейство AMQP 1.0 (request-reply, транзакции)	powersemmi.github.io/ruststream-amqp
Google Cloud Pub/Sub	ruststream-gcp-pubsub	Pub/Sub через официальный клиент (ключи упорядочивания, подтверждение exactly-once, политики dead-letter)	powersemmi.github.io/ruststream-gcp-pubsub
AWS SQS / SNS	ruststream-sqs-sns	Очереди SQS с доставкой через SNS всем подписчикам разом (FIFO-группы, управление видимостью, встроенная отложенная повторная доставка)	powersemmi.github.io/ruststream-sqs-sns
Apache Pulsar	ruststream-pulsar	Темы и шаблоны Pulsar (режимы подписки, политики dead-letter, перемотка)	powersemmi.github.io/ruststream-pulsar
MQTT 5	ruststream-rumqttc	MQTT v5 (уровни QoS, shared-группы, retained-сообщения)	powersemmi.github.io/ruststream-rumqttc
ZeroMQ	ruststream-zeromq	Без брокера: PUSH/PULL, PUB/SUB и request-reply на DEALER/ROUTER поверх TCP и IPC	powersemmi.github.io/ruststream-zeromq
Файлы потоков / stdio	ruststream-sea-file	Долговечные воспроизводимые файлы потоков и конвейеры оболочки; нулевая инфраструктура, перемотка на любую позицию	powersemmi.github.io/ruststream-sea-file
AWS Kinesis	ruststream-kinesis	Потоки данных Kinesis (аренда шардов, контрольные точки, перемотка)	powersemmi.github.io/ruststream-kinesis

Как реализовать брокер для другого транспорта, объясняет раздел Авторам брокеров.

Переключение брокеров

Любой брокер создаётся синхронно, а рантайм подключает его на старте приложения. В примерах ниже меняется только строка создания брокера.

MemoryNATSRedisRabbitMQKafka

use ruststream::memory::MemoryBroker;
use ruststream::runtime::{AppInfo, RustStream};

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(MemoryBroker::new(), |b| b.include_router(routes::orders()))
}

use ruststream::runtime::{AppInfo, RustStream};
use ruststream_nats::NatsBroker;

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(NatsBroker::new("nats://localhost:4222"), |b| {
            b.include_router(routes::orders())
        })
}

use ruststream::runtime::{AppInfo, RustStream};
use ruststream_fred::RedisBroker;

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(RedisBroker::standalone("redis://localhost:6379"), |b| {
            b.include_router(routes::orders())
        })
}

use ruststream::runtime::{AppInfo, RustStream};
use ruststream_lapin::LapinBroker;

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(LapinBroker::new("amqp://localhost:5672"), |b| {
            b.include_router(routes::orders())
        })
}

use ruststream::runtime::{AppInfo, RustStream};
use ruststream_rdkafka::KafkaBroker;

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(
            KafkaBroker::new(["localhost:9092"]).default_group("orders"),
            |b| {
                b.include_router(routes::orders())
            },
        )
}

Параметры подключения каждый крейт брокера документирует сам. Если подписке нужны специфичные для брокера опции (группы консьюмеров, durable-имена), вы можете указать дескриптор этого брокера в атрибуте #[subscriber(..)]; см. дескрипторы конкретных брокеров.