XiaoFeng.Net 3.1.5

XiaoFeng.Net

Nuget：XiaoFeng.Net

QQ群号	QQ群	公众号
748408911

源码： https://github.com/zhuovi/XiaoFeng.Net

教程： https://www.yuque.com/fayelf/xiaofeng

XiaoFeng网络库，封装了Socket客户端，服务端，根据当前库可轻松实现订阅，发布等功能。

XiaoFeng.Net

XiaoFeng.Net generator with XiaoFeng.Net.

Install

.NET CLI

$ dotnet add package XiaoFeng.Net --version 3.1.5

Package Manager

PM> Install-Package XiaoFeng.Net --Version 3.1.5

PackageReference

<PackageReference Include="XiaoFeng.Net" Version="3.1.5" />

Paket CLI

> paket add XiaoFeng.Net --version 3.1.5

Script & Interactive

> #r "nuget: XiaoFeng.Net, 3.1.5"

Cake

// Install XiaoFeng.Net as a Cake Addin
#addin nuget:?package=XiaoFeng.Net&version=3.1.5

// Install XiaoFeng.Net as a Cake Tool
#tool nuget:?package=XiaoFeng.Net&version=3.1.5

更新日志

2023-10-08 v3.1.5

1.修复SocketClient连接DNS时的bug;

2023-09-26 v 3.1.4

1.优化SocketClient中NetworkDelay最小值及最大值的判断;

2.优化SocketClient中连接host为IP的bug;

3.优化XiaoFeng.Net.WebSocketClient请求头;

4.优化网络客户端;

2023-08-30 v 3.1.3

1.优化网络延时时服务端接收websocket客户端时偶尔拒绝连接的bug

2.SocketServer,SocketClient增加NetworkDelay网络延时属性;

3.优化SocketServer中的AcceptTcpClient方法;

2023-08-29 v 3.1.2

1.优化SocketClient,在websocket客户端未解包的Bug;

2.优化SocketClient第一次连接只调用OnMessage事件未调用OnMessageByte事件的Bug;

3.SocketClient增加LastMessageTime最后通讯时间,ConnectedTime连接时间;

4.优化识别客户端是WebSocket还是Socket;

5.SocketClient连接方法增加返回类型;

2023-08-22 v 3.1.1

1.修复postman在ssl下,一直发送消息服务端不能收到的问题;

2023-08-22 v 3.1.0

1.增加WebSocketClient中属性WebSocketRequest为客户端请求信息;

2.WebSocketClient增加启动传参数据WebSocketRequestOptions;

3.优化Socket网络库注释;

4.修复SocketServer每次收到消息都发送一次新连接回调的bug;

2023-08-03 v 3.0.0

1.重新写Socket库,SocketServer,WebSocketServer,SocketClient,WebSocketClient;

XiaoFeng 类库包含库

XiaoFeng.Net Socket操作

服务端实例

//新建一个服务端,同时支持websocket,socket客户端连接
var server = new NetServer<ServerSession>(8088)
{
    //是否启用ping
    IsPing = true,
    //是否启用新行
    IsNewLine = true,
    //传输编码
    Encoding = System.Text.Encoding.UTF8,
    //认证 认证不过则直接断开
    SocketAuth = s =>
    {
        //判断 客户端是否符合认证,不符合则直接返回false即可
        return true;
    }
};
server.OnStart += (s, e) =>
{
    //服务端启动事件
    Console.WriteLine($"启动!-{DateTime.Now:yyyy-MM-dd HH:mm:ss.fffffff}");
};
server.OnNewConnection += (s, e) =>
{
    //客户端新连接事件
    Console.WriteLine($"新连接-{DateTime.Now:yyyy-MM-dd HH:mm:ss.fffffff}");
    //给当前客户端设置一个频道名  为后边按频道名发送作准备
    //一个客户端可以订阅多个频道
    //websocket可以从头里面获取标识
    //如果非websocket 可以从消息里设置频道消息
    if (s.Headers.IndexOf("Channel:a") > 0)
        s.AddChannel("a");
    else
        s.AddChannel("b");
};
server.OnDisconnected += (s, e) =>
{
    //客户端断开连接事件
    Console.WriteLine($"断开连接!-{DateTime.Now:yyyy-MM-dd HH:mm:ss.fffffff}");
};
server.OnMessage += (s, m, e) =>
{
    //接收消息事件
    if (m.IndexOf("Channel:a") > 0)
    {
        s.AddChannel("a");
        return;
    }
    else if (m.IndexOf("Channel:b") > 0)
    {
        s.AddChannel("b");
        return;
    }
    Console.WriteLine($"消息-{m}-{DateTime.Now:yyyy-MM-dd HH:mm:ss.fffffff}");
    //把当前消息发送到频道名为a的所有客户端
    server.Send("a", Encoding.UTF8.GetBytes("消息"));
    //回复当前客户端消息
    s.Send("消息");
    //发送消息给所有客户端
    server.Send("消息");
};
server.OnMessageByte += (session, message, e) =>
{
    //接收消息事件
    session.Send("回复客户端消息");
};
server.OnError += (s, e) =>
{
    //服务端出错事件
    Console.WriteLine($"出错-{e.Message}-{DateTime.Now:yyyy-MM-dd HH:mm:ss.fffffff}");
};
server.OnClientError += (session, e) =>
{
    //客户端出错事件
};
server.OnError += (session, e) =>
{
    //服务端出错事件
};
server.OnStop += (socket, e) =>
{
    //服务端停止事件
};
server.Start();
//添加黑名单
server.AddIpBlack("10.10.10.10");
//移除黑名单
server.RemoveIpBlack("10.10.10.10");
//清空黑名单
server.ClearIpBlack();
//断开所有客户端
server.ClearQueue();
//在线客户端列表 复制出来的
var clients = server.GetData();
//在线客户端列表 原列表
var clients1 = server.ConnectionSocketList;

客户端实例

var client = new XiaoFeng.Net.NetClient<XiaoFeng.Net.ClientSession>("127.0.0.1", 8888);
client.OnStart += (socket, e) =>
{
    //启动消息
};
client.OnClose += (socket,e)=>
{
    //关闭消息
};
client.OnDisconnected += (session,e)=>{
    //断开连接消息
};
client.OnError += (socket,e)=>
{
    //出错消息
};
client.OnMessageByte += (session,message,e)=>
{
//接收信息
};
//启动客户端
client.Start();

client.Send("发送消息");

client.Subscribe("订阅频道");
client.UnSubscribe("取消订阅频道");

作者介绍

• 网址 : http://www.fayelf.com
• QQ : 7092734
• EMail : jacky@fayelf.com