nmkyy/surging

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 0

nmkyy/surging

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

新建文件新建 Diagram 文件

新建子模块

上传文件

分支 24

标签 3

贡献代码

同步代码

创建 Pull Request

了解更多

对比差异通过 Pull Request 同步

同步更新到分支

通过 Pull Request 同步

将会在向当前分支创建一个 Pull
Request,合入后将完成同步

nmkyy 修复dll 87315db

1050 次提交

docs

src

.gitattributes

.gitignore

FETCH_HEAD

LICENSE

README.EN.md

README.md

RELEASE_NOTES.md

Statement-of-Income-and-Expense.md

bash.exe.stackdump

docfx.json

index.md

logo.jpg

sh.exe.stackdump

toc.yml

README

MIT

# surging           [English](https://github.com/dotnetcore/surging/blob/master/README.EN.md)
[![Member project of .NET Core Community](https://img.shields.io/badge/member%20project%20of-NCC-9e20c9.svg)](https://github.com/dotnetcore)
[![GitHub license](https://img.shields.io/badge/license-MIT-blue.svg)](https://mit-license.org/)
### surging 是一个分布式微服务框架,提供高性能RPC远程服务调用,采用Zookeeper、Consul作为surging服务的注册中心,集成了哈希,随机,轮询,压力最小优先作为负载均衡的算法,RPC可以选择采用netty或thrift框架,采用异步非阻塞传输。

### 名字由来

英文名:surging

中文名:滔滔

中文名来自周星驰的经典台词

我对阁下的景仰犹如滔滔江水,连绵不绝,犹如黄河泛滥,一发而不可收拾,而取名英文的含义也希望此框架能流行起来,也能像《.net core surging》这句英文语句含义一样,.net core技术风起云涌,冲击整个软件生态系统。

### 微服务定义
微服务应该是可以自由组合拆分,对于每个业务都是独立的,针对于业务模块的 CRUD 可以注册为服务,而每个服务都是高度自治的,从开发,部署都是独立,而每个服务只做单一功能,利用领域驱动设计去更好的拆分成粒度更小的模块

### 微服务边界
微服务是针对业务的松耦合,也是粒度最小的功能业务模块,针对于行业解决方案,集成相应的service host,而针对于业务需要一些中间件来辅助,比如缓存中间件,eventbus中间件(消息中间件),数据储存中间件,而各个服务又可以互相通过rpc进行可靠性通信。

引擎是微服务的容器,而docker 是服务引擎的容器,而利用k8s或rancher可以针对docker集群化管理,可以服务编排弹性扩容,熟知工具,让工具物尽其用。

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

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

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

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

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

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

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

### 引擎如何安装

docker hub : docker pull serviceengine/surging:版本号

nuget:Install-Package surging -Version 版本号

### 架构图

### 调用链

### 配置:

```c#
var host = new ServiceHostBuilder()
 .RegisterServices(builder =>
 {
 builder.AddMicroService(option =>
 {
 option.AddServiceRuntime();//
 option.AddRelateService();//添加支持服务代理远程调用
 option.AddConfigurationWatch();//添加同步更新配置文件的监听处理
 // option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181")); //使用Zookeeper管理
 option.UseConsulManager(new ConfigInfo("127.0.0.1:8500"));//使用Consul管理
 option.UseDotNettyTransport();//使用Netty传输
 option.UseRabbitMQTransport();//使用rabbitmq 传输
 option.AddRabbitMQAdapt();//基于rabbitmq的消费的服务适配
 // option.UseProtoBufferCodec();//基于protobuf序列化
 option.UseMessagePackCodec();//基于MessagePack序列化
 builder.Register(p => new CPlatformContainer(ServiceLocator.Current));//初始化注入容器
 });
 })
 .SubscribeAt() //消息订阅
 //.UseServer("127.0.0.1", 98)
 //.UseServer("127.0.0.1", 98,"true") //自动生成Token
 //.UseServer("127.0.0.1", 98,"123456789") //固定密码Token
 .UseServer(options=> {
 options.Ip = "127.0.0.1";
 options.Port = 98;
 //options.IpEndpoint = new IPEndPoint(IPAddress.Any, 98);
 //options.Ip = "0.0.0.0";
 options.ExecutionTimeoutInMilliseconds = 30000; //执行超时时间
 options.Strategy=(int)StrategyType.Failover; //容错策略使用故障切换
 options.RequestCacheEnabled=true; //开启缓存(只有通过接口代理远程调用,才能启用缓存)
 options.Injection="return null"; //注入方式
 options.InjectionNamespaces= new string[] { "Surging.IModuleServices.Common" }); //脚本注入使用的命名空间
 options.BreakeErrorThresholdPercentage=50; //错误率达到多少开启熔断保护
 options.BreakeSleepWindowInMilliseconds=60000; //熔断多少毫秒后去尝试请求
 options.BreakerForceClosed=false; //是否强制关闭熔断
 options.BreakerRequestVolumeThreshold = 20;//10秒钟内至少多少请求失败,熔断器才发挥起作用
 options.MaxConcurrentRequests=100000;//支持最大并发
 options.ShuntStrategy=AddressSelectorMode.Polling; //使用轮询负载分流策略
 options.NotRelatedAssemblyFiles = "Centa.Agency.Application.DTO\\w*|StackExchange.Redis\\w*"; //排除无需依赖注册
 })
 //.UseLog4net("Configs/log4net.config") //使用log4net记录日志
 .UseNLog(LogLevel.Error, "Configs/NLog.config")// 使用NLog 记录日志
 //.UseLog4net(LogLevel.Error) //使用log4net记录日志
 //.UseLog4net() //使用log4net记录日志
 .Configure(build =>
 build.AddEventBusFile("eventBusSettings.json", optional: false))//使用eventBusSettings.json文件进行配置
 .Configure(build =>
 build.AddCacheFile("cacheSettings.json", optional: false))//使用cacheSettings.json文件进行配置
 .UseProxy() //使用Proxy
 .UseStartup<Startup>()
 .Build();
 
 using (host.Run())
 {
 Console.WriteLine($"服务端启动成功,{DateTime.Now}。");
 }
 ```

### 文件配置:

```c#
{
 "ConnectionString": "${Register_Conn}|127.0.0.1:8500", // ${环境变量名} |默认值,
 "SessionTimeout": "${Register_SessionTimeout}|50",
 "ReloadOnChange": true
}

```

### 非容器环境文件配置

```c#
 {
 "Ip": "${Server_IP}|127.0.0.1",
 "WatchInterval": 30,
 "Port": "${Server_port}",
 "Token": "true",
 "Protocol": "${Protocol}|Tcp", //支持Http,Tcp协议
 "RootPath": "${RootPath}",
 "RequestCacheEnabled": false
}

```

### 容器环境文件配置

```c#
 {
 "Ip": "${Server_IP}|0.0.0.0",//私有容器IP
 "WatchInterval": 30,
 "Port": "${Server_port}|98",//私有容器端口
 "MappingIp": "${Mapping_ip}",//公开主机IP
 "MappingPort": "${Mapping_Port}",//公开主机端口
 "Protocol": "${Protocol}|Tcp", //支持Http,Tcp协议
 "Token": "true",
 "RootPath": "${RootPath}",
 "RequestCacheEnabled": false
}

```

服务路由访问配置:

```c#
[ServiceBundle("api/{Service}")]
 ```

JWT验证,接口方法添加以下特性:

```c#
 [Authorization(AuthType = AuthorizationType.JWT)];
 ```

AppSecret验证,接口方法添加以下特性:

```c#
 [Authorization(AuthType = AuthorizationType.AppSecret)];
 ```

订阅功能:

```c#
 ServiceLocator.GetService< ISubscriptionAdapt >().SubscribeAt();
 ``` 
 
 
增加服务容错、服务容错降级、服务强制降级

* 增加容错策略Injection,脚本注入:

```c#
[Command(Strategy= StrategyType.Injection ,Injection = @"return null;")]
```

```C# 
[Command(Strategy= StrategyType.Injection ,Injection = @"return 
Task.FromResult(new Surging.IModuleServices.Common.Models.UserModel
 {
 Name=""fanly"",
 Age=18
 });",InjectionNamespaces =new string[] { "Surging.IModuleServices.Common"})] 
```

* 增加容错策略Injection,本地模块注入:

```C# 
[Command(Strategy= StrategyType.Injection ,Injection = @"return true;")] 
```

增加缓存降级,怎么使用?
 
在业务接口方法上添加如下特性

```C# 
 [Command(Strategy= StrategyType.Failover,FailoverCluster =3,RequestCacheEnabled =true)] //RequestCacheEnabled =true 就是启用缓存
```

怎么拦截获取缓存
 
在业务接口方法上添加如下特性
 
 
```C# 
 [InterceptMethod(CachingMethod.Get, Key = "GetUser_id_{0}", Mode = CacheTargetType.Redis, Time = 480)]
```
 
 
怎么拦截删除缓存
 
在业务接口方法上添加如下特性
 
 
```C# 
 [InterceptMethod(CachingMethod.Remove, "GetUser_id_{0}", "GetUserName_name_{0}", Mode = CacheTargetType.Redis)]
```
 
 
怎么添加缓存KEY
 
在业务模型属性上添加,如下特性,可以支持多个
 
 
```C# 
[CacheKey(1)]
```
 
 
配置拦截器
 
 
```C# 
 .AddClientIntercepted(typeof(CacheProviderInterceptor))
```

## 捐赠明细

surging 接受来自社区的捐赠,所有款项将通过 [捐赠明细表](Statement-of-Income-and-Expense.md) 进行公示,接受社区监督。

IDE:Visual Studio 2017 15.5,vscode
 
框架:.NET core 2.1
 
QQ群:615562965
* [文档](http://docs.dotnet-china.org/surging/)
* [简单示例](https://github.com/dotnetcore/surging/blob/master/docs/docs.en/INDEX.md)

## 谁在使用

MIT License Copyright (c) 2017 Fanly Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.