淺談surging服務引擎中的rabbitmq組件和容器化部署

時間 2019-11-12

標籤淺談 surging 服務引擎 rabbitmq 組件容器部署欄目 RabbitMQ 简体版

原文原文鏈接

1、前言

上個星期完成了surging 的0.9.0.1 更新工做，此版本經過nuget下載引擎組件，下載後，無需經過代碼build集成，引擎會經過Sidecar模式自動掃描裝配異構組件來構建服務引擎，而這篇將介紹淺談surging服務引擎中的rabbitmq組件和容器化部署 html

surging源碼下載git

2、Sidecar模式

　　好比如今比較火的Service Mesh，談到Service Mesh，就不得不瞭解下Sidecar模式，Sidecar設計模式被愈來愈多的關注和採用，此模式之因此稱做Sidecar，是由於它相似於三輪摩托車上的挎鬥。在此模式中，挎鬥附加到應用程序中，爲應用程序提供支持性功能。挎鬥與應用程序具備相同的生命週期：與應用程序一塊兒建立，一塊兒停用。挎鬥模式有時也稱爲搭檔模式，這是一種分解模式。而surging 採用了Sidecar模式用來附加組件，而使用Sidecar模式有如下功能github

共享存儲空間

　引擎組件部署到共享的文件目錄裏，服務引擎從共享的文件目錄掃描引擎組件文件。docker

共享組件和業務的配置文件

針對於組件的配置文件部署到共享的文件目錄裏，服務引擎從共享的文件目錄加載文件。json

獨立的業務服務

針對於業務能夠把依賴的組件打包部署到共享的文件目錄裏，服務引擎從共享的文件目錄掃描加載，從而部署成獨立的業務服務設計模式

內置多種協議

針對於獨立部署的業務服務，內置了多種協議，提供給服務和外部程序進行調用併發

模式特色

隔離：讓組件都可以關注核心問題。好比eventbus、Logger、 netty 在實現功能的同時無需關注其它組件的實現而發生的衝突；app
單一責任原則：每一個組件都應該職責分開，而根據這一原則，職責應該是對應一個類、模塊或者接口，從而可以獨立進行處理。async
內聚性/可重用性：針對組件的特性，方法能夠進行重用，從而知足組件可持續擴展。分佈式

3、基於Event Bus 的Rabbitmq組件

surging服務引擎擴展了基於eventbus 的rabbitmq ，組件能夠選擇綁定 Normal，Retry(Dead letter)，Fail ，以下圖所示。

而針對於該組件有哪些應用場景呢？

商品秒殺和搶購

搶購/秒殺是現在很常見的一個應用場景，在高併發的流量訪問下能夠將用戶放入到搶購隊列中，購買成功則銷燬消息。

最終數據的一致性

在大型業務中，系統通常由多個獨立的服務組成，在分佈式調用時候把消息放入到rabbitmq 隊列中，再經過消息的冪等性來解決數據的最終一致性

訂單失效處理

在購買商品/服務生成訂單業務中，會設定支付時間，若是一直未支付，會直接關閉訂單，而這個場景能夠經過死信隊列的來解決

示例代碼

能夠經過繼承BaseIntegrationEventHandler或者IIntegrationEventHandler，再經過QueueConsumer特性進行標識，具體代碼以下

  [QueueConsumer("UserLoginDateChangeHandler",QueueConsumerMode.Normal)]
    public  class UserLoginDateChangeHandler : BaseIntegrationEventHandler<UserEvent>
    {
        private readonly IUserService _userService;
        public UserLoginDateChangeHandler()
        {
            _userService = ServiceLocator.GetService<IUserService>("User");
        }
        public override async Task Handle(UserEvent @event)
        {
            Console.WriteLine($"消費1。");
            await _userService.Update(@event.UserId, new UserModel()
            {
                Age = @event.Age,
                Name = @event.Name,
                UserId = @event.UserId
            });
            Console.WriteLine($"消費1失敗。");
            throw new Exception();
        }

        public override Task Handled(EventContext context)
        {
            Console.WriteLine($"調用{context.Count}次。類型:{context.Type}");
            var model = context.Content as UserEvent;
            return Task.CompletedTask;
        }
    }

能夠經過如下選項去更改配置

 1 "EventBus": {
 2     "EventBusConnection": "${EventBusConnection}|localhost",
 3     "EventBusUserName": "${EventBusUserName}|guest",//用戶名
 4     "EventBusPassword": "${EventBusPassword}|guest",//密碼
 5     "VirtualHost": "${VirtualHost}|/",
 6     "MessageTTL": "${MessageTTL}|30000",//消息過時時間，好比過時時間是30分鐘就是1800000
 7     "RetryCount": "${RetryCount}|1",//重試次數，這裏設置的延遲隊列，只能設置爲1
 8     "FailCount": "${FailCount}|3",//處理失敗流程重試次數，若是出現異常，會進行重試
 9     "prefetchCount": "${PrefetchCount}|0",//設置均勻分配消費者消息的個數
10     "BrokerName": "${BrokerName}|surging_demo",//exchange 名稱
11     "Port": "${EventBusPort}|5672"//端口
12   }

