打不死的小強(qiáng) .net core 微服務(wù) 快速開發(fā)框架 Viper 限流

using NetTools;...// rangeA.Begin is "192.168.0.0", and rangeA.End is "192.168.0.255".var rangeA = IPAddressRange.Parse("192.168.0.0/255.255.255.0");rangeA.Contains(IPAddress.Parse("192.168.0.34")); // is True.rangeA.Contains(IPAddress.Parse("192.168.10.1")); // is False.rangeA.ToCidrString(); // is 192.168.0.0/24
// rangeB.Begin is "192.168.0.10", and rangeB.End is "192.168.10.20".var rangeB1 = IPAddressRange.Parse("192.168.0.10 - 192.168.10.20");rangeB1.Contains(IPAddress.Parse("192.168.3.45")); // is True.rangeB1.Contains(IPAddress.Parse("192.168.0.9")); // is False.
// Support shortcut range description. // ("192.168.10.10-20" means range of begin:192.168.10.10 to end:192.168.10.20.)var rangeB2 = IPAddressRange.Parse("192.168.10.10-20");
// Support CIDR expression and IPv6.var rangeC = IPAddressRange.Parse("fe80::/10"); rangeC.Contains(IPAddress.Parse("fe80::d503:4ee:3882:c586%3")); // is True.rangeC.Contains(IPAddress.Parse("::1")); // is False.
// "Contains()" method also support IPAddressRange argument.var rangeD1 = IPAddressRange.Parse("192.168.0.0/16");var rangeD2 = IPAddressRange.Parse("192.168.10.0/24");rangeD1.Contains(rangeD2); // is True.
// IEnumerable support, it's lazy evaluation.foreach (var ip in IPAddressRange.Parse("192.168.0.1/23")){    Console.WriteLine(ip);}
// You can use LINQ via "AsEnumerable()" method.var longValues = IPAddressRange.Parse("192.168.0.1/23")  .AsEnumerable()  .Select(ip => BitConvert.ToInt32(ip.GetAddressBytes(), 0))  .Select(adr => adr.ToString("X8"));Console.WriteLine(string.Join(",", longValues);
// Constructors from IPAddress objects.var ipBegin = IPAddress.Parse("192.168.0.1");var ipEnd = IPAddress.Parse("192.168.0.128");var ipSubnet = IPAddress.Parse("255.255.255.0");
var rangeE = new IPAddressRange(); // This means "0.0.0.0/0".var rangeF = new IPAddressRange(ipBegin, ipEnd);var rangeG = new IPAddressRange(ipBegin, maskLength: 24);var rangeH = new IPAddressRange(ipBegin, IPAddressRange.SubnetMaskLength(ipSubnet));
// Calculates Cidr subnetsvar rangeI = IPAddressRange.Parse("192.168.0.0-192.168.0.254");rangeI.ToCidrString();  // is 192.168.0.0/24

using System;using System.Collections.Generic;using System.Text;using System.Threading;using System.Threading.Tasks;using Anno.RateLimit;
namespace ConsoleTest{    /// 
    /// 限流測試    /// 
    public class RateLimitTest    {        /// 
        /// 限流測試        /// 
        public void Handle()        {            var service = LimitingFactory.Build(TimeSpan.FromSeconds(1),LimitingType.TokenBucket, 20, 5);            Console.Write("請輸入線程數(shù)：");            long.TryParse(Console.ReadLine(), out long th);            for (int i = 0; i < th; i++)            {                var t = Task.Factory.StartNew(() =>                {                    while (true)                    {                        var result = service.Request();                        //如果返回true，說明可以進(jìn)行業(yè)務(wù)處理，否則需要繼續(xù)等待                        if (result)                        {                            Console.WriteLine($"{DateTime.Now}--{Task.CurrentId}---ok");                            //業(yè)務(wù)處理......                        }                        else                            Thread.Sleep(100);                    }                }, TaskCreationOptions.LongRunning);            }        }    }}

{  "Target": {    "AppName": "ApiGateway",    "IpAddress": "127.0.0.1",    "Port": 7010,    "TraceOnOff": true  },  "Limit": {    "Enable": true,    "TagLimits": [      {        "channel": "*",        "router": "*",        "timeSpan": "1",//限流周期單位秒        "rps": 100,//周期內(nèi)通過的請求個數(shù)        "limitSize": 100//令牌桶，漏桶池子大小      }    ],    "IpLimit": {//ip限流      "timeSpan": 1,//限流周期單位秒      "rps": 100,//周期內(nèi)通過的請求個數(shù)      "limitSize": 100//池子大小    },    "White": [//白名單 用法可以參考IPAddressRange      "0.0.0.1",      "192.168.1.2",      "192.168.2.18"    ],    "Black": [//黑名單      "0.0.0.2",      "192.168.3.18"    ]  }}

channel: Anno.Plugs.Logic//請求tag 必須參數(shù)router: Platform　　　　　　//模塊名稱（沒有Module） 必須參數(shù)method: GetFunc　　　　　　//模塊方法 必須參數(shù)profile: fSFhFv5d4ZlC/JTz1EvoBDNWTr+sNtAhKWTuykqfZHU2oB8/W7aUayqsXmFJXPlRuname: yrm