点击或拖拽改变大小

NetComplexServer 类

高性能的异步网络服务器类,适合搭建局域网聊天程序,消息推送程序
继承层次
SystemObject
  HslCommunication.Core.NetNetworkBase
    HslCommunication.Core.NetNetworkXBase
      HslCommunication.Core.NetNetworkServerBase
        HslCommunication.EnthernetNetComplexServer

命名空间:  HslCommunication.Enthernet
程序集:  HslCommunication (在 HslCommunication.dll 中) 版本:8.1.3.0 (8.1.3.0)
语法
public class NetComplexServer : NetworkServerBase

NetComplexServer 类型公开以下成员。

构造函数
  名称说明
公共方法NetComplexServer
实例化一个网络服务器类对象
Top
属性
  名称说明
公共属性ClientCount
所有在线客户端的数量
公共属性ConnectMax
所支持的同时在线客户端的最大数量,商用限制1000个,最小10个
公共属性IsSaveLogClientLineChange
获取或设置服务器是否记录客户端上下线信息
公共属性IsStarted
服务器引擎是否启动
(继承自 NetworkServerBase。)
公共属性代码示例LogNet
组件的日志工具,支持日志记录
(继承自 NetworkBase。)
公共属性Port
服务器的端口号
(继承自 NetworkServerBase。)
公共属性代码示例Token
网络类的身份令牌
(继承自 NetworkBase。)
公共属性UseSynchronousNet
是否使用同步的网络通讯
(继承自 NetworkBase。)
Top
方法
  名称说明
