通信协议—WebSocket

news2025/1/23 18:10:41

一、WebSocket编程概念

1.1 什么是WebSocket

WebSocket 是一种全双工通信协议，允许在客户端（通常是浏览器）和服务器之间建立持久连接，以实现实时的双向通信。它是 HTML5 标准的一部分，相比传统的 HTTP 请求，WebSocket 提供了更低的延迟和更高的性能，特别适合于需要实时更新数据的应用程序，如在线聊天、实时监控、游戏等

1.2 WebSocket的基本使用步骤

1.2.1 ）服务器端
1.2.1.1）使用System.Net.WebSocket命名空间
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using System.Text;
1.2.1.2） 创建WebSocket服务器端点
public async Task HandleWebSocketConnection(HttpContext context)
{
    if (context.WebSockets.IsWebSocketRequest)
    {
        WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
        await EchoWebSocket(webSocket);
    }
    else
    {
        context.Response.StatusCode = 400;
    }
}
1.2.1.3）处理WebSocket消息
private async Task EchoWebSocket(WebSocket webSocket)
{
    var buffer = new byte[1024 * 4];
    WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    while (!result.CloseStatus.HasValue)
    {
        // 发送接收到的消息回客户端
        await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);
        // 继续接收下一条消息
        result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    }
    // 关闭 WebSocket 连接
    await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
}
1.2.1.4）启动服务器
public static async Task Main(string[] args)
{
    var webSocketServer = new WebSocketServer();
    await webSocketServer.Start();
}
1.2.2 ）客户端
1.2.2.1）使用System.Net.WebSocket.ClientWebSocket 命名空间
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using System.Text;
1.2.2.2）创建WebSocket客户端并连接到服务器
public async Task ConnectToWebSocketServer()
{
    using (var clientWebSocket = new ClientWebSocket())
    {
        Uri serverUri = new Uri("ws://localhost:8080/ws");
        await clientWebSocket.ConnectAsync(serverUri, CancellationToken.None);
        await SendAndReceiveData(clientWebSocket);
    }
}
1.2.2.3）发送和接收数据
private async Task SendAndReceiveData(ClientWebSocket clientWebSocket)
{
    var buffer = new byte[1024 * 4];
    string message = "Hello, WebSocket Server!";
    var sendBuffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message));
    await clientWebSocket.SendAsync(sendBuffer, WebSocketMessageType.Text, true, CancellationToken.None);

    WebSocketReceiveResult result = await clientWebSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    string receivedMessage = Encoding.UTF8.GetString(buffer, 0, result.Count);
    Console.WriteLine($"Received: {receivedMessage}");
}
1.2.2.4）启动客户端
public static async Task Main(string[] args)
{
    var webSocketClient = new WebSocketClient();
    await webSocketClient.ConnectToWebSocketServer();
}
1.2.3) 运行步骤

1.2.3.1）先启动服务器程序，服务器将开始监听请求。
1.2.3.2）再启动客户端程序，客户端会连接到服务器并发送一条消息。
1.2.3.3）服务器接收到消息后，打印消息并回复。
1.2.3.4）客户端接收到服务器的回复并打印。

1.3 完整代码示例

1.3.1）服务器端
using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using System.Text;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

namespace WebSocketServerExample
{
    public class WebSocketServer
    {
        private readonly IWebHost _webHost;

        public WebSocketServer()
        {
            _webHost = new WebHostBuilder()
              .UseKestrel()
              .ConfigureServices(services => services.AddRouting())
              .Configure(app =>
               {
                   app.UseWebSockets();
                   app.Use(async (context, next) =>
                   {
                       if (context.WebSockets.IsWebSocketRequest)
                       {
                           WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
                           await EchoWebSocket(webSocket);
                       }
                       else
                       {
                           context.Response.StatusCode = 400;
                       }
                   });
               })
              .Build();
        }

        public async Task Start()
        {
            await _webHost.StartAsync();
        }

        private async Task EchoWebSocket(WebSocket webSocket)
        {
            var buffer = new byte[1024 * 4];
            WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
            while (!result.CloseStatus.HasValue)
            {
                // 发送接收到的消息回客户端
                await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);
                // 继续接收下一条消息
                result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
            }
            // 关闭 WebSocket 连接
            await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
        }
    }

    class Program
    {
        static async Task Main(string[] args)
        {
            var webSocketServer = new WebSocketServer();
            await webSocketServer.Start();
        }
    }
}

