.net core实践系列之短信服务-Sikiro.SMS.Bus服务的实现

简介: .net core实践系列之短信服务-Sikiro.SMS.Bus服务的实现

前言


前两篇《.net core实践系列之短信服务-Sikiro.SMS.Api服务的实现》、《.net core实践系列之短信服务-Api的SDK的实现与测试》分别讲解了API提供服务与SDK调用API实现。

本篇会继续讲解Sikiro.SMS.Bus的服务实现,此实现是基于开篇的架构设计的拥有调度任务服务,在最后一篇会给架构优化的,抛弃了调度任务服务使用MQ代替。


源码地址:https://github.com/SkyChenSky/Sikiro.SMS


功能流程描述


image.png



如上图所示,消费者订阅到消费消息后,通过工厂类创建出对应的短信运营商类,通过调用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


目录
相关文章
|
9天前
|
数据可视化 网络协议 C#
C#/.NET/.NET Core优秀项目和框架2024年3月简报
公众号每月定期推广和分享的C#/.NET/.NET Core优秀项目和框架(每周至少会推荐两个优秀的项目和框架当然节假日除外),公众号推文中有项目和框架的介绍、功能特点、使用方式以及部分功能截图等(打不开或者打开GitHub很慢的同学可以优先查看公众号推文,文末一定会附带项目和框架源码地址)。注意:排名不分先后,都是十分优秀的开源项目和框架,每周定期更新分享(欢迎关注公众号:追逐时光者,第一时间获取每周精选分享资讯🔔)。
|
3月前
|
开发框架 前端开发 JavaScript
盘点72个ASP.NET Core源码Net爱好者不容错过
盘点72个ASP.NET Core源码Net爱好者不容错过
65 0
|
3月前
|
开发框架 .NET
ASP.NET Core NET7 增加session的方法
ASP.NET Core NET7 增加session的方法
37 0
|
3月前
|
开发框架 JavaScript .NET
ASP.NET Core的超级大BUG
ASP.NET Core的超级大BUG
40 0
|
1月前
|
开发框架 人工智能 .NET
C#/.NET/.NET Core拾遗补漏合集(持续更新)
C#/.NET/.NET Core拾遗补漏合集(持续更新)
|
1月前
|
Windows
windows server 2019 安装NET Framework 3.5失败,提示:“安装一个或多个角色、角色服务或功能失败” 解决方案
windows server 2019 安装NET Framework 3.5失败,提示:“安装一个或多个角色、角色服务或功能失败” 解决方案
|
1月前
|
开发框架 中间件 .NET
C# .NET面试系列七:ASP.NET Core
## 第一部分:ASP.NET Core #### 1. 如何在 controller 中注入 service? 在.NET中,在ASP.NET Core应用程序中的Controller中注入服务通常使用<u>依赖注入(Dependency Injection)</u>来实现。以下是一些步骤,说明如何在Controller中注入服务: 1、创建服务 首先,确保你已经在应用程序中注册了服务。这通常在Startup.cs文件的ConfigureServices方法中完成。例如: ```c# services.AddScoped<IMyService, MyService>(); //
60 0
|
2月前
|
开发框架 前端开发 .NET
福利来袭,.NET Core开发5大案例,30w字PDF文档大放送!!!
为了便于大家查找,特将之前开发的.Net Core相关的五大案例整理成文,共计440页,32w字,免费提供给大家,文章底部有PDF下载链接。
32 1
福利来袭,.NET Core开发5大案例,30w字PDF文档大放送!!!
|
2月前
|
算法 BI API
C#/.NET/.NET Core优秀项目和框架2024年1月简报
C#/.NET/.NET Core优秀项目和框架2024年1月简报
|
3月前
|
算法 C#
C# .Net Core bytes转换为GB/MB/KB 算法
C# .Net Core bytes转换为GB/MB/KB 算法
32 0