36

基于surging 的stage组件设计,谈谈我眼中的微服务。 - fanly11

 4 years ago
source link: https://www.cnblogs.com/fanliang11/p/11204793.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

基于surging 的stage组件设计,谈谈我眼中的微服务。

surging 开源地址:https://github.com/dotnetcore/surging

随着业务的发展,并发量的增多,业务的复杂度越来越大,对于系统架构能力要求越来越高,这时候微服务的设计思想应运而生,但是对于微服务需要引擎进行驱动,这时候基于.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就能访问

192878-20190722151323246-659326917.png

 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 进行测试

192878-20190722153033196-718015282.png
192878-20190722153308379-567195314.png

4. SSL认证

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

5. 网关

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

测试环境

CPU:Intel Core i7-4710MQ

内存:16G

硬盘:1T SSD+512G HDD

网络:局域网

版本:.net core 2.2

 

192878-20190722154725124-404775447.png

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


About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK