<appSettings>
  <!-- 数据库连接字符串 Mysql-->
  <add key="ConnStr" value="server=127.0.0.1;database=viper;uid=bif;pwd=123456;SslMode=None;"/>
</appSettings>

<!--ViperCenter 端口-->
<Port>7010</Port>
<!--ViperCenter 超时时间-->
<TimeOut>120000</TimeOut>

<Servers>
   <!--dc 注册到注册中心的 服务节点 （下面的内容是ViperService 启动后自动写入的内容）-->
    <dc name="Anno.Plugs.LogicService,Anno.Plugs.TraceService,Anno.Plugs.ViperService" nickname="ViperService-01" ip="100.100.100.9" port="7011" timeout="20000" weight="1" />
  </Servers>

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <!--0,0 第一位是 工作站，第二位数据中心
  （所有的 AnnoService 的 两位数不能重复例如不能存在【1,2】【1,2】）
  可以存在【1,2】【2,1】
  -->
  <IdWorker>0,0</IdWorker>
  <!--App名称-->
  <AppName>ViperService-01</AppName>
  <!--监听端口-->
  <Port>7011</Port>
  <!--权重-->
  <Weight>1</Weight>
  <!--注册到的目标-->
  <Ts Ip="127.0.0.1" Port="7010"/>

new Exception("Исключение потребления, демонстрация тестирования: уведомление о сбое потребления от FirstMessageExceptionEventHandler!");
}
}

Install-Package Anno.EngineData.Cache

using System;
using System.Collections.Generic;
using System.Text;
using Anno.EngineData;
using Anno.EngineData.Cache;

namespace Anno.Plugs.CacheRateLimitService
{
    public class CacheModule : BaseModule
    {
        /*
        Параметр 1: длина кэша
        Параметр 2: время жизни кэша
        Параметр 3: является ли время жизни кэша скользящим
        */
        [CacheLRU(5,6,true)]
        public ActionResult Cache(string msg)
        {
            Console.WriteLine(msg);
            return new ActionResult(true, null,null,msg);
        }
    }
}

Install-Package Anno.EngineData.RateLimit

using System;
using System.Collections.Generic;
using System.Text;
using Anno.EngineData;
using Anno.RateLimit;

namespace Anno.Plugs.CacheRateLimitService
{
    public class LimitModule : BaseModule
    {
        /*
        Параметр 1: алгоритм ограничения скорости — токен-ведро или ведро с утечкой
        Параметр 2: временной интервал ограничения скорости в секундах
        Параметр 3: максимальное количество запросов, которое может быть выполнено за один временной интервал
        Параметр 4: ёмкость ведра
        */
        [EngineData.Limit.RateLimit(LimitingType.TokenBucket,1,5,5)]
        public ActionResult Limit(string msg)
        {
            Console.WriteLine(msg);
            return new ActionResult(true, null, null, msg);
        }
    }
}

{
  "Target": {
    "AppName": "traceWeb",--имя службы
    "IpAddress": "127.0.0.1",--адрес центра регистрации
    "Port": 6660,--порт центра регистрации
    "TraceOnOff": true--включить отслеживание цепочки вызовов
  },
  "Limit": {--ограничение скорости
    "Enable": true,--включать ли ограничение скорости
    "TagLimits": [--ограничения по тегам
      {
        "channel": "*",--канал
        "router": "*",--маршрутизатор
        "timeSpan": "10",--единица времени в секундах
        "rps": 1,--количество допустимых запросов за единицу времени
        "limitSize": 2--размер буфера для хранения
      }
    ],
    "DefaultIpLimit": {--политика ограничения скорости по умолчанию для IP
      "timeSpan": 1,
      "rps": 20,
      "limitSize": 200
    },
    "IpLimits": [--политики ограничения скорости для IP (ipMatch ссылается на IPAddressRange)
      {
        "ipMatch": "0.0.0.1",
        "timeSpan": 1,
        "rps": 100,
        "limitSize": 100
      },
      {
        "ipMatch": "192.168.0.10 - 192.168.10.20",
        "timeSpan": 1,
        "rps": 100,
        "limitSize": 100
      }
    ],
    "White": [--белый список
      "0.0.0.1",
      "192.168.1.2",
      "192.168.2.18"
    ],
    "Black": [--чёрный список
      "0.0.0.2",
      "192.168.3.18"
    ]
  }
}