Wing致力于打造一个功能强大、最接地气的.NET微服务框架,支持.NET6+运行平台。支持Consul服务注册与发现,服务间通讯支持http和grpc调用,内置负载均衡器。支持服务策略配置,服务异常降级处理。支持
Saga分布式事务,支持三种恢复策略:向前恢复、向后恢复、先前再后。自带配置中心,服务配置可以在线集中统一管理。支持http/grpc/sql链路追踪APM及耗时分析统计。内置服务网关,支持全局服务策略和个性化服务策略配置。支持RabbitMQ事件总线,自带人性化的Dashboard管理界面。
gitee:https://linguicheng.gitee.io/Wing (暂停访问,请使用github地址)
github:https://linguicheng.github.io/Wing
需要用到的第三方中间件:Consul(强依赖)、RabbitMQ(弱依赖)、数据库(强依赖)
QQ:183015352
服务注册是指服务启动后将该服务的IP、端口等信息注册到Consul。
-
提前准备:安装并启动Consul
-
打开 Visual Studio 2022 并创建Web Api项目(点击查看完整示例代码1.2)
dotnet add package Wing.Consul
using Wing; var builder = WebApplication.CreateBuilder(args); builder.Host.AddWing(builder => builder.AddConsul()); // Add services to the container. builder.Services.AddControllers(); builder.Services.AddWing(); var app = builder.Build(); // Configure the HTTP request pipeline. app.UseHttpsRedirection(); app.UseAuthorization(); app.MapControllers(); app.Run();
{
// 是否启用配置中心,默认启用
"ConfigCenterEnabled": false,
"Consul": {
"Url": "http://localhost:8500",
"Service": {
//Http Grpc
"Option": "Http",
"HealthCheck": {
"Url": "http://localhost:1210/health",
//单位:秒
"Timeout": 10,
//单位:秒
"Interval": 10
},
"Name": "Wing.Demo_1.2.1",
"Host": "localhost",
"Port": 1210,
"Tag": "",
"LoadBalancer": {
//RoundRobin WeightRoundRobin LeastConnection
"Option": "WeightRoundRobin",
//权重
"Weight": 60
},
"Scheme": "http",
"Developer": "linguicheng"
},
//定时同步数据时间间隔,单位:秒 小于等于0表示立即响应
"Interval": 10,
//数据中心
"DataCenter": "dc1",
//等待时间,单位:分钟
"WaitTime": 3
}
}- 程序运行后,打开consul UI管理界面,可以看到注册服务
Wing.Demo_1.2,如下图:
Wing.UI是Wing微服务框架中的一个可视化操作管理系统,主要功能有服务治理、配置中心、APM管理、Saga分布式事务查询。
-
提前准备:安装并启动Consul
-
打开 Visual Studio 2022 并创建Web Api项目(点击查看完整示例代码1.3)
安装服务注册nuget包Wing.Consul,UI可视化界面管理nuget包Wing.UI,选择对应的数据库驱动(参考FreeSql官网),以SqlServer为例,安装FreeSql.Provider.SqlServer。
dotnet add package Wing.Consul dotnet add package Wing.UI dotnet add package FreeSql.Provider.SqlServer
using Wing; var builder = WebApplication.CreateBuilder(args); builder.Host.AddWing(builder => builder.AddConsul()); // Add services to the container. builder.Services.AddControllers(); builder.Services.AddWing().AddWingUI(FreeSql.DataType.SqlServer); var app = builder.Build(); // Configure the HTTP request pipeline. app.UseHttpsRedirection(); app.UseAuthorization(); app.MapControllers(); app.Run();
{
// 是否启用配置中心,默认启用
"ConfigCenterEnabled": false,
"Consul": {
"Url": "http://localhost:8500",
//定时同步数据时间间隔,单位:秒 小于等于0表示立即响应
"Interval": 10,
//数据中心
"DataCenter": "dc1",
//等待时间,单位:分钟
"WaitTime": 3
},
// 数据库链接
"ConnectionStrings": {
"Wing": "Data Source=192.168.56.96;User Id=sa;Password=wing123.;Initial Catalog=Wing;TrustServerCertificate=true;Pooling=true;Min Pool Size=1"
},
//自动同步实体结构到数据库
"UseAutoSyncStructure": true,
// 首页
"Home": {
// 指标耗时异常统计 单位:毫秒 默认60秒
"Timeout": {
"Gateway": 2000,
"Apm": {
"Http": 2000,
"WorkServiceHttp": 2000,
"WorkServiceSql": 2000
},
// 查询统计时间 默认:最近一个月
"SearchTime": "2020年01月01日"
}
},
}- 程序运行后,浏览器访问 http://localhost:1310/wing ,运行效果如下图:
- 可以看到示例 1.2 注入的服务
Wing.Demo_1.2
服务发现是指服务启动后将服务注册信息定时同步刷新到本地或实时获取Consul的服务信息。
-
提前准备:安装并启动Consul
-
打开 Visual Studio 2022 并创建Grpc Service项目(点击查看完整示例代码1.4)
dotnet add package Wing.Consul
protobuf文件
syntax = "proto3"; package grpc.health.v1; message HealthCheckRequest { string service = 1; } message HealthCheckResponse { enum ServingStatus { UNKNOWN = 0; SERVING = 1; NOT_SERVING = 2; } ServingStatus status = 1; } service Health { rpc Check(HealthCheckRequest) returns (HealthCheckResponse); rpc Watch(HealthCheckRequest) returns (stream HealthCheckResponse); }
HealthCheck代码
public class HealthCheck : Health.HealthBase { public override Task<HealthCheckResponse> Check(HealthCheckRequest request, ServerCallContext context) { return Task.FromResult(new HealthCheckResponse() { Status = HealthCheckResponse.Types.ServingStatus.Serving }); } public override async Task Watch(HealthCheckRequest request, IServerStreamWriter<HealthCheckResponse> responseStream, ServerCallContext context) { await responseStream.WriteAsync(new HealthCheckResponse() { Status = HealthCheckResponse.Types.ServingStatus.Serving }); } }
using Wing; var builder = WebApplication.CreateBuilder(args); builder.Host.AddWing(builder => builder.AddConsul()); // Add services to the container. builder.Services.AddGrpc(); builder.Services.AddWing(); var app = builder.Build(); // Configure the HTTP request pipeline. app.MapGrpcService<GreeterService>(); app.MapGet("/", () => "Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909"); app.Run();
{
// 是否启用配置中心,默认启用
"ConfigCenterEnabled": false,
"Consul": {
"Url": "http://localhost:8500",
"Service": {
//Http Grpc
"Option": "Grpc",
"HealthCheck": {
"Url": "localhost:1410",
//单位:秒
"Timeout": 10,
//单位:秒
"Interval": 10,
"GRPCUseTLS": false
},
"Name": "Wing.Demo_1.4",
"Host": "localhost",
"Port": 1410,
"Tag": "",
"LoadBalancer": {
//RoundRobin WeightRoundRobin LeastConnection
"Option": "WeightRoundRobin",
//权重
"Weight": 4
},
"Scheme": "http",
"Developer": "linguicheng"
},
//定时同步数据时间间隔,单位:秒 小于等于0表示立即响应
"Interval": 10,
//数据中心
"DataCenter": "dc1",
//等待时间,单位:分钟
"WaitTime": 3
}
}- 运行当前程序并启动示例 1.3,浏览器访问 http://localhost:1310/wing ,可以看到注入的Grpc服务
Wing.Demo_1.4,运行效果如下图:
- 在示例 1.2 中调用当前Grpc服务中
SayHello方法,代码如下:
[HttpGet("hello")] public Task<string> SayHello() { return _serviceFactory.InvokeAsync("Wing.Demo_1.4", async serviceAddr => { var channel = GrpcChannel.ForAddress(serviceAddr.ToString()); var greeterClient = new Greeter.GreeterClient(channel); var result = await greeterClient.SayHelloAsync(new HelloRequest { Name = "Wing" }); return result.Message; }); }
- 运行示例 1.2,浏览器访问 http://localhost:1210/weatherforecast/hello ,运行效果如下图:
