技术标签: c# websocket C# .net 异步操作 WebSocket
ClientWebSocket
这里用到的核心代码就是ClientWebSocket
类。提供用于连接到WebSocket服务的客户端。
csharp public sealed class ClientWebSocket : System.Net.WebSockets.WebSocket
属性 | 作用 |
---|---|
CloseStatus |
获取在ClientWebSocket实例上启动关闭握手的原因。 |
CloseStatusDescription |
获取对关闭ClientWebSocket实例的原因的描述。 |
Options |
获取ClientWebSocket实例的WebSocket选项。 |
State |
获取ClientWebSocket实例的WebSocket状态。 |
SubProtocol |
获取ClientWebSocket实例支持的WebSocket子协议。 |
方法 | 作用 |
---|---|
Abort() |
中止连接并取消任何挂起的IO操作。 |
CloseAsync(WebSocketCloseStatus, String, CancellationToken) |
关闭作为异步操作的ClientWebSocket 实例。 |
CloseOutputAsync(WebSocketCloseStatus, String, CancellationToken) |
关闭作为异步操作的ClientWebSocket 实例的输出。 |
ConnectAsync(Uri, CancellationToken) |
连接到WebSocket服务器以作为异步操作。 |
Dispose() |
释放ClientWebSocket 实例使用的非托管资源。 |
Equals(Object) |
确定指定对象是否等于当前对象。(继承自Object ) |
GetHashCode() |
作为默认哈希函数。(继承自Object ) |
GetType() |
获取当前实例的Type 。(继承自Object ) |
MemberwiseClone() |
创建当前Object 的浅表副本。(继承自Object ) |
ReceiveAsync(ArraySegment<Byte>, CancellationToken) |
将ClientWebSocket 上的数据作为异步操作进行接收。 |
ReceiveAsync(Memory<Byte>, CancellationToken) |
将ClientWebSocket 上的数据作为异步操作进行接收。 |
SendAsync(ArraySegment<Byte>, WebSocketMessageType, Boolean, CancellationToken) |
以异步操作方式,发送ClientWebSocket 上的数据。 |
SendAsync(ReadOnlyMemory<Byte>, WebSocketMessageType, Boolean, CancellationToken) |
以异步操作方式,从只读字节内存范围发送ClientWebSocket 上的数据。 |
ToString() |
返回表示当前对象的字符串。(继承自Object ) |
以下是我项目中用到的父类实例,仅供参考:
using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using UnityEngine;
/// <summary>WebSocket链接</summary>
public class WebSocketLink
{
public WebSocketLink(string url)
{
m_uri = new Uri(url);
m_client = new ClientWebSocket();
m_cToken = new CancellationToken();
}
protected readonly Uri m_uri = null;
/// <summary>WebSocket客户端对象</summary>
protected readonly ClientWebSocket m_client = null;
protected readonly CancellationToken m_cToken;
/// <summary>接收WebSocket返回的信息数据</summary>
protected WebSocketReceiveResult m_websocketReceiveResult = null;
/// <summary>byte数组,用于接收WebSocket返回的数据</summary>
protected byte[] m_byteArrBuffer = null;
/// <summary>接收WebSocket返回的字符串数据</summary>
protected string m_result = null;
/// <summary>是否循环(链接处于打开状态)</summary>
protected bool Loop {
get {
return m_client.State == WebSocketState.Open; } }
/// <summary>获取缓冲区的byte数组段</summary>
/// <param name="arr">byte数组内容</param>
/// <returns>结果byte数组段</returns>
protected ArraySegment<byte> GetBuffer(byte[] arr)
{
return new ArraySegment<byte>(arr);
}
/// <summary>获取缓冲区的byte数组段</summary>
/// <param name="str">字符串内容</param>
/// <returns>结果byte数组段</returns>
protected ArraySegment<byte> GetBuffer(string str)
{
return GetBuffer(Encoding.UTF8.GetBytes(str));
}
/// <summary>接收信息</summary>
/// <returns>返回值为WebSocketReceiveResult的Task</returns>
protected async Task<WebSocketReceiveResult> ReceiveMessage()
{
m_byteArrBuffer = new byte[1024];
WebSocketReceiveResult wsrResult = await m_client.ReceiveAsync(GetBuffer(m_byteArrBuffer), new CancellationToken());//接受数据
//Debug.Log(wsrResult.Count + "---" + wsrResult.EndOfMessage + "---" + wsrResult.MessageType);
m_result += Encoding.UTF8.GetString(m_byteArrBuffer, 0, wsrResult.Count);
return wsrResult;
}
/// <summary>解析结果</summary>
protected virtual void ParseResult()
{
}
/// <summary>网络报错</summary>
/// <param name="ex">错误信息</param>
protected virtual void WebSocketError(Exception ex)
{
Debug.LogError(ex.Message + "\n" + ex.StackTrace + "\n" + ex.Source + "\n" + ex.HelpLink);
}
/// <summary>连接、接收</summary>
public async void ConnectAuthReceive()
{
try
{
await m_client.ConnectAsync(m_uri, m_cToken);//连接
while (Loop)
{
//遍历接受信息
m_websocketReceiveResult = await ReceiveMessage();
if (m_websocketReceiveResult.EndOfMessage)
{
//接收完一条完整信息,解析
//Debug.Log("完整一条信息:" + m_result);
if (string.IsNullOrEmpty(m_result))
{
//正规闭包的返回值
break;
}
ParseResult();
}
}
}
catch (Exception ex)
{
WebSocketError(ex);
}
}
/// <summary>发送请求</summary>
/// <param name="text">请求信息内容</param>
public async Task SendRequest(string text)
{
if (m_client.State == WebSocketState.None) {
Debug.Log("未建立链接!"); return; }
await m_client.SendAsync(GetBuffer(text), WebSocketMessageType.Text, true, m_cToken);//发送数据
}
/// <summary>关闭</summary>
public async void Close()
{
if (m_client.State == WebSocketState.None) {
Debug.Log("未建立链接!"); return; }
await m_client.CloseAsync(WebSocketCloseStatus.NormalClosure, "正规闭包", m_cToken);
}
/// <summary>终止</summary>
public void Abort()
{
if (m_client.State == WebSocketState.None) {
Debug.Log("未建立链接!"); return; }
m_client.Abort();
}
}
async/await
代码中使用的是async/await
的异步编程:C# async/await异步编程。
文章浏览阅读3.2k次,点赞4次,收藏10次。解决TortoiseGitPlink要求输入密码_tortoisegitplink
文章浏览阅读4.7k次,点赞2次,收藏5次。详细了解大端和小端的存储_大端存储和小端存储
文章浏览阅读6.3k次,点赞5次,收藏49次。一、从零开始建设企业信息安全系统:企业信息安全体系分为:信息安全技术体系和信息安全管理体系 信息安全技术体系: 两个层面: 1.需建设安全相关基础设施和系统,以具备解决相关安全问题的能力。 2.需具备安全运营能力,只有正确部署和使用设备,才能真正保障信息安全。 信息安全管理体系: 两个层面: 1.具备信息安全相关的制度、规范、流程及策略。 2.具..._信息安全运营服务实施指南研究
文章浏览阅读455次。import osimport shutil def select_file(dir, dir_out): # dir为查询文件路径,dir_out为拷贝路径 if os.path.isfile(dir): if(dir[-4:] == '.bmp' or '.jpg' or 'png'): #拷贝所有以上格式的文件,也可以修改为其他格式 filename = dir.split('\\')[-1] # 提取文件名称 s_python遍历所有文件复制指定文件?tn=02003390_71_hao_pg
文章浏览阅读5.1k次,点赞17次,收藏10次。https://pan.baidu.com/s/1IV_lBCeFFM712xx_iXnhqQ 提取码:0pr5_win11 cudatookit安装包 百度云
文章浏览阅读2.1k次。springboot项目的css 和js默认位置是在static中,所以如果没有另外的修改的话,直接创建一个static文件夹,把css和js放入即可。这里放一个实例<!DOCTYPE html><html><head> <meta charset="utf-8"> <title>儿童随访记录表</title> <!-- 引入 echarts.js --> <script src="ht._springboot thymeleaf 不显示css js
文章浏览阅读3.7k次,点赞90次,收藏24次。VMware虚拟机安装Linux纯净版(含卸载,图文超详细)_虚拟机安装linuxqq和卸载的图片
文章浏览阅读1.1k次。AnyChat开发流程指南下面列出AnyChatPlatform Core SDK基本开发流程,适用于开发视频会议系统、语音视频聊天系统、远程教育平台以及即时通讯平台(IM)等。 一、初始化该部分是首先要完成的,用于设置SDK的一些行为,包括设置对应的回调函数、设置SDK组件路径、设置是否产生日志文件等,通常初始化AnyChat SDK的代码如下(C++): 01.// 打_axchat的使用过程
文章浏览阅读190次。项目运行环境配置:Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持)。项目技术:SSM + mybatis + Maven + Vue 等等组成,B/S模式 + Maven管理等等。环境需要1.运行环境:最好是java jdk 1.8,我们在这个平台上运行的。其他版本理论上也可以。2.IDE环境:IDEA,Eclipse,Myeclipse都可以。_在线作业管理系统测试用例
文章浏览阅读758次。好久没更新博客了。近期忙着一个项目, 还要应付各种考试就顾不上博客了。今天遇到了一个蛋疼的问题, 通过BLE4.0与蓝牙外设通信。按照客户给的协议文档发送的数据, 可是外设不能正确识别。折腾了一下午。最后问了客户才知道... 数据头fffe, 他们在外设里面已经做规定了。 所以不须要发送。真是蛋疼。也怪自..._unicode fffe
文章浏览阅读42次。1.表单中get与post提交方法的区别? get是发送请求HTTP协议通过url参数传递进行接收,而post是实体数据,可以通过表单提交大量信息.而且post提交方式比get提交方式安全。2. 用最少的代码写一个求3值最大值的函数? function($a,$b,$c){ return $a>$b? ($a>$c? $a : $c) : ($b>$...
文章浏览阅读2w次,点赞19次,收藏226次。我们在做开发任务时可能会创建多个项目,这些项目可能会依赖于不同的Python环境。比如有的用到Python3.6、有的用到Python3.7;有的用Pytorch开发、有的用TensorFlow开发。这时我们需要为不同的项目分别提供所需的版本和依赖项放到不同的虚拟环境中,这样可以将各项目所需环境隔离开,让项目之间不会起冲突。_anaconda 虚拟环境