beetlex-io / fasthttpapi

a lightweight and high-performance http/websocket service component in the dotnet core platform that supports TLS.

Beetlex framework 👋

high performance socket tcp communication framework, support Unix domain Socket, TLS, HTTP, HTTPS, WebSocket, Gateway, RPC, Redis ... protocols , custom protocols and 1M connections solution

Package	Nuget version	Download
BeetleX(tcp component)
BeetleX.FastHttpApi(Http/Websocket server component)
BeetleX.Redis(Redis client component)
BeetleX.Http.Clients(Http/Websocket client component)
XRPC(Remote interface invoke)
MQTT(MQTT Server)

BeetleX's tcp, http, websocket, xprc, web, vue ... samples

Web Framework Benchmarks Round 20 in the top 10

fasthttpapi's Issues

Counter.Next()方法存在线程安全问题

Counter用于获取组件的统计信息，Next()方法存在线程安全问题，有可能导致调用这方法获取组件信息返回出现
collection was modified异常

捕获websocket 客户端掉线

通过HttpDisconnect事件可以捕获websocket 客户端掉线，判断HttpToken.WebSocket

  mApiServer.HttpDisconnect += (o, e) =>
            {
                HttpToken httpToken = (HttpToken)e.Session.Tag;
                if(httpToken.WebSocket)
                {

                }
}

为什么这个benchmark里beetlex排名比aspcore差这么多?

https://www.techempower.com/benchmarks/#section=test&runid=2681edff-2c12-42fe-a5a3-1597b89d36ef&hw=ph&test=plaintext

一个POST访问的参数问题

开发前端时遇以一个怪问题，后端一个服务接口用的FastHttpApi，平时调用都正常，postman访问几百次都正常，在某个时间用浏览器开发调试前端时调用这个服务接口后，POST 方式提交数据 IHttpContext.Data为空，只要出现一次后，再用各种工具重复调用接口数据都是空，只有重启服务后，恢复正常。后面又可能随机再次出现。进一步确认的是IHttpContext.Data的值是有的，是在某种情况下
string result;
context.Data.TryGetString(this.Name, out result);
return result; 这段取值 为空

执行 server.SendToWebSocket(data) 内存飙升

用FS的websocket，执行了
mApiServer.SendToWebSocket(data);
这一句后，内存从150M瞬间飙升到550M。

文件切片上传问题

用https://github.com/moxiecode/plupload 做文件切片上传时，服务端会切片解析不全的问题。出现的是有规律的。
服务端代码大概如下
[Post]
[MultiDataConvert]
public object UploadFile(string name, int chunk, int chunks,int offset,string originalname, IHttpContext context)
{
//Console.WriteLine($"--------------------- {name} chunk {chunk} chunks {chunks} ");

        if (context.Request.Files.Count==0)
        {
            Console.WriteLine("Files count ===0");
        }
        if (chunk==3)
        {

        }
        foreach (var file in context.Request.Files)
        {
            using (System.IO.Stream stream = System.IO.File.Open(name, System.IO.FileMode.OpenOrCreate, System.IO.FileAccess.ReadWrite))
            {
                stream.Seek(stream.Length, System.IO.SeekOrigin.Begin);
          
                byte[] buf = new byte[file.Data.Length];
                file.Data.Read(buf,0,buf.Length);

                stream.Write(buf,0,buf.Length);
                stream.Flush();
                Console.WriteLine($"{name} chunk {chunk} chunks {chunks} file {file.Data.Length}");
            }
        }

        return $"{DateTime.Now} {name} {string.Join(",", (from fs in context.Request.Files select fs.FileName).ToArray())}";
    }

如何自定义IResult 谢谢

如何自定义IResult 谢谢

demo

System.TypeLoadException: 'Method 'Init' in type 'BeetleX.FastHttpApi.Admin._Admin' from assembly 'BeetleX.FastHttpApi.Admin, Version=0.7.6.0, Culture=neutral, PublicKeyToken=null' does not have an implementation.'

Standard 2.0在.net framework 4.6.1 GZIP异常

Standard 2.0在.net framework 4.6.1 GZIP处理数据为空。
https://developercommunity.visualstudio.com/content/problem/540565/netstandard-20-gzipstream-write-date-error-in-net.html
在httpconfig.json把相关文件类型配置到，不进行GZIP处理可暂时解决这一问题

 "NoGzipFiles": "jpg;jpeg;png;gif;png;ico;zip;rar;bmp",

当文件内容为空的时候，文件输出异常

当文件内容为空的时候，文件输出异常

有成功案例吗？

有成功的案例和大规模使用吗？

请问websocket能用jwtfilter的方式吗？

blog里介绍的是http get和http post的

返回自定义的JSON

组件默认返回的json附加了一些信息，如果需要返回自己的Json内容可以通过方法返回JsonResult对象

return new JsonResult($"hello {name}");

