<develop>:(Web 端)<无> 增加 微服务 网关 Ocelot.ApiGateWay

ConsulAndOcelot.ApiGateWay/ConsulAndOcelot.ApiGateWay.csproj

+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Ocelot" Version="24.0.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
+  </ItemGroup>
+
+</Project>

ConsulAndOcelot.ApiGateWay/Controllers/WeatherForecastController.cs

+using Microsoft.AspNetCore.Mvc;
+
+namespace ConsulAndOcelot.ApiGateWay.Controllers
+{
+    [ApiController]
+    [Route("[controller]")]
+    public class WeatherForecastController : ControllerBase
+    {
+        private static readonly string[] Summaries = new[]
+        {
+            "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
+        };
+
+        private readonly ILogger<WeatherForecastController> _logger;
+
+        public WeatherForecastController(ILogger<WeatherForecastController> logger)
+        {
+            _logger = logger;
+        }
+
+        [HttpGet(Name = "GetWeatherForecast")]
+        public IEnumerable<WeatherForecast> Get()
+        {
+            return Enumerable.Range(1, 5).Select(index => new WeatherForecast
+            {
+                Date = DateOnly.FromDateTime(DateTime.Now.AddDays(index)),
+                TemperatureC = Random.Shared.Next(-20, 55),
+                Summary = Summaries[Random.Shared.Next(Summaries.Length)]
+            })
+            .ToArray();
+        }
+    }
+}

ConsulAndOcelot.ApiGateWay/Program.cs

+
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+
+namespace ConsulAndOcelot.ApiGateWay
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            var builder = WebApplication.CreateBuilder(args);
+
+            // Add services to the container.
+            builder.Services.AddControllers();
+            builder.Services.AddEndpointsApiExplorer();
+            builder.Services.AddSwaggerGen(c => { /* Configuration */ });
+
+            //添加 Ocelot 并添加配置文件
+            builder.Configuration.AddJsonFile("ocelot.json", optional: true, reloadOnChange: true);
+
+            //使用 Ocelot 接管代码
+            builder.Services.AddOcelot(builder.Configuration);
+
+            var app = builder.Build();
+
+            // Configure the HTTP request pipeline.
+            if (app.Environment.IsDevelopment())
+            {
+                app.UseSwagger();
+                app.UseSwaggerUI();
+            }
+
+            app.UseOcelot();
+
+            app.Run();
+
+        }
+    }
+}

ConsulAndOcelot.ApiGateWay/Properties/launchSettings.json

+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:15944",
+      "sslPort": 44370
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "http://localhost:5198",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "https://localhost:7171;http://localhost:5198",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

ConsulAndOcelot.ApiGateWay/WeatherForecast.cs

+namespace ConsulAndOcelot.ApiGateWay
+{
+    public class WeatherForecast
+    {
+        public DateOnly Date { get; set; }
+
+        public int TemperatureC { get; set; }
+
+        public int TemperatureF => 32 + (int)(TemperatureC / 0.5556);
+
+        public string? Summary { get; set; }
+    }
+}

ConsulAndOcelot.ApiGateWay/appsettings.Development.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

ConsulAndOcelot.ApiGateWay/appsettings.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

ConsulAndOcelot.ApiGateWay/ocelot.json

+{
+  "Routes": [
+    {
+      //转发到下游服务地址--url变量
+      "DownstreamPathTemplate": "/api/{url}",
+      //下游http协议
+      "DownstreamScheme": "http",
+      //负载方式，
+      "LoadBalancerOptions": {
+        "Type": "RoundRobin" // 轮询
+      },
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "192.168.8.248",
+          "Port": 5201 //服务端口
+        }, //可以多个，自行负载均衡
+        {
+          "Host": "192.168.8.248",
+          "Port": 5202 //服务端口
+        },
+        {
+          "Host": "192.168.8.248",
+          "Port": 5203 //服务端口
+        }
+      ],
+
+      //上游地址
+      "UpstreamPathTemplate": "/T1/{url}", //网关地址--url变量   //冲突的还可以加权重Priority
+      "UpstreamHttpMethod": [ "GET", "POST", "DELETE", "PUT" ]
+    }
+  ]
+}

