Карпачева Полина Лаб. 2 Группа 6512

.gitignore

@@ -416,3 +416,5 @@ FodyWeavers.xsd
 *.msix
 *.msm
 *.msp
+
+.DS_Store

AspireApp.ApiGateway/AspireApp.ApiGateway.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Ocelot" Version="24.1.0" />
+  </ItemGroup>
+
+</Project>

AspireApp.ApiGateway/LoadBalancing/WeightedRandomLoadBalancer.cs

@@ -0,0 +1,50 @@
+using Microsoft.AspNetCore.Http;
+using Ocelot.LoadBalancer.Interfaces;
+using Ocelot.Responses;
+using Ocelot.Values;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace AspireApp.ApiGateway.LoadBalancing;
+
+/// <summary>
+/// Weighted Random балансировщик нагрузки.
+/// Распределяет запросы между сервисами по заданным весам.
+/// </summary>
+public class WeightedRandomLoadBalancer(List<Service> services) : ILoadBalancer
+{
+    private readonly List<Service> _services = services;
+    private readonly List<int> _weights = services.Select(s => GetWeight(s)).ToList();
+    private readonly Random _random = new();
+
+    private static int GetWeight(Service service)
+    {
+        var port = service.HostAndPort.DownstreamPort;
+        return port == 5001 ? 5 : port == 5002 ? 3 : port == 5003 ? 2 : 1;
+    }
+
+    public async Task<Response<ServiceHostAndPort>> LeaseAsync(HttpContext httpContext)
+    {
+        var totalWeight = _weights.Sum();
+        var randomValue = _random.Next(totalWeight);
+
+        var current = 0;
+        for (var i = 0; i < _services.Count; i++)
+        {
+            current += _weights[i];
+            if (randomValue < current)
+            {
+                return new OkResponse<ServiceHostAndPort>(_services[i].HostAndPort);
+            }
+        }
+
+        return new OkResponse<ServiceHostAndPort>(_services.First().HostAndPort);
+    }
+
+    public void Release(ServiceHostAndPort hostAndPort) {}
+
+    public string Name => nameof(WeightedRandomLoadBalancer);
+    public string Type => "WeightedRandom";
+}

AspireApp.ApiGateway/LoadBalancing/WeightedRandomLoadBalancerFactory.cs

@@ -0,0 +1,24 @@
+using Ocelot.Configuration;
+using Ocelot.LoadBalancer.Interfaces;
+using Ocelot.Responses;
+using Ocelot.Values;
+using System.Collections.Generic;
+using System.Linq;
+
+namespace AspireApp.ApiGateway.LoadBalancing;
+
+/// <summary>
+/// Фабрика для создания WeightedRandomLoadBalancer.
+/// </summary>
+
+public class WeightedRandomLoadBalancerFactory : ILoadBalancerFactory
+{
+    public Response<ILoadBalancer> Get(DownstreamRoute route, ServiceProviderConfiguration serviceProviderConfiguration)
+    {
+        var services = route.DownstreamAddresses
+            .Select(x => new Service("service", new ServiceHostAndPort(x.Host, x.Port), "", "", new List<string>()))
+            .ToList();
+
+        return new OkResponse<ILoadBalancer>(new WeightedRandomLoadBalancer(services));
+    }
+}

AspireApp.ApiGateway/Program.cs

@@ -0,0 +1,29 @@
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+using Ocelot.LoadBalancer.Interfaces;
+using AspireApp.ApiGateway.LoadBalancing;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("AllowClient", policy =>
+    {
+        policy.WithOrigins("http://localhost:5127")
+              .AllowAnyMethod()
+              .AllowAnyHeader();
+    });
+});
+
+builder.Configuration.AddJsonFile("ocelot.json", optional: false, reloadOnChange: true);
+
+builder.Services.AddOcelot();
+builder.Services.AddSingleton<ILoadBalancerFactory, WeightedRandomLoadBalancerFactory>();
+
+var app = builder.Build();
+
+app.UseCors("AllowClient");
+
+await app.UseOcelot();
+
+app.Run();