也可以在控制器上标记

    [Controller]
    [DefaultJsonResultFilter]
    public class Controller 
    {
    }

请问如果前后端分离，如何解决跨域的问题呢？

添加服务查看插件

Install-Package BeetleX.FastHttpApi.Admin -Version 0.8.0

加载插件并设置登陆信息

            mApiServer.Options.Manager = "admin";
            mApiServer.Options.ManagerPWD = "123456";
            mApiServer.Options.FileManager = true;
            mApiServer.Register(typeof(FastHttpApi.Admin.APIAssembly).Assembly);

访问地址

http://host:port/_admin/

默认DataFrame会用base64编码，请问怎么直接返回binary数据？

试着修改DataFrame.type == binary，body=binary data，但还是用base64编码了，base64不仅多了一步编解码，带宽也额外多占用1/3

有计划增加 TCP 支持吗？

有计划增加 TCP 支持吗？
虽然名字是带Http 但Http本身不是个好协议
所以问问

怎么限定Action是get或者post

`[Controller(BaseUrl = "/WxApp/PushMessage")]
public class WebController : IController
{
private BeetleX.FastHttpApi.HttpApiServer mServer;
[NotAction]
public void Init(BeetleX.FastHttpApi.HttpApiServer server)
{
mServer = server;
}

    public string Get()
    {
        return ("GET:"+DateTime.Now.ToString());
    }

    public string Post()
    {
        return("POST"+DateTime.Now.ToString());
    }
}`

如上代码,怎么实现 GET请求/WxApp/PushMessage输出GET+时间
POST请求/WxApp/PushMessage输出POST+时间

希望出一个依赖注入的DEMO

如何设置http请求的header呢

如何设置http请求的header呢

当body消息过长的时候响应413，而不是直接关闭连接

当body消息过长的时候响应413，而不是直接关闭连接

BeetleX版本和FastHttpApi 中的不一至

BeetleX代码不更新了么？

当Header值以':'开头的情况下存在解释Header name错误

当Header值以':'开头的情况下存在解释Header name错误

Action task

Action task

是不是可以支持websocket了？

出个JWT认证的示例就更好啦 API服务走起

出个JWT认证的示例就更好啦 API服务走起

限定Action是get或者Post提交

`[Controller(BaseUrl = "/WxApp/PushMessage")]
public class WebController : IController
{
private BeetleX.FastHttpApi.HttpApiServer mServer;
[NotAction]
public void Init(BeetleX.FastHttpApi.HttpApiServer server)
{
mServer = server;
}

    public string Get()
    {
        return ("GET:"+DateTime.Now.ToString());
    }

    public string Post()
    {
        return("POST"+DateTime.Now.ToString());
    }
}`

get 请求 /WxApp/PushMessage 调用get方法

Very good project, hope to continue to improve the documentation.

Very good project, hope to continue to improve the documentation.

请问有没有NET Standard的fast的版本吗，看了只有core的

请问有没有NET Standard的fast的版本吗，看了只有core的

linux中，客户端调用rpc，压测 QPS 很低 好像是有死锁问题，

异步web api中使用客户端调用异步http
在windows中响应还可以
但是在linux中 QPS很低，只有3或者4样子

DataFrame doesn't collect via GC

Hey! I'm making web socket server with broadcasting.
I have constant count of connections (for example 500, separate for room by 30 users). One user sends to the server message, server broadcast to another in the same room.
And after a stress test I'm looking up some way to resolve issue: GC doesn't collect DataFrame object. I tried to turn on Server GC but result still the same, DataFrame objects still grows. I tried to make debug field "false"...

请问Autofac如何接入

请问Autofac如何接入

静态资源打包路径小写问题

由于静态资源打包路径是小写，导致关闭UrlIgnoreCase后，无法正常访问原有路径资源

类 必须有空的构造不?

是否可以设置不以方法名做路由？

比如如下方法想以 ip:port/medias/10003形式的地址访问 而不是 ip:port/getmedias/10003，再就是{mediaid} 不能写成{media_id}，是否下划线在参数中是不允许使用的
[Get(Route = "{mediaid}")]
public object GetMedias(string mediaid)

Question about performance test

I saw some performance test reports in Readme, some of which made me wonder, so I did a performance test

Environment

Benchmark Tools: wrk
dotnet sdk version: 2.1.300
asp.net core version: 2.1

TestCode

FastHttpApi Code : https://github.com/IKende/FastHttpApi/tree/master/samples/HttpApiServer.JsonBody

ASP.NET Core Web Api Code:

 [HttpGet]
public IActionResult Get(string name)
{
    return new JsonResult( DateTime.Now + " hello " + name);
}

Benchmark Report

FastHttpApi

