Asp.Net Core中WebSocket绑定的方法详解

说明

Websocket是html5后的产物,对于asp.net core中也得到了支持,Asp.Net Core中WebScoket的操作使用基本上和Asp.net中相同,不同的是,绑定监听。

Asp.Net Core2.0默认已经支持WebSocket,不需要另外安装Nuget包。

通过对HttpContext中的WebSockets.AcceptWebSocketAsync方法,接受WebSocket请求;并返回WebScoket对象。

下面话不多说了,来一起看看详细的介绍吧。

一、示例1,

1.后台启动文件Startup的configure中绑定WebSocket的路由监听

public void Configure(IApplicationBuilder app, IHostingEnvironment env, IServiceProvider svp)
{
......
 //绑定WebSocket
 app.Map("/wsone/Connect", (con) =>
 {
  con.UseWebSockets();
  WSHanleTwo _two = new WSHanleTwo();
  con.Use(_two.Connect);
 });
} 

2.定义请求处理类

using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
namespace Core_Razor_2
{
 public class WSHanleTwo
 {
  private WebSocket socket = null;
  //创建链接
  public async Task Connect(HttpContext context, Func<Task> n)
  {
   try
   {
    //执行接收
    WebSocket socket = await context.WebSockets.AcceptWebSocketAsync();
    this.socket = socket;
    //执行监听
    await EchoLoop();
   }
   catch (Exception ex)
   {
    throw ex;
   }
  }
  /// <summary>
  /// 响应处理
  /// </summary>
  /// <returns></returns>
  async Task EchoLoop()
  {
   var buffer = new byte[1024];
   var seg = new ArraySegment<byte>(buffer);
   while (this.socket.State == WebSocketState.Open)
   {
    var incoming = await this.socket.ReceiveAsync(seg, CancellationToken.None);
    byte[] backInfo = System.Text.UTF8Encoding.Default.GetBytes("服务端相应内容");
    var outgoing = new ArraySegment<byte>(backInfo, 0, incoming.Count);
    await this.socket.SendAsync(outgoing, WebSocketMessageType.Text, true, CancellationToken.None);
   }
  }
 }
} 

3.前台请求代码

var socket;
//var uri = "ws://" + window.location.host + "/ws";
var uri = "ws://" + window.location.host + "@Url.Action("Connect")";
var output;
var text = "test echo";
function write(s) {
 var p = document.createElement("p");
 p.innerHTML = s;
 output.appendChild(p);
}
function doConnect() {
 socket = new WebSocket(uri);
 socket.onopen = function (e) { write("opened " + uri); doSend(); };
 socket.onclose = function (e) { write("closed"); };
 socket.onmessage = function (e) { write("Received: " + e.data); socket.close(); };
 socket.onerror = function (e) { write("Error: " + e.data); };
}
function doSend() {
 write("Sending: " + text);
 socket.send(text);
}
function onInit() {
 output = document.getElementById("output");
 doConnect();
}
window.onload = onInit; 

二、为了简单绑定,可以这样封装

public class SocketHandler
{
 public const int BufferSize = 4096;
 WebSocket socket;
 SocketHandler(WebSocket socket)
 {
  this.socket = socket;
 }
 async Task EchoLoop()
 {
  var buffer = new byte[BufferSize];
  var seg = new ArraySegment<byte>(buffer);
  while (this.socket.State == WebSocketState.Open)
  {
   var incoming = await this.socket.ReceiveAsync(seg, CancellationToken.None);
   var outgoing = new ArraySegment<byte>(buffer, 0, incoming.Count);
   await this.socket.SendAsync(outgoing, WebSocketMessageType.Text, true, CancellationToken.None);
  }
 }
 static async Task Acceptor(HttpContext hc, Func<Task> n)
 {
  if (!hc.WebSockets.IsWebSocketRequest)
   return;
  var socket = await hc.WebSockets.AcceptWebSocketAsync();
  var h = new SocketHandler(socket);
  await h.EchoLoop();
 }
 /// <summary>
 /// 路由绑定处理
 /// </summary>
 /// <param name="app"></param>
 public static void Map(IApplicationBuilder app)
 {
  app.UseWebSockets();
  app.Use(SocketHandler.Acceptor);
 }
} 

路由绑定:

[csharp] view plain copy
//绑定websocket
app.Map("/ws", SocketHandler.Map); 

Asp.Net Core上传控件:http://xiazai.jb51.net/201712/yuanma/Uploader(jb51.net).rar

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对我们的支持。

(0)

