Áttekintés: alkalmazott kód
A osztály tartalmazza az új megrendelések feldolgozásának logikáját. Kinyeri a megrendeléseket és a pozíciókat az adatbázisból, majd HTTP-kérést küld egy külső mikroservice-nek, a Stocknak, amely a megrendelés pozíciói szerint foglalja a termékeket. Ha minden foglalás sikeresen megtörtént, a mikroservice megerősíti a megrendelés foglalását a Stockban, és megjelöli a megrendelést feldolgozottként. A mikroservice több példányban fut, ezért a Process metódus párhuzamosan is végrehajtható. Az ugyanazon sorok feldolgozásának elkerülése érdekében a PostgreSQL Select for update ... skip locked mechanizmust használják. Az IBus implementáció üzeneteket küld a RabbitMq-nak.
```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;" }
};
```
