dotNet Core使用SignalR实现websocket

前言:

        最近有一个公司项目做一个排队叫号系统,系统功能不复杂,所以后端就我一人,难点在于消息推送到安卓屏上,最近有点时间,把我工作中使用的技术分享出来!

整个技术架构:前端使用vue uniapp,后端使用dotNet core3.1,数据库是Sqlserver,ORM框架是SqlSuagar,中间件有log4net,Newtonsoft.Json,

Microsoft.AspNet.SignalR.Core。

当然我们在使用一个自己以前没使用的技术时都是先写一个demo,那么我今天就给大家分享我写的demo!

首先我们新建一个dotNet Core3.1程序

54e612f859e88b335e40fb7615491b63.png

然后我们打开Nuget包管理器,搜索SignalR安卓最新的稳定版本1.1.0

d305474a2bdd57e1a4750458b14f8da5.png

然后我们新建一个文件夹,用来存放我们新建的SignalR自定义集线器,代码如下!

public class ChatHub : Hub{/// <summary>/// 这里的方法是给前端调用的/// </summary>/// <param name="user"></param>/// <param name="message"></param>/// <returns></returns>public async Task SendMessage(string user, string message){await Clients.All.SendAsync("ReceiveMessage", user, message);}/// <summary>/// 连接成功/// </summary>/// <returns></returns>public override async Task OnConnectedAsync(){await Clients.All.SendAsync("Connected", "连接成功[来至服务器的信息]");}}

然后我们在StartUp类的ConfigureServices方法中配置Signalr,配置跨域,代码如下!

public void ConfigureServices(IServiceCollection services){services.AddControllers();services.AddCors(options => options.AddPolicy("CorsPolicy",builder =>{builder.AllowAnyMethod().AllowAnyHeader().SetIsOriginAllowed(o => true).AllowCredentials();}));services.AddSignalR();}

最后我们在StartUp类的Configure方法中使用Signalr,使用我们自定义的集线器ChatHub,代码如下!

public void Configure(IApplicationBuilder app, IWebHostEnvironment env){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}app.UseRouting();app.UseAuthorization();app.UseCors("CorsPolicy");app.UseEndpoints(endpoints =>{endpoints.MapHub<ChatHub>("/chathub"); //设置长连接地址endpoints.MapControllers();});}

这样我们服务端就搭建好了,当然搭建好之后我们需要自己写个前端代码验证自己的WebSocket服务是否搭建成功!

客户端代码 打开Vscode 新建WebSocket.html

我们在head标签内链接外部Signalr JS外部资源文件,代码如下!

<!--微软SignalR js 客户端 必须要 --><script src="https://cdnjs.cloudflare.com/ajax/libs/microsoft-signalr/3.1.3/signalr.min.js"></script>

然后写一个简单的发送消息界面

html代码

<div id="app"><div class="view"><div><textarea v-autosize v-model="sendValue" rows=3 placeholder="请输入要发送的内容"></textarea></div><div><input type="text" v-model="name" placeholder="输入名称" /></div><div><h-button color="primary" @click="send">发送消息</h-button></div></div></div>

js代码

<script>new Vue({el: "#app",data: {signalR: null,name: "MissLiu",sendValue: "其实AspNetCore.SignalR 非常简单"},methods: {initSignalR() {var _this = this;_this.signalR = new signalR.HubConnectionBuilder().withUrl("http://localhost:64059/ChatHub").configureLogging(signalR.LogLevel.Information).build();try {_this.signalR.start();} catch (err) {console.log(err);}//监听连接成功_this.signalR.on("Connected", (message) => {HeyUI.$Message(message)});_this.signalR.on("ReceiveMessage", (user, message) => {HeyUI.$Notice({type: "info",title: user + " 说 ",content: message});});},send() {this.signalR.invoke("SendMessage", this.name, this.sendValue).catch(function(err) {return console.error(err.toString());});}},mounted() {this.initSignalR();},})
</script>

界面展示效果

2cd3e5d11aa8c88ffa9acd319a8d6dcd.png

b45442ec93ce0522c33aee643de37a55.gif

b0a40fd526652d87f89a17f56967347d.png

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

JPA和hibernate的关系

实际上&#xff0c;JPA的标准的定制是hibernate作者参与定制的&#xff0c;所以JPA是hibernate的一个总成&#xff0c;可以这么理解转载于:https://www.cnblogs.com/cyh2009/p/4709465.html

nagios监控mysql(check_mysql)及内存使用率(check_mem)

一、监控本地&#xff08;localhost&#xff09;内存1、上传监控脚本 check_mem 到/usr/local/nagios/libexec# chown -R nagios.nagios check_mem # chmod x check_mem2、修改commands配置# vim /usr/local/nagios/etc/objects/commands.cfg define command{command_name …

Android之jni编译报错comparsion between signed and unsigned integer expressions解决办法

1、问题 jni编译报错comparsion between signed and unsigned integer expressions 2、原因 在for循环里面&#xff0c;不能用无符号32整形数据作为判断条件 2、解决办法 先把无符号32整形数据强转为整型数据&#xff0c;然后再去作为条件

《手机测试Robotium实战教程》——导读

本节书摘来自异步社区《手机测试Robotium实战教程》一书中的导读&#xff0c;作者 杨志伟&#xff0c;更多章节内容可以访问云栖社区“异步社区”公众号查看 目 录前 言第1章 自动化测试简介 1.1节何为自动化测试1.2节自动化测试和手动测试的对比1.3节移动端自动化测试工具的选…

linux内核的冒险md来源释义# 14raid5非条块读

linux内核的冒险md来源释义&#xff03; 14raid5非条块读转载请注明出处&#xff1a;http://blog.csdn.net/liumangxiong假设是非条块内读。那么就至少涉及到两个条块的读&#xff0c;这就须要分别从这两个条块内读出数据。然后再凑成整个结果返回给上层。接下来我们将看到怎样…

为record类型自定义Equals方法

前言record类型&#xff0c;这是一种新引用类型&#xff0c;而不是类或结构。record与类不同&#xff0c;区别在于record类型使用基于值的相等性。例如&#xff1a;public record DemoRecord(int id);public class DemoClass {public DemoClass(int id){this.id id;}public in…

解决IDEA修改已有项目为maven项目时目录结构被改变的问题

Idea可以在项目根目录上右键选择“添加框架支持”&#xff0c;选择maven&#xff0c;为项目添加Maven支持。 但这样会导致原有项目的目录结构被破坏。 更好的方法是在根目录添加pom.xml文件 在<build>标签内添加 <sourceDirectory>标签&#xff0c;并填入源码根目…

C语言之获取32字节随机数的字符串

1、问题 获取32字节随机数的字符串 2、代码实现 #include <stdio.h> #include <time.h> #include <stdlib.h>#define SIZE 32void get_rand(char *p, int length) { char value[10] "0123456789";srand(time(NULL));for (int i 0; i < leng…

排序——选择排序

选择排序 作者&#xff1a;上品物语 知识点&#xff1a; 原理示意图算法特点复杂度1.1 原理 首先&#xff0c;找到数组中最小的那个元素&#xff0c;其次&#xff0c;将它和数组的第一个元素交换位置&#xff08;如果第一个元素就是最小元素&#xff0c;那么它就和自己交换&…

《Java线程与并发编程实践》—— 2.3 谨防活跃性问题

本节书摘来异步社区《Java线程与并发编程实践》一书中的第2章&#xff0c;第2.3节&#xff0c;作者&#xff1a; 【美】Jeff Friesen&#xff0c;更多章节内容可以访问云栖社区“异步社区”公众号查看。 2.3 谨防活跃性问题 活跃性这个词代表着某件正确的事情最终会发生。活跃…

.Net/C#分库分表高性能O(1)瀑布流分页

框架介绍依照惯例首先介绍本期主角:ShardingCore 一款ef-core下高性能、轻量级针对分表分库读写分离的解决方案&#xff0c;具有零依赖、零学习成本、零业务代码入侵dotnet下唯一一款全自动分表,多字段分表框架,拥有高性能,零依赖、零学习成本、零业务代码入侵,并且支持读写分离…

centos静默安装oracle关于报错UnsatisfiedLinkError exception loading native library:njni10

静默安装oracle时&#xff0c;日志文件中打印出如下语句 提示Oracle NetConfiguration Assistant failed&#xff0c;原因是找不到libaio.so.1 这是缺少依赖 执行指令 yum -y install libaio* libaio-devel* 删除home文件夹&#xff0c;再次执行 ./runInstaller -silent…

Ant—使用Ant构建一个简单的Java工程(两)

博客《Ant—使用Ant构建一个简单的Java项目&#xff08;一&#xff09;》演示了使用Ant工具构建简单的Java项目&#xff0c;接着这个样例来进一步学习Ant&#xff1a;上面样例须要运行多条ant命令才干运行Test类中的main函数&#xff0c;能不能简化须要运行命令呢&#xff1f;答…

C++之函数指针实现函数回调

1、问题 C++很多地方需要函数指针回调,但是我理解还是不够深刻,今天再写了测试例子,方便后面更深入理解和记忆。 2、代码实现 A.h 文件实现 // // A.h // TestC++ // // Created by 1111 on 17/8/17. // Copyright © 2017年 sangfor. All rights reserved. //#…

JMS的样例

1、JMS是一个由AS提供的Message服务。它能接受消息产生者(Message Provider)所发出的消息&#xff0c;并把消息转发给消息消费者(Message Consumer)。2、JMS提供2种类型的消息服务&#xff1a;(1)Queue&#xff0c;即点对点&#xff0c;每一个消息仅仅转发给一个消息消费者使用…

《面向对象的思考过程(原书第4版)》一1.11 组合

本节书摘来自华章出版社《面向对象的思考过程&#xff08;原书第4版&#xff09;》一书中的第1章&#xff0c;第1.11节&#xff0c;&#xff3b;美&#xff3d; 马特魏斯费尔德&#xff08;Matt Weisfeld&#xff09; 著黄博文 译更多章节内容可以访问云栖社区“华章计算机”…

Hadoop 新增删除节点

1 新增Data节点 1.1 修改/etc/hosts&#xff0c;增加datanode的ip 1.2 在新增加的节点启动服务 hadoop-daemon.sh start datanode yarn-daemon.sh start nodemanager 1.3 均衡block start-balancer.sh 1&#xff09;如果不balance&#xff0c;那么cluster会把新的数据都存放在…

Java Thread Status(转)

public static enum Thread.State extends Enum<Thread.State>线程状态。线程可以处于下列状态之一&#xff1a; 1.NEW 至今尚未启动的线程的状态。 2.RUNNABLE 可运行线程的线程状态。 处于可运行状态的某一线程正在 Java 虚拟机中运行&#xff0c;但它可能正在…

秀!微软《550页图解.Net+WPF完整版》.pdf 附下载!

赶紧看看微软公司基于最新的.netwpf编写文档。对于零基础可以作为.net的快速入门教材&#xff0c;对于高级程序员而言&#xff0c;这也是你的充电之路&#xff01;NO.1资料介绍该手册,全面的介绍.net的新特性&#xff0c;看完这个资料&#xff0c;你能够对.net/c#WPF的新功能&a…

Android之编译jni出错解决办法

1、问题 1&#xff09;、我编写的类一开始都能编译&#xff0c;后来编译不过 2&#xff09;、undefined reference to Qt::value 2、解决办法 1 )、我在写Android.mk的时候这样注释了下面的代码 LOCAL_SRC_FILES : \A.cpp \B.cpp \# C.cpp \D.cpp \这样导致找不到D…