Yoxlama: tətbiq olunan kod
Sinif yeni sifarişlərin emalı üçün məntiqi ehtiva edir. O, verilənlər bazasından sifarişləri və mövqeləri çıxarır, sonra xarici mikroservis Stock-ə HTTP çağırışı edir və sifariş mövqelərinə görə məhsulları rezerve edir. Əgər bütün rezervasiyalar uğurla tamamlanarsa, mikroservis Stock-da sifariş rezervasiyasını təsdiqləyir və sifarişi işlənmiş kimi işarələyir. Mikroservis bir neçə nüsxədə işlədilir, ona görə də Process metodu paralel şəkildə icra oluna bilər. Eyni sətirlərin işlənməsinin qarşısını almaq üçün PostgreSQL Select for update ... skip locked mexanizmi istifadə olunur. IBus tətbiqi mesajları RabbitMq-ya göndərir.
```csharp
public sealed class PendingOrdersProcessor
{
public async Task PendingOrdersProcessor(ILogger logger, IBus bus, HttpStockService st
{
var env = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
var cs = _cs[env];
_db = new OrdersRepository(cs);
_bus = bus;
logger = logger;
```
```csharp
_stockService = stockService;
}
private readonly ILogger _logger;
private readonly IOrdersRepository _db;
private readonly IStockService _stockService;
private readonly IBus _bus;
private static readonly Dictionary<string, string> _cs = new {
{ "Development",
"User ID=root;Password=myPassword;Host=localhost;Port=5432;Database=myDataBase"
},
{ "Production", "User ID=root;Password=myPassword;Host=prod-db;Port=5432;Database="
"Pooling=true;Min Pool Size=0;Max Pool Size=1;" }
};
```
