Peržiūra: taikomas kodas
Klasė apima logiką, skirtą naujų užsakymų apdorojimui. Ji ištraukia užsakymus ir pozicijas iš duomenų bazės, tada atlieka HTTP užklausą į išorinį mikroservisą Stock, kuriame rezervuoja prekes pagal užsakymo pozicijas. Jei visi rezervavimai sėkmingai įvyksta, mikroservisas patvirtina užsakymo rezervavimą Stock ir pažymi užsakymą kaip apdorotą. Mikroservisas veikia keliuose egzemplioriuose, todėl metodas Process gali būti vykdomas lygiagrečiai. Norint išvengti tų pačių eilučių apdorojimo, naudojamas pesimistinio užrakto mechanizmas PostgreSQL Select for update ... skip locked. IBus įgyvendinimas siunčia žinutes į RabbitMq.
```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;" }
};
```
