授权协议 GPL
开发语言 C# .NET
操作系统 跨平台
软件类型 开源软件
开源组织
地区 国产
投 递 者 bouyeijiang
适用人群 未知
收录时间 2017-07-30

软件简介

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 指数为
超过 的项目

评论 (6)

加载中
bouyeijiang软件作者
项目有例子
2020/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();
2020/02/12 23:40
回复
举报
作者在吗,这个项目能否出一个在线教程文档什么的
2017/12/14 10:52
回复
举报
如何确定发送数据的有效性的。
2017/08/19 09:53
回复
举报
bouyeijiang软件作者
打分: 推荐
使用简单,性能高效,高并发
2017/08/09 20:48
回复
举报
请问大神有关此开源是否有相关教程?
2020/09/03 16:43
回复
举报
更多评论
2019/06/23 23:07

Bouyei.NetFactory 1.3.4 bug 修复

Bouyei.NetFactory 是简单、易用、高效性能的通信库,支持 tcp、udp、websocket 和协议包定义。 1.3.4 版本更新如下: 修复 udp 问题并提升服务端模块稳定性。 修复和优化 WebSocket 在 centos 的 bug。 优化并修改其他部分代码可能导致的问题。 完善同学们提到的各种问题。

0
2
2019/02/01 00:17

Bouyei.NetFactory 支持 websocket

高性能TCP、UDP通信服务客户端库 1、修复服务端可能的异常崩溃问题。 2、增加WebSocket服务端和客户端支持。 3、调整接口接收事件支持直接返回字符串。 4、修改接收数据事件方式使用偏移量缓冲区。

0
1
2018/03/28 21:46

Socket 通信库 Bouyei.NetFactory 升级支持 .net core

c# 高性能大并发 socket 异步、同步通信库,建立独立的发送缓冲池和接收缓冲池解决发送和接收不断分配缓冲区问题,主要功能模块: 支持.net core和.net framework 。 tcp客户端和服务端,客户端分为同步和异步通信连接; udp客户端服务端,客户端分为同步和异步通信连接; 数据包通信协议独立模块,帮助使用者提供数据包格式定制。 数据包解析独立模块; 客户端连接管理池模块; 升级内容: 修改接口参数方式。 项目支持.net co...

2
13
发表了资讯
2017/10/17 21:53

Bouyei.NetFactory 稳定升级优化

.net 高性能socket异步通信库,提供服务端和客户端异步、同步通信模块,高性能数据包协议模块、客户端连接管理池模块、数据包解析模块等。 更新内容: 1、优化锁机制,实现原子锁自动释放。 2、优化同步发送和接收方法。 3、优化接口方法提供。 4、优化发送缓冲区等待机制 5、项目由原来Bouyei.NetProviderFactory名称简化为Bouyei.NetFactory Install-Package Bouyei.NetFactory -Version 1.2.6497.27420...

1
10
发表了资讯
2017/09/10 19:28

NetProviderFactory 高性能异步通信库升级

.net 高性能socket异步通信库,提供服务端和客户端异步、同步通信模块,高性能数据包协议模块、客户端连接管理池模块、数据包解析模块等。 更新和修复内容: 1、新增协议解析独立模块; 2、新增连接池管理独立模块; 3、优化和修复数据包协议模块; 4、修复连接断开事件不触发问题,修改为异步断开操作; 5、优化发送大块数据自动分片发送; 6、修改已知bug并增强稳定性; 7、修复其他小bug问题等等......

0
10
发表了资讯
2017/08/24 19:19

C# 高并发通信库 NetProviderFactory 发布更新

.net csharp 高性能大并发 socket 异步、同步通信库,建立独立的发送缓冲池和接收缓冲池解决发送和接收不断分配缓冲区问题。 更新内容: 1、增加协议模块Protocols; 2、修改udp通信和缓冲区bug; 3、增强稳定和其他优化; 4、增加同步通信功能; 通信协议数据包例子:  INetProtocolProvider protocolProvider = NetProtocolProvider.CreateNetProtocolProvider();             //数据内容打包成字节     ...

0
20
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表于服务端专区
2017/06/25 00:13

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

https://gitee.com/bouyei/Bouyei.BdProto 终端连接平台鉴权通信应答数据包格式 PacketConvert pConvert = new PacketConvert(); string phone = "18212004771"; //终端连接鉴权平台回复通用应答 byte[] body = new REQ_PB_8001().Serialized(new PB8001() { MessageId = JT808Cmd.RSP_0102, Serialnumber = 0, Result = 0 }); byte[] buffer = pConvert.Serialized(new PacketFrom() { msgBody = body, msgId = JT808Cmd.REQ_...

0
1
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
6 评论
103 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部