Tahlil: qo'llanilgan kod
Klass yangi buyurtmalarni qayta ishlash logikasini o'z ichiga oladi. U bazadan buyurtmalar va pozitsiyalarni chiqaradi, so'ngra tashqi mikroservis Stockga HTTP chaqiruvini amalga oshiradi, unda buyurtma pozitsiyalariga ko'ra mahsulotlar bron qilinadi. Agar barcha bronlar muvaffaqiyatli bo'lsa, mikroservis Stockda buyurtma bronini tasdiqlaydi va buyurtmani qayta ishlashga belgilaydi. Mikroservis bir nechta nusxalarda ishga tushiriladi, shuning uchun Process metodi parallel ravishda bajarilishi mumkin. Bir xil satrlarni qayta ishlashdan saqlash uchun PostgreSQL Select for update ... skip locked mexanizmi ishlatiladi. IBus implementatsiyasi RabbitMq'ga xabar yuboradi.
```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;" }
};
```
