Замотохина Мария Лаб. 2 Группа 6511 (неудачный PR, простите...)

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>№1 "Кэширование"</Strong></UnorderedListItem>
+            <UnorderedListItem>Вариант <Strong>№6 "Медицинский пациент"</Strong></UnorderedListItem>
+            <UnorderedListItem>Выполнена <Strong>Замотохиной Марией 6511</Strong> </UnorderedListItem>
+            <UnorderedListItem><Link To="https://github.com/ZamotohinaMaria/cloud-development">Ссылка на форк</Link></UnorderedListItem>
         </UnorderedList>
     </CardBody>
 </Card>

Client.Wasm/Properties/launchSettings.json

@@ -22,7 +22,7 @@
     "https": {
       "commandName": "Project",
       "dotnetRunMessages": true,
-      "launchBrowser": true,
+      "launchBrowser": false,
       "inspectUri": "{wsProtocol}://{url.hostname}:{url.port}/_framework/debug/ws-proxy?browser={browserInspectUri}",
       "applicationUrl": "https://localhost:7282;http://localhost:5127",
       "environmentVariables": {
@@ -31,7 +31,7 @@
     },
     "IIS Express": {
       "commandName": "IISExpress",
-      "launchBrowser": true,
+      "launchBrowser": false,
       "inspectUri": "{wsProtocol}://{url.hostname}:{url.port}/_framework/debug/ws-proxy?browser={browserInspectUri}",
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"

Client.Wasm/wwwroot/appsettings.json

@@ -6,5 +6,5 @@
     }
   },
   "AllowedHosts": "*",
-  "BaseAddress": ""
+  "BaseAddress": "http://localhost:5100/medicalpatient-generator"
 }

CloudDevelopment.sln

