内容简介:这个DEMO主要完成的工作是:首先需要准备两个工程:
将会使用到的 Package:
websocket-sharp
Newtonsoft.JSON
这个DEMO主要完成的工作是:
- HTML 连接 WebSocket 并传送一个Json,Json包含两个数字a和b。
- 服务器监听 WebSocket 并解析Json里面的两个数字,将两个数字加起来的和作为结果以Json的形式传送给HTML。
- HTML 得到返回以后更新显示。
- 10秒之后,服务器主动向浏览器再发送一次消息。
准备姿势
新建工程
首先需要准备两个工程:
- 一个是Web项目,可以是任何Web项目,因为我们只用到HTML。HTML单文件也是没有问题的。这里我用的是vscode live server。
- 另一个是C#命令行项目,当然也可以不是命令行,只是觉得命令行比较方便,DEMO也不需要窗体,如果你需要窗体可以使用WPF或者WinForms。
必要依赖
- 在C#项目中,我们需要安装Nuget包:WebSocketSharp (由于这个Nuget包在写文的时候还是rc,所以需要勾选包括抢鲜版才会搜索出来哦)和 Newtonsoft.JSON
服务器代码
首先我们需要新建一个类,作为一个app,去处理传送来的消息。
using Newtonsoft.Json; using Newtonsoft.Json.Linq; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WebSocketSharp; using WebSocketSharp.Server; namespace WebSocketDemo { class Add : WebSocketBehavior { protected override void OnOpen() { Console.WriteLine("Connection Open"); base.OnOpen(); } protected override void OnMessage(MessageEventArgs e) { var data = e.Data; if (TestJson(data)) { var param = JToken.Parse(data); if (param["a"] != null && param["b"] != null) { var a = param["a"].ToObject<int>(); var b = param["b"].ToObject<int>(); Send(JsonConvert.SerializeObject(new { code = 200, msg = "result is " + (a + b) })); Task.Factory.StartNew(() => { Task.Delay(10000).Wait(); Send(JsonConvert.SerializeObject(new { code = 200, msg = "I just to tell you, the connection is different from http, i still alive and could send message to you." })); }); } } else { Send(JsonConvert.SerializeObject(new { code = 400, msg = "request is not a json string." })); } } protected override void OnClose(CloseEventArgs e) { Console.WriteLine("Connection Closed"); base.OnClose(e); } protected override void OnError(ErrorEventArgs e) { Console.WriteLine("Error: " + e.Message); base.OnError(e); } private static bool TestJson(string json) { try { JToken.Parse(json); return true; } catch (JsonReaderException ex) { Console.WriteLine(ex); return false; } } } }
上面这一段代码中,重点在于OnMessage方法,这个方法就是处理消息的主要流程。
在Main函数中,我们加入下面的代码。6690是这次Demo使用的端口号,第二行AddWebSocketService添加了一行路由,使得连接到 ws://localhost:6690/add
可以导向我们预定义好的App类中的处理逻辑。
using System; using WebSocketSharp.Server; namespace WebSocketDemo { class Program { static void Main(string[] args) { var wssv = new WebSocketServer(6690); wssv.AddWebSocketService<Add>("/add"); wssv.Start(); Console.WriteLine("Server starting, press any key to terminate the server."); Console.ReadKey(true); wssv.Stop(); } } }
客户端代码
<!DOCTYPE html> <html> <head> <meta charset="utf-8" /> <meta http-equiv="X-UA-Compatible" content="IE=edge" /> <title>WebSocket DEMO</title> <meta name="viewport" content="width=device-width, initial-scale=1" /> <style> ul, li { padding: 0; margin: 0; list-style: none; } </style> </head> <body> <div> a:<input type="text" id="inpA" /> b:<input type="text" id="inpB" /> <button type="button" id="btnSub">submit</button> </div> <ul id="outCnt"></ul> <script> let wsc; var echo = function(text) { var echoone = function(text) { var dom = document.createElement("li"); var t = document.createTextNode(text); dom.appendChild(t); var cnt = document.getElementById("outCnt"); cnt.appendChild(dom); }; if (Array.isArray(text)) { text.map(function(t) { echoone(t); }); } else { echoone(text); } }; (function() { if ("WebSocket" in window) { // init the websocket client wsc = new WebSocket("ws://localhost:6690/add"); wsc.onopen = function() { echo("connected"); }; wsc.onclose = function() { echo("closed"); }; wsc.onmessage = function(e) { var data = JSON.parse(e.data); echo(data.msg || e.data); console.log(data.msg || e.data); }; // define click event for submit button document.getElementById("btnSub").addEventListener('click', function() { var a = parseInt(document.getElementById("inpA").value); var b = parseInt(document.getElementById("inpB").value); if (wsc.readyState == 1) { wsc.send(JSON.stringify({ a: a, b: b })); } else { echo("service is not available"); } }); } })(); </script> </body> </html>
当创建WebSocket对象的时候,会自动进行连接,这个对象可以用onopen,onclose,onmessage分别处理事件。主要通讯的流程也是在onmessage中进行处理。
以上所述就是小编给大家介绍的《纯静态HTML 与 C# Server 进行WebSocket 连接》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- CentOS下VMware使用桥接模式与静态IP连接外网
- 静态库遇到静态库
- 全局变量,静态全局变量,局部变量,静态局部变量
- Android NDK秘籍--编译静态库、调用静态库
- static特别用法【静态导包】——Java包的静态导入
- c# – 为什么委托在静态方法中使用时不能引用非静态方法?
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
从零开始学创业大全集
阳飞扬 / 中国华侨出版社 / 2011-10-1 / 29.80元
为了让每一个怀揣梦想走上创业之路的有志者能在最短的时间内叩开创业的大门,了解创业的流程和方法,从而找到适合自己的创业之路,我们精心编写了这本《从零开始学创业大全集》。阳飞扬编著的《从零开始学创业大全集(超值白金版)》从创业准备、创业团队的组建、创业项目和商业模式的选择、创业计划书的制作、创业资金的筹集、企业的经营策略、资本运作以及产品营销方法、危机应对策略等方面,全面系统地阐述了创业的基本理论与实......一起来看看 《从零开始学创业大全集》 这本书的介绍吧!
URL 编码/解码
URL 编码/解码
Markdown 在线编辑器
Markdown 在线编辑器