Developer

Dapr и Orleans: sidecar-блоки и виртуальные акторы

↑ 8.3 Микросервисы и распределённые системы · ← Предыдущая

Желательно~11 мин чтенияУровень: senior

Зачем это на собесе

«Как вы реализуете состояние, pub/sub и вызовы между сервисами, чтобы не привязываться к брокеру и базе?» и «Что такое модель акторов?» Dapr и Orleans это два разных ответа: Dapr выносит инфраструктурные блоки в sidecar и работает с любым языком, Orleans даёт модель виртуальных акторов внутри .NET.

Подтемы

  • Dapr: building blocks и sidecar
  • Компоненты и переносимость
  • Orleans: grains и виртуальные акторы
  • Когда что выбирать
  • Альтернативы и риски

Объяснение

Dapr

Dapr (Distributed Application Runtime, проект CNCF) запускает рядом с каждым сервисом sidecar, который предоставляет через HTTP или gRPC типовые блоки распределённых систем. Приложение говорит с sidecar на localhost, а тот общается с реальной инфраструктурой.

flowchart LR
    subgraph Сервис Orders
      A["Приложение<br/>(любой язык)"] -- "HTTP/gRPC localhost" --> S1["Dapr sidecar"]
    end
    subgraph Сервис Pricing
      S2["Dapr sidecar"] --> B["Приложение"]
    end
    S1 -- "service invocation<br/>(mTLS, повторы)" --> S2
    S1 --> ST[("State store<br/>Redis, PostgreSQL...")]
    S1 --> PS"Pub/Sub<br/>Kafka, RabbitMQ, NATS..."
БлокЧто делает
Service invocationвызов другого сервиса по имени с mTLS, повторами и трассировкой
State managementхранение ключ-значение в подключаемом хранилище
Pub/Subпубликация и подписка через подключаемый брокер
Bindingsвходящие и исходящие связи с внешними системами
Secrets, Configurationдоступ к секретам и настройкам
Actors, Workflowsакторы и долгие оркестрации

Компоненты и переносимость

Конкретное хранилище или брокер задаются компонентом (YAML), а не кодом. Сменить Redis на PostgreSQL для состояния или RabbitMQ на Kafka можно, поменяв компонент, код приложения остаётся тем же.

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.redis
  version: v1
  metadata:
    - name: redisHost
      value: redis:6379

Orleans

Orleans — фреймворк виртуальных акторов для .NET (от Microsoft Research). Grain это объект с идентификатором и состоянием, который платформа создаёт по требованию, размещает на одном из серверов кластера и активирует или выгружает автоматически. Вы вызываете grain по ключу, не заботясь о том, где он находится.

flowchart LR
    C["Клиент"] --> G["IGrainFactory.GetGrain&lt;ICartGrain&gt;('user-42')"]
    G --> S1["Silo 1"]
    G --> S2["Silo 2"]
    S1 --> A1["Grain user-42<br/>(активирован здесь)"]
    S2 --> A2["Grain user-7"]

Ключевые свойства:

  • Один поток на grain: вызовы одного grain обрабатываются по очереди, гонок данных внутри нет.
  • Виртуальность: grain существует логически всегда, физически активируется по запросу.
  • Состояние сохраняется в подключаемое хранилище, есть таймеры и reminders, потоки событий.
  • Подходит для сущностей с состоянием и высокой конкурентностью: корзины, игровые сессии, чаты, устройства IoT.

Dapr Actors и Orleans

Dapr тоже умеет акторов, но Orleans глубже интегрирован с .NET и проще для сложной логики на C♯. Dapr выбирают, когда нужен переносимый набор блоков на многих языках.

Сравнение и выбор

DaprOrleans
Идеяsidecar с готовыми блокамивиртуальные акторы в процессе приложения
Языкилюбые.NET
Состояниечерез state storegrain с состоянием
Накладные расходыдополнительный sidecar, сетевой хопвызовы внутри кластера
Подходитполиглот-микросервисы, переносимость инфраструктурысущности с состоянием, высокая конкурентность

Альтернативы и риски

  • Akka.NET, Proto.Actor — другие модели акторов.
  • MassTransit, библиотеки и обычный код (абстракции над брокерами) дешевле, если инфраструктура у вас одна и стабильна.
  • Риски Dapr: лишний слой и задержка, ограничения абстракции (общий интерфейс скрывает возможности конкретного брокера), эксплуатация sidecar.
  • Риски Orleans: необычная модель, нужно мыслить grain’ами; ограничения на блокирующие вызовы и размер состояния.

Примеры

Dapr: состояние, pub/sub и вызов сервиса

using Dapr.Client;
 
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddDaprClient();
var app = builder.Build();
 
app.MapPost("/orders", async (Order order, DaprClient dapr) =>
{
    await dapr.SaveStateAsync("statestore", $"order-{order.Id}", order);                    // состояние
    await dapr.PublishEventAsync("pubsub", "orders", order);                                // pub/sub
    var price = await dapr.InvokeMethodAsync<Order, decimal>(HttpMethod.Post, "pricing", "calculate", order);  // вызов сервиса pricing
    return Results.Ok(new { order.Id, price });
});
app.Run();
 
public record Order(int Id, decimal Total);

Пакет Dapr.AspNetCore. Локальный запуск: dapr run --app-id orders --app-port 5000 -- dotnet run.

Orleans: корзина как grain

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Orleans;
 
var host = Host.CreateDefaultBuilder(args)
    .UseOrleans(silo => silo.UseLocalhostClustering().AddMemoryGrainStorageAsDefault())
    .Build();
await host.StartAsync();
 
var client = host.Services.GetRequiredService<IGrainFactory>();
var cart = client.GetGrain<ICartGrain>("user-42");     // один экземпляр на ключ
await cart.AddAsync("milk");
Console.WriteLine(await cart.CountAsync());            // 1
 
await host.StopAsync();
 
public interface ICartGrain : IGrainWithStringKey
{
    Task AddAsync(string item);
    Task<int> CountAsync();
}
 
public class CartGrain : Grain, ICartGrain
{
    private readonly List<string> _items = [];
    public Task AddAsync(string item) { _items.Add(item); return Task.CompletedTask; }
    public Task<int> CountAsync() => Task.FromResult(_items.Count);
}

Пакеты Microsoft.Orleans.Server, Microsoft.Orleans.Sdk. В продакшене используют постоянное хранилище и кластеризацию (например, Redis, PostgreSQL) вместо локальной.

Нюансы и подводные камни

  • Абстракция не бесплатна. Dapr скрывает отличия брокеров и хранилищ, но самые полезные возможности конкретной технологии могут оказаться недоступными.
  • Sidecar это ещё один процесс. Добавляет задержку, потребляет ресурсы и требует мониторинга.
  • Grain не должен блокироваться. Длительные синхронные операции блокируют очередь вызовов grain.
  • Размер состояния и частота записи. Большое состояние и частые записи в grain убивают производительность.
  • Идентификатор grain. Продумайте ключи: по ним распределяется нагрузка, горячий ключ станет узким местом.
  • Не усложняйте. Для типичного CRUD-сервиса ни Dapr, ни Orleans не нужны.
  • Совместимость версий. Dapr, Orleans и их компоненты быстро развиваются, фиксируйте версии.

Вопросы с ответами

Связанные темы

Вид графа

Обратные ссылки