ConsulAndOcelot.GateWay/ConsulAndOcelot.GateWay.csproj

+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <InvariantGlobalization>true</InvariantGlobalization>
+    <PublishAot>true</PublishAot>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Ocelot" Version="24.0.0" />
+  </ItemGroup>
+
+</Project>

ConsulAndOcelot.GateWay/ConsulAndOcelot.GateWay.http

+@ConsulAndOcelot.GateWay_HostAddress = http://localhost:5153
+
+GET {{ConsulAndOcelot.GateWay_HostAddress}}/todos/
+Accept: application/json
+
+###
+
+GET {{ConsulAndOcelot.GateWay_HostAddress}}/todos/1
+Accept: application/json
+
+###

ConsulAndOcelot.GateWay/Program.cs

+
+using Ocelot.DependencyInjection;
+using Ocelot.Middleware;
+using System.Threading.Tasks;
+
+namespace ConsulAndOcelot.GateWay
+{
+    public class Program
+    {
+        public static async Task Main(string[] args)
+        {
+            var builder = WebApplication.CreateBuilder(args);
+
+            //添加 Ocelot 并添加配置文件
+            builder.Configuration.AddJsonFile("ocelot.json", optional: true, reloadOnChange: true);
+
+            builder.Services.AddOcelot(builder.Configuration);//使用 Ocelot 接管代码
+
+            var app = builder.Build();
+
+            //启用 Ocelot 中间件
+            await app.UseOcelot();
+
+            app.Run();
+        }
+    }
+}
\ No newline at end of file

ConsulAndOcelot.GateWay/Properties/launchSettings.json

+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "todos",
+      "applicationUrl": "http://localhost:5153",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

ConsulAndOcelot.GateWay/appsettings.Development.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

ConsulAndOcelot.GateWay/appsettings.json

+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

ConsulAndOcelot.GateWay/ocelot.json

+{
+  "Routes": [
+    {
+      //转发到下游服务地址--url变量
+      "DownstreamPathTemplate": "/api/{url}",
+      //下游http协议
+      "DownstreamScheme": "http",
+      //负载方式，
+      "LoadBalancerOptions": {
+        "Type": "RoundRobin" // 轮询
+      },
+      "DownstreamHostAndPorts": [
+        {
+          "Host": "192.168.8.248",
+          "Port": 5201 //服务端口
+        }, //可以多个，自行负载均衡
+        {
+          "Host": "192.168.8.248",
+          "Port": 5202 //服务端口
+        },
+        {
+          "Host": "192.168.8.248",
+          "Port": 5203 //服务端口
+        }
+      ],
+
+      //上游地址
+      "UpstreamPathTemplate": "/T1/{url}", //网关地址--url变量   //冲突的还可以加权重Priority
+      "UpstreamHttpMethod": [ "GET", "POST", "DELETE", "PUT" ]
+    }
+  ]
+}

CoreCms.Net.Auth/obj/Debug/net8.0/CoreCms.Net.Auth.csproj.CoreCompileInputs.cache

-0fc1819d58ab31eed6b40887ba13d8157f6c169c807440241c2623947fdcb23b

CoreCms.Net.Caching/obj/Debug/net8.0/CoreCms.Net.Caching.csproj.CoreCompileInputs.cache

-a5e79141b1b4f602b82fe29582374509e17daeb925f0bcd6f6263c52da3afe32

CoreCms.Net.Core/obj/Debug/net8.0/CoreCms.Net.Core.csproj.CoreCompileInputs.cache

-515be560c2b1cb046e38567d2ee007af5e00151ec7907753ca92e8aefca8672b

CoreCms.Net.Filter/obj/Debug/net8.0/CoreCms.Net.Filter.csproj.CoreCompileInputs.cache

-1a5cec2c18a94b87e91fd29df781ce5fbecc86700b5f24531ca20baaf29fb690

CoreCms.Net.Loging/obj/Debug/net8.0/CoreCms.Net.Loging.csproj.CoreCompileInputs.cache

-13dea82d2b65a33097a42e7e8ef6ce87162c2feb36a9c6ff0e44b7e4001fa8d1

