基于 NET CORE微服务框架 -浅析如何使用surging

柔情只为你懂 2022-04-16 00:19 222阅读 0赞

**分享一下我老师大神的人工智能教程！零基础，通俗易懂！[http://blog.csdn.net/jiangjunshow][http_blog.csdn.net_jiangjunshow]**

**也欢迎大家转载本篇文章。分享知识，造福人民，实现我们中华民族伟大复兴！**

**1****、前言**

surging受到大家这么强烈的关注，我感到非常意外，比如有同僚在公司的分享会上分享surging, 还有在博客拿其它的RPC框架，微服务做对比等等，这些举动都让我感觉压力很大，毕竟作为个人的开源项目，无法与成熟的开源社区的项目相比，也只有等到后面有许许多多志同道合的朋友加入一起研发完善surging，这样才能让surging 成为流行的微服务框架。

这篇文章介绍如何使用surging

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

# **2****、设计模式** #

Surging 提供了以下四种设计模式

## 2.1 **代理模式** ##

通过代理调用不同的微服务。并且针对于规则控制其访问，如下图所示：

![640?wx\_fmt=png&wxfrom=5&wx\_lazy=1][640_wx_fmt_png_wxfrom_5_wx_lazy_1]

## **2.2** **异步消息模式** ##

再处理等待而阻塞的问题时候， 基于微服务的架构会选择使用消息队列来代替请求/响应模式，如下图所示：

![0?wx\_fmt=png][0_wx_fmt_png]

## 2.3 链式模式 ##

这种模式在接收到请求后会进行互相合并的响应，如下图所示：

服务A接收到请求后会与服务B进行通信，服务B会同服务C进行通信。所有服务之间的通信使用基于Netty的RPC通信。

![0?wx\_fmt=png][0_wx_fmt_png 1]

## 2.4 分支模式 ##

这种模式允许调用多个服务提供者,来合并数据进行返回，如下图所示：

![0?wx\_fmt=png][0_wx_fmt_png 2]

# **3****、外部如何交互** #

服务主要针对提交的数据进行处理，在单个服务或多个服务调用的问题上，采取使用网关统一访问的形式进行处理，如下图所示

![0?wx\_fmt=png][0_wx_fmt_png 3]

网关包括以下功能：

1.  安全身份认证
2.  统一访问
3.  流量控制
4.  分流控制
5.  数据监控
6.  缓存拦截

## 2.简单示例 ##

### 服务端 ###

<table> 
 <tbody> 
  <tr> 
   <td><br></td> 
   <td> 
    <div> 
     <code>var</code>&nbsp; 
     <code>host&nbsp;=&nbsp;</code> 
     <code>new</code>&nbsp; 
     <code>ServiceHostBuilder()</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.RegisterServices(option=&gt;&nbsp;{ </code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.Initialize();&nbsp;</code> 
     <code>//初始化服务</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.RegisterServices();</code> 
     <code>//依赖注入领域服务</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.RegisterRepositories();</code> 
     <code>//依赖注入仓储</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.RegisterModules();</code> 
     <code>//依赖注入第三方模块</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.RegisterServiceBus();</code> 
     <code>//依赖注入ServiceBus</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>})</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.RegisterServices(builder&nbsp;=&gt;</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>{ </code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>builder.AddMicroService(option&nbsp;=&gt;</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>{ </code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.AddServiceRuntime();</code> 
     <code>//</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>//&nbsp;option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181")); //使用Zookeeper管理</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.UseConsulManager(</code> 
     <code>new</code>&nbsp; 
     <code>ConfigInfo(</code> 
     <code>"127.0.0.1:8500"</code> 
     <code>));</code> 
     <code>//使用Consul管理</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.UseDotNettyTransport();</code> 
     <code>//使用Netty传输</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.UseRabbitMQTransport();</code> 
     <code>//使用rabbitmq&nbsp;传输</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>option.AddRabbitMQAdapt();</code> 
     <code>//基于rabbitmq的消费的服务适配</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>builder.Register(p&nbsp;=&gt;&nbsp;</code> 
     <code>new</code>&nbsp; 
     <code>CPlatformContainer(ServiceLocator.Current));</code> 
     <code>//初始化注入容器</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>});</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>})</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.SubscribeAt()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>//消息订阅</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.UseServer(</code> 
     <code>"127.0.0.1"</code> 
     <code>,&nbsp;98)</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>//.UseServer("127.0.0.1",&nbsp;98，“true”) //自动生成Token</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>//.UseServer("127.0.0.1",&nbsp;98，“123456789”) //固定密码Token</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.UseStartup&lt;Startup&gt;()</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>.Build();</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>using</code>&nbsp; 
     <code>(host.Run())</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>{ </code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>Console.WriteLine($</code> 
     <code>"服务端启动成功，{DateTime.Now}。"</code> 
     <code>);</code> 
    </div> 
    <div> 
     <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
     <code>}</code> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