mac:FastHttpApi yangxiaodong$ wrk -t 4 -c 20 -d 10 http://localhost:9090/hello?name=word
Running 10s test @ http://localhost:9090/hello?name=word
  4 threads and 20 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency     7.43ms   42.43ms 476.30ms   97.51%
    Req/Sec     2.03k   763.60     3.93k    75.64%
  16388 requests in 10.01s, 3.69MB read
  Socket errors: connect 0, read 16388, write 0, timeout 0
Requests/sec:   1637.30
Transfer/sec:    377.35KB

Asp.Net Core web api

mac:WebApi yangxiaodong$ wrk -t 4 -c 20 -d 10 http://localhost:5000/api/values?name=word
Running 10s test @ http://localhost:5000/api/values?name=word
  4 threads and 20 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency     4.07ms   10.62ms 158.47ms   92.55%
    Req/Sec     4.33k   722.51    14.24k    82.79%
  172684 requests in 10.10s, 32.11MB read
Requests/sec:  17096.93
Transfer/sec:      3.18MB

FastHttpApi QPS : 1637
ASP.NET Core QPS: 17096

For the ASP.NET CORE test report in readme, I suspect you did not adjust the log level when you tested.

调整最大RPS限制异常的默认状态码

现有最大RPS限制异常的状态码是500，在网关统计中不好区分，进行调整。

数据参数定义

是否支持post这种参数格式 { "Data": { "StoryID": 0, "Order": 0 }, "Uid": "string", "Timestamp": 0, "Signature": "string", "Salt": "string" }

options问题

options问题
设置了options的表头后。
接口在无请求状态一段时间后，options貌似失效了。中间过程是1点到4点多中间是无数据请求。空置状态。然后4点多再次请求。提示的是 cors不支持跨域。疑似options失效。很费解。这。。。

serverGC提示问题

true

都设置了，但是还是提示[Warring] no serverGC mode,please enable serverGC mode!

Websocket如何处理原始数据

如果我想把websocket当作tcp一样来使用，应该怎么做？

client 能否支持带有证书 X509CertificateCollection 的请求

支持多个IP绑定

现在只支持单个IP或Any绑定，需要加入指定多个IP端口绑定

Controller基类如何实现

Controller基类如何实现
如：
方法加载前打开数据库，
方法结束后关闭数据库

返回值赋值

对于返回的json中的，Error,Code,ID如何赋值

Websocket 请求参数格式问题

https://github.com/IKende/FastHttpApi/blob/6de8b648cc80d4a6365fb6190643e693e4dc365b/src/ActionHandlerFactory.cs#L395-L400

客户端发送登录请求

匹配服务端Controller

    [Controller(BaseUrl = "/User/")]
    public class User
    {
        public object Login(string username, string password)
        {
            Console.WriteLine($"{username}, {password}");
            return new LoginResult
            {
                State = true,
                SessionId = Guid.NewGuid().ToString("N"),
                UserName = username
            };
        }
    }

报错无法找到_requestid项

请教下多个参数应该如何写JSON？

Controller异常错误类如何实现

翻遍文档，没查到Demo，求教

性能测试时，打印大量出错信息

[15:46:26] [Error] session [::1]:46079@3767 error send data completed SocketError Success!@object reference not set to an instance of an object.
at BeetleX.TcpServer.SendCompleted(SocketAsyncEventArgs e)
[15:46:26] [Error] session [::1]:46078@3766 error [::1]:46078 send data completed process handler error Object reference not set to an instance of an object.!@object reference not set to an instance of an object.
at BeetleX.FastHttpApi.HttpApiServer.SendCompleted(ISession session, SocketAsyncEventArgs e)
at BeetleX.TcpServer.SendCompleted(SocketAsyncEventArgs e)

Linux下使用https访问启动几分钟后就挂了

[08:15:32] [Error] session [::ffff:219.145.5.89]:10579@1 error [::ffff:219.145.5.89]:10579 create session ssl error Connection reset by peer@Connection reset by peer
at System.Net.Sockets.Socket.BeginSend(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags, AsyncCallback callback, Object state)
at BeetleX.Buffers.PipeStream.BeginWrite(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
at System.Threading.Tasks.TaskFactory1.FromAsyncTrim[TInstance,TArgs](TInstance thisRef, TArgs args, Func5 beginMethod, Func`3 endMethod)
at System.IO.Stream.BeginEndWriteAsync(Byte[] buffer, Int32 offset, Int32 count)

错误信息是这样的

看什么时候方便支持一下IOC等功能

 看什么时候支持这种依赖注入，以前很多项目可能就会无缝切换到FastHttpApi上面来
    /// <summary>
    ///     IoC 初始化
    /// </summary>
    /// <param name="services"></param>
    /// <returns></returns>
    private IServiceProvider InitIoC(IServiceCollection services)
    {
        // 数据库链接字符串
        services.Configure<AppSettings>(Configuration.GetSection("AppSettings"));

        services.AddScoped<IDatabaseContext, MySqlContext>();

        services.AddTransient<IUnitOfWork, UnitOfWork>();

}