生成綁定的隊列以下圖

經過rabbitmq管理工具，能夠經過properties來查看重試次數count 等一些信息，以下圖所示

4、如何部署

surging 服務引擎構建鏡像部署在docker中，能夠按照業務需求自定義化引擎，也能夠從 docker hub中pull鏡像，能夠按照以下流程從docker hub 拉取部署鏡像

如何pull鏡像

能夠經過命令：

docker pull serviceengine/surging

能夠指定具體的tag來拉取，好比須要拉取v0.9.0.2，執行如下命令

docker pull serviceengine/surging:v0.9.0.2

如何配置

1.鏡像能夠用環境變量設置相關參數，而經過如下的默認配置文件知曉如何經過環境變量配置參數，配置的規則：${環境變量名}|默認值

{
  "Surging": {
    "Ip": "${Surging_Server_IP}|0.0.0.0",
    "WatchInterval": 30,
    "Port": "${Surging_Server_Port}|99",
    "MappingIp": "${Mapping_ip}",
    "MappingPort": "${Mapping_Port}",
    "Token": "true",
    "MaxConcurrentRequests": 20,
    "ExecutionTimeoutInMilliseconds": 30000,
    "Protocol": "${Protocol}|None", //Http、Tcp、None
    "RootPath": "${RootPath}|D:\\userapp",
    "Ports": {
      "HttpPort": "${HttpPort}|280",
      "WSPort": "${WSPort}|96"
    },
    "RequestCacheEnabled": false,
    "Packages": [
      {
        "TypeName": "EnginePartModule",
        "Using": "${UseEngineParts}|DotNettyModule;NLogModule;MessagePackModule;ConsulModule;HttpProtocolModule;WSProtocolModule;EventBusRabbitMQModule;"
      }
    ]
  }, //若是引用多個同類型的組件，須要配置Packages，若是是自定義按需引用，無需配置Packages
  "Consul": {
    "ConnectionString": "${Register_Conn}|127.0.0.1:8500", // "127.0.0.1:8500",
    "SessionTimeout": "${Register_SessionTimeout}|50",
    "RoutePath": "${Register_RoutePath}",
    "ReloadOnChange": true
  },
  "EventBus_Kafka": {
    "Servers": "${EventBusConnection}|localhost:9092",
    "MaxQueueBuffering": "${MaxQueueBuffering}|10",
    "MaxSocketBlocking": "${MaxSocketBlocking}|10",
    "EnableAutoCommit": "${EnableAutoCommit}|false",
    "LogConnectionClose": "${LogConnectionClose}|false",
    "OffsetReset": "${OffsetReset}|earliest",
    "GroupID": "${EventBusGroupID}|surgingdemo"
  },
  "EventBus": {
    "EventBusConnection": "${EventBusConnection}|localhost",
    "EventBusUserName": "${EventBusUserName}|guest",
    "EventBusPassword": "${EventBusPassword}|guest",
    "VirtualHost": "${VirtualHost}|/",
    "MessageTTL": "${MessageTTL}|30000",
    "RetryCount": "${RetryCount}|1",
    "FailCount": "${FailCount}|3",
    "BrokerName": "${BrokerName}|surging_demo",
    "Port": "${EventBusPort}|5672"
  },
  "Zookeeper": {
    "ConnectionString": "${Zookeeper_ConnectionString}|127.0.0.1:2181",
    "SessionTimeout": 50,
    "ReloadOnChange": true
  },
  "Logging": {
    "Debug": {
      "LogLevel": {
        "Default": "Information"
      }
    },
    "Console": {
      "IncludeScopes": true,
      "LogLevel": {
        "Default": "${LogLevel}|Debug"
      }
    },
    "LogLevel": {
      "Default": "${LogLevel}|Debug"
    }
  }
}

2.能夠經過設置環境變量surgingpath和cachepath來指定自定義文件配置，好比，掛載/home/fanly 目錄，經過如下命令參數 -v /home/fanly:/home/fanly 來設定，再經過設置如下命令參數用來設定自定義文件配置

--env surgingpath=/home/fanly/configs/surgingSettings.json
--env cachepath=/home/fanly/configs/cacheSettings.json

如何啓動內置引擎組件

引擎能夠加載多個同一類型的引擎組件，能夠經過如下配置啓用哪種引擎組件,若是是自定義的服務引擎，不須要配置如下配置，只須要按照需求引用組件

 "Packages": [
      {
        "TypeName": "EnginePartModule",
        "Using": "${UseEngineParts}|DotNettyModule;NLogModule;MessagePackModule;ConsulModule;HttpProtocolModule;WSProtocolModule;EventBusRabbitMQModule;"
      }
    ]

如何啓動引擎

好比 pull 的鏡像是serviceengine/surging:v0.9.0.2 ，能夠按照如下命令進行啓動

docker run --name surging --env surgingpath=/home/fanly/configs/surgingSettings.json  --env cachepath=/home/fanly/configs/cacheSettings.json -v /home/fanly:/home/fanly  serviceengine/surging:v0.9.0.2