@@ -3,7 +3,15 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio Version 17
 VisualStudioVersion = 17.14.36811.4
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Client.Wasm", "Client.Wasm\Client.Wasm.csproj", "{AE7EEA74-2FE0-136F-D797-854FD87E022A}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Client.Wasm", "Client.Wasm\Client.Wasm.csproj", "{AE7EEA74-2FE0-136F-D797-854FD87E022A}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MedicalPatient.AppHost.AppHost", "MedicalPatient.AppHost\MedicalPatient.AppHost.AppHost\MedicalPatient.AppHost.AppHost.csproj", "{892597A3-DF97-470C-AA27-6398D1C68C9E}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MedicalPatient.AppHost.ServiceDefaults", "MedicalPatient.AppHost\MedicalPatient.AppHost.ServiceDefaults\MedicalPatient.AppHost.ServiceDefaults.csproj", "{0E685E2F-3762-4FF1-AF4F-A3E204FDF791}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MedicalPatient.Generator", "MedicalPatient.Generator\MedicalPatient.Generator.csproj", "{B9054D03-6CF6-4B8C-8E6F-3D27D39983F5}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MedicalPatient.ApiGateway", "MedicalPatient.ApiGateway\MedicalPatient.ApiGateway.csproj", "{30D90454-DACC-4B41-86DF-FD441AC7AB6D}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -15,6 +23,22 @@ Global
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AE7EEA74-2FE0-136F-D797-854FD87E022A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{892597A3-DF97-470C-AA27-6398D1C68C9E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{892597A3-DF97-470C-AA27-6398D1C68C9E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{892597A3-DF97-470C-AA27-6398D1C68C9E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{892597A3-DF97-470C-AA27-6398D1C68C9E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0E685E2F-3762-4FF1-AF4F-A3E204FDF791}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0E685E2F-3762-4FF1-AF4F-A3E204FDF791}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0E685E2F-3762-4FF1-AF4F-A3E204FDF791}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0E685E2F-3762-4FF1-AF4F-A3E204FDF791}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B9054D03-6CF6-4B8C-8E6F-3D27D39983F5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B9054D03-6CF6-4B8C-8E6F-3D27D39983F5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B9054D03-6CF6-4B8C-8E6F-3D27D39983F5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B9054D03-6CF6-4B8C-8E6F-3D27D39983F5}.Release|Any CPU.Build.0 = Release|Any CPU
+		{30D90454-DACC-4B41-86DF-FD441AC7AB6D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{30D90454-DACC-4B41-86DF-FD441AC7AB6D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{30D90454-DACC-4B41-86DF-FD441AC7AB6D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{30D90454-DACC-4B41-86DF-FD441AC7AB6D}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

MedicalPatient.ApiGateway/Balancer/WeightedRoundRobin.cs

@@ -0,0 +1,59 @@
+using System.Threading;
+using Ocelot.LoadBalancer.Errors;
+using Ocelot.LoadBalancer.Interfaces;
+using Ocelot.Responses;
+using Ocelot.ServiceDiscovery.Providers;
+using Ocelot.Values;
+
+namespace MedicalPatient.ApiGateway.Balancer;
+
+public class WeightedRoundRobin(IServiceDiscoveryProvider serviceDiscovery, IReadOnlyList<int>? weights = null)
+    : ILoadBalancer
+{
+    private readonly int[] _weights = (weights is { Count: > 0 } ? [.. weights] : []);
+    private int _cursor = -1;
+
+    public string Type => nameof(WeightedRoundRobin);
+
+    public async Task<Response<ServiceHostAndPort>> LeaseAsync(HttpContext httpContext)
+    {
+        var services = await serviceDiscovery.GetAsync();
+
+        if (services is null)
+            return new ErrorResponse<ServiceHostAndPort>(
+                new ServicesAreNullError("Service discovery returned null"));
+
+        if (services.Count == 0)
+            return new ErrorResponse<ServiceHostAndPort>(
+                new ServicesAreNullError("No downstream services are available"));
+
+        var wheel = BuildWheel(services.Count);
+
+        var next = (uint)Interlocked.Increment(ref _cursor);
+        var wheelIndex = (int)(next % (uint)wheel.Count);
+        var serviceIndex = wheel[wheelIndex];
+
+        return new OkResponse<ServiceHostAndPort>(services[serviceIndex].HostAndPort);
+    }
+
+    private List<int> BuildWheel(int servicesCount)
+    {
+        var wheel = new List<int>();
+
+        for (var i = 0; i < servicesCount; i++)
+        {
+            var weight = i < _weights.Length ? _weights[i] : 1;
+            if (weight < 1) weight = 1;
+
+            for (var j = 0; j < weight; j++)
+                wheel.Add(i);
+        }
+
+        if (wheel.Count == 0)
+            wheel.Add(0);
+
+        return wheel;
+    }
+
+    public void Release(ServiceHostAndPort hostAndPort) { }
+}

MedicalPatient.ApiGateway/MedicalPatient.ApiGateway.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Ocelot" Version="24.1.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\MedicalPatient.AppHost\MedicalPatient.AppHost.ServiceDefaults\MedicalPatient.AppHost.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+</Project>

MedicalPatient.ApiGateway/Program.cs

@@ -0,0 +1,45 @@
+using MedicalPatient.ApiGateway.Balancer;
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.Configuration
+    .AddJsonFile("ocelot.json", optional: false, reloadOnChange: true);
+
+var generators = builder.Configuration.GetSection("Generators").Get<string[]>() ?? [];
+
+var configuredWeights = builder.Configuration
+    .GetSection("Routes:0:DownstreamHostWeights")
+    .GetChildren()
+    .Select(x => x.GetValue("Weight", 1))
+    .Where(w => w > 0)
+    .ToArray();
+var weights = configuredWeights.Length > 0 ? configuredWeights : [3, 2, 1];
+
+var addressOverrides = new List<KeyValuePair<string, string?>>();
+
+for (var i = 0; i < generators.Length; ++i)
+{
+    var name = generators[i];
+    var url = builder.Configuration[$"services:{name}:http:0"];
+
+    if (!string.IsNullOrEmpty(url) && Uri.TryCreate(url, UriKind.Absolute, out var uri))
+    {
+        addressOverrides.Add(new($"Routes:0:DownstreamHostAndPorts:{i}:Host", uri.Host));
+        addressOverrides.Add(new($"Routes:0:DownstreamHostAndPorts:{i}:Port", uri.Port.ToString()));
+    }
+}
+
+if (addressOverrides.Count > 0)
+    builder.Configuration.AddInMemoryCollection(addressOverrides);
+
+builder.Services
+    .AddOcelot(builder.Configuration)
+    .AddCustomLoadBalancer<WeightedRoundRobin>((route, serviceDiscovery) =>
+        new WeightedRoundRobin(serviceDiscovery, weights));
+
+var app = builder.Build();
+
+await app.UseOcelot();
+await app.RunAsync();

MedicalPatient.ApiGateway/Properties/launchSettings.json

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

MedicalPatient.ApiGateway/appsettings.Development.json

@@ -0,0 +1,11 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "GlobalConfiguration": {
+    "BaseUrl": "http://localhost:5100"
+  }
+}

MedicalPatient.ApiGateway/appsettings.json

@@ -0,0 +1,10 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*",
+  "Generators": [ "generator-1", "generator-2", "generator-3" ]
+}

MedicalPatient.ApiGateway/libman.json

@@ -0,0 +1,5 @@
+{
+  "version": "1.0",
+  "defaultProvider": "cdnjs",
+  "libraries": []
+}

MedicalPatient.ApiGateway/ocelot.json

@@ -0,0 +1,44 @@
+{
+  "Routes": [
+    {
+      "DownstreamPathTemplate": "/medicalpatient-generator",
+      "DownstreamScheme": "http",
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "localhost",
+          "Port": 5101
+        },
+        {
+          "Host": "localhost",
+          "Port": 5102
+        },
+        {
+          "Host": "localhost",
+          "Port": 5103
+        }
+      ],
+      "UpstreamPathTemplate": "/medicalpatient-generator",
+      "UpstreamHttpMethod": [ "GET" ],
+      "LoadBalancerOptions": {
+        "Type": "WeightedRoundRobin"
+      },
+      "DownstreamHostWeights": [
+        {
+          "Host": "localhost",
+          "Port": 5101,
+          "Weight": 3
+        },
+        {
+          "Host": "localhost",
+          "Port": 5102,
+          "Weight": 2
+        },
+        {
+          "Host": "localhost",
+          "Port": 5103,
+          "Weight": 1
+        }
+      ]
+    }
+  ]
+}

