Überprüfung: angewandter Code
Die Klasse enthält die Logik zur Verarbeitung neuer Bestellungen. Sie extrahiert die Bestellungen und Positionen aus der Datenbank, führt dann einen HTTP-Aufruf an einen externen Microservice Stock durch, der die Produkte entsprechend den Bestellpositionen reserviert. Wenn alle Reservierungen erfolgreich sind, bestätigt der Microservice die Reservierung der Bestellung in Stock und markiert die Bestellung als verarbeitet. Der Microservice läuft in mehreren Instanzen, daher kann die Methode Process parallel ausgeführt werden. Um zu vermeiden, dass dieselben Zeilen verarbeitet werden, wird ein Mechanismus der pessimistischen Sperrung in PostgreSQL Select for update ... skip locked verwendet. Die Implementierung von IBus sendet Nachrichten an 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;" }
};
```