CoreCms.Net.Middlewares/obj/Debug/net8.0/CoreCms.Net.Middlewares.csproj.CoreCompileInputs.cache

-717d961410a689cc4359cbd43f922d1a556456b73f23c5da38ab7e5df68d35a2

CoreCms.Net.RedisMQ/obj/Debug/net8.0/CoreCms.Net.RedisMQ.csproj.CoreCompileInputs.cache

-f71725fb3e287df0b6c49ea1c270b7c120001c296db0996182d9f722e39b7b1c

CoreCms.Net.Repository/obj/Debug/net8.0/CoreCms.Net.Repository.csproj.CoreCompileInputs.cache

-e2924aeb7d9e7bedf526d486815d971376a5c6bdbd894bbeb5a8de9a52974fcc

CoreCms.Net.Services/obj/Debug/net8.0/CoreCms.Net.Services.csproj.CoreCompileInputs.cache

-6493cfd535f113d076362190b9b6c33bfe5d08d36d2d53257c6fa9fb9cc57ae6

CoreCms.Net.Task/obj/Debug/net8.0/CoreCms.Net.Task.csproj.CoreCompileInputs.cache

-262c6486c621daa2975b0f50f5a8b3415e99f4e3cc61f8086ffde768c852ba63

CoreCms.Net.Utility/Consul/ConsulRegister.cs

+using Consul;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using System;
+using System.Collections.Generic;
+using System.Configuration.Internal;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CoreCms.Net.Utility.Consul
+{
+    /// <summary>
+    /// Consul 注册
+    /// </summary>
+    public static class ConsulRegister
+    {
+        #region 服务注册
+        /// <summary>
+        /// 服务注册
+        /// </summary>
+        /// <param name="app"></param>
+        /// <param name="configuration"></param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseConsul(this IApplicationBuilder app, IConfiguration configuration)
+        {
+            //获取主机生命周期管理接口
+            var lifetime = app.ApplicationServices.GetRequiredService<IHostApplicationLifetime>();
+
+            ConsulClient client = new ConsulClient(c =>
+            {
+                c.Address = new Uri(configuration["Consul:consulAddress"]);
+                c.Datacenter = "orderService";
+            });
+
+            string ip = configuration["ip"];//优先接收变量的值
+            string port = configuration["port"];//优先接收变量的值
+
+            string currentIp = configuration["Consul:currentIP"];
+            string currentPort = configuration["Consul:currentPort"];
+
+            ip = string.IsNullOrEmpty(ip) ? currentIp : ip;//当前程序的 IP
+            port = string.IsNullOrEmpty(port) ? currentPort : port;//当前程序的端口
+
+            string serviceID = $"service:{ip}:{port}";
+
+            //服务注册
+            client.Agent.ServiceRegister(new AgentServiceRegistration()
+            {
+                ID = serviceID,//唯一的
+                Name = configuration["Consul:serviceName"],//组名称-Group
+                Address = ip,//IP 地址
+                Port = int.Parse(port),//端口
+                Tags = new string[] { "api 站点" },
+
+                //健康检查
+                Check = new AgentServiceCheck()
+                {
+                    Interval = TimeSpan.FromSeconds(10),//多久检查一次心跳
+                    HTTP = $"http://{ip}:{port}/Health",//健康检查地址
+                    Timeout = TimeSpan.FromSeconds(5), //超时时间
+                    DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5)//服务启动多久后注册
+                }
+
+            }).Wait();
+
+            //健康检查，不需要新建 Controller
+            app.MapWhen(context => context.Request.Path.Equals("/Health"), appBuilder =>
+            {
+                appBuilder.Run(async context =>
+                {
+                    context.Response.StatusCode = (int)HttpStatusCode.OK;
+                    await context.Response.WriteAsync("Success");
+                });
+            });
+
+            //应用程序终止时，取消注册
+            lifetime.ApplicationStopping.Register(() => 
+            {
+                client.Agent.ServiceDeregister(serviceID).Wait();
+            });
+
+            return app;
+        } 
+        #endregion
+
+    }
+}