受保护的方法AsyncAcceptCallback
异步传入的连接申请请求
(继承自 NetworkServerBase。)
受保护的方法CheckRemoteToken
检查当前的头子节信息的令牌是否是正确的
(继承自 NetworkBase。)
受保护的方法CloseAction
关闭网络时的操作
(重写 NetworkServerBaseCloseAction.)
公共方法ConnectHslAlientClient
创建一个指定的异形客户端连接,使用Hsl协议来发送注册包
(继承自 NetworkServerBase。)
受保护的方法代码示例CreateSocketAndConnect(IPEndPoint, Int32)
创建一个新的socket对象并连接到远程的地址
(继承自 NetworkBase。)
受保护的方法代码示例CreateSocketAndConnect(String, Int32)
创建一个新的socket对象并连接到远程的地址,默认超时时间为10秒钟
(继承自 NetworkBase。)
受保护的方法代码示例CreateSocketAndConnect(String, Int32, Int32)
创建一个新的socket对象并连接到远程的地址
(继承自 NetworkBase。)
受保护的方法DeleteFileByName
删除文件的操作
(继承自 NetworkXBase。)
公共方法Equals (继承自 Object。)
受保护的方法Finalize (继承自 Object。)
公共方法GetHashCode (继承自 Object。)
公共方法GetType (继承自 Object。)
受保护的方法HeadBytesReceiveCallback
指令头接收方法
(继承自 NetworkXBase。)
受保护的方法MemberwiseClone (继承自 Object。)
受保护的方法PreprocessFolderName
预处理文件夹的名称,除去文件夹名称最后一个'\',如果有的话
(继承自 NetworkXBase。)
受保护的方法ReadStream
读取流中的数据到缓存区
(继承自 NetworkBase。)
受保护的方法Receive
接收固定长度的字节数组
(继承自 NetworkBase。)
受保护的方法ReceiveAndCheckBytes
[自校验] 接收一条完整的同步数据,包含头子节和内容字节,基础的数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法ReceiveAsync
接收固定长度的字节数组
(继承自 NetworkBase。)
受保护的方法ReceiveByMessage
接收一条完整的 数据内容 -> Receive a complete data content
(继承自 NetworkBase。)
受保护的方法ReceiveBytesContentFromSocket(Socket)
[自校验] 从网络中接收一串字节数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法ReceiveBytesContentFromSocket(Socket, Int32)
[自校验] 从网络中接收一串字节数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法ReceiveFileFromSocket(Socket, Stream, ActionInt64, Int64)
[自校验] 从网络中接收一个文件,写入数据流,如果结果异常,则结束通讯,参数顺序文件名,文件大小,文件标识,上传人
(继承自 NetworkXBase。)
受保护的方法ReceiveFileFromSocket(Socket, String, ActionInt64, Int64)
[自校验] 从网络中接收一个文件,如果结果异常,则结束通讯
(继承自 NetworkXBase。)
受保护的方法ReceiveFileHeadFromSocket
[自校验] 从套接字中接收文件头信息
(继承自 NetworkXBase。)
受保护的方法ReceiveStringArrayContentFromSocket
[自校验] 从网络中接收一个字符串数组,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法ReceiveStringContentFromSocket
[自校验] 从网络中接收一个字符串数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法Send(Socket, Byte)
发送消息给套接字,直到完成的时候返回
(继承自 NetworkBase。)
公共方法Send(AppSession, NetHandle, Byte)
服务器端用于发送字节的方法
公共方法Send(AppSession, NetHandle, String)
服务器端用于数据发送文本的方法
受保护的方法SendAccountAndCheckReceive
[自校验] 直接发送字符串数组并确认对方接收完成数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
公共方法SendAllClients(NetHandle, Byte)
服务端用于发送所有数据到所有的客户端
公共方法SendAllClients(NetHandle, String)
服务端用于发送所有数据到所有的客户端
受保护的方法SendAsync
发送一个异步的数据信息,该方式在NET35里是不可用的。
(继承自 NetworkBase。)
受保护的方法SendBaseAndCheckReceive
[自校验] 发送字节数据并确认对方接收完成数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法SendBytesAndCheckReceive
[自校验] 发送字节数据并确认对方接收完成数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
公共方法SendClientByAlias(String, NetHandle, Byte)
根据客户端设置的别名进行发送消息
公共方法SendClientByAlias(String, NetHandle, String)
根据客户端设置的别名进行发送消息
受保护的方法SendFileAndCheckReceive(Socket, Stream, String, String, String, ActionInt64, Int64)
[自校验] 将流数据发送至套接字,具体发送细节将在继承类中实现,如果结果异常,则结束通讯
(继承自 NetworkXBase。)
受保护的方法SendFileAndCheckReceive(Socket, String, String, String, String, ActionInt64, Int64)
[自校验] 将文件数据发送至套接字,具体发送细节将在继承类中实现,如果结果异常,则结束通讯
(继承自 NetworkXBase。)
受保护的方法SendFileStreamToSocket
[自校验] 将文件数据发送至套接字,如果结果异常,则结束通讯
(继承自 NetworkXBase。)
受保护的方法SendStream
发送一个流的所有数据到网络套接字
(继承自 NetworkXBase。)
受保护的方法SendStringAndCheckReceive(Socket, Int32, String)
[自校验] 直接发送字符串数据并确认对方接收完成数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
受保护的方法SendStringAndCheckReceive(Socket, Int32, String)
[自校验] 直接发送字符串数组并确认对方接收完成数据,如果结果异常,则结束通讯
(继承自 NetworkBase。)
公共方法ServerClose
关闭服务器的引擎
(继承自 NetworkServerBase。)
公共方法ServerStart
使用已经配置好的端口启动服务器的引擎
(继承自 NetworkServerBase。)
公共方法ServerStart(Int32)
启动服务器的引擎
(继承自 NetworkServerBase。)
受保护的方法SocketAcceptExtraCheck
当客户端的socket登录的时候额外检查的信息
(继承自 NetworkServerBase。)
受保护的方法StartInitialization
初始化操作
(重写 NetworkServerBaseStartInitialization.)
受保护的方法ThreadPoolCheckTimeOut
检查网络套接字是否操作超时,需要对套接字进行封装
(继承自 NetworkBase。)
受保护的方法ThreadPoolLogin
当接收到了新的请求的时候执行的操作
(重写 NetworkServerBaseThreadPoolLogin(Socket, IPEndPoint).)
公共方法ToString
获取本对象的字符串表示形式
(重写 NetworkXBaseToString.)
受保护的方法WriteStream(Stream, Byte)
将缓冲区的数据写入到流里面去
(继承自 NetworkBase。)
受保护的方法WriteStream(Socket, Stream, Int64, ActionInt64, Int64, Boolean)
从套接字中接收所有的数据然后写入到流当中去
(继承自 NetworkXBase。)
Top
事件
  名称说明
公共事件AcceptByte
当接收到字节数据的时候,触发此事件
公共事件AcceptString
当接收到文本数据的时候,触发此事件
公共事件AllClientsStatusChange
客户端的上下限状态变更时触发,仅作为在线客户端识别
公共事件ClientOffline
当客户端下线的时候,触发此事件
公共事件ClientOnline
当客户端上线的时候,触发此事件
Top
字段
  名称说明
受保护的字段CoreSocket
通讯类的核心套接字
(继承自 NetworkBase。)
Top
备注
详细的使用说明,请参照博客http://www.cnblogs.com/dathlin/p/8097897.html
示例
此处贴上了Demo项目的服务器配置的示例代码
NetComplexServer示例
public partial class FormServer : Form
{
    public FormServer( )
    {
        InitializeComponent( );

    }

