12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
ADADADADAD
建站问答 时间:2024-11-30 19:39:54
作者:文/会员上传
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
12-09
在C#中搭建WebSocket服务器的方法是通过使用WebSocket类和相关的命名空间来实现。以下是一个简单的例子:首先,确保你的项目引用了System.Net.WebSockets命名空间。创建一个Web
以下为本文的正文内容,内容仅供参考!本站为公益性网站,复制本文以及下载DOC文档全部免费。
在C#中搭建WebSocket服务器的方法是通过使用WebSocket类和相关的命名空间来实现。
以下是一个简单的例子:
首先,确保你的项目引用了System.Net.WebSockets命名空间。
创建一个WebSocket服务器端的类,并在其中初始化WebSocket对象。例如:
using System;using System.Net;using System.Net.WebSockets;using System.Threading;using System.Threading.Tasks;public class MyWebSocketServer{private HttpListener _httpListener;private CancellationTokenSource _cts;public MyWebSocketServer(string url){_httpListener = new HttpListener();_httpListener.Prefixes.Add(url);_cts = new CancellationTokenSource();}public async Task Start(){_httpListener.Start();Console.WriteLine("WebSocket server started.");while (!_cts.Token.IsCancellationRequested){HttpListenerContext context = await _httpListener.GetContextAsync();if (context.Request.IsWebSocketRequest){ProcessWebSocketRequest(context);}else{// Handle non-WebSocket requestcontext.Response.StatusCode = 400;context.Response.Close();}}}private async void ProcessWebSocketRequest(HttpListenerContext context){HttpListenerWebSocketContext webSocketContext = null;try{webSocketContext = await context.AcceptWebSocketAsync(subProtocol: null);Console.WriteLine("WebSocket connection established.");await HandleWebSocketConnection(webSocketContext.WebSocket);}catch (Exception ex){Console.WriteLine("WebSocket connection failed: " + ex.Message);if (webSocketContext != null){webSocketContext.WebSocket.CloseAsync(WebSocketCloseStatus.InternalServerError, "Internal Server Error", CancellationToken.None);}}}private async Task HandleWebSocketConnection(WebSocket webSocket){byte[] buffer = new byte[1024];WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);while (!result.CloseStatus.HasValue){// Handle received datastring receivedMessage = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);Console.WriteLine("Received: " + receivedMessage);// Echo the received message back to the clientawait webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), WebSocketMessageType.Text, true, CancellationToken.None);// Get next messageresult = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);}await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);Console.WriteLine("WebSocket connection closed.");}public void Stop(){_cts.Cancel();_httpListener.Stop();_httpListener.Close();}}
class Program{static async Task Main(string[] args){string url = "http://localhost:8080/";MyWebSocketServer server = new MyWebSocketServer(url);await server.Start();Console.WriteLine("Press any key to stop the server.");Console.ReadKey();server.Stop();}}
以上代码创建了一个简单的WebSocket服务器,监听指定的URL,并处理接收到的WebSocket连接和消息。你可以根据自己的需求进行修改和扩展。
11-20
11-19
11-20
11-20
11-20
11-19
11-20
11-20
11-19
11-20
11-19
11-19
11-19
11-19
11-19
11-19