相关推荐

  • NetCore WebSocket即时通讯示例

    NetCore WebSocket 即时通讯示例,供大家参考,具体内容如下 1.新建Netcore Web项目 2.创建简易通讯协议 public class MsgTemplate { public string SenderID { get; set; } public string ReceiverID { get; set; } public string MessageType { get; set; } public string Content { get; set; } } Se

  • Asp.Net Core中WebSocket绑定的方法详解

    说明 Websocket是html5后的产物,对于asp.net core中也得到了支持,Asp.Net Core中WebScoket的操作使用基本上和Asp.net中相同,不同的是,绑定监听. Asp.Net Core2.0默认已经支持WebSocket,不需要另外安装Nuget包. 通过对HttpContext中的WebSockets.AcceptWebSocketAsync方法,接受WebSocket请求:并返回WebScoket对象. 下面话不多说了,来一起看看详细的介绍吧. 一.示例1

  • ASP.NET Core中Cookie验证身份用法详解

    目录 添加配置 ASP.NETCore1.x ASP.NETCore2.x 创建身份认证Cookie ASP.NETCore1.x ASP.NETCore2.x Signingout(登出) ASP.NETCore1.x ASP.NETCore2.x 服务端变化反馈 ASP.NETCore1.x ASP.NETCore2.x Cookie设置选项 ASP.NETCore1.x ASP.NETCore2.x 持久Cookie ASP.NETCore1.x ASP.NETCore2.x 绝对到期时间

  • asp.net core中灵活的配置方式详解

    前言 asp.net core支持外部文件和命令行参数方式来配置系统运行所需要的配置信息,我们从下面两个常用场景来具体说下具体使用方法. 一.监听地址及端口配置 1,命令行方式 asp.net core系统通过命令行方式启动,使用的命令如下: dotnet run 上面的命令直接在源代码目录下执行,便可以编译程序并运行.那对于已经发布好的程序,就不能使用上面的指令了,应该使用下面的指令: dotnet 程序集文件名(程序集文件名就是程序发布后生成的dll文件) 上面两个指令都能够启动应用程序.程

  • 在ASP.NET Core 中发送邮件的实现方法(必看篇)

    前言 我们知道目前 .NET Core 还不支持 SMTP 协议,当我么在使用到发送邮件功能的时候,需要借助于一些第三方组件来达到目的,今天给大家介绍两款开源的邮件发送组件,它们分别是 MailKit 和 FluentEmail , 下面我对它们分别进行介绍. MailKit 在 ASP.NET Core 中,可以使用 MailKit 来发送邮件,它支持跨平台,并且支持 IMAP, POP3, SMTP 等协议. 你可以使用下面的方式安装: Install-Package MailKit 下面是

  • Hangfire在ASP.NET CORE中的简单实现方法

    hangfire是执行后台任务的利器,具体请看官网介绍:https://www.hangfire.io/ 新建一个asp.net core mvc 项目 引入nuget包 Hangfire.AspNetCore hangfire的任务需要数据库持久化,我们在Startup类中修改ConfigureServices 然后在Configure方法中启用hangfire中间件 现在我们运行一下项目,可以看到,数据库里自动生成了很多表,这些表就是用来持久化任务的 我们打开如下地址,可以看到hangfir

  • 在 ASP.Net Core 中使用 MiniProfiler的方法

    web应用程序的性能相信是大家普遍关心的一个问题,也相信大家有很多工具可用来分析应用程序的性能并能够找到其中的瓶颈,MiniProfiler 就是这个领域中的一款产品,它是一款简单的,功能强大的web应用分析工具,MiniProfiler 可用来帮助我们找到 慢查询, 慢响应 等问题. MiniProfiler 可用在 Asp.Net 和 ASP.Net Core 中,这篇文章将会讨论如何使用 MiniProfiler,并通过它找到应用程序的性能问题. 安装 MiniProfiler 要想使用

  • 如何在ASP.Net Core中使用 IHostedService的方法

    在我们应用程序中常常会有一些执行后台任务和任务调度的需求,那如何在 ASP.Net Core 中实现呢? 可以利用 Azure WebJobs 或者其他一些第三方任务调度框架,如:Quartz 和 Hangfire. 在 ASP.Net Core 中,也可以将 后台任务 作为托管服务的模式,所谓的 托管服务 只需要实现框架中的 IHostedService 接口并囊括进你需要的业务逻辑作为后台任务,这篇文章将会讨论如何在 ASP.Net Core 中构建托管服务. 创建托管服务 要想创建托管服务

  • jQueryUI中的datepicker使用方法详解

    jQuery UI很强大,其中的日期选择插件Datepicker是一个配置灵活的插件,我们可以自定义其展示方式,包括日期格式.语言.限制选择日期范围.添加相关按钮以及其它导航等. 之前做的一个排班考勤系统,跟时间打交道较多,对时间控件做过一些对比,觉得jqueryUI里的这个datepicker更为实用,下面抽点时间给大家整理,方便以后查阅,同时也希望能帮助到大家! 1,引入js,css <link rel="stylesheet" href="http://code.

  • 对Python闭包与延迟绑定的方法详解

    Python闭包可能会在面试或者是工作中经常碰到,而提到Python的延迟绑定,肯定就离不开闭包的理解,今天总结下 关于闭包的概念以及一个延迟绑定的面试题. Python闭包 1.什么是闭包,闭包必须满足以下3个条件: 必须是一个嵌套的函数. 闭包必须返回嵌套函数. 嵌套函数必须引用一个外部的非全局的局部自由变量. 举个栗子 # 嵌套函数但不是闭包 def nested(): def nst(): print('i am nested func %s' % nested.__name__) ns

  • Vue实现contenteditable元素双向绑定的方法详解

    目录 前言 contenteditable 基础使用 进阶使用 总结 前言 如何实现一个即时通讯的聊天页面,网上有很多的开源或不开源的成品,可以直接使用,或者简单修改后使用.但在实际项目中,直接使用开源的即时通讯往往不是我们想要的,如何自己开发一个聊天页面呢.本文就着学习的目的,从0开始一步步实现一个聊天框的开发,至于消息的发送和接收,这个就得依靠后端大佬了. 在开发前,首先得明确用什么来实现.用input输入框和textare文本输入肯定是不行的,这两个只能输入文本类数据(输入法表情也算),想

随机推荐