// 代码解释
// 创建 WebSocket 服务器端点：
// app.UseWebSockets();：启用 WebSocket 中间件。
// context.WebSockets.IsWebSocketRequest：检查请求是否为 WebSocket 请求。
// context.WebSockets.AcceptWebSocketAsync()：接受 WebSocket 请求并创建 WebSocket 对象。

// 处理 WebSocket 消息：
// await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);：接收客户端发送的消息。
// await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);：将接收到的消息发送回客户端。
// await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);：当收到关闭请求时，关闭连接。

 

1.3.2）客户端
using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using System.Text;

namespace WebSocketClientExample
{
    public class WebSocketClient
    {
        public async Task ConnectToWebSocketServer()
        {
            using (var clientWebSocket = new ClientWebSocket())
            {
                Uri serverUri = new Uri("ws://localhost:8080/ws");
                await clientWebSocket.ConnectAsync(serverUri, CancellationToken.None);
                await SendAndReceiveData(clientWebSocket);
            }
        }

        private async Task SendAndReceiveData(ClientWebSocket clientWebSocket)
        {
            var buffer = new byte[1024 * 4];
            string message = "Hello, WebSocket Server!";
            var sendBuffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message));
            await clientWebSocket.SendAsync(sendBuffer, WebSocketMessageType.Text, true, CancellationToken.None);

            WebSocketReceiveResult result = await clientWebSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
            string receivedMessage = Encoding.UTF8.GetString(buffer, 0, result.Count);
            Console.WriteLine($"Received: {receivedMessage}");
        }
    }

    class Program
    {
        static async Task Main(string[] args)
        {
            var webSocketClient = new WebSocketClient();
            await webSocketClient.ConnectToWebSocketServer();
        }
    }
}

// 代码解释
// 创建 WebSocket 客户端并连接到服务器：
// new ClientWebSocket()：创建 WebSocket 客户端对象。
// clientWebSocket.ConnectAsync(serverUri, CancellationToken.None);：连接到服务器。

发送和接收数据：
// await clientWebSocket.SendAsync(sendBuffer, WebSocketMessageType.Text, true, CancellationToken.None);：向服务器发送消息。
// await clientWebSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);：接收服务器的消息。

1.4 注意事项

1.4.1）端口号和URI : 确保服务器和客户端使用相同的端口号和URI路径

1.4.2）异常处理 ：在实际应用中，需要添加适当的异常处理代码，例如处理连接失败、接收或发送消息时的异常等

1.4.3）多客户端处理 ：上述服务器端代码仅处理一个客户端，对于多客户端场景，需要使用更复杂的逻辑，例如使用  ConcurrentDictionary  来管理多个客户端连接

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2281035.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

算法刷题笔记——图论篇

算法刷题笔记——图论篇

这里写目录标题 理论基础图的基本概念图的种类度 连通性连通图强连通图连通分量强连通分量 图的构造邻接矩阵邻接表 图的遍历方式 深度优先搜索理论基础dfs 与 bfs 区别dfs 搜索过程深搜三部曲所有可达路径广度优先搜索理论基础广搜的使用场景广搜的过程 岛屿数量孤岛的总面积沉…
阅读更多...
神经网络：什么是交叉熵？

神经网络：什么是交叉熵？

在机器学习和深度学习中&#xff0c;交叉熵&#xff08;Cross Entropy&#xff09; 是一种常见的损失函数&#xff0c;特别适用于分类问题。尽管这个术语听起来可能有点复杂&#xff0c;但通过一个类比&#xff0c;我们可以更直观地理解它的含义和作用。 类比场景&#xff1a;…
阅读更多...
数据结构——队列和栈（介绍、类型、Java手搓实现循环队列）

数据结构——队列和栈（介绍、类型、Java手搓实现循环队列）

我是一个计算机专业研0的学生卡蒙Camel&#x1f42b;&#x1f42b;&#x1f42b;&#xff08;刚保研&#xff09; 记录每天学习过程&#xff08;主要学习Java、python、人工智能&#xff09;&#xff0c;总结知识点&#xff08;内容来自&#xff1a;自我总结网上借鉴&#xff0…
阅读更多...
[Spring] OpenFeign的使用

