【转】基于WebSocketSharp 的IM 简单实现

websocket-sharp 是一个websocket的C#实现,支持.net 3.5及以上来开发服务端或者客户端。本文主要介绍用websocket-sharp来做服务端、JavaScript做客户端来实现一个简单的IM。

WebSocketBehavior

WebSocketBehavior是核心对象,他包含了OnOpen,OnMessage,OnClose,OnError四个事件(回调)以及一个Sessions对象和一个Send方法。熟悉websocket的都知道前四个事件(回调函数)是用来处理客户端链接、发送消息、链接关闭以及出错。sessions则是用来管理所有的会话连接。每产生一个连接,都会有一个新Id,sessions中会新增一个IWebSocketSession对象。当页面关闭或者刷新都会触发OnClose,继而sessions中会移除对应的IwebSocketSession对象。

WebSocketSessionManager 有一个广播方法:Sessions.Broadcast,通知所有连接的客户端。而WebSocketBehavior中的Send相当于是单发,只能将消息发送到此刻连接的一个客户端。摸清了以上这些我们就可以做一个简单的IM了。

Websoket.Server

新建一个C#控制台程序。现在Nugget中添加websocket-sharp.以及JSON。

然后新增一个Chat类,继承WebSocketBehavior,Chat相当于是一个websocket的服务,你可以创建多个websocketBehavior的实例然后在挂载在websocketServer上。

 

 public class Chat : WebSocketBehavior{private  Dictionary<string,string> nameList=new Dictionary<string, string>();protected override async Task OnMessage(MessageEventArgs e){StreamReader reader = new StreamReader(e.Data);string text = reader.ReadToEnd();try{var obj = Json.JsonParser.Deserialize<JsonDto>(text);Console.WriteLine("收到消息:" + obj.content + " 类型:" + obj.type + " id:" + Id);switch (obj.type){//正常聊天case "1":obj.name = nameList[Id];await Sessions.Broadcast(Json.JsonParser.Serialize(obj));break;//修改名称case "2":Console.WriteLine("{0}修改名称{1}",nameList[Id],obj.content);Broadcast(string.Format("{0}修改名称{1}", nameList[Id], obj.content),"3");nameList[Id] = obj.content;break;default:await Sessions.Broadcast(text);break;}}catch (Exception exception){Console.WriteLine(exception);}//await Send(text);}protected override async Task OnClose(CloseEventArgs e){Console.WriteLine("连接关闭" + Id);Broadcast(string.Format("{0}下线,共有{1}人在线", nameList[Id], Sessions.Count), "3");nameList.Remove(Id);}protected override async Task OnError(WebSocketSharp.ErrorEventArgs e) {var el = e;}protected override async Task OnOpen(){Console.WriteLine("建立连接"+Id);nameList.Add(Id,"游客"+Sessions.Count);Broadcast(string.Format("{0}上线了,共有{1}人在线", nameList[Id],Sessions.Count), "3");}private void Broadcast(string msg, string type = "1"){var data= new  JsonDto(){content = msg,type = type,name = nameList[Id]};Sessions.Broadcast(Json.JsonParser.Serialize(data));}}

JsonDto

 

    class JsonDto{public string content { get; set; }public string type { get; set; }public string name { get; set; }}

 

这里用nameList来管理所有的链接Id和用户名称的对应关系,新上线的人都默认为游客。然后再OnMessage中定义了三种消息类型。1表示正常聊天,2表示修改名称。3表示系统通知。用来让前端做一些界面上的区分。

然后在Program中启动WebSocketServer。下面指定了8080端口。

 

  public class Program{public static void Main(string[] args){var wssv = new WebSocketServer(null,8080);wssv.AddWebSocketService<Chat>("/Chat");wssv.Start();Console.ReadKey(true);wssv.Stop();}}

 

Client

html:

 <div id="messages"></div><input type="text" id="content" value=""/><button id="sendbt">发送</button><div>昵称:<input type="text" id="nickName"  /> <button id="changebt">修改</button> </div>

js:

 

 function initWS() {ws = new WebSocket("ws://127.0.0.1:8080/Chat");ws.onopen = function (e) {console.log("Openened connection to websocket");console.log(e);};ws.onclose = function () {console.log("Close connection to websocket");// 断线重连initWS();}ws.onmessage = function (e) {console.log("收到",e.data)var div=$("<div>");var data=JSON.parse(e.data);switch(data.type){case "1":div.html(data.name+":"+data.content);break;case "2":div.addClass("gray");div.html("修改名称"+data.content)break;case "3":div.addClass("gray");div.html(data.content)break;}$("#messages").append(div);}}initWS();function sendMsg(msg,type){ws.send(JSON.stringify({content:msg,type:type}));}$("#sendbt").click(function(){var text=$("#content").val();sendMsg(text,"1")$("#content").val("");})$("#changebt").click(function(){var text=$("#nickName").val();sendMsg(text,"2")})

 

运行效果:

是不是很方便~~,喜欢就赞一个。

源码:https://files.cnblogs.com/files/stoneniqiu/websocket-sharp.zip

websocket-sharp:http://sta.github.io/websocket-sharp/

nodejs 实现websocket服务端:http://www.cnblogs.com/stoneniqiu/p/5402311.html 

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

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

相关文章

我的技术观

变化 技术是日新月异层出不穷的。人类在不断实践&#xff0c;技术也在不断更新变化。 选择 有的技术只是为了解决某一领域内的问题&#xff0c;有的技术只有在某个领域的某个时期才有用。 一个人没有必要也不可能掌握所有技术。 个人要首先熟练掌握自己涉猎领域内的相关技术…

【转】极限编程一览

极限编程&#xff08;XP&#xff09;起源始于1990年代。当时肯特布莱克&#xff08;Kent Black&#xff09;在戴姆勒克莱斯勒&#xff08;DaimlerChrysler&#xff09;处理项目时&#xff0c;试图寻找一种更好的软件开发方法。他的创立新方法后来被称为极限编程方法论&#xff…

mysql 关联更新_跳出初学MySQL知识的原理整理(一)

一、基础架构MySQL 可以分为 Server 层和存储引擎层两部分。Server 层包括连接器、查询缓存、分析器、优化器、执行器等&#xff0c;所有跨存储引擎的功能都在这一层实现&#xff0c;比如存储过程、触发器、视图等。而存储引擎层负责数据的存储和提取。支持 InnoDB、MyISAM等多…

如何看待编程语言

什么是语言 语言是用来传递信息的交流工具。它的常见形式有&#xff1a;文字&#xff08;视觉上&#xff09;、话语&#xff08;听觉上&#xff09;。 语言是如何表达信息的 语言提供了模型和规则。 语言模型必须有足够的信息复杂度&#xff0c;如字、词、短语。只有语言本身…

【转】TcpListener和tcpclient使用

前段时间公司项目中遇着需要做文件的远程传输&#xff0c;场景是用户通过网页选择一些文件&#xff0c;然后提交请求到服务器&#xff0c;同时把请求标识传递给本机的TCP文件传输端&#xff1b;服务器收到请求后在服务器端创建任务生成保存文件的路径同时通知文件传输端开始传文…

sleep期间读取所有_ceph部分数据所有副本先后故障的抢救

半天河网易游戏高级运维工程师&#xff0c;主要负责云存储的运维&#xff1b;一个既希望跟业务聊又喜欢能够默默在后面忙活的普通运维人。背景故障现场故障恢复故障恢复分析第一种方式&#xff1a;物理磁盘对拷第二种方式&#xff1a;服务启动时跳过故障扇区来避免异常退出解决…

面向过程和面向对象的联系和区别

以C语言和C为例。 C语言是面向过程的&#xff0c;封装单元是函数。函数里面按照逻辑流程一步一步实现就行了&#xff0c;这符合我们现实生活中解决问题时的思考过程。 C是面向对象的&#xff0c;封装单元是类。首先&#xff0c;面向对象是为了提高开发效率而设计的。使用C语言…

【转】有限状态机用法教程

如博文无法正常显示&#xff0c;请访问原文地址&#xff1a; https://blog.csdn.net/ChinarCSDN/article/details/82263126 有限状态机用法教程 文章目录 有限状态机用法教程 [toc]1Finite-state machine —— 有限状态机2Foreword —— 前言()3Example —— 示例4Moltimode —…

通用usb集线器驱动_多口充电、高速传输——ORICO晶锐系列7口集线器测评

随着笔电越来越薄&#xff0c;机身接口数量越来越少&#xff0c;U盘、存储卡、移动硬盘、鼠标、蓝牙适配器等明显感觉无处可插&#xff0c;因此USB集线器就成为笔电的最佳拍档。近期&#xff0c;ORICO(奥睿科)推出了一款晶锐系列7口集线器产品&#xff0c;它集成了7个USB3.0接口…

信息系统中的树

代码树 作用域树 类树 窗口树 文件系统树 图形场景树 设备树 Git版本树

【转】C#开发笔记之05-迭代器中的状态机(State Machine)到底是什么?

C#开发笔记概述 该文章的最新版本已迁移至个人博客【比特飞】&#xff0c;单击链接 https://www.byteflying.com/archives/961 访问。 状态机可以理解为实现了备忘录模式&#xff08;仅作为理解&#xff09;的、能够记录状态的机器&#xff0c;这个机器记录的是某个对象的中间…

python两个集合相减_python集合的运算,两个集合相减是什么意思

&#xfeff;# 在对集合做运算时&#xff0c;不会影响原来的集合&#xff0c;而是返回一个运算结果# 创建两个集合s {1,2,3,4,5}s2 {3,4,5,6,7}# & 交集运算result s & s2 # {3, 4, 5}# | 并集运算result s | s2 # {1,2,3,4,5,6,7}# - 差集result s - s2 # {1, 2}…

什么是runtime?

常见的有以下类型 C/C编译型静态语言的runtimeObjective C的编译型动态语言runtimeJAVA运行在虚拟机上的准动态语言的runtime runtime就是程序运行时的环境&#xff0c;指程序中除去程序开发者编写的代码剩下的那部分代码&#xff0c;它存在的目的是实现语言特性、运行特性、…

【转】状态机思路在程序设计中的应用

状态机思路在单片机程序设计中的应用 状态机的概念 状态机是软件编程中的一个重要概念。比这个概念更重要的是对它的灵活应用。在一个思路清晰而且高效的程序中&#xff0c;必然有状态机的身影浮现。 比如说一个按键命令解析程序&#xff0c;就可以被看做状态机&#xff1a;本…

python表格处理免费教程_手把手教你用Python处理Excel表格

openpyxl是一个第三方库&#xff0c;可以处理xlsx格式的Excel文件。pip install openpyxl安装。读取Excel文件需要导入相关函数from openpyxl import load_workbook# 默认可读写&#xff0c;若有需要可以指定write_only和read_only为Truewb load_workbook(pythontab.xlsx)默认…

LNK2019:无法解析的外部符号

原因1&#xff1a; .lib里面的函数没有导出。 原因2&#xff1a; 没有链接.lib文件 原因3&#xff1a; 没有添加.lib文件所在目录到库目录。 原因4&#xff1a; 所引用的lib文件引用了其他.lib文件&#xff0c;而这个.lib你也要引入进来。 原因5&#xff1a; 导出库是…

【转】超详细的UML状态图符号,初学者也能轻松看懂状态图

UML状态图&#xff0c;用于显示状态机&#xff0c;即描述一个对象所处的可能状态以及状态之间的转移。用状态图建模可以帮助开发人员分析复杂对象的各种状态的转换&#xff0c;以及对象何时执行怎样的动作。那状态图又是怎样表示这些信息的呢&#xff1f;要想看明白其中的奥妙&…

舒尔特注意力训练表格_舒尔特注意力训练,舒尔特方格练习入口

孩子的注意力是否集中&#xff0c;直接影响孩子的上课效率和作业正确率&#xff0c;最终影响学习成绩。道理大家都懂&#xff0c;关键是如何保证注意力的集中。接下来&#xff0c;我给大家推荐一个简单方便在家就能完成的训练方法&#xff0c;把它比作小游戏也不为过。那就是舒…

VS静态库和动态库的区别

静态库&#xff1a; 没有链接完整依赖就能生成成功&#xff0c;使用者在使用时会涉及到链接问题&#xff0c;弱引用&#xff0c;只是记录的引用。 动态库&#xff1a; 必须链接完整依赖才能生成成功 &#xff0c;强引用。

【转】浅析C# 状态机Stateless

最近在折腾一些控制相关的软件设计&#xff0c;想起来 状态机 这个东西&#xff0c;对解决一些控制系统状态切换还是挺有用的。 状态机&#xff08;有限状态自动机&#xff09;网上有很多介绍。简单理解就是定义一系列状态&#xff0c;通过一系列的事件&#xff0c;可以使得状…