CoreCms.Net.Utility/CoreCms.Net.Utility.csproj

@@ -5,6 +5,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Consul" Version="1.7.14.7" />
+    <PackageReference Include="Microsoft.AspNetCore.Http.Abstractions" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.0" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="NPOI" Version="2.6.2" />
     <PackageReference Include="ToolGood.Words" Version="3.1.0" />

CoreCms.Net.Utility/obj/Debug/net8.0/CoreCms.Net.Utility.csproj.CoreCompileInputs.cache

-ab9b525c1b2a7b02403c93c7337ce8e2bb3da8d52544b953bb2b71e984609e61

CoreCms.Net.Web.Admin/obj/Debug/net8.0/CoreCms.Net.Web.Admin.csproj.CoreCompileInputs.cache

-df775e89be116d9d4ef20cd4837ad740ed5ee2d15b6c4eab3c5c1e417aea4393

CoreCms.Net.Web.Admin/wwwroot/index.html

@@ -21,11 +21,6 @@
 
     <script charset="utf-8" src="https://map.qq.com/api/js?v=2.exp&libraries=place&key=225d6c323c15ed3391a890f834bc4533"></script>
 
-    <!-- 让IE8/9支持媒体查询，从而兼容栅格 -->
-    <!--[if lt IE 9]>
-        <script src="https://cdn.staticfile.org/html5shiv/r29/html5.min.js"></script>
-        <script src="https://cdn.staticfile.org/respond.js/1.4.2/respond.min.js"></script>
-    <![endif]-->
     <script>
         /^http(s*):\/\//.test(location.href) || alert('请先部署到 localhost 下再访问');
     </script>

CoreCms.Net.Web.Admin/wwwroot/views/user/login.html

@@ -70,7 +70,7 @@
     </div>
 </div>
 <style>
-    body { font-family: 'Inter',sans-serif; line-height: 1.5; color: #4f5464; }
+  /*  body { font-family: 'Inter',sans-serif; line-height: 1.5; color: #4f5464; }*/
 </style>
 <script>
     layui.use(['admin', 'form', 'coreHelper'], function () {

CoreCms.Net.Web.WebApi/obj/Debug/net8.0/CoreCms.Net.Web.WebApi.csproj.CoreCompileInputs.cache

-1b8b8f466d29504b5f480e527e2cb802e87c629815de130a63797e102681a4a0

ShopERP.Portal.sln

@@ -55,6 +55,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CoreCms.Net.RedisMQ", "Core
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "8.MicroService", "8.MicroService", "{213FB1ED-B055-4E93-B735-70B3741EDB3F}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "5.MicroService", "5.MicroService", "{02EA681E-C7D8-13C7-8484-4AC65E1B71E8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsulAndOcelot.ApiGateWay", "ConsulAndOcelot.ApiGateWay\ConsulAndOcelot.ApiGateWay.csproj", "{1262A559-1A8D-444D-B191-86A904770FCB}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -141,6 +145,10 @@ Global
 		{927E68B4-92D1-4F66-B137-87804055DE93}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{927E68B4-92D1-4F66-B137-87804055DE93}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{927E68B4-92D1-4F66-B137-87804055DE93}.Release|Any CPU.Build.0 = Release|Any CPU
+		{1262A559-1A8D-444D-B191-86A904770FCB}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{1262A559-1A8D-444D-B191-86A904770FCB}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{1262A559-1A8D-444D-B191-86A904770FCB}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{1262A559-1A8D-444D-B191-86A904770FCB}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -166,6 +174,7 @@ Global
 		{0E024CA5-FCE6-48A7-8209-201FF2D9237E} = {82634406-6F43-4E90-B57D-5C7AC3DAFF11}
 		{7043B7B2-6496-4FCB-A230-1EBC5E11B91C} = {B3F41F4C-3681-48F3-9BE3-809763AC1937}
 		{927E68B4-92D1-4F66-B137-87804055DE93} = {B3F41F4C-3681-48F3-9BE3-809763AC1937}
+		{1262A559-1A8D-444D-B191-86A904770FCB} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {A325D634-06E7-4F4E-BA15-AB3E14622FF1}