.net core實踐系列之簡訊服務-Sikiro.SMS.Bus服務的實現
前言
本篇會繼續講解Sikiro.SMS.Bus的服務實現,此實現是基於開篇的架構設計的擁有排程任務服務,在最後一篇會給架構優化的,拋棄了排程任務服務使用MQ代替。
原始碼地址:https://github.com/SkyChenSky/Sikiro.SMS
功能流程描述
如上圖所示,消費者訂閱到消費訊息後,通過工廠類創建出對應的簡訊運營商類,通過呼叫Send方法進行對簡訊運營商服務請求,得到響應結果後對持久化資料的狀態進行更新。假如中途遇到異常則回滾資料狀態,等待下一次排程任務進行排程。
下面是MainService的程式碼示例:
public class MainService : IMicroService {private readonly IBus _bus; private readonly SmsService _smsService; public MainService(IBus bus, SmsService smsService) { _bus = bus; _smsService = smsService; } public void Start() { Console.WriteLine("I started"); _bus.Subscribe<SmsQueueModel>("", msg => { try { _smsService.Send(msg.MapTo<SmsQueueModel, SmsModel>()); } catch (Exception e) { _smsService.RollBack(); e.WriteToFile(); } }); }public void Stop() { ConfigServer.Container?.Dispose(); Console.WriteLine("I stopped"); } }
下面是SmsService的程式碼示例:
public void Send(SmsModel item) { Sms = item; var isSuccess = _smsFactory.Create(item.Type).SendSMS(item.Mobiles, item.Content, _configuration["Sms:SignName"]); if (isSuccess) Success(item.Id); else Fail(item.Id); } public void RollBack() { RollBack(Sms.Id); } public void RollBack(string id) { _mongoProxy.Update<SmsModel>(a => a.Id == id, a => new SmsModel { Status = SmsEnums.SmsStatus.待處理 }); } private void Success(string id) { _mongoProxy.Update<SmsModel>(a => a.Id == id, a => new SmsModel { Status = SmsEnums.SmsStatus.成功 }); } private void Fail(string id) { _mongoProxy.Update<SmsModel>(a => a.Id == id, a => new SmsModel { Status = SmsEnums.SmsStatus.失敗 }); }
元件選擇
宿主框架
對於有在.Net Framework上開發Windows服務的朋友對TopShelf應該會很熟悉。
優勢主要體現下面三點:
- 基於控制檯應用
- 除錯方便
- 易於安裝部署
不少人認為,Core的出現,跨平臺加命令列的優勢,可以輕易的在Linux部署守護程序。難道還需要宿主框架?
然而並不是所有公司選用了Linux系統的伺服器,就像我們公司。既然使用了Windows伺服器應該將他部署為Windows服務使其視覺化方便管理,另外沒有等待到TopShelf的Core版本,因此我選擇了另一款宿主框架:PeterKottas.DotNetCore.WindowsService
PeterKottas.DotNetCore.WindowsService
原始碼地址:https://github.com/PeterKottas/DotNetCore.WindowsService
雖然比不起TopShelf的功能強大,但是對於一般的需求使用基本滿足,而且使用方式也與TopShelf相似。下面是使用示例:
class Program { static void Main(string[] args) { ServiceRunner<MainService>.Run(config => { config.SetServiceInfo(); config.Service(serviceConfig => { serviceConfig.UseAutofac(); serviceConfig.UseServiceFactory(); serviceConfig.OnStart((service, extraParams) => { service.Start(); }); serviceConfig.OnStop(service => { service.Stop(); }); serviceConfig.OnError(Console.WriteLine); }); }); } }
下面是安裝解除安裝的命令示例:“
dotnet Sikiro.SMS.BUS.dll action:install dotnet Sikiro.SMS.BUS.dll action:uninstall
結尾
這裡就是本篇的內容,相比於前面幾篇的內容相對少點,如果有中途來看的朋友可以把《.net core實踐系列之簡訊服務-架構設計》看看作個補充,如果有任何建議,可以在下方評論反饋給我。