c#Socket服务器与客户端的开发(2)
上一篇文章我们使用原生的socket分别实现了服务器和客户端,
本篇文章使用SuperSocket来开发实现服务器,
之前也介绍了SuperSocket是一个轻量级, 跨平台而且可扩展的 .Net/Mono Socket 服务器程序框架。你无须了解如何使用 Socket, 如何维护 Socket 连接和 Socket 如何工作,但是你却可以使用 SuperSocket 很容易的开发出一款 Socket 服务器端软件,例如游戏服务器,GPS 服务器, 工业控制服务和数据采集服务器等等。
接下来开始我们的开发,首先我们需要安装SuperSocket相关程序包,我们新建一个项目开发SuperSocket服务器
然后打开NuGet程序包管理器,搜索SuperSocket ,下载安装SuperSocket和SuperSocket.Engine
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; using System.Net.Sockets; using System.Net; using System.Threading; using SuperSocket; using SuperSocket.SocketBase; using SuperSocket.SocketBase.Protocol; namespace SuperSocket { public partial class SuperSocketServer : Form { public SuperSocketServer() { InitializeComponent(); } private void SuperSocketServer_Load(object sender, EventArgs e) { //txt_ip.Text = "127.0.0.1"; txt_port.Text = "3333"; } //AppServer 代表了监听客户端连接,承载TCP连接的服务器实例。理想情况下,我们可以通过AppServer实例获取任何你想要的客户端连接,服务器级别的操作和逻辑应该定义在此类之中。 AppServer appServer; //缓冲字节数组 byte[] buffer = new byte[2048]; string ipAddress_Connect; string ipAddress_Close; string ipAddress_Receive; //存储session和对应ip端口号的泛型集合 Dictionary<string, AppSession> sessionList = new Dictionary<string, AppSession>(); enum OperateType { Add = 1, //添加 Remove = 2 //移除 } /// <summary> /// 开启服务 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_StartListen_Click(object sender, EventArgs e) { appServer = new AppServer(); if (!appServer.Setup(int.Parse(txt_port.Text))) { SetMessage("Failed to Setup"); return; } if (!appServer.Start()) { SetMessage("Failed to Start"); return; } else { SetMessage("开启监听"); } //SuperSocket自定义了三个事件 ,连接事件,接收事件,关闭事件 appServer.NewSessionConnected += appServer_NewSessionConnected; appServer.NewRequestReceived += appServer_NewRequestReceived; appServer.SessionClosed += appServer_SessionClosed; } /// <summary> /// 接收连接 /// </summary> /// <param name="session"></param> void appServer_NewSessionConnected(AppSession session) { //有新连接的时候,添加记录 session.LocalEndPoint属性获取当前session的ip和端口号 //AppSession 代表一个和客户端的逻辑连接,基于连接的操作应该定于在该类之中。你可以用该类的实例发送数据到客户端,接收客户端发送的数据或者关闭连接。 //获取远程客户端的ip端口号 ipAddress_Connect = session.RemoteEndPoint.ToString(); ComboboxHandle(ipAddress_Connect, OperateType.Add); sessionList.Add(ipAddress_Connect, session); SetMessage(ipAddress_Connect + "已连接!"); } /// <summary> /// 接收数据 /// </summary> /// <param name="session"></param> /// <param name="requestInfo"></param> void appServer_NewRequestReceived(AppSession session, StringRequestInfo requestInfo) { //requestInfo.Key 是请求的命令行用空格分隔开的第一部分 //requestInfo.Parameters 是用空格分隔开的其余部分 //requestInfo.Body 是出了请求头之外的所有内容 ipAddress_Receive = session.RemoteEndPoint.ToString(); SetMessage("收到" + ipAddress_Receive + "数据: "+requestInfo.Key +" "+ requestInfo.Body); } /// <summary> /// 关闭连接 /// </summary> /// <param name="session"></param> /// <param name="value"></param> void appServer_SessionClosed(AppSession session, SocketBase.CloseReason value) { ipAddress_Close = session.RemoteEndPoint.ToString(); ComboboxHandle(ipAddress_Close, OperateType.Remove); sessionList.Remove(ipAddress_Close); SetMessage(ipAddress_Close + "已关闭连接!"); } /// <summary> /// 发送数据 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_send_Click(object sender, EventArgs e) { //从客户端列获取想要发送数据的客户端的ip和端口号,然后从sessionList中获取对应session然后调用send()发送数据 if (cmb_socketlist.Items.Count != 0) { if (cmb_socketlist.SelectedItem == null) { MessageBox.Show("请选择一个客户端发送数据!"); return; } else { sessionList[cmb_socketlist.SelectedItem.ToString()].Send(txt_send.Text); } } else { SetMessage("当前没有正在连接的客户端!"); } txt_send.Clear(); } /// <summary> /// 添加信息 /// </summary> /// <param name="str"></param> private void SetMessage(string str) { richTextBox1.Invoke(new Action(() => { richTextBox1.AppendText(str + "\r\n"); })); } /// <summary> /// combobox操作 /// </summary> /// <param name="ipAddress"></param> /// <param name="operateType">add 添加项/remove 移除项</param> private void ComboboxHandle(string ipAddress, OperateType operateType) { if (operateType == OperateType.Add) { cmb_socketlist.Invoke(new Action(() => { cmb_socketlist.Items.Add(ipAddress); })); } if (operateType == OperateType.Remove) { cmb_socketlist.Invoke(new Action(() => { cmb_socketlist.Items.Remove(ipAddress); })); } } } }View Code 先挂上官方说明文档 http://docs.supersocket.net/v1-6/zh-CN
这里说明几点:
(1)这里appServer_NewRequestReceived(AppSession session, StringRequestInfo requestInfo)方法中的StringRequestInfo
是包含请求信息的,
requestInfo.Key 是请求的命令行用空格分隔开的第一部分
requestInfo.Parameters 是用空格分隔开的其余部分,用空格分割开的字符串数组
requestInfo.Body 是出了请求头之外的所有内容,是一个字符串
(2)这里requestInfo是客户端发送过来 严格按照 请求头 请求参数 请求参数 请求参数 \r\n 的格式发送, 空格隔开的第一部分是请求头,后边用空格分割后组成的数据就是请求参数
而且必须是以回车换行结尾 SuperSocket才能正确接收;
(3)这里请求头和请求参数用什么分割是可以自定义;我们可以自定义AppServer类,继承APPServer类,然后使用下面的代码扩展命令行协议
比如用":"分割请求头和请求参数,用","分隔请求参数.
public class YourServer : AppServer<YourSession> { public YourServer() : base(new CommandLineReceiveFilterFactory(Encoding.Default, new BasicRequestInfoParser(":", ","))) { } }View Code
接下来我们开始测试,还是默认使用3333端口,开启监听,我们依旧是使用SocketTool工具创建三个客户端,一起访问服务器
服务器:
客户端
接下来三个客户端分别以"9100"为请求头,test为请求体给服务器发送数据,记住客户端发送数据一定以回车换行为结尾
客户端:
服务器:
接下里测试服务器给客户端,这里以服务器给端口为1083的客户端发送数据"aaaa"
从客户端列选择端口号为1083的客户端,在textbox输入aaaa 发送数据
服务器
客户端
接下里客户端关闭连接
服务器
到此,SuperSocket实现的服务器测试完美收官,其实SuperSocket的功能远不止于此,我也只是刚开始使用
待后续研究官方文档后什么新的发现在更新,告辞!
感谢客观阅读,拜谢(抱拳~)
两篇文章的源码
本来想上传GitHub的,毕竟这样显得专业一点,奈何初来乍到的,实在操作不了(留下了不懂英文的泪水),还是放云盘吧!
链接:https://pan.baidu.com/s/1zjCvkP2Ne9U3KR8vyBKhFw
提取码:gee7
- C# 异步TCP Socket聊天室(1服务器,N客户端)
- Unity C#作为客户端与C++服务器 传递结构体进行Socket通讯
- C# Socket简单例子(服务器与客户端通信)和客户端批运行
- C# Socket简单例子(服务器与客户端通信)
- 【C#】Socket客户端与服务器的简单通信
- C#使用Socket实现一个socket服务器与多个socket客户端通信
- C#和PHP Socket通信实例代码(服务器与客户端通信)
- C#开发网络服务器和客户端
- C# Socket TCP简单例子(服务器与客户端通信)
- C#(服务器)与Java(客户端)通过Socket传递对象(序列化 json)
- GCDAsyncSocket不通过服务器进行客户端间直接连接—iOS移动开发
- C# 异步TCP Socket聊天室(1服务器,N客户端)
- C#和PHP Socket通信实例代码(服务器与客户端通信)
- C# Socket简单例子(服务器与客户端通信)
- C# Socket异步编程,重启服务器,客户端连接不上?
- C#Socket服务器开发(Unity)
- C#编写socket客户端,服务器断开连接时客户端报异常
- C# Socket简单例子(服务器与客户端通信)
- C#和PHP Socket通信实例代码(服务器与客户端通信)
- C# Socket简单例子(服务器与多个客户端通信)