談談surging 微服務引擎 2.0的鏈路跟蹤和其它新增功能

一、前言

surging是基於.NET CORE 服務引擎。初始版本誕生於2017年6月份，經過NCC社區二年的孵化，2.0版本將在2019年08月28日進行發佈，經歷二年的發展，已經全部攘括了微服務架構的技術棧，覆蓋了從服務註冊、服務發現、中間件、協議主機再到鏈路跟蹤，並且制定了一套微服務的規則，形成了一套統一的規範。以下是surging的服務引擎架構圖

上圖Diagnostic能夠實現整個服務鏈路的各種信息採集。

比如來源地址、遠程地址、報錯、執行時間、調用鏈路、協議類型以及參數的信息採集，採集完之後通過Skywaking Middleware 中間件的Grpc 推給Skywaking，再通過Skywaking WebUI進行展示。

前面的協議是針對於移動端、Web端和物聯網的解決方案。

後面是服務引擎提供的功能。

二、服務調用鏈路跟蹤

 鏈路跟蹤集成了Skywalking, 參考了SkyAPM-dotnet 而擴展的Surging.Apm.Skywalking引擎組件，而2.0版本只實現rpc 和rest 調用進行鏈路跟蹤，具體配置如下

 1.首先創建文件skyapm.json，放在引擎根目錄下或者是指定的rootpath根目錄下，配置代碼如下

{
  "SkyWalking": {
    "ServiceName": "Surging.Services.Server",
    "Namespace": "",
    "HeaderVersions": [
      "sw6"
    ],
    "Sampling": {
      "SamplePer3Secs": -1,
      "Percentage": -1.0
    },
    "Logging": {
      "Level": "Information",
      "FilePath": "logs/skyapm-{Date}.log"
    },
    "Transport": {
      "Interval": 3000,
      "ProtocolVersion": "v6",
      "QueueSize": 30000,
      "BatchSize": 3000,
      "gRPC": {
        "Servers": "localhost:11800",
        "Timeout": 100000,
        "ConnectTimeout": 100000,
        "ReportTimeout": 600000
      }
    }
  }
}

2.然後添加引用或者掃描引用Surging.Apm.Skywalking組件，就能把採集的數據提交到Skywalking

3.或者可以通過配置項DisableDiagnostic禁用數據採集，配置如下

  {
"Surging": {
    "DisableDiagnostic": true,
}
}

 然後通過stage 組件GET 調用http://127.0.0.1:281/api/user/getusername/222?serviceKey=User 地址，就能通過Skywalking WebUI 看到以下界面

 三、Stage支持白黑名單、HttpMethod規則的設定

 1.白黑名單可以指定RoutePath，全局配置通過不指定RoutePath進行配置，白名單的配置要高於黑名單的配置，也就說有重合的IP, 白名單會進行覆蓋，代碼配置具體如下

  "Stage": {
    
    "AccessSetting": [
      {
        "BlackList": "${blacklist}|127.0.0.1",
        "Enable": false
      },
      {
        "WhiteList": "${whitelist}|192.168.10.50,192.168.43.0/24,127.0.0.1",
        "BlackList": "${blacklist}|192.168.2.50,192.168.1.0/16",
        "RoutePath": "api/user/exists",
        "Enable": true
      }
    ]
  }

2.  通過配置HttpPost ,HttpPut , HttpDelete 和 HttpGet就能配置rest的請求方式，如果不配置，所有請求都支持。而 設置isRegisterMetadata為True，就會把httpmethod註冊為服務元數據。如果是微服務可以設置為true ，如果只是載入業務介面，中轉服務或者聚合服務可以設置為false

    [ServiceBundle("api/{Service}/{Method}")]
    //[ServiceBundle("api/{Service}")]
    //[ServiceBundle("api/{Service}/{Method}/test")]
    //[ServiceBundle("api/{Service}/{Method}/test",false)]
    public interface IUserService: IServiceKey
    {

        /// <summary>
        /// 判斷是否存在
        /// </summary>
        /// <param name="id">用戶編號</param>
        /// <returns></returns>
        [ServiceRoute("{id}")]
        [HttpPost(),HttpPut(), HttpDelete(), HttpGet()]
        // [ServiceBundle("api/{Service}/{id}", false)]
        Task<bool> Exists(int id);

        /// <summary>
        /// 報錯用戶
        /// </summary>
        /// <param name="requestData">請求參數</param>
        /// <returns></returns>
        [Authorization(AuthType = AuthorizationType.JWT)]
        [HttpPost(true),HttpPut(true)]
        Task<IdentityUser> Save(IdentityUser requestData);

     }

四、總結

2019年08月28日發佈2.0版本，敬請期待