public class MyRequestInfo : IRequestInfo{public MyRequestInfo(byte[] header, byte[] bodyBuffer){Key = ((header[0] * 256) + header[1]).ToString();Data = bodyBuffer;}/// <summary>/// 协议号对应自定义命令Name，会触摸自定义命令/// </summary>public string Key { get; set; }/// <summary>/// 正文字节码/// </summary>public byte[] Data { get; set; }/// <summary>/// 正文文本，大部分协议都不是这么玩的/// </summary>public string Body{get{return Encoding.UTF8.GetString(Data);}}}

    public class MyReceiveFilter : FixedHeaderReceiveFilter<MyRequestInfo>{/// +-------+---+-------------------------------+/// |request| l |                               |/// | name  | e |    request body               |/// |  (2)  | n |                               |/// |       |(2)|                               |/// +-------+---+-------------------------------+public MyReceiveFilter(): base(4){}protected override int GetBodyLengthFromHeader(byte[] header, int offset, int length){return (int)header[offset + 2] * 256 + (int)header[offset + 3];}protected override MyRequestInfo ResolveRequestInfo(ArraySegment<byte> header, byte[] bodyBuffer, int offset, int length){var body = bodyBuffer.Skip(offset).Take(length).ToArray();return new MyRequestInfo(header.Array, body);}}

    public class MySession : AppSession<MySession, MyRequestInfo>{public MySession(){}protected override void OnSessionStarted(){}protected override void OnInit(){base.OnInit();}protected override void HandleUnknownRequest(MyRequestInfo requestInfo){
}protected override void HandleException(Exception e){
}protected override void OnSessionClosed(CloseReason reason){base.OnSessionClosed(reason);}}

    public class MyServer : AppServer<MySession, MyRequestInfo>{/// <summary>/// 通过配置文件安装服务从这里启动/// </summary>public MyServer(): base(new DefaultReceiveFilterFactory<MyReceiveFilter, MyRequestInfo>()){this.NewSessionConnected += MyServer_NewSessionConnected;this.SessionClosed += MyServer_SessionClosed;}/// <summary>/// winform启动，不使用这里的事件/// </summary>public MyServer(SessionHandler<MySession> NewSessionConnected, SessionHandler<MySession, CloseReason> SessionClosed): base(new DefaultReceiveFilterFactory<MyReceiveFilter, MyRequestInfo>()){this.NewSessionConnected += NewSessionConnected;this.SessionClosed += SessionClosed;}protected override void OnStarted(){//启动成功LogHelper.WriteLog(string.Format("Socket启动成功：{0}:{1}", this.Config.Ip, this.Config.Port));}void MyServer_NewSessionConnected(MySession session){//连接成功
        }void MyServer_SessionClosed(MySession session, CloseReason value){}}

            var config = new SuperSocket.SocketBase.Config.ServerConfig(){Name = "SSServer",ServerTypeName = "SServer",ClearIdleSession= true, //60秒执行一次清理90秒没数据传送的连接ClearIdleSessionInterval = 60,IdleSessionTimeOut = 90,MaxRequestLength = 2048, //最大包长度Ip = "Any",Port = 18888,MaxConnectionNumber = 100000,};app = new MyServer(app_NewSessionConnected, app_SessionClosed);LogHelper.SetOnLog(new LogHelper.LogEvent((m) =>{txtAll.Text = string.Join(" ", m, "\r\n");txtAll.Select(txtAll.TextLength, 0);txtAll.ScrollToCaret();}));app.Setup(config);if (!app.Start()){LogHelper.WriteLog(string.Format("Socket {0}:{1}启动失败，请检查权限或端口是否被占用！", config.Ip, config.Port));}