surging 微服務引擎 -協議主機的Behavior特性

1、前言

由於工做的關係，最近不多更新surging,由於surging 一直處在不溫不火的狀態，而本身天天利用業餘時間進行完善，天天都是疲憊的狀態，還要應付新手的提問，曾經一度想放棄，可是有些人勸說，surging 已經有必定的忠粉，放棄不免惋惜，你能夠發展收費版本，這樣你也有動力進行更新，用戶也有需求，付費也是情理之中，你也能更好的發展下去。就在上個月我剝離了企業版、預約版、社區版。

社區版：閹割版本，不帶配置中心，文檔，服務編排流程引擎，管理中心等功能，並且沒有諮詢服務

預約版：部分企業版本功能，有配置中心，文檔，部分中間件，帶諮詢服務，

企業版：2天一對一培訓課程，諮詢服務，有配置中心，文檔，服務編排流程引擎，管理中心，全部中間件，

社區版地址：https://github.com/dotnetcore/surging

二、什麼是微服務

這幾年微服務這個話題很火，可謂是你方唱罷我登場，什麼框架都要和微服務牽扯點關係，和微服務不要緊就會顯得很low,對於微服務設計，沒有明確的定義，因此市面大多都有本身的理解和定義，而我我的認爲大部分開源都是老湯換新葯，都是一個療效，沒有本質的區別，最主要是騙騙領導，對外宣傳公司的技術實力，而對於現實來說，基本上真正的微服務都在一二線互聯網公司，並且你會發現總公司，分公司，附屬公司都要本身開發一套微服務，而這是爲何呢？由於有弊端，要開發屬於本身的微服務，來知足業務的需求。那麼我是怎麼理解這個微服務呢？

微服務是針對業務的鬆耦合，是對於業務的解耦，也是粒度最小的功能業務模塊，對於協議高度集成化，對於本地和遠程調用的抽象化和服務治理保證了可靠性通訊，技術人員只關注業務實現和拆分，而無需關注底層的業務實現。

  而以上只是談了微服務的思想，那麼對於微服務就須要經過引擎掃描或者引用加載業務服務模塊驅動生成服務提供者，而針對於行業解決方案，咱們能夠加載須要協議服務主機。那麼咱們下面來談談如何擴展協議服務主機

三、協議主機集成-behavior特性

針對於協議服務主機，咱們有必要認識下behaviors，那麼什麼是behaviors呢？

behaviors是協議服務主機引擎特性， 每一個擴展的主機都包含一個 behavior， 能夠包含屬性、數據、標識和方法，組件引用它時，它的屬性、數據和方法會被合併到組件中，對於各自的behavior會在啓動的時候進行初始化生成ServiceEntries。裏面包含了類型，routepath, behaviors. 如下各個協議服務主機的behavior

BackgroundServiceBehavior：繼承IServiceBehavior， 後臺託管服務，能夠構建後臺定時任務

UdpBehavior：繼承IServiceBehavior，能夠集成UDP協議 

WSBehavior：繼承於IServiceBehavior，能夠集成ws協議

GreeterBehavior： 繼承於IServiceBehavior和Protos生成的GreeterBase，能夠集成Grpc

MqttBehavior：繼承於ServiceBase，能夠集成MQTT協議

DnsBehavior：繼承於IServiceBehavior，能夠集成DNS

以上全部的Behavior，IServiceBehavior和ServiceBase都支持rest，rpc可靠性遠程調用。

四、協議主機-Grpc

 對於剛剛更新Grpc 服務主機，有些人還不會用，這裏咱們談談如何構建Grpc

業務接口

首先創建業務接口，代碼以下

  [ServiceBundle("api/{Service}/{Method}")]
    public  interface IGreeterService : IServiceKey
    {
    }

proto文件

在建立proto 文件前，須要nuget安裝Google.Protobuf，Grpc.Core，Grpc.Tools。

而後在業務接口模塊建立的Protos/greet.proto 文件內容以下：

syntax = "proto3";
 
package Greet;
 
// The greeting service definition.
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}
 
// The request message containing the user's name.
message HelloRequest {
  string name = 1;
}
 
// The response message containing the greetings.
message HelloReply {
  string message = 1;
}

由於是利用Grpc.Tools工具 經過.proto文件生成C#資源文件。因此還須要編輯.csproject文件，須要把如下代碼添加到.csproject文件中。

  <ItemGroup>
    <Protobuf Include="Protos\greet.proto" GrpcServices="Server" />
 </ItemGroup>

Behavior特性

針對於grpc須要再建立Behavior，而且繼承經過Grpc.Tools生成的Greeter.GreeterBase和IServiceBehavior，代碼以下

 public  partial class GreeterBehavior : Greeter.GreeterBase,IServiceBehavior
    {
        
    }

業務模塊

針對於業務模塊，須要繼承Behavior和業務接口，代碼以下

    public class GreeterService: GreeterBehavior, IGreeterService
    {
        public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
        {
            return Task.FromResult(new HelloReply
            {
                Message = "Hello " + request.Name
            });
        }
    }

配置

添加Surging.Core.Grpc引擎組件，配置GrpcPort,啓用GrpcModule，配置surgingSettings.json以下

    "Ports": {
      "HttpPort": "${HttpPort}|280",
      "WSPort": "${WSPort}|96",
      "MQTTPort": "${MQTTPort}|97",
      "GrpcPort": "${GrpcPort}|95"
    }

    "Packages": [
      {
        "TypeName": "EnginePartModule",
        "Using": "${UseEngineParts}|ServiceProxyModule;DotNettyModule;NLogModule;MessagePackModule;ConsulModule;WSProtocolModule;MqttProtocolModule;EventBusRabbitMQModule;CachingModule;KestrelHttpModule;DnsProtocolModule;SwaggerModule;ApiGeteWayModule;SkywalkingModule;KestrelNLogModule;ServiceHostModule;GrpcModule"
      }
    ]

經過以上服務端配置，那麼再經過建立client 進行測試

客戶端

而針對於客戶端，也須要nuget 安裝須要Google.Protobuf，Grpc.Core，Grpc.Tools。同時建立greet.proto 文件，而後咱們須要編輯.csproject文件，須要把如下代碼添加到.csproject文件中。

  <ItemGroup>
    <Protobuf Include="Protos\greet.proto" GrpcServices="Client" />
  </ItemGroup>

而後封裝ServiceClient調用，代碼以下

using Greet;
using Grpc.Core;
 
namespace GrpcService1
{
    public class ServiceClient
    {
        private static ChannelBase _channel;
        private static Greeter.GreeterClient _client;

        static ServiceClient()
        {
            _channel = new Channel("127.0.0.1", 95, ChannelCredentials.Insecure);
            _client = new Greeter.GreeterClient(_channel);
        }

        public static HelloReply SayHello(string name)
        {
            return _client.SayHello(new HelloRequest
            {
                Name = name
            });
        }
    }
}

再在Main函數中調用封裝好的ServiceClient，代碼以下

using System;

namespace GrpcService1
{
    public class Program
    {
        public static void Main(string[] args)
        {
            var result = ServiceClient.SayHello("fanly");

            Console.WriteLine("grpc Client Call SayHello():" + result);
            Console.WriteLine("任意鍵退出...");
            Console.ReadKey();
        }

    
    }
}

運行結果以下圖所示