html5-websocket基于远程方法调用的数据交互实现

一般在传统网页中注册用户信息都是通过post或ajax提交到页面处理,到了html5后我们有另一种方法就是通过websocket进行数据交互.websocket在数据交互有着传统网页所不具备的灵活性,通过websocket建立长连接后服务器可以直接向client发送数据,而每次数据交互没有必要带上大量的http头信息.websocket协议本身支持两种数据格式文本和流,通过文本json的方式和javascript交互是一件非常简单事情,通过json网页和websocket通讯就非常便利,但要达到这个便利性我们还是要做简单的一些包装还好现有的json在各平台的组件都比较成熟.通过分析json数据映射到服务端对应的方法执行处理.

下面通过一个简单的用户注册来体现html5用josn和websocket进行交互的处理过程.由于经过封装处理所以使用起来非常方便.

html:

功能很简单就是连接到websocket服务后进行注册信息提交,当然为了更灵活点我们在监测到连接关闭的时候重新打开连接窗体,具体的js代码如下:

复制代码

代码如下:

function connect() {
channel = new tcpchannel();
channel.connected = function (evt) {
$('#dlgconnect').dialog('close');
};
channel.disposed = function (evt) {
$('#dlgconnect').dialog('open');
};
channel.error = function (evt) {
alert(evt);
};
channel.connect($('#txthost').val());
}

代码是不是很简洁,主要原因是在websocket的基础上封装了一个tcpchannel,详细代码可以下载了解.连接成功后就进入了注册窗体

 

通过填写一些注册信息后,点击注册把信息通过websocket提交给服务端,相关提交的js代码如下:

复制代码

代码如下:

var invokeregister = { url: 'handler.onregister', parameters: { username: '', email: '', password: ''} };
function register() {
$('#frmregister').form('submit', {
onsubmit: function () {
var isvalid = $(this).form('validate');
if (isvalid) {
invokeregister.parameters = $('#frmregister').serializeobject();
channel.send(invokeregister, function (result) {
alert(result.data);
});
}
return false;
}
});
}

当验证数据成功后通过tcpchannel发送一个方法调用描述对象即可,url是指定调用的类方法,而paramters即是方法的参数,参数也可以是复杂的结构类型.第二个参数是一个回调处理.  c#

服务由于基于beetle的扩展处理,所以代码是非常简单的.针对以上注册的逻辑方法代码如下:

复制代码

代码如下:

public class handler
{
public string onregister(string username, string email, string password)
{
console.writeline(username);
console.writeline(email);
console.writeline(password);
return username;
}
}

方法只需要定义相关参数即可,beetle的消息扩展控制器会自动分析js提交的json数据进行分析并绑定到相关方法中执行.对于控制器的详细代码也可以通过下载代得到.逻辑编写完成我们只需要简单地打开相关websocket服务即可.

复制代码

代码如下:

class program:websocketjsonserver
{
static void main(string[] args)
{
beetle.controllers.controller.register(new handler());
tcputils.setup("beetle");
program server = new program();
server.open(8088);
console.writeline("websocket start@8088");
system.threading.thread.sleep(-1);
}
protected override void onerror(object sender, channelerroreventargs e)
{
base.onerror(sender, e);
console.writeline(e.exception.message);
}
protected override void onconnected(object sender, channeleventargs e)
{
base.onconnected(sender, e);
console.writeline("{0} connected", e.channel.endpoint);
}
protected override void ondisposed(object sender, channeldisposedeventargs e)
{
base.ondisposed(sender, e);
console.writeline("{0} disposed", e.channel.endpoint);
}
}

这样一个基于html5的websocket对象消息交互和处理就完成,只需很少量的代码就实现了js和服务进行数据交互的处理.要实现这方便交互功能以下几个封装省不了.websocket协议分析,对象json处理和消息控制分发;如果想了解相关细可以下载源码查看.

websocket.server.rar (641.79 kb)