MedicalPatient.AppHost/MedicalPatient.AppHost.AppHost/MedicalPatient.AppHost.AppHost.csproj

@@ -0,0 +1,25 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<Sdk Name="Aspire.AppHost.Sdk" Version="9.5.2" />
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireHost>true</IsAspireHost>
+    <UserSecretsId>fe743bf2-08eb-41c7-817b-f144b739dce3</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+	<PackageReference Include="Aspire.Hosting" Version="9.5.2" />
+    <PackageReference Include="Aspire.Hosting.AppHost" Version="9.5.2" />
+    <PackageReference Include="Aspire.Hosting.Redis" Version="9.5.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\Client.Wasm\Client.Wasm.csproj" />
+    <ProjectReference Include="..\..\MedicalPatient.ApiGateway\MedicalPatient.ApiGateway.csproj" />
+    <ProjectReference Include="..\..\MedicalPatient.Generator\MedicalPatient.Generator.csproj" />
+  </ItemGroup>
+
+</Project>

MedicalPatient.AppHost/MedicalPatient.AppHost.AppHost/Program.cs

@@ -0,0 +1,39 @@
+var builder = DistributedApplication.CreateBuilder(args);
+
+var redis = builder.AddRedis("redis")
+    .WithRedisCommander();
+
+var generator1 = builder.AddProject<Projects.MedicalPatient_Generator>("generator-1")
+    .WithEndpoint("http", endpoint => endpoint.Port = 5101)
+    .WithReference(redis)
+    .WaitFor(redis)
+    .WithExternalHttpEndpoints();
+
+var generator2 = builder.AddProject<Projects.MedicalPatient_Generator>("generator-2")
+    .WithEndpoint("http", endpoint => endpoint.Port = 5102)
+    .WithReference(redis)
+    .WaitFor(redis)
+    .WithExternalHttpEndpoints();
+
+var generator3 = builder.AddProject<Projects.MedicalPatient_Generator>("generator-3")
+    .WithEndpoint("http", endpoint => endpoint.Port = 5103)
+    .WithReference(redis)
+    .WaitFor(redis)
+    .WithExternalHttpEndpoints();
+
+var gateway = builder
+    .AddProject<Projects.MedicalPatient_ApiGateway>("medicalpatient-apigateway")
+    .WithReference(generator1)
+    .WithReference(generator2)
+    .WithReference(generator3)
+    .WithExternalHttpEndpoints()
+    .WaitFor(generator1)
+    .WaitFor(generator2)
+    .WaitFor(generator3);
+
+builder.AddProject<Projects.Client_Wasm>("client")
+    .WithReference(gateway)
+    .WaitFor(gateway);
+
+builder.Build().Run();
+