Նայվածք՝ կիրառված կոդ
Դասը պարունակում է նոր պատվերների մշակման տրամաբանությունը։ Այն բազայից հանում է պատվերներն ու դիրքերը, ապա HTTP կանչ է կատարում արտաքին microservice Stock-ին, որտեղ պատվերի դիրքերի համաձայն ամրագրում է ապրանքները։ Եթե բոլոր ամրագրումները հաջողությամբ կատարվեն, microservice-ը հաստատում է պատվերի ամրագրումը Stock-ում և նշում է պատվերը որպես մշակված։ Microservice-ը մի քանի օրինակով է աշխատում, այդ պատճառով Process մեթոդը կարող է կատարվել զուգահեռ։ Որպեսզի նույն տողերը չմշակվեն, օգտագործվում է PostgreSQL Select for update ... skip locked պեսիմիստիկ փակման մեխանիզմը։ IBus-ի իրականացումը ուղարկում է հաղորդագրություններ 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;" }
};
```
