【3分钟就会系列】使用Ocelot+Consul搭建微服务吧!

{
  "ReRoutes": [ { "UseServiceDiscovery": true, "DownstreamPathTemplate": "/api/values", "DownstreamScheme": "http", "ServiceName": "T169.OcelotConsul.Service", "LoadBalancerOptions": { "Type": "RoundRobin" }, "UpstreamPathTemplate": "/ss", "UpstreamHttpMethod": [ "Get", "Post" ], "ReRoutesCaseSensitive": false // non case sensitive  } ], "GlobalConfiguration": { "ServiceDiscoveryProvider": { "Host": "localhost", // Consul Service IP "Port": 8500 // Consul Service Port  } } }

{
  //官⽅方⽂文档ReRoutes全节点示例例
  "ReRoutes": [ { //Upstream表示上游请求，即客户端请求到API Gateway的请求 "UpstreamPathTemplate": "/", //请求路路径模板 "UpstreamHttpMethod": [ //请求⽅方法数组 "Get", "POST", "PUT", "DELETE", "OPTIONS" ], //Downstreamb表示下游请求，即API Gateway转发的⽬目标服务地址 "DownstreamScheme": "http", //请求协议，⽬目前应该是⽀支持http和https "DownstreamHostAndPorts": [ { "Host": "localhost", //请求服务地址，应该是可以是IP及域名 "Port": 8081 //端⼝口号  } ], "DownstreamPathTemplate": "/", //下游请求地址模板 // 以下节点可选 "RouteClaimsRequirement": { //标记该路路由是否需要认证 "UserType": "registered" //示例例,K/V形式，授权声明，授权token中  会包含⼀一些claim，如填写则会判断是否和token中的⼀一致，不不⼀一致则不不准访问 }, //以下三个是将access claims转为⽤用户的Header Claims,QueryString，该  功能只有认证后可⽤用 "AddHeadersToRequest": { // "UserType": "Claims[sub] > value[0] > |", //示例例 "UserId": "Claims[sub] > value[1] > |" //示例例  }, "AddClaimsToRequest": {}, "AddQueriesToRequest": {}, "RequestIdKey": "", //设置客户端的请求标识key，此key在请求header中  ，会转发到下游请求中 "FileCacheOptions": { //缓存设置 "TtlSeconds": 15, //ttl秒被设置为15，这意味着缓存将在15秒后过期  。 "Region": "" //缓存region，可以使⽤用administrator API清除  }, "ReRouteIsCaseSensitive": false, //路路由是否匹配⼤大⼩小写 "ServiceName": "", //服务名称，服务发现时必填 "QoSOptions": { //断路路器器配置,⽬目前Ocelot使⽤用的Polly "ExceptionsAllowedBeforeBreaking": 0, //打开断路路器器之前允许的例例  外数量量。 "DurationOfBreak": 0, //断路路器器复位之前，打开的时间(毫秒) "TimeoutValue": 0 //请求超时时间(毫秒)  }, "LoadBalancer": "", //负载均衡 RoundRobin(轮询)/LeastConnection(  最少连接数) "RateLimitOptions": { //官⽅方⽂文档未说明 "ClientWhitelist": [], // 客户端⽩白明代 ？ "EnableRateLimiting": false, // 是否限流 ？ "Period": "", "PeriodTimespan": 0, "Limit": 0 }, "AuthenticationOptions": { //认证配置 "AuthenticationProviderKey": "", //这个key对应的是代码中.AddJW  TBreark中的Key "AllowedScopes": [] //使⽤用范围  }, "HttpHandlerOptions": { "AllowAutoRedirect": true, //指示请求是否应该遵循重定向响应。  如果请求应该⾃自动遵循来⾃自Downstream资源的重定向响应，则将其设置为true; 否则为假。 默认值是true。 "UseCOOKIEContainer": true //该值指示处理理程序是否使⽤用COOKIECon  tainer属性来存储服务器器COOKIE，并在发送请求时使⽤用这些COOKIE。 默认值是true。 }, "UseServiceDiscovery": false //使⽤用服务发现，⽬目前Ocelot只⽀支持Consu  l的服务发现 } ], "GlobalConfiguration": {} }

public class Program
    {
        public static void Main(string[] args) { IWebHostBuilder builder = new WebHostBuilder(); builder.ConfigureServices(s => { s.AddSingleton(builder); }); builder.UseKestrel() .UseContentRoot(Directory.GetCurrentDirectory()) .ConfigureAppConfiguration((hostingContext, cfg) => { cfg.AddJsonFile("ocelot.json", false, true); }) .UseStartup(); var host = builder.Build(); host.Run(); } }

// This method gets called by the runtime. Use this method to add services to the container.
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc();
            services.AddOcelot(Configuration);
        }

        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        public void Configure(IApplicationBuilder app, IHostingEnvironment env) { if (env.IsDevelopment()) { app.UseDeveloperExceptionPage(); } app.UseMvc(); app.UseOcelot().Wait(); }

{
  "profiles": { "WebApplication1": { "commandName": "Project", "launchBrowser": false, "launchUrl": "api/values", "environmentVariables": { "ASPNETCORE_ENVIRONMENT": "Development" }, "applicationUrl": "http://localhost:5000/" } } }

{
  "services": [ { "ID": "OcelotConsul1_service", "name": "T169.OcelotConsul.Service", "tags": [ "urlprefix-/T169.Studeent.Service" ], "address": "localhost", "port": 8081, "checks": [ { "name": "Student Service check", "http": "http://localhost:8081/api/health", "interval": "10s", "timeout": "5s" } ] },{ "ID": "OcelotConsul2_service", "name": "T169.OcelotConsul.Service", "tags": [ "urlprefix-/T169.Studeent.Service" ], "address": "localhost", "port": 8080, "checks": [ { "name": "Student Service check", "http": "http://localhost:8080/api/health", "interval": "10s", "timeout": "5s" } ] } ] }

{
  "profiles": { "ConsulGoForProject": { "commandName": "Project", "applicationUrl": "http://localhost:8081", "environmentVariables": { "ASPNETCORE_ENVIRONMENT": "Development" } } } }

consul agent -dev -config-dir=/tmp/consul/config

"RateLimitOptions": {
    "ClientWhitelist": [], "EnableRateLimiting": true, "Period": "1s", "PeriodTimespan": 1, "Limit": 1 }