.NET Aspire: 올바른 방법으로 클라우드 네이티브 애플리케이션 구축

dotnet workload update
dotnet workload install aspire

dotnet new aspire-starter -n MyCloudApp

dotnet run --project MyCloudApp.AppHost

var builder = DistributedApplication.CreateBuilder(args);

// Infrastructure resources
var postgres = builder.AddPostgres("postgres")
    .WithPgAdmin()
    .AddDatabase("catalogdb");

var redis = builder.AddRedis("cache");

var rabbitmq = builder.AddRabbitMQ("messaging")
    .WithManagementPlugin();

// Application services
var catalogApi = builder.AddProject<Projects.CatalogApi>("catalog-api")
    .WithReference(postgres)
    .WithReference(redis)
    .WithReference(rabbitmq);

var orderApi = builder.AddProject<Projects.OrderApi>("order-api")
    .WithReference(postgres)
    .WithReference(rabbitmq);

var frontend = builder.AddProject<Projects.WebFrontend>("frontend")
    .WithExternalHttpEndpoints()
    .WithReference(catalogApi)
    .WithReference(orderApi);

builder.Build().Run();
```해당 코드를 소리내어 읽어보세요. 실제로는 그 자체를 문서화합니다. "카탈로그 API는 PostgreSQL, Redis 및 RabbitMQ를 참조합니다. 프런트엔드는 카탈로그 API 및 주문 API를 참조합니다." 이것이 코드로 표현된 아키텍처입니다.

주목할 만한 몇 가지 사항:

- **`WithReference`** 무거운 작업을 수행합니다. 환경 변수 및 구성을 통해 연결 문자열과 서비스 URL을 소비 프로젝트에 자동으로 삽입합니다. 귀하의 서비스는 Redis가 *어디* 실행되고 있는지 알 필요가 없습니다. Aspire가 이를 처리합니다.
- **`WithPgAdmin()`** 및 **`WithManagementPlugin()`** 실제 서비스와 함께 PostgreSQL 및 RabbitMQ용 관리 UI를 실행합니다. 개발하는 동안 이는 매우 중요합니다.
- **`WithExternalHttpEndpoints()`** 서비스를 외부에서 액세스할 수 있는 것으로 표시하며 이는 배포 시 중요합니다.

### 리소스 구성

세분화된 제어를 통해 리소스를 구성할 수 있습니다.

```csharp
var postgres = builder.AddPostgres("postgres")
    .WithEnvironment("POSTGRES_MAX_CONNECTIONS", "200")
    .WithDataVolume("postgres-data")
    .AddDatabase("catalogdb");

var redis = builder.AddRedis("cache")
    .WithDataVolume("redis-data");

public static class Extensions
{
    public static IHostApplicationBuilder AddServiceDefaults(
        this IHostApplicationBuilder builder)
    {
        builder.ConfigureOpenTelemetry();
        builder.AddDefaultHealthChecks();
        builder.Services.AddServiceDiscovery();

        builder.Services.ConfigureHttpClientDefaults(http =>
        {
            http.AddStandardResilienceHandler();
            http.AddServiceDiscovery();
        });

        return builder;
    }

    public static IHostApplicationBuilder ConfigureOpenTelemetry(
        this IHostApplicationBuilder builder)
    {
        builder.Logging.AddOpenTelemetry(logging =>
        {
            logging.IncludeFormattedMessage = true;
            logging.IncludeScopes = true;
        });

        builder.Services.AddOpenTelemetry()
            .WithMetrics(metrics =>
            {
                metrics.AddAspNetCoreInstrumentation()
                    .AddHttpClientInstrumentation()
                    .AddRuntimeInstrumentation();
            })
            .WithTracing(tracing =>
            {
                tracing.AddAspNetCoreInstrumentation()
                    .AddHttpClientInstrumentation()
                    .AddGrpcClientInstrumentation();
            });

        builder.AddOpenTelemetryExporters();
        return builder;
    }

    public static IHostApplicationBuilder AddDefaultHealthChecks(
        this IHostApplicationBuilder builder)
    {
        builder.Services.AddHealthChecks()
            .AddCheck("self", () => HealthCheckResult.Healthy(),
                ["live"]);

        return builder;
    }
}

var builder = WebApplication.CreateBuilder(args);
builder.AddServiceDefaults();

// Your service-specific configuration...

var app = builder.Build();
app.MapDefaultEndpoints();
app.Run();

