SuperSocket实例

下载地址：https://files.cnblogs.com/files/xixixing/ConsoleApp.zip

建立控制台应用程序：ConsoleApp

MySession.cs

using SuperSocket.SocketBase; using SuperSocket.SocketBase.Protocol; using System; namespace ConsoleApp { /// <summary>
    /// 用来发送和接收客户端信息,一个客户端至关于一个session(会话)。 /// 自定义链接类MySession，继承AppSession，并传入到AppSession /// </summary>
    public class MySession : AppSession<MySession> { /// <summary>
        /// 新链接 /// </summary>
        //protected override void OnSessionStarted() //{ // this.Send("\r\nHello User"); //}

        /// <summary>
        /// 未知的请求 /// </summary>
        /// <param name="requestInfo"></param>
        protected override void HandleUnknownRequest(StringRequestInfo requestInfo) { //this.Send("\r\nUnknown Request");
 } /// <summary>
        /// 捕捉异常并输出 /// </summary>
        /// <param name="e"></param>
        protected override void HandleException(Exception e) { //this.Send("\r\nException: {0}", e.Message);
 } /// <summary>
        /// 链接关闭 /// </summary>
        /// <param name="reason"></param>
        protected override void OnSessionClosed(CloseReason reason) { base.OnSessionClosed(reason); } } }

MyServer.cs

using SuperSocket.SocketBase; using System; namespace ConsoleApp { /// <summary>
    /// 自定义服务器类MyServer，继承AppServer，并传入自定义链接类MySession /// </summary>
    public class MyServer : AppServer<MySession> { protected override void OnStarted() { base.OnStarted(); //Console.WriteLine("服务器已启动");
 } /// <summary>
        /// 输出新链接信息 /// </summary>
        /// <param name="session"></param>
        protected override void OnNewSessionConnected(MySession session) { base.OnNewSessionConnected(session); //输出客户端IP地址
            Console.Write("\r\n" + session.LocalEndPoint.Address.ToString() + ":链接"); } /// <summary>
        /// 输出断开链接信息 /// </summary>
        /// <param name="session"></param>
        /// <param name="reason"></param>
        protected override void OnSessionClosed(MySession session, CloseReason reason) { base.OnSessionClosed(session, reason); //输出客户端IP地址
            Console.Write("\r\n" + session.LocalEndPoint.Address.ToString() + ":断开链接"); } protected override void OnStopped() { base.OnStopped(); Console.WriteLine("服务器已中止"); } } }

Program.cs

using System; using SuperSocket.SocketBase; using SuperSocket.SocketEngine; namespace ConsoleApp { class Program { static void Main(string[] args) { var bootstrap = BootstrapFactory.CreateBootstrap(); if (!bootstrap.Initialize()) //启动SuperSocket
 { Console.WriteLine("初始化失败!"); Console.ReadKey(); return; } var result = bootstrap.Start(); Console.WriteLine("服务正在启动: {0}!", result); if (result == StartResult.Failed) { Console.WriteLine("服务启动失败!"); Console.ReadKey(); return; } Console.WriteLine("服务启动成功，请按'E'中止服务!"); while (Console.ReadKey().KeyChar != 'E') { Console.WriteLine(); continue; } //中止服务
 bootstrap.Stop(); Console.WriteLine("服务已中止!"); Console.ReadKey(); } } }

MyKey.cs，写了两个Key：HELLO、READY，响应的结果都是1234

using SuperSocket.SocketBase.Command; using SuperSocket.SocketBase.Protocol; namespace ConsoleApp { public class HELLO : CommandBase<MySession, StringRequestInfo> { /// <summary>
        /// 自定义执行命令方法，注意传入的变量session类型为MySession /// </summary>
        /// <param name="session"></param>
        /// <param name="requestInfo"></param>
        public override void ExecuteCommand(MySession session, StringRequestInfo requestInfo) { session.Send("1234"); } } public class READY : CommandBase<MySession, StringRequestInfo> { public override void ExecuteCommand(MySession session, StringRequestInfo requestInfo) { session.Send("1234"); } } }

App.config

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <!--log 日志记录-->
    <section name="log4net" type="System.Configuration.IgnoreSectionHandler"/>
    <!--SocketEngine-->
    <section name="superSocket" type="SuperSocket.SocketEngine.Configuration.SocketServiceConfig, SuperSocket.SocketEngine"/>
  </configSections>
  <!--服务信息描述，在window服务模式下的名称标识-->
  <appSettings>
    <add key="ServiceName" value="SupperSocketService"/>
    <add key="ServiceDescription" value="黄昏前黎明后的Socket程序"/>
  </appSettings>
  <!--SuperSocket服务配置信息 serverType是项目的服务，如我自定义的MyServer-->
  <!--name: 实例名称 textEncoding 编码方式"gb2312","utf-8" 默认是acii serverType: 实例运行的AppServer类型。逗号左边的是你自定义的server在项目中的位置,逗号右边是项目名 ip: 服务器ip port: 侦听端口-->
  <superSocket>
    <servers>
      <server name="ConsoleApp" textEncoding="gb2312" serverType="ConsoleApp.MyServer,ConsoleApp" ip="Any" port="2000">
        <!--ip="192.168.0.40"-->
      </server>
    </servers>
  </superSocket>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
  </startup>
</configuration>