[Spring] OpenFeign的使用

&#x1f338;个人主页:https://blog.csdn.net/2301_80050796?spm1000.2115.3001.5343 &#x1f3f5;️热门专栏: &#x1f9ca; Java基本语法(97平均质量分)https://blog.csdn.net/2301_80050796/category_12615970.html?spm1001.2014.3001.5482 &#x1f355; Collection与…
阅读更多...
LangChain + llamaFactory + Qwen2-7b-VL 构建本地RAG问答系统

LangChain + llamaFactory + Qwen2-7b-VL 构建本地RAG问答系统

单纯仅靠LLM会产生误导性的 “幻觉”&#xff0c;训练数据会过时&#xff0c;处理特定知识时效率不高&#xff0c;缺乏专业领域的深度洞察&#xff0c;同时在推理能力上也有所欠缺。 正是在这样的背景下&#xff0c;检索增强生成技术&#xff08;Retrieval-Augmented Generati…
阅读更多...
SpringCloud Gateway 集成 Sentinel 详解 及实现动态监听Nacos规则配置实时更新流控规则

SpringCloud Gateway 集成 Sentinel 详解 及实现动态监听Nacos规则配置实时更新流控规则

目录 一、前言二、版本选择和适配2.1、本文使用各组件版本2.2、官方推荐版本 三、部署sentinel-dashboard3.1、下载 sentinel-dashboard jar包3.2、启动 sentinel-dashboard 四、Gateway 集成 Sentinel实现控制台配置流控规则测试4.1、添加Gateway 集成 Sentinel 包4.2、添加 G…
阅读更多...
三相电变为家庭220V，市电火线和零线关系，为什么用三相电输送

三相电变为家庭220V，市电火线和零线关系，为什么用三相电输送

参考&#xff1a; https://www.zhihu.com/question/30555841/answer/85723024 上面是电力系统的主要组成&#xff0c;发电站发电后升压传输&#xff0c;然后到各大城市再降压使用。 我们看到电塔上都是三根线&#xff0c;那么因为整个过程都是三相电。 为什么用三相电&#xff…
阅读更多...
YOLOv8改进，YOLOv8检测头融合DSConv(动态蛇形卷积)，并添加小目标检测层（四头检测），适合目标检测、分割等

YOLOv8改进，YOLOv8检测头融合DSConv(动态蛇形卷积)，并添加小目标检测层（四头检测），适合目标检测、分割等

精确分割拓扑管状结构例如血管和道路，对各个领域至关重要，可确保下游任务的准确性和效率。然而，许多因素使任务变得复杂，包括细小脆弱的局部结构和复杂多变的全局形态。在这项工作中，注意到管状结构的特殊特征，并利用这一知识来引导 DSCNet 在三个阶段同时增强感知：特征…
阅读更多...
DNS未响应服务问题的解决（电脑连着网但浏览器访问不了网页）

DNS未响应服务问题的解决（电脑连着网但浏览器访问不了网页）

天行健&#xff0c;君子以自强不息&#xff1b;地势坤&#xff0c;君子以厚德载物。 每个人都有惰性&#xff0c;但不断学习是好好生活的根本&#xff0c;共勉&#xff01; 文章均为学习整理笔记&#xff0c;分享记录为主&#xff0c;如有错误请指正&#xff0c;共同学习进步。…
阅读更多...
鸿蒙Harmony json转对象（1）

鸿蒙Harmony json转对象（1）

案例1 运行代码如下 上图的运行结果如下: 附加1 Json_msg interface 案例2 import {JSON } from kit.ArkTS; export interface commonRes {status: numberreturnJSON: ESObject;time: string } export interface returnRes {uid: stringuserType: number; }Entry Component …
阅读更多...
Transformer详解：Attention机制原理

Transformer详解：Attention机制原理

前言 Hello&#xff0c;大家好&#xff0c;我是GISer Liu&#x1f601;&#xff0c;一名热爱AI技术的GIS开发者&#xff0c;本系列文章是作者参加DataWhale2025年1月份学习赛&#xff0c;旨在讲解Transformer模型的理论和实践。&#x1f632; 本文将详细探讨Attention机制的原理…
阅读更多...
SpringBoot为什么要禁止循环依赖?

SpringBoot为什么要禁止循环依赖?

