.NET Core微服务引擎Surging之Stage组件设计

来自:fanly11

一、前言


随着业务的发展,并发量的增多,业务的复杂度越来越大,对于系统架构能力要求越来越高,这时候微服务的设计思想应运而生,但是对于微服务需要引擎进行驱动,这时候基于.NET Core的微服务引擎Surging就诞生了。


1、那么怎么样去理解微服务呢?


微服务是针对业务的松耦合,是对于业务的解耦,也是粒度最小的功能业务模块,对于本地和远程的抽象化,对于远程调用提供了服务治理保证了可靠性通信。


2、那么什么是微服务引擎呢?


微服务引擎是微服务的容器,是扫描或引用加载业务服务模块驱动生成服务提供者,针对于行业解决方案,集成相应的service host,而针对于业务需要一些中间件来辅助,比如缓存中间件,eventbus中间件(消息中间件),数据储存中间件,而各个服务又可 以互相通过rpc进行可靠性通信。


3、是不是需要有非微服务不可的心态去重构系统?


微服务是针对于业务的松耦合,是针对于调用的抽象,所以相关复杂的系统都可以使用微服务的设计思想去重构,但是团队对于微服务把握不到位的话,我建议还是使用SOA去设计系统,后面可以使用k8s做服务治理。


4、那么Surging 又能做什么呢?


  • 构建Web应用程序,微服务和api网关


  • 微服务可以部署在docker。可以使用k8s、rancher服务编排弹性扩容


  • 提供了多协议支持


  • 支持负载平衡分流压力


  • 基于.NET Core的跨平台可以在Windows,macOS和Linux上运行;也可以移植到其他操作系统。


  • 简化的服务调用,通过服务规则的指定,就可以做到服务之间的远程调用,无需其它方式的侵入


  • 服务自动注册与发现,不需要配置服务提供方地址,注册中心基于ServiceId 或者RoutePath查询服务提供者的地址和元数据,并且能够平滑添加或删除服务提供者。


  • 软负载均衡及容错机制,通过surging内部负载算法和容错规则的设定,从而达到内部调用的负载和容错


  • 分布式缓存中间件:通过哈希一致性算法来实现负载,并且有健康检查能够平滑的把不健康的服务从列表中删除


  • 事件总线:通过对于事件总线的适配可以实现发布订阅交互模式


  • 容器化持续集成与持续交付 :通过构建一体化Devops平台,实现项目的自动化构建、部署、测试和发布,从而提高生产环境的可靠性、稳定性、弹性和安全性。


  • 业务模块化驱动引擎,通过加载指定业务模块,能够更加灵活、高效的部署不同版本的业务功能模块


针对于以上描述,我们再来看看Surging 2.0新提供的stage组件,在引擎中又有什么作用呢?


5、Stage(关卡)组件介绍


stage从字面翻译是关卡,阶段。而取名设计的目的是通过这个阶段关卡就能进行下一个阶段的访问。其作用针对于对外访问,其功能有路由转发,鉴权,第三方调用,服务聚合网关,中转服务。


二、功能使用


1、swagger与stage同时使用


swagger组件可以通过加载的业务接口在线生成API文档,这样可以给开发人员进行测试和调试,那么配合stage组件使用就可以针对鉴权服务进行测试。


设置jwt 鉴权


[ServiceBundle("api/{Service}/{Method}")]
//[ServiceBundle("api/{Service}")]
//[ServiceBundle("api/{Service}/{Method}/test")]
//[ServiceBundle("api/{Service}/{Method}/test",false)]
public interface IUserService: IServiceKey
{
 [Authorization(AuthType = AuthorizationType.JWT)]
 Task<int> GetUserId(string userName);
}


通过设置HttpPort 或者stage 的HttpsPort和HttpPort,就能通过相关端口访问,默认是280,然后可以通过http://127.0.0.1:280/swagger/index.html就能访问



2、服务聚合和中转服务


针对于第三方或者移动端调用,需要做服务聚合,以满足业务结果返回的需要, 这个时候就可以使用stage组件了


注:


  • 聚合服务、中转服务没有服务治理,服务注册与发现


  • 聚合服务、中转服务调用微服务,可以支持服务治理,服务注册与发现,服务缓存降级


3、文件服务


通过引用stage组件,然后设置Policy配置就能跨域进行文件上传和下载功能,而且文件服务可以水平扩展部署


需要按照以下代码进行编码,最主要是注意参数和返回结果类型


[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="form">HttpFormCollection 类型参数</param>
/// <returns></returns>
Task<bool> UploadFile(HttpFormCollection form);

/// <summary>
/// 测试下载文件
/// </summary>
/// <param name="fileName">文件名</param>
/// <param name="contentType">Content-Type</param>
/// <returns></returns>
[ServiceRoute("{fileName}/{contentType}")]
Task<IActionResult> DownFile(string fileName, string contentType);
}

然后可以通过swagger 进行测试


上传文件



下载文件



4、SSL认证


可以通过配置HttpsPort、CertificateFileName、CertificateLocation、CertificatePassword来生成ssl认证


5、网关


stage 可以生成对外访问网关,其作用是路由转发和鉴权


三、性能

 

测试环境


CPU:Intel Core i7-4710MQ


内存:16G


硬盘:1T SSD+512G HDD


网络:局域网


版本:.NET Core 2.2



四、总结


Surging 2.0将在下月底进行发布,敬请期待

推荐↓↓↓
DotNet程序员
上一篇:.NET Core 3.0 Preview 7 发布 下一篇:C# 管道式编程