AspireApp.ApiGateway/Properties/launchSettings.json

@@ -0,0 +1,13 @@
+{
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "applicationUrl": "http://localhost:5101",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

AspireApp.ApiGateway/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

AspireApp.ApiGateway/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

AspireApp.ApiGateway/ocelot.json

@@ -0,0 +1,24 @@
+{
+  "Routes": [
+    {
+      "DownstreamPathTemplate": "/warehouse",
+      "DownstreamScheme": "http",
+      "DownstreamHostAndPorts": [
+        { "Host": "localhost", "Port": 5001 },
+        { "Host": "localhost", "Port": 5002 },
+        { "Host": "localhost", "Port": 5003 }
+      ],
+      "UpstreamPathTemplate": "/warehouse",
+      "UpstreamHttpMethod": [ "GET" ],
+      "LoadBalancerOptions": {
+        "Type": "WeightedRandom"
+      },
+      "HttpHandlerOptions": {
+        "UseTracing": true
+      }
+    }
+  ],
+  "GlobalConfiguration": {
+    "BaseUrl": "http://localhost:5101"
+  }
+}

AspireApp.ApiService/AspireApp.ApiService.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\AspireApp.ServiceDefaults\AspireApp.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.StackExchange.Redis.DistributedCaching" Version="9.5.2" />
+    <PackageReference Include="Bogus" Version="35.6.5" />
+    <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.15" />
+  </ItemGroup>
+
+</Project>

AspireApp.ApiService/Entities/Warehouse.cs

@@ -0,0 +1,69 @@
+using System.Text.Json.Serialization;
+
+namespace AspireApp.ApiService.Entities;
+
+/// <summary>
+/// Товар на складе
+/// </summary>
+public class Warehouse
+{
+    /// <summary>
+    /// Идентификатор
+    /// </summary>
+    [JsonPropertyName("id")]
+    public int Id { get; set; }
+
+    /// <summary>
+    /// Наименование товара
+    /// </summary>
+    [JsonPropertyName("name")]
+    public string? Name { get; set; }
+
+    /// <summary>
+    /// Категория товара
+    /// </summary>
+    [JsonPropertyName("category")]
+    public string? Category { get; set; }
+
+    /// <summary>
+    /// Количество на складе
+    /// </summary>
+    [JsonPropertyName("stockQuantity")]
+    public int StockQuantity { get; set; }
+
+    /// <summary>
+    /// Цена за единицу товара
+    /// </summary>
+    [JsonPropertyName("price")]
+    public decimal Price { get; set; }
+
+    /// <summary>
+    /// Вес единицы товара
+    /// </summary>
+    [JsonPropertyName("weight")]
+    public double Weight { get; set; }
+
+    /// <summary>
+    /// Габариты единицы товара 
+    /// </summary>
+    [JsonPropertyName("dimensions")]
+    public string? Dimensions { get; set; }
+
+    /// <summary>
+    /// Хрупкий ли товар
+    /// </summary>
+    [JsonPropertyName("isFragile")]
+    public bool IsFragile { get; set; }
+
+    /// <summary>
+    /// Дата последней поставки
+    /// </summary>
+    [JsonPropertyName("lastDeliveryDate")]
+    public DateOnly LastDeliveryDate { get; set; }
+
+    /// <summary>
+    /// Дата следующей планируемой поставки
+    /// </summary>
+    [JsonPropertyName("nextDeliveryDate")]
+    public DateOnly NextDeliveryDate { get; set; }
+}

AspireApp.ApiService/Generator/IWarehouseCache.cs

@@ -0,0 +1,19 @@
+using AspireApp.ApiService.Entities;
+
+namespace AspireApp.ApiService.Generator;
+
+/// <summary>
+/// Интерфейс для работы с кэшем товаров
+/// </summary>
+public interface IWarehouseCache
+{
+    /// <summary>
+    /// Получить товар из кэша по идентификатору
+    /// </summary>
+    Task<Warehouse?> GetAsync(int id);
+
+    /// <summary>
+    /// Сохранить товар в кэш
+    /// </summary>
+    Task SetAsync(Warehouse warehouse);
+}

AspireApp.ApiService/Generator/IWarehouseGeneratorService.cs

@@ -0,0 +1,11 @@
+using AspireApp.ApiService.Entities;
+
+namespace AspireApp.ApiService.Generator;
+
+/// <summary>
+/// Сервис обработки товаров на складе
+/// </summary>
+public interface IWarehouseGeneratorService
+{
+    Task<Warehouse> ProcessWarehouse(int id);
+}

AspireApp.ApiService/Generator/WarehouseCache.cs

@@ -0,0 +1,47 @@
+using Microsoft.Extensions.Caching.Distributed;
+using System.Text.Json;
+using AspireApp.ApiService.Entities;
+
+namespace AspireApp.ApiService.Generator;
+
+/// <summary>
+/// Кэширование товаров 
+/// </summary>
+public class WarehouseCache(
+    IDistributedCache cache,
+    ILogger<WarehouseCache> logger,
+    IConfiguration configuration) : IWarehouseCache
+{
+    private readonly TimeSpan _defaultExpiration = int.TryParse(configuration["CacheExpiration"], out var seconds)
+        ? TimeSpan.FromSeconds(seconds)
+        : TimeSpan.FromSeconds(3600);
+
+    public async Task<Warehouse?> GetAsync(int id)
+    {
+        var key = $"warehouse_{id}";
+        var cached = await cache.GetStringAsync(key);
+        if (cached == null)
+            return null;
+
+        try
+        {
+            return JsonSerializer.Deserialize<Warehouse>(cached);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "Ошибка десериализации товара {Id} из кэша", id);
+            return null;
+        }
+    }
+
+    public async Task SetAsync(Warehouse warehouse)
+    {
+        var key = $"warehouse_{warehouse.Id}";
+        var options = new DistributedCacheEntryOptions
+        {
+            AbsoluteExpirationRelativeToNow = _defaultExpiration
+        };
+        var serialized = JsonSerializer.Serialize(warehouse);
+        await cache.SetStringAsync(key, serialized, options);
+    }
+}

