ywscr/spear

Spear轻量级微服务框架，高扩展性，目前已支持TCP、HTTP、WebSocket以及GRPC协议，采用Consul/Nacos作为服务注册与发现组件，TCP协议采用DotNetty底层实现，HTTP协议采用ASP.NET CORE MVC实现。

spear

Spear轻量级微服务框架，高扩展性，目前已支持TCP、HTTP协议，采用Consul作为服务注册与发现组件，TCP协议采用DotNetty底层实现，HTTP协议采用ASP.NET CORE MVC实现。

Package Name	NuGet	Downloads
Spear.ProxyGenerator
Spear.Core			Wiki
Spear.Codec.MessagePack
Spear.Codec.ProtoBuffer
Spear.Consul
Spear.Nacos
Spear.Protocol.Http
Spear.Protocol.Tcp
Spear.Protocol.WebSocket
Spear.Protocol.Grpc

Contracts

[ServiceRoute("test")] //自定义路由键
public interface ITestContract : ISpearService
{
    Task Notice(string name);
    Task<string> Get(string name);
}

Server

var services = new MicroBuilder();
//服务协议
var protocol = ServiceProtocol.Tcp;
services.AddMicroService(builder =>
{
    //服务端需指定编解码器和使用协议
    builder
        .AddJsonCoder()             //Json编解码
        //.AddMessagePackCodec()    //MessagePack
        //.AddProtoBufCodec()       //ProtoBuf
        .AddSession()
        //.AddNacos()
        .AddConsul("http://127.0.0.1:8500"); //Consul服务注册与发现
    switch (protocol)
    {
        case ServiceProtocol.Tcp:
            builder.AddTcpProtocol();       //TCP
            break;
        case ServiceProtocol.Http:
            builder.AddHttpProtocol();      //Http
            break;
        case ServiceProtocol.Ws:
            builder.AddWebSocketProtocol(); //WebSocket
            break;
        case ServiceProtocol.Grpc:
            builder.AddGrpcProtocol();      //GRpc
            break;
    }
});

services.AddTransient<ITestContract, TestService>();

var provider = services.BuildServiceProvider();

provider.UseMicroService(address =>
{
    address.Service = "192.168.1.xx";   //服务注册地址,需要保持与客户端的网络访问
    address.Host = "localhost";         //主机地址
    address.Port = 5001;                //端口地址
    address.Weight = 1.5;               //服务权重
    address.Gzip = true;                //是否启用GZip压缩
});

Client

var services = new MicroBuilder()
    .AddMicroClient(builder =>
    {
        //支持多编解码&多协议
        builder
            .AddJsonCodec()
            .AddMessagePackCodec()
            .AddProtoBufCodec()
            .AddHttpProtocol()          //Http
            .AddTcpProtocol()           //TCP
            .AddWebSocketProtocol()     //WebSocket
            .AddGrpcProtocol()          //GRpc
            .AddSession()
            //.AddNacos()
            .AddConsul("http://127.0.0.1:8500");
    });
var provider = services.BuildServiceProvider();
var proxy = provider.GetService<IProxyFactory>();
var service = proxy.Create<ITestContract>();

BenchMark

Protocol:Tcp,Codec:Json,Gzip:False

Protocol:Tcp,Codec:Json,Gzip:True

Protocol:Tcp,Codec:MessagePack,Gzip:True

Protocol:Tcp,Codec:ProtoBuf,Gzip:True

Protocol:Http,Codec:Json,Gzip:False

Protocol:Http,Codec:Json,Gzip:True

Protocol:Http,Codec:MessagePack,Gzip:True

Protocol:Http,Codec:ProtoBuf,Gzip:True

Protocol:WebSocket,Codec:Json,Gzip:False

Protocol:WebSocket,Codec:Json,Gzip:True

Protocol:WebSocket,Codec:MessagePack,Gzip:True

Protocol:WebSocket,Codec:ProtoBuf,Gzip:True

Protocol:GRpc