Przegląd: kod zastosowany
Klasa zawiera logikę obsługi nowych zamówień. Wyciąga zamówienia i pozycje z bazy danych, a następnie wykonuje wywołanie HTTP do zewnętrznego mikroserwisu Stock, w którym rezerwuje produkty według pozycji zamówienia. Jeśli wszystkie rezerwacje zakończą się powodzeniem, mikroserwis potwierdza rezerwację zamówienia w Stock i oznacza zamówienie jako przetworzone. Mikroserwis jest uruchamiany w kilku instancjach, więc metoda Process może być wykonywana równolegle. Aby uniknąć przetwarzania tych samych linii, używa się mechanizmu pesymistycznego blokowania PostgreSQL Select for update ... skip locked. Implementacja IBus wysyła wiadomości do 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;" }
};
```
