Bouyei.NetFactory 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
Bouyei.NetFactory 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议: GPL
开发语言: C# .NET
操作系统: 跨平台
收录时间: 2017-07-30
提 交 者: bouyeijiang

c# 高性能大并发 socket 异步、同步通信库,建立独立的发送缓冲池和接收缓冲池解决发送和接收不断分配缓冲区问题,主要功能模块:

支持.net core和.net framework 。

tcp客户端和服务端,客户端分为同步和异步通信连接;

udp客户端服务端,客户端分为同步和异步通信连接;

数据包通信协议独立模块,帮助使用者提供数据包格式定制。

数据包解析独立模块;

客户端连接管理池模块;

测试:

简单测试结果单个连接实例收发10w个数据包程序内存消耗在4MB左右,每秒稳定传输256mb的数据量,峰值在512MB左右浮动,根据网络和网卡有所误差,请以实际环境为主,一切尽在 demo 中,例子:

 using NetProviderFactory;
    class Program
    {
        static void Main(string[] args)
        {
            int port = 13145;
            //服务端         
           INetServerProvider serverSocket =  NetServerProvider.CreateProvider();
            //直接返回缓冲区和接收到的偏移  
           serverSocket.ReceiveOffsetHanlder = new OnReceiveOffsetHandler((sToken, buffer, offset, cnt) =>
            {
                 Console.WriteLine("offset:from client[" + Encoding.UTF8.GetString(buffer,offset,cnt));
            });

            bool isOk=serverSocket.Start(port);
            if (isOk)
            {
                Console.WriteLine("已启动服务。。。");

                //客户端     
               NetClientProvider clientSocket =  NetClientProvider.CreateProvider();
                //异步接收数据例子
                clientSocket.ReceiveHanlder = new OnReceiveHandler((sToken, buffer) =>
                {
                    Console.WriteLine("client:from server[" + Encoding.UTF8.GetString(buffer));
                });
                //异步连接
               bool isOk= clientSocket.ConnectTo(port, "127.0.0.1");
                if(isOk){
                    clientSocket.Send(Encoding.UTF8.GetBytes("hello" + DateTime.Now));
                }

                //同步连接和发送接收数据例子
               if (clientSocket.ConnectSync(port, "127.0.0.1"))
               {
                clientSocket.SendSync(Encoding.UTF8.GetBytes("I'm client" + DateTime.Now), (recCnt, buffer) =>
                {
                    Console.WriteLine("client:from server[" + Encoding.UTF8.GetString(buffer, 0, recCnt));
                });
              }
            }
            Console.ReadKey();
        }
    }
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

Bouyei.NetFactory 的相关博客

北斗终端设备通信协议(JT/T808)

https://gitee.com/bouyei/Bouyei.BdProto 终端连接平台鉴权通信应答数据包格式 PacketConvert pConvert = new PacketConvert...

Bouyei.NetFactory 的相关问答

还没有任何问答,马上提问

评论 (6)

加载中
bouyeijiang软件作者
项目有例子
09/03 17:25
回复
举报
//异步socket通信,采用JSON数据包,可读可写,数据包不粘连 private void PacketSocketDemo() { Hashtable hs1 = new Hashtable(); Hashtable hs2 = new Hashtable(); try { //int pktCnt = 0; netServerProvider.ReceivedOffsetHandler = new OnReceivedSegmentHandler((SegmentToken session) => { try { bool isEn = netPacketProvider.SetBlocks(session.Data.buffer, session.Data.offset, session.Data.size); if (isEn == false) { ////Invoke(new MethodInvoker(delegate ////{ //// listBox1.Items.Add("队列异常!"); ////})); netPacketProvider.Clear();//清除 } List packets = netPacketProvider.GetBlocks();
02/12 23:40
回复
举报
作者在吗,这个项目能否出一个在线教程文档什么的
2017/12/14 10:52
回复
举报
如何确定发送数据的有效性的。
2017/08/19 09:53
回复
举报
bouyeijiang软件作者
打分: 推荐
使用简单,性能高效,高并发
2017/08/09 20:48
回复
举报
请问大神有关此开源是否有相关教程?
09/03 16:43
回复
举报
更多评论
6 评论
98 收藏
分享
返回顶部
顶部