Томашайтис Павел Лаб. 3 Группа 6513

Client.Wasm/Client.Wasm.csproj

@@ -10,6 +10,10 @@
     <None Remove="Components\StudentCard.razor~RF1bb17a4.TMP" />
   </ItemGroup>
 
+  <ItemGroup>
+    <None Include="Client.Wasm.csproj.user" />
+  </ItemGroup>
+
   <ItemGroup>
     <PackageReference Include="Blazorise" Version="1.8.8" />
     <PackageReference Include="Blazorise.Bootstrap" Version="1.8.8" />

Client.Wasm/Components/StudentCard.razor

@@ -4,10 +4,10 @@
     </CardHeader>
     <CardBody>
         <UnorderedList Unstyled>
-            <UnorderedListItem>Номер <Strong>№X "Название лабораторной"</Strong></UnorderedListItem>
-            <UnorderedListItem>Вариант <Strong>№Х "Название варианта"</Strong></UnorderedListItem>
-            <UnorderedListItem>Выполнена <Strong>Фамилией Именем 65ХХ</Strong> </UnorderedListItem>
-            <UnorderedListItem><Link To="https://puginarug.com/">Ссылка на форк</Link></UnorderedListItem>
+            <UnorderedListItem>Номер <Strong>№ 3</Strong></UnorderedListItem>
+            <UnorderedListItem>Вариант <Strong>№ 52</Strong></UnorderedListItem>
+            <UnorderedListItem>Выполнена <Strong>Томашайтисом Павлом 6513</Strong> </UnorderedListItem>
+            <UnorderedListItem><Link To="https://github.com/Tomashaytis/cloud-development">Ссылка на форк</Link></UnorderedListItem>
         </UnorderedList>
     </CardBody>
 </Card>

Client.Wasm/wwwroot/appsettings.json

@@ -6,5 +6,5 @@
     }
   },
   "AllowedHosts": "*",
-  "BaseAddress": "https://localhost:7170/land-plot"
+  "BaseAddress": "https://localhost:5000/course-management"
 }

CourseManagement.ApiGateway/CourseManagement.ApiGateway.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="10.0.2" />
+    <PackageReference Include="Ocelot" Version="24.1.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\CourseManagement.ServiceDefaults\CourseManagement.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+</Project>

CourseManagement.ApiGateway/LoadBalancers/QueryBased.cs

@@ -0,0 +1,44 @@
+using Ocelot.LoadBalancer.Interfaces;
+using Ocelot.Responses;
+using Ocelot.Values;
+
+namespace CourseManagement.ApiGateway.LoadBalancers;
+
+/// <summary>
+/// Балансировщик нагрузки на основе запроса
+/// </summary>
+/// <param name="logger">Логгер</param>
+/// <param name="services">Список сервисов</param>
+public class QueryBased(ILogger<QueryBased> logger, List<Service> services) : ILoadBalancer
+{
+    /// <summary>
+    /// Тип балансировщика нагрузки
+    /// </summary>
+    public string Type => nameof(QueryBased);
+
+    /// <summary>
+    /// Метод выбора сервиса на основе запроса
+    /// </summary>
+    /// <param name="httpContext">HTTP запрос</param>
+    /// <returns>Выбранный сервис</returns>
+    public Task<Response<ServiceHostAndPort>> LeaseAsync(HttpContext httpContext)
+    {
+        var idString = httpContext.Request.Query["id"].FirstOrDefault();
+
+        if (!int.TryParse(idString, out var id))
+            id = 0;
+
+        var service = services[id % services.Count];
+
+        logger.LogInformation("Request {ResourceId} sent to service on port {servicePort}", id, service.HostAndPort.DownstreamPort);
+
+        return Task.FromResult<Response<ServiceHostAndPort>>(
+            new OkResponse<ServiceHostAndPort>(service.HostAndPort));
+    }
+
+    /// <summary>
+    /// Метод очистки ресурсов для сервиса
+    /// </summary>
+    /// <param name="hostAndPort">Параметры сервиса</param>
+    public void Release(ServiceHostAndPort hostAndPort) { }
+}

CourseManagement.ApiGateway/Program.cs

@@ -0,0 +1,40 @@
+using CourseManagement.ApiGateway.LoadBalancers;
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.AddServiceDefaults();
+
+// Подключение конфига Ocelot
+builder.Configuration.AddJsonFile("ocelot.json", optional: false, reloadOnChange: true);
+
+// Добавление Ocelot с Query Based балансировщиком нагрузки
+builder.Services.AddOcelot()
+    .AddCustomLoadBalancer<QueryBased>((serviceProvider, downstreamRoute, serviceDiscoveryProvider) =>
+    {
+        var logger = serviceProvider.GetRequiredService<ILogger<QueryBased>>();
+
+        var services = serviceDiscoveryProvider.GetAsync().GetAwaiter().GetResult().ToList();
+
+        return new QueryBased(logger, services);
+    });
+
+// CORS
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("AllowClient", policy =>
+    {
+        policy.AllowAnyOrigin()
+              .WithMethods("GET")
+              .WithHeaders("Content-Type");
+    });
+});
+
+var app = builder.Build();
+
+app.UseCors("AllowClient");
+
+await app.UseOcelot();
+
+app.Run();