    private void FormServer_Load( object sender, EventArgs e )
    {
        textBox3.Text = Guid.Empty.ToString( );

        logNet = new HslCommunication.LogNet.LogNetDateTime( Application.StartupPath + "\\Logs", HslCommunication.LogNet.GenerateMode.ByEveryDay );
        logNet.BeforeSaveToFile += LogNet_BeforeSaveToFile;
    }


    #region Complex Server

    private ILogNet logNet = null;
    private NetComplexServer complexServer = null;

    private void ComplexServerStart(int port)
    {
        complexServer = new NetComplexServer( );
        complexServer.LogNet = logNet;
        complexServer.Token = new Guid( textBox3.Text );
        complexServer.AcceptString += ComplexServer_AcceptString;
        complexServer.AcceptByte += ComplexServer_AcceptByte;
        complexServer.ClientOnline += ComplexServer_ClientOnline;
        complexServer.ClientOffline += ComplexServer_ClientOffline;
        complexServer.AllClientsStatusChange += ComplexServer_AllClientsStatusChange;
        complexServer.ServerStart( port );
    }

    private void ComplexServer_AllClientsStatusChange( int count )
    {
        Invoke( new Action<int>( m =>
         {
             label11.Text = count.ToString( );
         } ), count );
    }

    private void ComplexServer_ClientOffline( HslCommunication.Core.Net.AppSession session, string reason )
    {
        // 下线触发
    }

    private void ComplexServer_ClientOnline( HslCommunication.Core.Net.AppSession session )
    {
        // 上线触发
    }

    private void ComplexServer_AcceptByte( HslCommunication.Core.Net.AppSession session, NetHandle handle, byte[] data )
    {
        // 接收字节数据,
        ShowTextInfo( $"[{session.IpEndPoint}] [{handle}] {HslCommunication.BasicFramework.SoftBasic.ByteToHexString(data)}" );

        // 也可以回发客户端信息,选择发送的session即可
    }

    private void ComplexServer_AcceptString( HslCommunication.Core.Net.AppSession session, NetHandle handle, string data )
    {
        // 接收字符串
        logNet.WriteInfo( $"[{session.IpEndPoint}] [{handle}] {data}" );

        // 举个例子,当handle==1时,回发一串信息
        // for example , when handle == 1. return text
        if(handle == 1)
        {
            complexServer.Send( session, handle, "This is test Text" );
        }
    }

    private void LogNet_BeforeSaveToFile( object sender, HslCommunication.LogNet.HslEventArgs e )
    {
        // 显示日志信息
        ShowTextInfo( e.HslMessage.ToString( ) );
    }



    #endregion

    private void ShowTextInfo(string text)
    {
        if(InvokeRequired)
        {
            Invoke( new Action<string>( ShowTextInfo ), text );
            return;
        }

        textBox2.AppendText( text + Environment.NewLine );
    }

    private void userButton1_Click( object sender, EventArgs e )
    {
        if(!int.TryParse(textBox1.Text,out int port))
        {
            MessageBox.Show( "端口号输入异常!" );
            return;
        }

        try
        {
            ComplexServerStart( port );
            userButton1.Enabled = false;
            panel1.Enabled = true;
        }
        catch(Exception ex)
        {
            HslCommunication.BasicFramework.SoftBasic.ShowExceptionMessage( ex );
        }
    }


    private void button1_Click( object sender, EventArgs e )
    {
        // 广播数据,此处其实也可以对指定的客户端进行广播数据,需要知道AppSession对象,通常的做法的建立一个房间号引擎,
        // 缓存登录到该房间号的AppSession对象,这样就可以实现针对这个房间号的客户端进行广播数据了。


        // Broadcast data, in fact, broadcast data can also be specified for the specified client, you need to know the AppSession object, 
        // the usual practice to create a room number engine, cache the AppSession object logged in to the room number, 
        // so that you can achieve this room number The client broadcasts data.


        // 数据发送
        NetHandle handle = new NetHandle( );
        if (textBox5.Text.IndexOf( '.' ) >= 0)
        {
            string[] values = textBox5.Text.Split( '.' );
            handle = new NetHandle( byte.Parse( values[0] ), byte.Parse( values[1] ), ushort.Parse( values[2] ) );
        }
        else
        {
            handle = int.Parse( textBox5.Text );
        }


        complexServer.SendAllClients( handle, textBox4.Text );
    }
}
参见