SPMS/SPMS_API
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: RabbitMQ 연결 실패 시 앱 크래시 방지 (#124) #125

Merged
seonkyu.kim merged 2 commits from fix/#124-rabbitmq-crash into develop 2026-02-10 10:16:33 +00:00
Conversation 0 Commits 2 Files Changed 4 +56 -55
1 changed files with 56 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit efd6615809 - Show all commits

19
SPMS.Infrastructure/Messaging/RabbitMQInitializer.cs
View File

@ -25,10 +25,19 @@ public class RabbitMQInitializer : IHostedService
public async Task StartAsync(CancellationToken cancellationToken) public async Task StartAsync(CancellationToken cancellationToken)
{ {
try try
{
await InitializeAsync(cancellationToken);
}
catch (Exception ex)
{
_logger.LogWarning(ex, "RabbitMQ 초기화 실패 — 서버는 계속 실행됩니다. 메시지 발송 시 재연결을 시도합니다.");
}
}
public async Task InitializeAsync(CancellationToken cancellationToken)
{ {
await using var channel = await _connection.CreateChannelAsync(cancellationToken); await using var channel = await _connection.CreateChannelAsync(cancellationToken);
// Exchange 선언: Direct, Durable
await channel.ExchangeDeclareAsync( await channel.ExchangeDeclareAsync(
exchange: _settings.Exchange, exchange: _settings.Exchange,
type: ExchangeType.Direct, type: ExchangeType.Direct,
@ -44,7 +53,6 @@ public class RabbitMQInitializer : IHostedService
{ "x-message-ttl", _settings.MessageTtl } { "x-message-ttl", _settings.MessageTtl }
}; };
// Push Queue 선언
await channel.QueueDeclareAsync( await channel.QueueDeclareAsync(
queue: _settings.PushQueue, queue: _settings.PushQueue,
durable: true, durable: true,
@ -62,7 +70,6 @@ public class RabbitMQInitializer : IHostedService
_logger.LogInformation("Queue 선언 및 바인딩 완료: {Queue} → {Exchange} (routing_key: push)", _logger.LogInformation("Queue 선언 및 바인딩 완료: {Queue} → {Exchange} (routing_key: push)",
_settings.PushQueue, _settings.Exchange); _settings.PushQueue, _settings.Exchange);
// Schedule Queue 선언
await channel.QueueDeclareAsync( await channel.QueueDeclareAsync(
queue: _settings.ScheduleQueue, queue: _settings.ScheduleQueue,
durable: true, durable: true,
@ -80,12 +87,6 @@ public class RabbitMQInitializer : IHostedService
_logger.LogInformation("Queue 선언 및 바인딩 완료: {Queue} → {Exchange} (routing_key: schedule)", _logger.LogInformation("Queue 선언 및 바인딩 완료: {Queue} → {Exchange} (routing_key: schedule)",
_settings.ScheduleQueue, _settings.Exchange); _settings.ScheduleQueue, _settings.Exchange);
} }
catch (Exception ex)
{
_logger.LogError(ex, "RabbitMQ Exchange/Queue 초기화 실패");
throw;
}
}
public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask; public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
} }