###    服务路由访问配置 ###

在接口上，添加以下特性（还未实现统一方法配置）

[ServiceBundle("api/{Service}")]

### 服务创建代理调用 （需要依赖接口创建代理） ###

ServiceLocator.GetService<IServiceProxyFactory>().CreateProxy<T>(key)

###  ###

### 服务根据RoutePath 进行调用（不需要依赖接口，耦合性低） ###

<table> 
 <tbody> 
  <tr> 
   <td><br></td> 
   <td> 
    <div> 
     <code>ServiceLocator.GetService&lt;IServiceProxyProvider&gt;().Invoke&lt;</code> 
     <code>string</code> 
     <code>&gt;(model,&nbsp;path, serviceKey)</code> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

###  ###

### 本地模块和服务调用 ###

ServiceLocator.GetService<T>(key)

通过以上配置，可以通过网关进行访问，如果我们要访问接口IUserService ,方法为GetUser，路由映射的规则\[ServiceBundle("api/\{Service\}/\{ Method\}")\],所转化地址应该是api/User/GetUser,

用Postman测试的效果如下：

![0?wx\_fmt=png][0_wx_fmt_png 4]

# 4. 总结 #

surging外部通过Api 网关 Rest 访问，内部通过netty RPC访问，surging还在不断完善中，帮助文档也正在赶工中，请大家耐心等待。如感兴趣请多关注或者加入QQ群：615562965

原文地址：http://www.cnblogs.com/fanliang11/p/7766955.html

--------------------

**.NET社区新闻，深度好文，微信中搜索dotNET跨平台或扫描二维码关注**

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg]

#### 给我老师的人工智能教程打call！[http://blog.csdn.net/jiangjunshow][http_blog.csdn.net_jiangjunshow] ####

![这里写图片描述][SouthEast]

[http_blog.csdn.net_jiangjunshow]: https://blog.csdn.net/jiangjunshow/article/details/77338485
[640_wx_fmt_png_wxfrom_5_wx_lazy_1]: https://img-blog.csdnimg.cn/img_convert/11efda94fe611b88d648d589c67ea012.png;wxfrom=5&wx_lazy=1
[0_wx_fmt_png]: /images/20220416/14a2a9c483ea480896c21043337a327f.png
[0_wx_fmt_png 1]: /images/20220416/0a94ea8987774831aa0cb12e2f314f42.png
[0_wx_fmt_png 2]: /images/20220416/ab67177ad8a047e2a01802c4d87a8ecc.png
[0_wx_fmt_png 3]: /images/20220416/c0bd1e920b2f4027823936789322b1cc.png
[0_wx_fmt_png 4]: /images/20220416/a84c35f5b8124309950ef8228cd31ac3.png
[640_wx_fmt_jpeg]: /images/20220416/14aeb73e85024c4a9873b0253a27a219.png
[SouthEast]: /images/20220416/7db3a9c8a947450fbf7d04087f8c9419.png