Mvp24Hours.Infrastructure.RabbitMQ 3.1.101

Message Broker

Message Broker is software that allows applications, systems and services to communicate with each other and exchange information. What is a Message Broker?

RabbitMQ

Prerequisites

Add a configuration file to the project named "appsettings.json", as below:

{
  "Mvp24Hours": {
    "Brokers": {
      "RabbitMQ": {
        "HostName": "localhost",
        "Port": 6672,
        "UserName": "admin",
        "Password": "admin@123"
      }
    }
  }
}

Installation

/// Package Manager Console >
Install-Package Mvp24Hours.Infrastructure.RabbitMQ

Configuration

/// Startup.cs
services.AddScoped<CustomerProducer, CustomerProducer>();
services.AddScoped<CustomerConsumer, CustomerConsumer>();

Producer/Consumer Implementation

/// CustomerProducer.cs
public class CustomerProducer : MvpRabbitMQProducer
{
    public CustomerProducer()
        : base("RoutingKey") { }
}

/// CustomerService.cs // Save Method
producer.Publish(new CustomerDto
{
    Id = 99,
    Name = "Test 1",
    Active = true
});

/// CustomerConsumer.cs
public class CustomerConsumer : MvpRabbitMQConsumer<CustomerDto>
{
    public CustomerConsumer()
        : base("RoutingKey")
    {
    }

    public override Task Received(CustomerDto message)
    {
        Trace.WriteLine($"Received customer {message?.Name}");
        return Task.FromResult(false);
    }
} 

/// HostService.cs
var source = new CancellationTokenSource(TimeSpan.FromSeconds(5));
while (!source.IsCancellationRequested)
{
    var consumer = ServiceProviderHelper.GetService<CustomerConsumer>();
    consumer?.Consume();
}

Using Docker

// Command
docker run -d --name my-rabbit -p 5672:5672 -p 5673:5673 -p 15672:15672 rabbitmq:3-management

// Connect
[127.0.0.1:6379](amqp://guest:guest@localhost:5672)