Wing
致力于打造一个功能强大、最接地气的.NET
微服务框架,支持.NET6+
运行平台。支持Consul
服务注册与发现,服务间通讯支持http
和grpc
调用,内置负载均衡器。支持服务策略
配置,服务异常降级处理。支持
Saga分布式事务
,支持三种恢复策略:向前恢复、向后恢复、先前再后。自带配置中心
,服务配置可以在线集中统一管理。支持http/grpc/sql链路追踪APM
及耗时分析统计。内置服务网关
,支持全局服务策略和个性化服务策略配置。支持RabbitMQ
事件总线,自带人性化的Dashboard
管理界面。
gitee:https://linguicheng.gitee.io/Wing
github:https://linguicheng.github.io/Wing
需要用到的第三方中间件:Consul
(强依赖)、RabbitMQ
(弱依赖)、数据库
(强依赖,目前支持SqlServer、Oracle、MySql、PostgreSql、Sqlite)
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
}
}
Wing.Demo_1.2
,如下图:Wing.UI
是Wing
微服务框架中的一个可视化操作管理系统,主要功能有服务治理、配置中心、APM管理、Saga分布式事务查询。
提前准备:安装并启动Consul、数据库支持(SqlServer、Oracle、MySql、PostgreSql、Sqlite)
打开 Visual Studio 2022 并创建Web Api项目(点击查看完整示例代码1.3)
安装服务注册nuget包Wing.Consul
,UI可视化界面管理nuget包Wing.UI
,选择对应的数据库包,以SqlServer为例,安装Wing.SqlServer
。
dotnet add package Wing.Consul
dotnet add package Wing.UI
dotnet add package Wing.SqlServer(可选Wing.MySql/Wing.Oracle/Wing.PostgreSQL)
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().AddPersistence();
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"
}
},
}
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
}
}
Wing.Demo_1.4
,运行效果如下图: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. 协作、人、软件
3. 评估模型