C#实现WebSocket服务端教程4.5中实现了对websocket的⽀持
在这⾥我使⽤的是4.0。因此需要对原本的socket发送的数据根据websocket的协议进⾏解析和打包。
u sing System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Threading;
using System.Net;
namespace WebSocketServer
{
class Program
{
static void Main(string[] args)
{
WebSocket socket = new WebSocket();
socket.start(8064);
}
}
}
u sing System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
namespace WebSocketServer
{
public class Session
{
private Socket _sockeclient;
private byte[] _buffer;
private string _ip;
private bool _isweb = false;
public Socket SockeClient
{
set { _sockeclient = value; }
get { return _sockeclient; }
}
public byte[] buffer
{
set { _buffer = value; }
get { return _buffer; }
}
public string IP
{
set { _ip = value; }
get { return _ip; }
}
public bool isWeb
{
set { _isweb = value; }
get { return _isweb; }
}
}
}
u sing System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Net.Sockets;
using System.Net;
using System.Text.RegularExpressions;
using System.Security.Cryptography;
namespace WebSocketServer
{
public class WebSocket
{
private Dictionary<string, Session> SessionPool = new Dictionary<string, Session>();
private Dictionary<string, string> MsgPool = new Dictionary<string, string>();
#region 启动WebSocket服务
/// <summary>
/// 启动WebSocket服务
/// </summary>
public void start(int port)
{
Socket SockeServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
SockeServer.Bind(new IPEndPoint(IPAddress.Any, port));
SockeServer.Listen(20);
SockeServer.BeginAccept(new AsyncCallback(Accept), SockeServer);
Console.WriteLine("服务已启动");
Console.WriteLine("按任意键关闭服务");
Console.ReadLine();
}
#endregion
#region 处理客户端连接请求
/// <summary>
/// 处理客户端连接请求
/// </summary>
/// <param name="result"></param>
private void Accept(IAsyncResult socket)
{
// 还原传⼊的原始套接字
Socket SockeServer = (Socket)socket.AsyncState;
// 在原始套接字上调⽤EndAccept⽅法，返回新的套接字
Socket SockeClient = SockeServer.EndAccept(socket);
byte[] buffer = new byte[4096];
try
{
//接收客户端的数据
SockeClient.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(Recieve), SockeClient);
//保存登录的客户端
Session session = new Session();
session.SockeClient = SockeClient;
session.IP = SockeClient.RemoteEndPoint.ToString();
{
if (SessionPool.ContainsKey(session.IP))
{
this.SessionPool.Remove(session.IP);
}
this.SessionPool.Add(session.IP, session);
}
//准备接受下⼀个客户端
SockeServer.BeginAccept(new AsyncCallback(Accept), SockeServer);
Console.WriteLine(string.Format("Client {0} connected", SockeClient.RemoteEndPoint));
}
catch (Exception ex)
{
Console.WriteLine("Error : " + ex.ToString());
}
}
#endregion
#region 处理接收的数据
/// <summary>
/// 处理接受的数据
/// </summary>
/// <param name="socket"></param>
private void Recieve(IAsyncResult socket)
{
Socket SockeClient = (Socket)socket.AsyncState;
string IP = SockeClient.RemoteEndPoint.ToString();
if (SockeClient == null || !SessionPool.ContainsKey(IP))
{
return;
}
try
{
int length = SockeClient.EndReceive(socket);
byte[] buffer = SessionPool[IP].buffer;
SockeClient.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(Recieve), SockeClient);
string msg = Encoding.UTF8.GetString(buffer, 0, length);
/
/ websocket建⽴连接的时候，除了TCP连接的三次握⼿，websocket协议中客户端与服务器想建⽴连接需要⼀次额外的握⼿动作
if (msg.Contains("Sec-WebSocket-Key"))
{
SockeClient.Send(PackageHandShakeData(buffer, length));
SessionPool[IP].isWeb = true;
return;
}
if (SessionPool[IP].isWeb)
{
msg = AnalyzeClientData(buffer, length);
}
byte[] msgBuffer = PackageServerData(msg);
foreach (Session se in SessionPool.Values)
{
se.SockeClient.Send(msgBuffer, msgBuffer.Length, SocketFlags.None);
}
}
catch
{
SockeClient.Disconnect(true);
Console.WriteLine("客户端 {0} 断开连接", IP);
SessionPool.Remove(IP);
}
}
#endregion
#region 客户端和服务端的响应
/*
* 客户端向服务器发送请求
*
* GET / HTTP/1.1
* Origin: localhost:1416
* Sec-WebSocket-Key: vDyPp55hT1PphRU5OAe2Wg==
* Connection: Upgrade
* Upgrade: Websocket
*Sec-WebSocket-Version: 13
* User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64; Trident/7.0; rv:11.0) like Gecko
* Host: localhost:8064
* DNT: 1
* Cache-Control: no-cache
* Cookie: DTRememberName=admin
*
* 服务器给出响应
*
* HTTP/1.1 101 Switching Protocols
* Upgrade: websocket
* Connection: Upgrade
* Sec-WebSocket-Accept: xsOSgr30aKL2GNZKNHKmeT1qYjA=
*
* 在请求中的“Sec-WebSocket-Key”是随机的，服务器端会⽤这些数据来构造出⼀个SHA-1的信息摘要。把“Sec-WebSocket-Key”加上⼀个魔幻字符串
* “258EAFA5-E914-47DA-95CA-C5AB0DC85B11”。使⽤ SHA-1 加密，之后进⾏ BASE-64编码，将结果做为 “Sec-WebSocket-Accept” 头的值，返回给客户端  */
#endregion
#region 打包请求连接数据
/// <summary>
/// 打包请求连接数据
/// </summary>
/// <param name="handShakeBytes"></param>writeline教程
/// <param name="length"></param>
/// <returns></returns>
private byte[] PackageHandShakeData(byte[] handShakeBytes, int length)
{
string handShakeText = Encoding.UTF8.GetString(handShakeBytes, 0, length);
string key = string.Empty;
Regex reg = new Regex(@"Sec\-WebSocket\-Key:(.*?)\r\n");
Match m = reg.Match(handShakeText);
if (m.Value != "")
{
key = Regex.Replace(m.Value, @"Sec\-WebSocket\-Key:(.*?)\r\n", "$1").Trim();
}
byte[] secKeyBytes = SHA1.Create().ComputeHash(Encoding.ASCII.GetBytes(key + "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"));
string secKey = Convert.ToBase64String(secKeyBytes);
var responseBuilder = new StringBuilder();
responseBuilder.Append("HTTP/1.1 101 Switching Protocols" + "\r\n");
responseBuilder.Append("Upgrade: websocket" + "\r\n");
responseBuilder.Append("Connection: Upgrade" + "\r\n");
responseBuilder.Append("Sec-WebSocket-Accept: " + secKey + "\r\n\r\n");
return Encoding.UTF8.GetBytes(responseBuilder.ToString());
}
#endregion
#region 处理接收的数据
/// <summary>
/// <param name="recBytes"></param>
/// <param name="length"></param>
/// <returns></returns>
private string AnalyzeClientData(byte[] recBytes, int length)
{
int start = 0;
// 如果有数据则⾄少包括3位
if (length < 2) return "";
// 判断是否为结束针
bool IsEof = (recBytes[start] >> 7) > 0;
// 暂不处理超过⼀帧的数据
if (!IsEof) return "";
start++;
// 是否包含掩码
bool hasMask = (recBytes[start] >> 7) > 0;
// 不包含掩码的暂不处理
if (!hasMask) return "";
// 获取数据长度
UInt64 mPackageLength = (UInt64)recBytes[start] & 0x7F;
start++;
// 存储4位掩码值
byte[] Masking_key = new byte[4];
// 存储数据
byte[] mDataPackage;
if (mPackageLength == 126)
{
// 等于126 随后的两个字节16位表⽰数据长度
mPackageLength = (UInt64)(recBytes[start] << 8 | recBytes[start + 1]);
start += 2;
}
if (mPackageLength == 127)
{
// 等于127 随后的⼋个字节64位表⽰数据长度
mPackageLength = (UInt64)(recBytes[start] << (8 * 7) | recBytes[start] << (8 * 6) | recBytes[start] << (8 * 5) | recBytes[start] << (8 * 4) | recBytes[start] << (8 * 3) | recBytes[start] << (8 * 2) | recBytes[start] << 8 | recBytes[start + 1]);
start += 8;
}
mDataPackage = new byte[mPackageLength];
for (UInt64 i = 0; i < mPackageLength; i++)
{
mDataPackage[i] = recBytes[i + (UInt64)start + 4];
}
Buffer.BlockCopy(recBytes, start, Masking_key, 0, 4);
for (UInt64 i = 0; i < mPackageLength; i++)
{
mDataPackage[i] = (byte)(mDataPackage[i] ^ Masking_key[i % 4]);
}
return Encoding.UTF8.GetString(mDataPackage);
}
#endregion
#region 发送数据
/
// <summary>
/// 把发送给客户端消息打包处理（拼接上谁什么时候发的什么消息）
/// </summary>
/// <returns>The data.</returns>
/// <param name="message">Message.</param>
private byte[] PackageServerData(string msg)
{
byte[] content = null;
byte[] temp = Encoding.UTF8.GetBytes(msg);
if (temp.Length < 126)
{
content = new byte[temp.Length + 2];
content[0] = 0x81;
content[1] = (byte)temp.Length;
Buffer.BlockCopy(temp, 0, content, 2, temp.Length);
}
else if (temp.Length < 0xFFFF)
{
content = new byte[temp.Length + 4];
content[0] = 0x81;
content[1] = 126;
content[2] = (byte)(temp.Length & 0xFF);
content[3] = (byte)(temp.Length >> 8 & 0xFF);
Buffer.BlockCopy(temp, 0, content, 4, temp.Length);
}
return content;
}
#endregion
}
}
补充知识：【TCP/IP】使⽤C#实现websocket服务端与客户端通信
⼀、websocket简介
websocket是⼀种在单个TCP连接上进⾏全双⼯通信的协议。
websocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在WebSocket API中，浏览器和服务器只需要完成⼀次握⼿，两者之间就直接可以创建持久性的连接，并进⾏双向数据传输。
⼆、背景
很多⽹站为了实现推送技术，所⽤的技术都是轮询。
轮询是在特定的时间间隔，由浏览器对客户端发出HTTP请求，然后由服务器返回最新的数据给客户端的浏览器。这种传统的模式带来很明显的缺点，即浏览器需要不断的向服务器发出请求，然后HTTP 请求可能包含较长的头部，其中真正有效的数据可能只是很⼩的⼀部分，显然这样会浪费很多的宽带等资源。
在这种情况下，HTML5定义了websocket协议，能更好的节省服务器资源和宽带，⽽且能够更实时地进⾏通讯。
三、优点
1、控制开销
创建连接后，服务器和客户端之间交换数据时，⽤于协议控制的数据包头部相对较⼩。
2、实时性更强
由于协议是全双⼯的，所以服务器可以随时主动给客户端下发数据。相对于HTTP请求需要等待客户端发起请求服务端才能响应，延迟明显更少。
3、保持连接状态
与HTTP不同的是，Websocket需要先创建连接，这就使得其成为⼀种有状态的协议，之后通信时可以省略部分状态信息。⽽HTTP请求可能需要在每个请求都携带状态信息（如⾝份认证等）。
4、更好的⼆进制⽀持
5、⽀持扩展和更好的实现压缩效果
四、原理
websocket同HTTP⼀样也是应⽤层的协议，但是它是⼀种双向通信协议，建⽴在TCP之上的。
连接过程（握⼿过程）
1、客户端、服务器建⽴TCP连接，三次握⼿。
这是通信的基础，传输控制层，若失败后续都不执⾏。
2、TCP连接成功后，客户端通过HTTP协议向服务器传送websocket⽀持的版本号信息。（开始前的HTTP握⼿）
3、服务器收到客户端的握⼿请求后，同样采⽤HTTP协议回馈数据。
4、当收到了连接成功的消息后，通过TCP通道进⾏传输通信。
五、websocket和socket的关系
socket其实并不是⼀个协议，⽽是为了⽅便使⽤TCP和UDP⽽抽象出来的⼀层，是位于应⽤层和传输控制层之间的⼀组接⼝。
socket是应⽤层与TCP/IP协议通信的中间软件抽象层，它是⼀组接⼝。在设计模式中，socket其实就是⼀个门⾯模式，它把复杂的TCP/IP协议隐藏在socket接⼝后⾯，对⽤户来说，⼀组简单的接⼝就是全部，让socket去组织数据，以符合指定的协议。
两台主机通信，必须通过socket连接，socket则利⽤TCP/IP协议建⽴TCP连接。TCP连接则更依靠于底层的IP协议，IP协议的连接则依赖于链路层等更低层次。
websocket则是⼀个典型的应⽤层协议。
六、使⽤C#实现websocket服务端与客户端通信
（⼀） SuperWebSocket实现服务端
1、创建窗⼝程序，WindowsFormsWebsocketServer
2、添加程序包
⼯具 -->Nuget包管理 -->管理解决⽅案的Nuget程序包 -->搜索 SuperWebSocket ，选择SuperWebSocketNETServer，点击右侧安装，等待安装完成，安装完成以后，项⽬会多出很多引⽤库，如下
3、代码实例
using SuperWebSocket;
using System;
using System.Windows.Forms;
namespace WindowsFormsWebsocketServer
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
websocketServer();
}
private void websocketServer()
{
Log("我是服务端");
WebSocketServer webSocketServer = new WebSocketServer();
webSocketServer.NewSessionConnected += WebSocketServer_NewSessionConnected;
webSocketServer.NewMessageReceived += WebSocketServer_NewMessageReceived;
webSocketServer.SessionClosed += WebSocketServer_SessionClosed;
if (!webSocketServer.Setup("127.0.0.1", 1234))
{
Log("设置服务监听失败！");
}
if (!webSocketServer.Start())
{
Log("启动服务监听失败！");
}
Log("启动服务监听成功！");
//webSocketServer.Dispose();
}
private void WebSocketServer_NewSessionConnected(WebSocketSession session)
{
Log("欢迎客户端：加⼊");
//SendToAll(session, msg);
}
private void WebSocketServer_NewMessageReceived(WebSocketSession session, string value)
{
Log("服务端收到客户端的数据 ==》"+value);
//SendToAll(session, value);
}
private void WebSocketServer_SessionClosed(WebSocketSession session, SuperSocket.SocketBase.CloseReason value)
{
Log("客户端：关闭，原因：");
//SendToAll(session, msg);
}
/// <summary>
/// ⼴播，同步推送消息给所有的客户端
/// </summary>
/// <param name="webSocketSession"></param>
/// <param name="msg"></param>
public static void SendToAll(WebSocketSession webSocketSession, string msg)
{
foreach (var item in webSocketSession.AppServer.GetAllSessions())
{
item.Send(msg);
}
}
private delegate void DoLog(string msg);
public void Log(string msg)
{
if (this.logReveal.InvokeRequired)
{
DoLog doLog = new DoLog(Log);
this.logReveal.Invoke(doLog, new object[] { msg });
}
else
{
if (this.logReveal.Items.Count > 20)
{
this.logReveal.Items.RemoveAt(0);
}
msg = DateTime.Now.ToLocalTime().ToString() + " " + msg;
this.logReveal.Items.Add(msg);
}
}
}
}
（⼆）WebSocket4Net实现客户端
1、创建窗⼝程序，WindowsFormsWebsocketClient
2、添加程序包
⼯具 -->Nuget包管理 -->管理解决⽅案的Nuget程序包 -->搜索 WebSocket4Net ，选择WebSocket4Net，点击右侧安装，等待安装完成，安装完成以后，项⽬会多出很多引⽤库，如下

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。