AspireApp.ApiService/Generator/WarehouseGenerator.cs

@@ -0,0 +1,32 @@
+using Bogus;
+using AspireApp.ApiService.Entities;
+
+namespace AspireApp.ApiService.Generator;
+
+/// <summary>
+/// Генератор случайных товаров с использованием Bogus
+/// </summary>
+public class WarehouseGenerator
+{
+    private readonly Faker<Warehouse> _faker;
+
+    public WarehouseGenerator()
+    {
+        _faker = new Faker<Warehouse>()
+            .RuleFor(w => w.Id, f => f.IndexFaker + 1) // будет перезаписан позже
+            .RuleFor(w => w.Name, f => f.Commerce.ProductName())
+            .RuleFor(w => w.Category, f => f.Commerce.Categories(1)[0])
+            .RuleFor(w => w.StockQuantity, f => f.Random.Int(0, 1000))
+            .RuleFor(w => w.Price, f => decimal.Parse(f.Commerce.Price()))
+            .RuleFor(w => w.Weight, f => f.Random.Double(0.1, 50.0))
+            .RuleFor(w => w.Dimensions, f => $"{f.Random.Int(10, 100)}x{f.Random.Int(10, 100)}x{f.Random.Int(10, 100)}")
+            .RuleFor(w => w.IsFragile, f => f.Random.Bool(0.3f))
+            .RuleFor(w => w.LastDeliveryDate, f => DateOnly.FromDateTime(f.Date.Past(30)))
+            .RuleFor(w => w.NextDeliveryDate, f => DateOnly.FromDateTime(f.Date.Future(30)));
+    }
+
+    /// <summary>
+    /// Генерирует один случайный товар (Id будет перезаписан вызывающим кодом)
+    /// </summary>
+    public Warehouse Generate() => _faker.Generate();
+}