var builder = WebApplication.CreateBuilder(args);
builder.AddServiceDefaults();
builder.AddRedisDistributedCache("cache");

builder.AddRedisOutputCache("cache");

builder.AddNpgsqlDbContext<CatalogDbContext>("catalogdb", settings =>
{
    settings.DisableRetry = false;
});

builder.AddRabbitMQClient("messaging");

// Azure Blob Storage
builder.AddAzureBlobClient("blobs");

// Azure Service Bus
builder.AddAzureServiceBusClient("servicebus");

// Azure Key Vault
builder.AddAzureKeyVaultClient("secrets");
```패턴은 항상 동일합니다. AppHost의 한 줄은 리소스를 정의하고 소비 서비스의 한 줄은 리소스를 사용합니다. 연결 세부정보가 자동으로 전달됩니다.

## 개발자 대시보드

Aspire 대시보드는 실제로 사용하기 전까지는 가지고 있으면 좋을 것 같은 기능 중 하나입니다. Aspire 대시보드 없이 작업하는 것은 상상할 수 없습니다.

AppHost를 로컬로 실행하면 대시보드가 시작되고 다음을 제공합니다.

- **리소스 개요** — 상태 표시기를 통해 모든 서비스와 인프라를 한 눈에 볼 수 있습니다.
- **구조화된 로그** — 모든 서비스의 실시간 로그 스트리밍, 필터링 및 검색 가능
- **분산 추적** — 플레임 차트로 시각화된 여러 서비스에 걸친 엔드투엔드 요청 추적
- **지표** — 실시간 HTTP 요청 비율, 오류율, 지연 시간 및 사용자 지정 지표
- **콘솔 로그** — 각 컨테이너 및 프로젝트의 원시 stdout/stderr

분산 추적은 특히 중요합니다. 요청이 프런트엔드에 도달하고 카탈로그 API를 통해 흐르고 Redis 및 PostgreSQL에 도달하면 각 홉에 대한 타이밍과 함께 전체 체인을 볼 수 있습니다. 더 이상 병목 현상이 발생하는 위치를 추측할 필요가 없습니다.

디버깅하는 동안 대시보드가 ​​가장 유용하다는 것을 알았습니다. 여러 터미널 창을 추적하거나 로그 파일 사이를 이동하는 대신 서비스 전반에 걸쳐 관련 이벤트를 연결하는 상관 관계 ID를 통해 모든 것이 한 곳에 있습니다.

대시보드는 독립형 컨테이너로도 제공됩니다. 즉, 스테이징 환경이나 CI 파이프라인에서 사용할 수 있습니다.

```bash
docker run --rm -p 18888:18888 \
  mcr.microsoft.com/dotnet/aspire-dashboard:latest

azd init
azd up

dotnet tool install -g aspirate
aspirate generate
aspirate apply

var postgres = builder.AddPostgres("postgres")
    .AddDatabase("catalogdb")
    .WithHealthCheck();

public static class AppHostExtensions
{
    public static IResourceBuilder<ProjectResource> AddWorkerService(
        this IDistributedApplicationBuilder builder,
        string name,
        IResourceBuilder<IResourceWithConnectionString> db,
        IResourceBuilder<IResourceWithConnectionString> messaging)
    {
        return builder.AddProject<Projects.WorkerService>(name)
            .WithReference(db)
            .WithReference(messaging)
            .WithReplicas(3);
    }
}

var catalogApi = builder.AddProject<Projects.CatalogApi>("catalog-api")
    .WithReference(postgres)
    .WithReference(redis)
    .WithReplicas(5);

var dbPassword = builder.AddParameter("db-password", secret: true);

var postgres = builder.AddPostgres("postgres", password: dbPassword)
    .AddDatabase("catalogdb");

[Fact]
public async Task CatalogApiReturnsProducts()
{
    var appHost = await DistributedApplicationTestingBuilder
        .CreateAsync<Projects.MyCloudApp_AppHost>();

    await using var app = await appHost.BuildAsync();
    await app.StartAsync();

    var httpClient = app.CreateHttpClient("catalog-api");
    var response = await httpClient.GetAsync("/api/products");

    response.EnsureSuccessStatusCode();

    var products = await response.Content
        .ReadFromJsonAsync<List<Product>>();
    Assert.NotEmpty(products);
}

var redis = builder.AddRedis("cache")
    .WithContainerRuntimeArgs("--memory=256m");