张家界建设网站制作,选择一个网站进行优化,wordpress 淘宝客,江苏城乡建设职业学院网站在学习使用websocket之前我们先了解一下websocket#xff1a; WebSocket是一种在单个TCP连接上进行全双工通信的通信协议。与HTTP协议不同#xff0c;它允许服务器主动向客户端发送数据#xff0c;而不需要客户端明确地请求。这使得WebSocket非常适合需要实时或持续通信的应…在学习使用websocket之前我们先了解一下websocket WebSocket是一种在单个TCP连接上进行全双工通信的通信协议。与HTTP协议不同它允许服务器主动向客户端发送数据而不需要客户端明确地请求。这使得WebSocket非常适合需要实时或持续通信的应用程序例如在线聊天、实时游戏、股票市场更新等。
websocket介绍
以下是WebSocket的一些关键特点 全双工通信WebSocket允许客户端和服务器在同一时间内彼此发送数据而不需要等待对方的响应。这种实时性使其成为许多实时应用程序的首选协议。 持久连接与HTTP请求-响应模型不同WebSocket连接在客户端和服务器之间保持打开状态直到一方选择关闭连接。这消除了频繁地建立和终止连接的开销。 较低的开销WebSocket在已建立连接的基础上传输数据减少了与每个请求都要建立新连接的HTTP协议的开销。 轻量级标头WebSocket协议的标头数据相对较小这有助于减少数据传输时的开销。 跨域支持WebSocket协议支持跨域通信这意味着您可以在不同域之间建立WebSocket连接。 安全性与HTTP一样WebSocket可以通过使用TLS/SSL来加密通信确保数据的安全性。 要建立WebSocket连接客户端和服务器之间的初始握手是通过HTTP完成的。一旦握手成功连接升级为WebSocket连接允许双方直接交换数据帧。数据帧可以是文本数据或二进制数据具体取决于应用程序的需求。
下面是一个示意性的WebSocket握手过程 客户端发起WebSocket握手请求包含特定的HTTP头信息。 服务器响应握手请求同样包含特定的HTTP头信息。 握手成功后连接从HTTP协议升级到WebSocket协议。 客户端和服务器可以通过发送数据帧进行实时通信直到其中一方关闭连接。
Ajax长轮询介绍
在websocket不被广泛使用之前Ajax的长轮询比较流行本质上两者都是用于实现实时通信的技术但是它们之间有以下区别 连接方式Ajax长轮询使用的是HTTP协议而Websocket使用的是WebSocket协议。 性能Ajax长轮询中客户端需要不断向服务器发送HTTP请求服务器在收到请求后才能返回数据给客户端。这种方式会导致不必要的网络延迟和服务器压力性能相对较差。Websocket采用双向通信方式只需要建立一次连接即可实现实时通信性能较好。 兼容性Ajax长轮询在大多数浏览器中都可以使用但是在一些较老的浏览器中可能会有兼容性问题。Websocket需要浏览器支持HTML5才能使用。 实时性Ajax长轮询的实时性较差因为客户端需要不断向服务器发送请求而服务器在收到请求后才能返回数据。Websocket的实时性较好因为它采用双向通信方式。
完整代码https://download.csdn.net/download/qq_39569480/88264479
websocket用例
后端代码
1.注册服务
首先要在Startup文件中的ConfigureServices方法中注册HttpContextAccessor
// This method gets called by the runtime. Use this method to add services to the container.public void ConfigureServices(IServiceCollection services){services.AddControllers();services.AddSwaggerGen(c {c.SwaggerDoc(v1, new OpenApiInfo { Title WebApplication3, Version v1 });});services.AddHttpContextAccessor();//注册http}其次在Startup文件中的Configure方法中添加wesocket
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.public void Configure(IApplicationBuilder app, IWebHostEnvironment env){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();app.UseSwagger();app.UseSwaggerUI(c c.SwaggerEndpoint(/swagger/v1/swagger.json, WebApplication2 v1));}app.UseWebSockets();//添加websocketapp.UseHttpsRedirection();app.UseRouting();app.UseAuthorization();app.UseEndpoints(endpoints {endpoints.MapControllers();});}2.创建服务
首先定义一个Controller或者Service 注入IHttpContextAccessor以便获取socket请求 声明全局变量用于存储socket链接这里没有将socket存储到类似redis或数据库中因为socket链接不能被反序列化如果有更好方法的小伙版可以留言。这里的socket链接池只要服务不停 链接就会一直存在。
[ApiController]public class WebSocketDemoController : ControllerBase{private readonly IHttpContextAccessor _httpContextAccessor;private static Dictionarystring, WebSocket _dic new Dictionarystring, WebSocket();public WebSocketDemoController(IHttpContextAccessor httpContextAccessor){this._httpContextAccessor httpContextAccessor;}}编写socket接口 [HttpGet(“/WsService”)]这里定义了socket的名字 http协议访问时直接通过ws://Ip:Port/WsService去访问 https协议访问时直接通过wss://Ip:Port/WsService去访问
[HttpGet(/WsService)]public async Task Get(){//Logger.LogInformation(CurrentUser.Id CurrentUser.Name);if (_httpContextAccessor.HttpContext.WebSockets.IsWebSocketRequest){//string token _httpContextAccessor.HttpContext.Request.Headers[Sec-WebSocket-Protocol];Console.WriteLine(有链接进入);//接受websocket客户端连接var webSocket await _httpContextAccessor.HttpContext.WebSockets.AcceptWebSocketAsync();//await ReadWriteWebSocektAsync(Add,CurrentUser.Id.ToString(),webSocket); //如果用户的连接不存在加进缓存await Echo(webSocket);}else{//不是websocket客户端请求 ]_httpContextAccessor.HttpContext.Response.StatusCode 400;}}消息处理方法 /// summary/// 对客户端的处理接受消息发送消息关闭连接/// /summary/// param namewebSocket/param/// param namedic/param/// param nameuserId/param/// returns/returnsprivate async Task Echo(WebSocket webSocket){try{var buffer new byte[1024 * 4];//webSocket.SubProtocol token;var result await webSocket.ReceiveAsync(new ArraySegmentbyte(buffer), CancellationToken.None);while (!result.CloseStatus.HasValue){var message Encoding.UTF8.GetString(buffer, 0, buffer.Length);WebSocektDto socketRequest JsonConvert.DeserializeObjectWebSocektDto(message);buffer new byte[1024 * 4];//Logger.LogInformation(${DateTime.Now.ToString(yyyy-MM-dd HH:mm:ss)}接收到的信息 message);if (socketRequest.type create_connect){//创建链接 //var (sysUserId, sysUserName) GetSystemUserId(socketRequest.auth);/***************************************//*******重要****看一下下面两行注释******//***************************************///这里只是举了一个简单的示例如果实际应用建议发起者传送token信息 比如上一行解析发起者传过来的token信息 把发起者的id和socket连接保存起来//这里特别说明一下 为什么token信息要通过参数的形式传送而不是直接写到websocket请求的head中是因为websocket不支持head传送信息StoreWebSocekt(Add, socketRequest.sponsorUserId, webSocket);}else if (socketRequest.type dialing){//发起者打电话//Logger.LogInformation(${DateTime.Now.ToString(yyyy-MM-dd HH:mm:ss)}发起通话);string targetId socketRequest.receiverUserId;//获取接收者idstring sponsorUserId socketRequest.sponsorUserId;//发起者string sponsorUserName socketRequest.sponsorUserName;//发起者的姓名 //var (sysUserId, sysUserName) GetSystemUserId(socketRequest.auth);//if (string.IsNullOrWhiteSpace(sysUserId)) throw new Exception(请认证);//这一步是确保接收信息方的socket链接是否存在如果不存在信息也找不到接收方//首先在系统登录或者系统初始化时所有的用户都需要建立起链接 并且链接保存起来以便此刻接收响应信息if (_dic.ContainsKey(targetId)){//向客户端发送消息if (_dic.TryGetValue(targetId, out WebSocket ReceiverSocket)){//在我们自定义的链接池中如果找到了接收者的链接 那么我们给接收者发送信息string sponsor socketRequest.sponsorUserId;//获取连接池中的接收者 连接 然后给接收者发送 通话信息WebSocektDto PushMessageDto new WebSocektDto(){type called,//类型可以自己定义 为了方便知道自己的每个链接的作用ok true,msg ,data new ResponseDetailsData { sponsorUserId sponsorUserId, sponsorUserName sponsorUserName, field1 , field2 , field3 }//这里定义了一个实体是用于给接收者传递消息的里边包含发起者的信息和发送的信息};byte[] serverMsg Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(PushMessageDto));await ReceiverSocket.SendAsync(new ArraySegmentbyte(serverMsg, 0, serverMsg.Length), WebSocketMessageType.Text, result.EndOfMessage, CancellationToken.None);}else{//如果在我们自定义的链接池中没有找到接收者的链接 那么我们需要给发起者响应告诉他为什么WebSocektDto rp new WebSocektDto() { type dialing_response, ok false, msg 对方意外断开连接, data new ResponseDetailsData { sponsorUserId null } };byte[] rpJson Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(rp));await webSocket.SendAsync(new ArraySegmentbyte(rpJson, 0, rpJson.Length), WebSocketMessageType.Text, result.EndOfMessage, CancellationToken.None);}}else{//如果在我们自定义的链接池中没有找到接收者 那么我们需要给发起者响应告诉他为什么WebSocektDto rp new WebSocektDto() { type dialing_response, ok false, msg 对方未建立链接, data new ResponseDetailsData { sponsorUserId null } };byte[] rpJson Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(rp));await webSocket.SendAsync(new ArraySegmentbyte(rpJson, 0, rpJson.Length), WebSocketMessageType.Text, result.EndOfMessage, CancellationToken.None);}}//继续接受客户端消息 result await webSocket.ReceiveAsync(new ArraySegmentbyte(buffer), CancellationToken.None);}//关闭释放与客户端连接await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);//await ReadWriteWebSocektAsync(Edit, CurrentUser.Id.ToString(), webSocket); //如果用户的连接不存在加进缓存string keys _dic.Where(q q.Value webSocket).Select(q q.Key).FirstOrDefault();//通过当前socket获取链接池中的key 然后删掉连接池中的链接if (!string.IsNullOrWhiteSpace(keys)) StoreWebSocekt(Edit, keys, webSocket);}catch (Exception e){}}3.完成以上步骤我们进行测试
启动服务
1.创建链接 此步骤为建立socket的连接 并不是实际的工作因为我们需要确保与服务器的socket通信所以先建立连接。 此步骤对应前端的代码 ws new WebSocket(“ws://192.168.0.107:8088”); 在创建ws服务后会自动创建监听 ws.onopen function() { };
2.让后台保存用户的socket链接 在系统登录时保存起用户的链接方便以后互相发送消息 这里我模拟两个用户登录后台保存其socket链接 3.1122用户给2211用户发送信息 1122用户发送信息 我们回到2211的窗口查看接收到了1122用户发送的信息 当然我们2211也可以给1122回复信息
再回到1122的窗口
