打通B/S与C/S !让HTML5 WebSocket与.NET Socket公用同一个服务端!

news/2024/7/5 1:53:43

随着HTML5 WebSocket技术的日益成熟与普及,我们能够借助WebSocket来更加方便地打通BS与CS -- 由于B/S中的WebSocket能够直接连接到C/S的服务端,并进行双向通信。例如以下图所看到的:

  

一.对Socket Server的要求

  我们能够尝试让Socket Server透明地支持WebSocketclient,所谓透明的意思是。服务端开发者不用关心client到底是什么类型。而是能够统一的接收数据、处理数据、发送数据。

为了做到这一点,我们能够构建一个服务端框架,让框架完毕透明化的工作,这就要求这个框架做到下面几点:

(1)依据clientTCP连接请求成功后的第一个消息中是否含有“websocket”标记,来推断其是否为WebSocketclient。假设client的类型是WebSocket,则自己主动完毕下面事情。

(2)自己主动完毕Web Sokects 握手协议。

(3)针对接收到的每一个WebSokect数据帧,都能自己主动将其解析,并从中分离出真正的消息内容。

(4)当您发送消息给WebSokectclient时,服务端引擎会自己主动将该消息封装成WebSokect数据帧。然后再发送出去。

  我们在 StriveEngine 中实现了对上述WebSocket的透明化支持,至于详细怎样实现的。大家能够參考一下WebSokect的标准协议。

下面我们就来做一个Demo,让.NET Socketclient和WebSocketclient能同一时候与一个StriveEngine服务端进行双向通信。

二.打通B/S与C/S的Demo 准备

  基于WebSokect,我们在绝大多数情况下,使用的都是文本消息,OK,那我们就基于文本消息来构建这个Demo。

(1)尽管WebSokect能够借助其HTML5协议来自己主动完毕一个消息的独立识别,可是对于我们的普通socket来说。必须有一个方法来识别一个完整的消息。

(2)经常使用的方法是使用特殊的消息结束标识符,那在这个demo中。我们就以'\0'作为消息的结束符吧。

(3)基于(2),那么WebSokect在发送消息给服务端时。也必须在消息结尾加上'\0'。

三.Demo实现

  我们先看看Demo执行起来的效果:

      

  在Demo中。WebSocketclient和.NET Socketclient都能够与同一个服务端进行互通消息。

1.源代码结构说明

  该Demo源代码总共包含三个项目和一个HTML文件:

(1)StriveEngine.SimpleDemoServer:基于StriveEngine开发的服务端。

(2)StriveEngine.SimpleDemoClient:基于StriveEngine开发的client。

(3)StriveEngine.SimpleDemo:直接基于.NET的Socket开发的client。

(4)WebSocketClient.html:基于HTML5 WebSocket的client。

与前两种client公用同一个StriveEngine服务端。

  接下来,我们着重看一下WebSocketclient实现,其他的.NET代码。大家直接去看Demo源代码就好了。

2.WebSocketclient实现

(1)HTML 页面布局

复制代码
<body><h3>WebSocketTest</h3><div id="login"><div><input id="serverIP" type="text" placeholder="服务器IP" value="127.0.0.1" autofocus="autofocus" /><input id="serverPort" type="text" placeholder="服务器端口" value="9000" /><input id="btnConnect" type="button" value="连接" onclick="connect()" /></div><div><input id="sendText" type="text" placeholder="发送文本" value="I'm WebSocket Client!" /><input id="btnSend" type="button" value="发送" onclick="send()" /></div><div><div>来自服务端的消息</div><textarea id="txtContent" cols="50" rows="10" readonly="readonly"></textarea></div></div>
</body>
复制代码

(2)js方法实现

