{"id":298019,"date":"2020-01-31T15:00:25","date_gmt":"2020-01-31T15:00:25","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=298019"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=298019","title":{"rendered":".NET Core + RabbitMQ"},"content":{"rendered":"\n
\u041f\u0440\u0438 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0435 \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432 \u0432\u043e\u0437\u043d\u0438\u043a\u0430\u0435\u0442 \u0432\u043e\u043f\u0440\u043e\u0441 \u043e \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u0438\u0438 \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u0438 \u043e\u0442 \u043e\u0434\u043d\u043e\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u0434\u0440\u0443\u0433\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c \u043f\u043e \u043c\u0435\u0440\u0435 \u0432\u043e\u0437\u043d\u0438\u043a\u043d\u043e\u0432\u0435\u043d\u0438\u044f \u043a\u0430\u043a\u0438\u0445-\u043b\u0438\u0431\u043e \u0441\u043e\u0431\u044b\u0442\u0438\u0439. \u041f\u0440\u0438 \u044d\u0442\u043e\u043c \u0432\u0430\u0436\u043d\u043e \u0438\u043c\u0435\u0442\u044c \u0441\u0438\u0441\u0442\u0435\u043c\u0443 \u0431\u0435\u0437 \u043f\u0440\u0438\u0432\u044f\u0437\u043a\u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044f \u043a \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u0435\u043b\u044f\u043c. \u0412 \u044d\u0442\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u0430\u0442\u0442\u0435\u0440\u043d Publisher-Subscriber.<\/p>\n

\u041d\u0430 \u0440\u044b\u043d\u043a\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u043e \u043f\u0440\u043e\u0434\u0443\u043a\u0442\u043e\u0432 \u0434\u043b\u044f \u043e\u0431\u043c\u0435\u043d\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u044e\u0442 \u043f\u0430\u0442\u0442\u0435\u0440\u043d Publisher-Subscriber, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 Azure Service Bus, RabbitMQ \u0438\u043b\u0438 Apache Kafka.<\/p>\n

\u041d\u0435\u0434\u0430\u0432\u043d\u043e \u043c\u043d\u043e\u044e \u0431\u044b\u043b\u0438 \u043e\u043f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u043d\u044b \u0434\u0432\u0435 NuGet \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u0434\u043b\u044f \u0431\u044b\u0441\u0442\u0440\u043e\u0439 \u0438 \u0443\u0434\u043e\u0431\u043d\u043e\u0439 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 event-based communication \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c Azure Service Bus \u0438 RabbitMQ. \u0412 \u044d\u0442\u043e\u0439 \u043a\u043e\u0440\u043e\u0442\u043a\u043e\u0439 how-to \u0441\u0442\u0430\u0442\u044c\u0435 \u043e\u043f\u0438\u0441\u0430\u043d\u044b \u0448\u0430\u0433\u0438 \u0434\u043b\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044f \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0439.<\/a><\/p>\n

\u0418\u0441\u0445\u043e\u0434\u043d\u044b\u0435<\/h3>\n

Publisher \u2014 .NET Core \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435, \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u0435\u0442 \u0432 \u0440\u043e\u043b\u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044f.
Subscriber \u2014 .NET Core \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435, \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u0435\u0442 \u0432 \u0440\u043e\u043b\u0438 \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u0435\u043b\u044f.<\/p>\n

How-To<\/h3>\n

1. \u0412 publisher<\/b> \u0438 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f\u0445 \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0435 \u0434\u0432\u0435 NuGet<\/b> \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438.<\/p>\n

PM> Install-Package Autofac.Extensions.DependencyInjection PM> Install-Package EventBus.RabbitMQ.Standard <\/code><\/pre>\n
  2. \u0412 publisher<\/b> \u0438 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f\u0445 \u0434\u043e\u0431\u0430\u0432\u044c\u0442\u0435 \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u044e \u0432 appsettings.json<\/b>.<\/p>\n
{   "RabbitMq": {     "BrokerName": "test_broker",     "AutofacScopeName": "test_autofac",     "QueueName": "test_queue",     "RetryCount": "5",     "VirtualHost": "your_virtual_host",     "Username": "your_username",     "Password": "your_password",     "Host": "your_host",     "DispatchConsumersAsync": true   } } <\/code><\/pre>\n
  \u042d\u0442\u0438 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u043b\u0443\u0447\u0438\u0442\u044c \u043d\u0430 CoudAMQP<\/a>. \u0410\u043b\u044c\u0442\u0435\u0440\u043d\u0430\u0442\u0438\u0432\u043d\u043e \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c RabbitMQ \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u043e (Docker image<\/a>).<\/p>\n
  3. \u0412 publisher<\/b> \u0438 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f\u0445 \u0441\u043e\u0437\u0434\u0430\u0439\u0442\u0435 \u043a\u043b\u0430\u0441\u0441 \u0434\u043b\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0431\u0443\u0434\u0435\u0442 \u043f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0438, \u0432 \u0434\u0430\u043b\u044c\u043d\u0435\u0439\u0448\u0435\u043c, \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0442\u044c\u0441\u044f.<\/p>\n
public class ItemCreatedIntegrationEvent : IntegrationEvent {     public string Title { get; set; }     public string Description { get; set; }      public ItemCreatedIntegrationEvent(string title, string description)     {         Title = title;         Description = description;     } } <\/code><\/pre>\n
  4. \u0412 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u0441\u043e\u0437\u0434\u0430\u0439\u0442\u0435 \u043a\u043b\u0430\u0441\u0441 \u0434\u043b\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0430 \u0441\u043e\u0431\u044b\u0442\u0438\u044f ItemCreatedIntegrationEvent<\/b>.<\/p>\n
public class ItemCreatedIntegrationEventHandler : IIntegrationEventHandler<ItemCreatedIntegrationEvent> {     public ItemCreatedIntegrationEventHandler()     {     }      public async Task Handle(ItemCreatedIntegrationEvent @event)     {         \/\/Handle the ItemCreatedIntegrationEvent event here.     } } <\/code><\/pre>\n
  5. \u0412 publisher<\/b> \u0438 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f\u0445 \u043e\u0431\u043d\u043e\u0432\u0438\u0442\u0435 Program.cs<\/b>, \u0434\u043e\u0431\u0430\u0432\u0438\u0432 \u043e\u0434\u043d\u0443 \u0441\u0442\u0440\u043e\u0447\u043a\u0443.<\/p>\n
public class Program {     public static void Main(string[] args)     {         CreateHostBuilder(args).Build().Run();     }      public static IHostBuilder CreateHostBuilder(string[] args) =>         Host.CreateDefaultBuilder(args)             .UseServiceProviderFactory(new AutofacServiceProviderFactory()) \/\/Add this line.             .ConfigureWebHostDefaults(webBuilder =>             {                 webBuilder.UseStartup<Startup>();             }); } <\/code><\/pre>\n
  6. \u0412 publisher<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u043e\u0431\u043d\u043e\u0432\u0438\u0442\u0435 \u043c\u0435\u0442\u043e\u0434 ConfigureServices<\/b> \u0432 Startup.cs<\/b>.<\/p>\n
public class Startup {     public void ConfigureServices(IServiceCollection services)     {         ...          var rabbitMqOptions = Configuration.GetSection("RabbitMq").Get<RabbitMqOptions>();          services.AddRabbitMqConnection(rabbitMqOptions);         services.AddRabbitMqRegistration(rabbitMqOptions);          ...     } } <\/code><\/pre>\n
  7. \u0412 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u0441\u043e\u0437\u0434\u0430\u0439\u0442\u0435 \u0440\u0430\u0441\u0448\u0438\u0440\u0435\u043d\u0438\u0435 EventBusExtension<\/b>.<\/p>\n
public static class EventBusExtension {     public static IEnumerable<IIntegrationEventHandler> GetHandlers()     {         return new List<IIntegrationEventHandler>         {             new ItemCreatedIntegrationEventHandler()         };     }      public static IApplicationBuilder SubscribeToEvents(this IApplicationBuilder app)     {         var eventBus = app.ApplicationServices.GetRequiredService<IEventBus>();          eventBus.Subscribe<ItemCreatedIntegrationEvent, ItemCreatedIntegrationEventHandler>();          return app;     } } <\/code><\/pre>\n
  8. \u0412 subscriber<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u043e\u0431\u043d\u043e\u0432\u0438\u0442\u0435 \u043c\u0435\u0442\u043e\u0434\u044b ConfigureServices<\/b> \u0438 Configure<\/b> \u0432 Startup.cs<\/b>.<\/p>\n
public class Startup {     public void ConfigureServices(IServiceCollection services)     {         ...          var rabbitMqOptions = Configuration.GetSection("RabbitMq").Get<RabbitMqOptions>();          services.AddRabbitMqConnection(rabbitMqOptions);         services.AddRabbitMqRegistration(rabbitMqOptions);         services.AddEventBusHandling(EventBusExtension.GetHandlers());          ...     }      public void Configure(IApplicationBuilder app, IWebHostEnvironment env)     {         ...          app.UseAuthorization();          ...     } } <\/code><\/pre>\n
  9. \u0414\u043b\u044f \u0434\u0435\u043c\u043e\u043d\u0441\u0442\u0440\u0430\u0446\u0438\u0438 \u0438 \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b \u043c\u043e\u0436\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u043b\u0435\u0440 \u0432 publisher<\/b> \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u0441 \u043c\u0435\u0442\u043e\u0434\u043e\u043c \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u0442 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u044f. <\/p>\n
public class ItemController : ControllerBase {     private readonly IEventBus _eventBus;      public ItemController(IEventBus eventBus)     {         _eventBus = eventBus;     }      [HttpPost]     public IActionResult Publish()     {         var message = new ItemCreatedIntegrationEvent("Item title", "Item description");          _eventBus.Publish(message);          return Ok();     } } <\/code><\/pre>\n
  10. \u0422\u0435\u043f\u0435\u0440\u044c \u043c\u043e\u0436\u043d\u043e \u043e\u043f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u0442\u044c ItemCreatedIntegrationEvent. \u0417\u0430\u043f\u0443\u0441\u0442\u0438\u0442\u0435 \u043e\u0431\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f, \u0432\u044b\u0437\u043e\u0432\u0438\u0442\u0435 POST \u043c\u0435\u0442\u043e\u0434 Publish \u0432 subscriber<\/b> \u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u0439\u0442\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u0432 subscriber<\/b>.<\/p>\n
\u0421\u0441\u044b\u043b\u043a\u0438<\/h3>\n
  <\/p>\n