CourseManagement.ApiGateway/Properties/launchSettings.json

@@ -0,0 +1,23 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "applicationUrl": "http://localhost:5256",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "applicationUrl": "https://localhost:7253;http://localhost:5256",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

CourseManagement.ApiGateway/appsettings.Development.json

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

CourseManagement.ApiGateway/appsettings.json

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

CourseManagement.ApiGateway/ocelot.json

@@ -0,0 +1,72 @@
+{
+  "Routes": [
+    {
+      "DownstreamPathTemplate": "/course-management",
+      "DownstreamScheme": "https",
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "localhost",
+          "Port": 8081
+        },
+        {
+          "Host": "localhost",
+          "Port": 8082
+        },
+        {
+          "Host": "localhost",
+          "Port": 8083
+        },
+        {
+          "Host": "localhost",
+          "Port": 8084
+        },
+        {
+          "Host": "localhost",
+          "Port": 8085
+        }
+      ],
+      "UpstreamPathTemplate": "/course-management",
+      "UpstreamHttpMethod": [ "GET" ],
+      "LoadBalancerOptions": {
+        "Type": "QueryBased",
+        "Key": "course-api"
+      }
+    },
+    {
+      "DownstreamPathTemplate": "/health",
+      "DownstreamScheme": "https",
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "localhost",
+          "Port": 8081
+        },
+        {
+          "Host": "localhost",
+          "Port": 8082
+        },
+        {
+          "Host": "localhost",
+          "Port": 8083
+        },
+        {
+          "Host": "localhost",
+          "Port": 8084
+        },
+        {
+          "Host": "localhost",
+          "Port": 8085
+        }
+      ],
+      "UpstreamPathTemplate": "/health",
+      "UpstreamHttpMethod": [ "GET" ],
+      "Priority": 1,
+      "LoadBalancerOptions": {
+        "Type": "QueryBased",
+        "Key": "course-api-health"
+      }
+    }
+  ],
+  "GlobalConfiguration": {
+    "BaseUrl": "https://localhost:5000"
+  }
+}

CourseManagement.ApiService/Cache/CacheService.cs

@@ -0,0 +1,66 @@
+using System.Text.Json;
+using Microsoft.Extensions.Caching.Distributed;
+
+namespace CourseManagement.ApiService.Cache;
+
+/// <summary>
+/// Универсальный сервис для взаимодействия с кэшем
+/// </summary>
+/// <param name="logger">Логгер</param>
+/// <param name="cache">Кэш</param>
+public class CacheService<T>(ILogger<CacheService<T>> logger, IDistributedCache cache) : ICacheService<T>
+{
+    /// <summary>
+    /// Время жизни данных в кэше
+    /// </summary>
+    private static readonly double _cacheDuration = 5;
+
+    /// <inheritdoc/>
+    public async Task<T?> FetchAsync(string key, int id)
+    {
+        var cacheKey = $"{key}:{id}";
+
+        try
+        {
+            var cached = await cache.GetStringAsync(cacheKey);
+            if (cached != null)
+            {
+                var obj = JsonSerializer.Deserialize<T>(cached);
+
+                logger.LogInformation("Cache hit for {EntityType} {ResourceId}", typeof(T).Name, id);
+
+                return obj;
+            }
+
+            logger.LogInformation("Cache miss for {EntityType} {ResourceId}", typeof(T).Name, id);
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Сache is unavailable");
+        }
+
+        return default;
+    }
+
+    /// <inheritdoc/>
+    public async Task StoreAsync(string key, int id, T entity)
+    {
+        var cacheKey = $"{key}:{id}";
+
+        var options = new DistributedCacheEntryOptions
+        {
+            AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(_cacheDuration)
+        };
+
+        try
+        {
+            var serialized = JsonSerializer.Serialize(entity);
+            await cache.SetStringAsync(cacheKey, serialized, options);
+            logger.LogInformation("{EntityType} {ResourceId} cached", typeof(T).Name, id);
+        }
+        catch (Exception ex)
+        {
+            logger.LogWarning(ex, "Сache is unavailable");
+        }
+    }
+}

CourseManagement.ApiService/Cache/ICacheService.cs

@@ -0,0 +1,23 @@
+namespace CourseManagement.ApiService.Cache;
+
+/// <summary>
+/// Универсальный интерфейс для работы с кэшем
+/// </summary>
+public interface ICacheService<T>
+{
+    /// <summary>
+    /// Асинхронный метод для извлечения данных из кэша
+    /// </summary>
+    /// <param name="key">Ключ для сущности</param>
+    /// <param name="id">Идентификатор сущности</param>
+    /// <returns>Объект или null при его отсутствии</returns>
+    public Task<T?> FetchAsync(string key, int id);
+
+    /// <summary>
+    /// Асинхронный метод для внесения данных в кэш
+    /// </summary>
+    /// <param name="key">Ключ для сущности</param>
+    /// <param name="id">Идентификатор сущности</param>
+    /// <param name="entity">Кешируемая сущность</param>
+    public Task StoreAsync(string key, int id, T entity);
+}