Богачев Матвей Лаб. 2 Группа 6511

ApiGateway/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="23.3.6" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Aspire.ServiceDefaults\Aspire.ServiceDefaults.csproj" />
+  </ItemGroup>
+
+</Project>

ApiGateway/Balancer/QueryBasedLoadBalancer.cs

@@ -0,0 +1,41 @@
+using Ocelot.LoadBalancer.LoadBalancers;
+using Ocelot.Responses;
+using Ocelot.ServiceDiscovery.Providers;
+using Ocelot.Values;
+
+namespace ApiGateway.Balancer;
+
+public sealed class QueryBasedLoadBalancer(
+    IServiceDiscoveryProvider serviceDiscovery) : ILoadBalancer
+{
+    public string Type => nameof(QueryBasedLoadBalancer);
+
+    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 service = SelectByQuery(httpContext, services);
+        return new OkResponse<ServiceHostAndPort>(service.HostAndPort);
+    }
+
+    private static Service SelectByQuery(HttpContext httpContext, List<Service> services)
+    {
+        var idRaw = httpContext.Request.Query["id"].FirstOrDefault();
+
+        if (!int.TryParse(idRaw, out var id))
+            return services[0];
+
+        var index = Math.Abs(id % services.Count);
+        return services[index];
+    }
+
+    public void Release(ServiceHostAndPort hostAndPort) { }
+}

ApiGateway/Program.cs

@@ -0,0 +1,57 @@
+using 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 overrides = new List<KeyValuePair<string, string?>>();
+
+for (var i = 0; i < generators.Length; i++)
+{
+    var serviceName = generators[i];
+    var url = builder.Configuration[$"services:{serviceName}:https:0"];
+
+    if (string.IsNullOrWhiteSpace(url))
+        continue;
+
+    if (!Uri.TryCreate(url, UriKind.Absolute, out var uri))
+        continue;
+
+    overrides.Add(new KeyValuePair<string, string?>(
+        $"Routes:0:DownstreamHostAndPorts:{i}:Host", uri.Host));
+
+    overrides.Add(new KeyValuePair<string, string?>(
+        $"Routes:0:DownstreamHostAndPorts:{i}:Port", uri.Port.ToString()));
+}
+
+if (overrides.Count != 0)
+{
+    builder.Configuration.AddInMemoryCollection(overrides);
+}
+
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("ClientPolicy", policy =>
+    {
+        policy
+            .AllowAnyOrigin()
+            .AllowAnyMethod()
+            .AllowAnyHeader();
+    });
+});
+
+builder.Services
+    .AddOcelot(builder.Configuration)
+    .AddCustomLoadBalancer((route, sp) =>
+        new QueryBasedLoadBalancer(sp));
+
+var app = builder.Build();
+
+app.UseCors("ClientPolicy");
+
+await app.UseOcelot();
+await app.RunAsync();

ApiGateway/Properties/launchSettings.json

@@ -0,0 +1,38 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:21053",
+      "sslPort": 44384
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:5194",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:7141;http://localhost:5194",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

ApiGateway/appsettings.Development.json

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

ApiGateway/appsettings.json

@@ -0,0 +1,14 @@
+{
+  "ClientAddress": "https://localhost:7282",
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning",
+      "Ocelot": "Debug"
+    }
+  },
+  "GlobalConfiguration": {
+    "BaseUrl": "https://localhost:8095"
+  },
+  "AllowedHosts": "*"
+}

ApiGateway/ocelot.json

@@ -0,0 +1,21 @@
+{
+  "Generators": [ "back-0", "back-1", "back-2" ],
+  "Routes": [
+    {
+      "DownstreamPathTemplate": "/contracts/vehicle",
+      "DownstreamScheme": "https",
+      "UpstreamPathTemplate": "/contracts/vehicle",
+      "UpstreamHttpMethod": [ "Get" ],
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "localhost",
+          "Port": 8090
+        }
+      ],
+      "LoadBalancerOptions": {
+        "Type": "QueryBasedLoadBalancer"
+      }
+    }
+  ],
+  "GlobalConfiguration": {}
+}

Aspire.AppHost/AppHost.cs

@@ -0,0 +1,22 @@
+var builder = DistributedApplication.CreateBuilder(args);
+var redis = builder.AddRedis("cache").WithRedisInsight();
+
+var gateway = builder.AddProject<Projects.ApiGateway>("gateway")
+    .WithEndpoint("https", endpoint => endpoint.Port = 8095);
+
+for (var i = 0; i < 3; i++)
+{
+    var generator = builder.AddProject<Projects.Server>($"back-{i}")
+    .WithEndpoint("https", endpoint => endpoint.Port = 8090+i)
+    .WithReference(redis)
+    .WaitFor(redis);
+
+    gateway.WithReference(generator)
+        .WaitFor(generator);
+}
+
+builder.AddProject<Projects.Client_Wasm>("front")
+    .WithReference(gateway)
+    .WaitFor(gateway);
+
+builder.Build().Run();

Aspire.AppHost/Aspire.AppHost.csproj

@@ -0,0 +1,24 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Sdk Name="Aspire.AppHost.Sdk" Version="9.5.0" />
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <UserSecretsId>332a680f-f1c5-49c8-a258-12e527af6b5e</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.Hosting.AppHost" Version="13.1.2" />
+    <PackageReference Include="Aspire.Hosting.Redis" Version="13.1.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\ApiGateway\ApiGateway.csproj" />
+    <ProjectReference Include="..\Server\Server.csproj" />
+    <ProjectReference Include="..\Client.Wasm\Client.Wasm.csproj" />
+  </ItemGroup>
+
+</Project>

Aspire.AppHost/Properties/launchSettings.json

@@ -0,0 +1,29 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:17077;http://localhost:15131",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "ASPIRE_DASHBOARD_OTLP_ENDPOINT_URL": "https://localhost:21228",
+        "ASPIRE_RESOURCE_SERVICE_ENDPOINT_URL": "https://localhost:22147"
+      }
+    },
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:15131",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "ASPIRE_DASHBOARD_OTLP_ENDPOINT_URL": "http://localhost:19273",
+        "ASPIRE_RESOURCE_SERVICE_ENDPOINT_URL": "http://localhost:20035"
+      }
+    }
+  }
+}

Aspire.AppHost/appsettings.Development.json

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

Aspire.AppHost/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning",
+      "Aspire.Hosting.Dcp": "Warning"
+    }
+  }
+}

Aspire.ServiceDefaults/Aspire.ServiceDefaults.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireSharedProject>true</IsAspireSharedProject>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <FrameworkReference Include="Microsoft.AspNetCore.App" />
+
+    <PackageReference Include="Microsoft.Extensions.Http.Resilience" Version="9.9.0" />
+    <PackageReference Include="Microsoft.Extensions.ServiceDiscovery" Version="9.5.0" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.9.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.9.0" />
+  </ItemGroup>
+
+</Project>