흑우마스터의 마법의 공간

using System; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; using Microsoft.Extensions.Hosting; using Microsoft.Extensions.Logging; using RabbitMQ.Client; using RabbitMQ.Client.Events; namespace MyWorkerService { public class Worker : BackgroundService { private readonly ILogger _logger; private IConnection _connection; private IModel ..

BasicConsume 서버와 연결이 유지 되는 동안 메시지를 지속적으로 수신하도록 구독하며 이 메서드를 사용하면 더 이상 메시지를 가져오기 위해 수동으로 호출 할 필요가 없음 메시지가 큐에 도착하면 자동으로 Consumer에게 전달되고 이렇게 전달 된 메시지는 Received 이벤트 핸들러에서 처리가 가능함 장점 - 큐에 메시지가 도착하는 동안 즉시 전달되므로 지연 시간이 최소화 됨 - 메시지를 수도으로 가져오기 위한 코드를 작성할 필요가 없음 단점 - 서버와 연결이 종료되면 메시지 전달이 중단 됨 - 비정상적인 연결 중단에 대한 처리 필요 BasicGet 메시지를 수동으로 가져오는 방법으로 이 메서드를 호출할 때마다 큐에서 메시지를 하나씩 가져옴. 메시지가 없으면 null을 반환하며 메시지를 가져온 ..

public class Worker : BackgroundService { private readonly IConnection _connection; private readonly IModel _channel; public Worker(IRabbitMQConnectionFactory factory) { _connection = factory.CreateConnection(); _channel = _connection.CreateModel(); // Declare the exchange and queue _channel.ExchangeDeclare(exchange: "mydirectexchange", type: "direct"); _channel.QueueDeclare(queue: "myqueue", du..

RabbitMQ는 응용 프로그램이 메시지 큐를 통해 서로 통신할 수 있도록 하는 메시징 브로커입니다. AMQP(Advanced Message Queuing Protocol)를 사용하여 애플리케이션 간에 메시지를 전송합니다. RabbitMQ에서 메시지는 임시 저장 위치인 대기열로 전송됩니다. 그런 다음 소비자는 메시지를 처리할 준비가 되면 대기열에서 메시지를 검색할 수 있습니다. 이를 통해 애플리케이션의 분리가 가능하고 애플리케이션 간의 비동기 통신이 가능합니다. 대기열 외에도 RabbitMQ는 교환도 사용합니다. Exchange는 생산자로부터 메시지를 받은 다음 일련의 라우팅 규칙에 따라 메시지를 하나 이상의 대기열로 라우팅합니다. RabbitMQ에는 4가지 유형의 교환이 있습니다. 직접 교환: 메시지는..