SuperSocket服务器架设(三)：在SuperSocket中自定义Command、AppServer和AppSession

1.      创建自定义类MySession，继承AppSession类并重写AppSession类的方法

注：一个AppSession对象对应一个连接

[csharp] view
plaincopyprint?

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using SuperSocket;
6. using SuperSocket.Common;
7. using SuperSocket.SocketBase;
8. using SuperSocket.SocketBase.Protocol;
9. namespace SuperSocketApp1
10. {
11. /// <summary>
12. /// 自定义连接类MySession，继承AppSession，并传入到AppSession
13. /// </summary>
14. public class MySession : AppSession<MySession>
15. {
16. /// <summary>
17. /// 新连接
18. /// </summary>
19. protected override void OnSessionStarted()
20. {

[csharp] view
plaincopyprint?

1. <span style="white-space:pre">  </span>    //输出客户端IP地址
2. Console.WriteLine(this.LocalEndPoint.Address.ToString());
3. this.Send("\n\rHello User");
4. }
5. /// <summary>
6. /// 未知的Command
7. /// </summary>
8. /// <param name="requestInfo"></param>
9. protected override void HandleUnknownRequest(StringRequestInfo requestInfo)
10. {
11. this.Send("\n\r未知的命令");
12. }
13. /// <summary>
14. /// 捕捉异常并输出
15. /// </summary>
16. /// <param name="e"></param>
17. protected override void HandleException(Exception e)
18. {
19. this.Send("\n\r异常: {0}", e.Message);
20. }
21. /// <summary>
22. /// 连接关闭
23. /// </summary>
24. /// <param name="reason"></param>
25. protected override void OnSessionClosed(CloseReason reason)
26. {
27. base.OnSessionClosed(reason);
28. }
29. }
30. }

2.      创建自定义类MyServer，继承AppServer类并重写AppServer类的方法

[csharp] view
plaincopyprint?

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using SuperSocket.SocketBase;
6. using SuperSocket.SocketBase.Config;
7. namespace SuperSocketApp1
8. {
9. /// <summary>
10. /// 自定义服务器类MyServer，继承AppServer，并传入自定义连接类MySession
11. /// </summary>
12. public class MyServer : AppServer<MySession>
13. {
14. protected override void OnStartup()
15. {
16. base.OnStartup();
17. Console.WriteLine("服务器已启动");
18. }
19. /// <summary>
20. /// 输出新连接信息
21. /// </summary>
22. /// <param name="session"></param>
23. protected override void OnNewSessionConnected(MySession session)
24. {
25. base.OnNewSessionConnected(session);

[csharp] view
plaincopyprint?

1. <span style="white-space:pre">  </span>    //输出客户端IP地址
2. Console.Write("\r\n" + session.LocalEndPoint.Address.ToString() + ":连接");
3. }
4. /// <summary>
5. /// 输出断开连接信息
6. /// </summary>
7. /// <param name="session"></param>
8. /// <param name="reason"></param>
9. protected override void OnSessionClosed(MySession session, CloseReason reason)
10. {
11. base.OnSessionClosed(session, reason);
12. <span style="font-family: monospace; white-space: pre;">    </span><span style="font-family: monospace; white-space: pre; background-color: rgb(240, 240, 240);">    //输出客户端IP地址</span>
13. Console.Write("\r\n" + session.LocalEndPoint.Address.ToString() + ":断开连接");
14. }
15. protected override void OnStopped()
16. {
17. base.OnStopped();
18. Console.WriteLine("服务器已停止");
19. }
20. }
21. }

3.      创建自定义命令HELLO类，继承CommandBase并重写ExecuteCommand方法

[csharp] view
plaincopyprint?

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using SuperSocket.SocketBase;
6. using SuperSocket.SocketBase.Command;
7. using SuperSocket.SocketBase.Protocol;
8. namespace SuperSocketApp1
9. {
10. /// <summary>
11. /// 自定义命令类HELLO，继承CommandBase，并传入自定义连接类MySession
12. /// </summary>
13. public class HELLO : CommandBase<MySession, StringRequestInfo>
14. {
15. /// <summary>
16. /// 自定义执行命令方法，注意传入的变量session类型为MySession
17. /// </summary>
18. /// <param name="session"></param>
19. /// <param name="requestInfo"></param>
20. public override void ExecuteCommand(MySession session, StringRequestInfo requestInfo)
21. {
22. session.Send("Hello World!");
23. }
24. }
25. }

4.      修改Main方法代码

[csharp] view
plaincopyprint?

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using SuperSocket;
6. using SuperSocket.Common;
7. using SuperSocket.SocketBase;
8. using SuperSocket.SocketEngine;
9. using SuperSocket.SocketBase.Protocol;
10. namespace SuperSocketApp1
11. {
12. class Program
13. {
14. static void Main(string[] args)
15. {
16. var appServer = new MyServer();
17. //服务器端口
18. int port = 2000;
19. //设置服务监听端口
20. if (!appServer.Setup(port))
21. {
22. Console.WriteLine("端口设置失败!");
23. Console.ReadKey();
24. return;
25. }
26. //启动服务
27. if (!appServer.Start())
28. {
29. Console.WriteLine("启动服务失败!");
30. Console.ReadKey();
31. return;
32. }
33. Console.WriteLine("启动服务成功，输入exit退出!");
34. while (true)
35. {
36. var str = Console.ReadLine();
37. if (str.ToLower().Equals("exit"))
38. {
39. break;
40. }
41. }
42. Console.WriteLine();
43. //停止服务
44. appServer.Stop();
45. Console.WriteLine("服务已停止，按任意键退出!");
46. Console.ReadKey();
47. }
48. }
49. }

5.      程序结构如图

6.      创建多服务器提供不同服务的方法：按照上面的过程，创建不同的AppServer 、AppSession子类、自定义命令，并在程序入口中启动。

7.      注意：

a) MyServer、自定义命令和MySession的访问权限必须设置为public

b) MyServer父类为AppServer<MySession>

c) MySession父类为AppSession<MySession>

d) HELLO父类为CommandBase<MySession,StringRequestInfo>，ExecueteCommand方法传入值类型分别为MySession和StringRequestInfo

e) 多服务器中需注意AppSession、AppServer、自定义命令中的AppSession不要搞错

//输出客户端IP地址