C# 使用SuperSocket

1 usingSuperSocket.SocketBase;
2 usingSystem;
3 usingSystem.Text;
4 usingSuperSocket.SocketBase.Protocol;
5 
6 namespaceSuperSocketBlog
7 {
8     public class SocketSession : AppSession<SocketSession>
9 {
10         public override void Send(stringmessage)
11 {
12             Console.WriteLine("发送消息:" +message);
13             base.Send(message);
14 }
15 
16         protected override voidOnSessionStarted()
17 {
18             Console.WriteLine("Session已启动");
19             base.OnSessionStarted();
20 }
21 
22         protected override voidOnInit()
23 {
24             this.Charset = Encoding.GetEncoding("gb2312");
25             base.OnInit();
26 }
27 
28         protected override voidHandleUnknownRequest(StringRequestInfo requestInfo)
29 {
30             Console.WriteLine("遇到未知的请求");
31             base.HandleUnknownRequest(requestInfo);
32 }
33 }
34 }

1 usingSuperSocket.SocketBase;
2 usingSystem;
3 usingSuperSocket.SocketBase.Config;
4 
5 namespaceSuperSocketBlog
6 {
7     public class SocketServer : AppServer<SocketSession>
8 {
9         protected override boolSetup(IRootConfig rootConfig, IServerConfig config)
10 {
11             Console.WriteLine("正在准备配置文件");
12             return base.Setup(rootConfig, config);
13 }
14 
15         protected override voidOnStarted()
16 {
17             Console.WriteLine("服务已开始");
18             base.OnStarted();
19 }
20 
21         protected override voidOnStopped()
22 {
23             Console.WriteLine("服务已停止");
24             base.OnStopped();
25 }
26         protected override voidOnNewSessionConnected(SocketSession session)
27 {
28             Console.WriteLine("新的连接地址为" + session.LocalEndPoint.Address.ToString() + ",时间为" +DateTime.Now);
29             base.OnNewSessionConnected(session);
30 }
31 }
32 }

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="superSocket"type="SuperSocket.SocketEngine.Configuration.SocketServiceConfig, SuperSocket.SocketEngine" />
    <section name="log4net"type="log4net.Config.Log4NetConfigurationSectionHandler, log4net" />
  </configSections>
  <!--配置SocketServer路径-->
  <superSocket>
    <servers>
      <server name="MySocket"textEncoding="gb2312"serverType="SuperSocketBlog.SocketServer, SuperSocketBlog"ip="Any"port="2018"maxConnectionNumber="100">
      </server>
    </servers>
  </superSocket>
    <startup> 
        <supportedRuntime version="v4.0"sku=".NETFramework,Version=v4.5.2" />
    </startup>
</configuration>

1 usingSuperSocket.SocketBase.Command;
2 usingSuperSocket.SocketBase.Protocol;
3 usingSystem;
4 
5 namespaceSuperSocketBlog
6 {
7     public class Apply:CommandBase<SocketSession,StringRequestInfo>
8 {
9         public override voidExecuteCommand(SocketSession session, StringRequestInfo requestInfo)
10 {
11             //根据参数个数或者其他条件判断，来进行一些自己的操作
12             if (requestInfo.Parameters.Length==2)
13 {
14                 Console.WriteLine("调用成功");
15                 session.Send("已经成功接收到你的请求
");
16 }
17             else
18 {
19                 session.Send("参数不正确
");
20 }
21 }
22 }
23 }

1             #region 初始化Socket
2             IBootstrap bootstrap =BootstrapFactory.CreateBootstrap();
3             if (!bootstrap.Initialize())
4 {
5                 Console.WriteLine(DateTime.Now + ":Socket初始化失败
");
6                 return;
7 }
8 
9             var result =bootstrap.Start();
10             foreach (var server inbootstrap.AppServers)
11 {
12                 if (server.State ==ServerState.Running)
13 {
14                     Console.WriteLine(DateTime.Now + ":serverName为:" + server.Name + "Socket运行中
");
15 Console.Read();
16 }
17                 else
18 {
19                     Console.WriteLine(DateTime.Now + ":serverName为:" + server.Name + "Socket启动失败
");
20 }
21 }
22             #endregion