大家好&#xff0c;我是锋哥。今天分享关于【SpringBoot为什么要禁止循环依赖?】面试题。希望对大家有帮助&#xff1b; SpringBoot为什么要禁止循环依赖? 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 Spring Boot 禁止循环依赖的原因与 Spring 框架本身的设计…
阅读更多...
利用Qt5.15.2编写Android程序时遇到的问题及解决方法

利用Qt5.15.2编写Android程序时遇到的问题及解决方法

文章目录 背景1.文件读写 背景 目前我用的是Qt5.15.2来编写Qt程序&#xff0c;环境的配置看我这篇文章【Qt5.15.2配置Android开发环境】 项目中的一些配置的截图&#xff1a; 1.文件读写 假如直接用 QFileDialog::getExistingDirectory来获取路径的话&#xff0c;会得到类…
阅读更多...
RV1126+FFMPEG推流项目源码

RV1126+FFMPEG推流项目源码

源码在我的gitee上面&#xff0c;感兴趣的可以自行了解 nullhttps://gitee.com/x-lan/rv126-ffmpeg-streaming-projecthttps://gitee.com/x-lan/rv126-ffmpeg-streaming-project
阅读更多...
三维扫描赋能文化：蔡司3D扫描仪让木质文化遗产焕发新生-沪敖3D

三维扫描赋能文化：蔡司3D扫描仪让木质文化遗产焕发新生-沪敖3D

挪威文化历史博物馆在其修复工作中融入现代3D扫描技术&#xff0c;让数百年的历史焕发新生。 文化历史博物馆的工作 文化历史博物馆是奥斯陆大学的一个院系。凭借其在文化历史管理、研究和传播方面的丰富专业知识&#xff0c;该博物馆被誉为挪威博物馆研究领域的领先机构。馆…
阅读更多...
2024年美赛C题评委文章及O奖论文解读 | AI工具如何影响数学建模？从评委和O奖论文出发-O奖论文做对了什么？

2024年美赛C题评委文章及O奖论文解读 | AI工具如何影响数学建模？从评委和O奖论文出发-O奖论文做对了什么？

模型假设仅仅是简单陈述吗&#xff1f;允许AI的使用是否降低了比赛难度&#xff1f;还在依赖机器学习的模型吗&#xff1f;处理题目的方法有哪些&#xff1f;O奖论文的优点在哪里&#xff1f; 本文调研了当年赛题的评委文章和O奖论文&#xff0c;这些问题都会在文章中一一解答…
阅读更多...
Text2Sql：开启自然语言与数据库交互新时代（30/30）

Text2Sql：开启自然语言与数据库交互新时代（30/30）

一、Text2Sql 简介 在当今数字化时代&#xff0c;数据处理和分析的需求日益增长。对于众多非技术专业人员而言&#xff0c;数据库操作的复杂性常常成为他们获取所需信息的障碍。而 Text2Sql 技术的出现&#xff0c;为这一问题提供了有效的解决方案。 Text2Sql&#xff0c;即文…
阅读更多...
初阶5 排序

初阶5 排序

本章重点 排序的概念常见排序的算法思想和实现排序算法的复杂度以及稳定性分析 1.排序的概念 排序: 所谓排序&#xff0c;就是使一串记录&#xff0c;按照其中的某个或某些关键字的大小&#xff0c;递增或递减的排列起来的操作。稳定性: 假定在待排序的记录序列中&#xff0…
阅读更多...
【优选算法】6----查找总价格为目标值的两个商品

【优选算法】6----查找总价格为目标值的两个商品

这道题相对于前寄到算法题较为容易~ 同样也是使用了双指针的算法哦~ ----------------------------------------begin-------------------------------------- 题目解析&#xff1a; 题目也是很简单地一句话&#xff0c;但是意图还是很明确~ 讲解算法原理&#xff1a; 同样的&…
阅读更多...
windows11关闭系统更新详细操作步骤

windows11关闭系统更新详细操作步骤

文章目录 1.打开注册表2.修改注册表内容2.1 新建文件2.2 修改值 3.修改设置 1.打开注册表 winR输入regedit(如下图所示) 2.修改注册表内容 进HKEY_LOCAL_MACHINE\SOFTWARE\Microsoft\WindowsUpdate\UX\Settings 2.1 新建文件 右侧界面右键即可 2.2 修改值 重命名为如下…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023