复制代码
<script>var socket;function connect() {var host = "ws://" + $("serverIP").value + ":" + $("serverPort").value + "/"socket = new WebSocket(host);try {socket.onopen = function (msg) {$("btnConnect").disabled = true;alert("连接成功!

"); }; socket.onmessage = function (msg) { if (typeof msg.data == "string") { displayContent(msg.data); } else { alert("非文本消息"); } }; socket.onclose = function (msg) { alert("socket closed!") }; } catch (ex) { log(ex); } } function send() { var msg = $("sendText").value + '\0' socket.send(msg); } window.onbeforeunload = function () { try { socket.close(); socket = null; } catch (ex) { } }; function $(id) { return document.getElementById(id); } Date.prototype.Format = function (fmt) { //author: meizz var o = { "M+": this.getMonth() + 1, //月份 "d+": this.getDate(), // "h+": this.getHours(), //小时 "m+": this.getMinutes(), // "s+": this.getSeconds(), // "q+": Math.floor((this.getMonth() + 3) / 3), //季度 "S": this.getMilliseconds() //毫秒 }; if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length)); for (var k in o) if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ?

(o[k]) : (("00" + o[k]).substr(("" + o[k]).length))); return fmt; } function displayContent(msg) { $("txtContent").value += "\r\n" +new Date().Format("yyyy/MM/dd hh:mm:ss")+ ": " + msg; } function onkey(event) { if (event.keyCode == 13) { send(); } } </script>

复制代码

  js代码中的重点都通过红色字体标记出来了,要特别注意。send方法在发送消息时,会自己主动在消息的末尾加入一个我们约定好的结束符'\0'

四.源代码下载

  打通BS与CS的Demo源代码

    假设有不论什么建议或问题。请留言给我。


http://lihuaxi.xjx100.cn/news/241245.html

相关文章

Jfinal Generator 不需要生成带某个前缀的表名数组的方法

2019独角兽企业重金招聘Python工程师标准>>> package com.demo.common.model; import javax.sql.DataSource; import com.jfinal.kit.PathKit; import com.jfinal.kit.Prop; import com.jfinal.kit.PropKit; import com.jfinal.plugin.activerecord.generato…

1008 Elevator

思路如下&#xff1a;用一个整型数组存楼层&#xff0c;0号元素为0(开始停在0层)&#xff0c;每读入一个元素&#xff0c;和上一个比较&#xff0c;更大说明是上升&#xff0c;总时长加上楼层差*6&#xff0c;反之说明是下降&#xff0c;总时长加上楼层差*4。最后再管停留时间&…

java中mypoiexception,java - 如何使用Poi获取Java中单元格的数据验证源? - 堆栈内存溢出...

此问题包含多个不同的问题。首先&#xff0c;我们需要获取工作表的数据验证&#xff0c;然后为每个数据验证获取数据验证所适用的Excel单元格范围。 如果该单元格位于该单元格范围之一中&#xff0c;并且数据验证是列表约束&#xff0c;则进行进一步处理。 否则返回默认值。如果…

jfinal框架下使用c3P0连接池连接sql server 2008

2019独角兽企业重金招聘Python工程师标准>>> 闲话少说 进入正题 首先是工程需要的jar包 然后是c3p0的配置文件。我是这样配置的 仅供参考 jdbcDriver com.microsoft.sqlserver.jdbc.SQLServerDriver jdbcUrl jdbc:sqlserver://localhost:7777;databaseNametest us…

(C++)一行代码递归实现辗转相除法

定理&#xff1a;两个整数的最大公约数等于其中较小的那个数和两数相除余数的最大公约数。 int gcd(int a,int b){return !b?a:gcd(b,a%b); } 这里递归边界是 gcd(a,0)a; 递归式是 gcd(a,b)gcd(b,a%b);

mysql left join超时,MySQL 行锁超时排查方法优化

一、大纲#### 20191219 10:10:10,234 | com.alibaba.druid.filter.logging.Log4jFilter.statementLogError(Log4jFilter.java:152) | ERROR | {conn-10593, pstmt-38675}executeerror.updatexxxsetxxx ? , xxx ?whereRowGuid ?com.mysql.jdbc.exceptions.jdbc4.MySQLTra…

Python常用操作记录

当前日期格式化&#xff1a; time.strftime(%Y-%m-%d,time.localtime(time.time())) pprint&#xff1a; import pprint pp pprint.PrettyPrinter(indent4) pp.pprint(stuff)或 import pprint pprint.pprint(stuff)django 模板遍历dict&#xff1a; {% for k,v in item.items…

编写程序记录文件位置

当我们编写程序是会注意到&#xff0c;首先是配置一些函数的结构体。 所以我们就要找到下面的界面&#xff0c;然后打开FWLB中.c文件下面所对应的.h文件&#xff0c;这样就能查找到相应的结构体。下图为我所找到的中断的结构体、 然后就是查找相对应的中断向量。具体就是打开 还…