Comet初步研究与实践 – PHP到C#应用程序的数据推送DEMO
前段时间小接触了一下comet,关于其基本原理和代码示例请参考我之前的博文《与comet的一次亲密接触——基于ajax的http的长连接技术》http://blog.csdn.net/rcfalcon/archive/2010/04/30/5546828.aspx
这次我们稍微系统的实现一个由PHP Web 服务器端向一个C#客户端应用程序推送的示例。实现“推送”、“用户状态”、“用户列表”的功能。具体一些代码细节就不详细介绍了,主要拿出几个关键问题来与大家分享和讨论。
本文不讨论复杂的comet框架,只从最基本的ajax长连接实现层面来构建应用。若有兴趣研究pushlet等comet框架的朋友请自行研究。
1. 数据传输流程。
应用程序 -> 内嵌webbrowser -> javascript -> ajax后台 -> Web服务器抓住请求 -> Web服务放开请求并附带数据 -> json数据流 -> javascript -> 应用程序
使用C#内嵌的一个WebBrowser 访问一个页面来启动我们的长连接。(因为我不想与平台进行太多的绑定,所以尽量把所有的数据传输层全部放在WEB上来做,下同,不再解释。)
Web服务器收到后抓住请求,直到需要推送数据,则放开属于该客户端的请求。打成json发回,然后javascript回调C#绑定的函数,将数据传送到应用程序中。
2. Web服务器如何“抓住请求”和“识别客户端”?
抓住请求,毫无疑问——使用轮询。
网上有comet的示例聊天室代码是轮询一个文件,我之前的博客中也是用轮询文件实现的。不管是轮询文件、管道、或者在数据库上轮询都是效率较低的。这里我使用 Linux的共享内存,相当于在PHP里有了常驻变量。
对于每个用户,长连接上来的时候都发送一个用户ID。然后我们PHP在共享内存中维护一张用户ID表。用这个ID表来维护所有到服务器的comet连接。
3. 如何“放开请求”?
即轮询何时结束——
我这儿实现是轮询共享内存,客户端找到自己ID对应的内存位置,不断轮询,直到有新的数据。所以很显然,必须存储推送数据内容、数据更新时间 和对应用户ID。(若想采用任务队列或者订制等策略也都可以在这里做。)那么,轮询就很简单:
while( $curr_time == $last_time )
{
usleep(1000000);
clearstatcache();
$data = user_fetch_data($id);
$curr_time = $data->timestamp;
}
直到有新的数据,就推送给该用户。
可能有人要问,为什么不直接就用一个数据字段呢?来了数据就把它“取走”(拿出来并且删掉),直到有数据就放开连接。——这样的想法很朴素,也是很容易第一点想到的。但是有个问题就是若客户端同一个ID重复comet连接,就会造成对该资源竞争,几个进程轮询同一个数据,当数据来了,被其中一个取走,其他的就取不到了……
可能你又要说,我不让一个id重复登录不就可以了么?
——这里很难控制,若用户刷新页面,之前那个长连接没有释放,又上来一个,就会存在一个“废物轮询进程”和自己竞争了。或者网络情况不好,用户断了,重新连接(这个场景还是会经常出现的),也会产生“废物轮询进程”。
所以这儿用时间戳作为轮询出口,还是能避免这种竞争问题的。
4. 如何知道用户下线?
没辙,为了简单实现,我只想到心跳包。因为浏览器的关闭我们在服务器端无法即时知晓,而我也不想在C#中做截获消息来实现。(原因同1,咱的应用完全独立于终端平台也要能做,不和平台绑定)
直接在数据库user表上做操作,
mysql> select * from user;
+----+--------+---------------------+
| id | status | updatetime |
+----+--------+---------------------+
| 1 | 1 | 2010-05-27 15:28:41 |
| 2 | 0 | 2010-05-27 14:08:21 |
| 3 | 0 | 2010-05-27 09:59:41 |
+----+--------+---------------------+
3 rows in set (0.00 sec)
我这里实现用的每5秒心跳包,服务器每20秒检测。基本还是好使的。
心跳包和comet的启动可以做到一起,都在访问的这个页面中,可以使用javascript定时器调用ajax给服务器发送心跳。
setInterval("heartbeat();",5000)
查询用户状态就简单了。直接在数据库上select就行了。
5. 推送数据如何发送到C#来?
C#的WebBrowser中ObjectForScripting可以暴露C#中一个Object给javascript,注意Object需要标记ComVisible。直接调用就可以了,示例代码如下:
[System.Runtime.InteropServices.ComVisible(true)]
public partial class Form1 : Form
{
static private string WebRoot = "http://192.168.25.152/comet/";
public Form1()
{
InitializeComponent();
}
private void button1_Click(object sender, EventArgs e)
{
string userid = textBox4.Text;
webBrowser1.Url = new Uri(WebRoot + "user_comet.php?id=" + userid);
webBrowser1.ObjectForScripting = this;
}
public void HandleData(string data)
{
//处理数据
}
}
Javascript直接用window.external就可以拿到该对象句柄。
Javascript代码:
window.external.HandleData(data);
最后,极度郁闷,本来这文章都写完了。Csdn这个页面莫名其妙的刷新了一下,@!#@#%#¥%于是我又重新写了一遍,崩溃中……
展示一下写的个简单测试工具的运行结果。上面部分是收到推送的数据。
下面发送指令和反馈数据是对Web服务器的操作。可以通过XML发送指令,控制推送
分享到:
相关推荐
通过tomcat服务器,向网页发送即时消息。comet的小例子,可以直接运行,用tomcat6.0。
comet4j推送Demo,tomcat7环境下
先进入login.jsp通过名字登陆,然后可以发邮件一个框输内容一个框输想收件人id
javaweb消息推送 基于comet实现局域网内部通讯(聊天室)demo 功能特性 推送消息广播。 推送定向消息。 提供连接上线前、上线、下线前、下线、发送消息等多种可处理事件。 消息缓存机制,确保长轮询工作模式下不丢失...
实现Comet消息推送功能,根据登陆人定向推送,解决刷新页面原有ScriptSession不能及时销毁的问题,DEMO比较简陋,请先进入login.jsp页面登陆。根据登陆名称判断推送目标,可登陆多个用户进行测试。
comet4j 自己写的消息推送 觉得实用
comet 下载既可以运行,在线会话,支持多人,消息推送!非常好用!
实现Comet消息推送功能,根据登陆人定向推送,解决刷新页面原有ScriptSession不能及时销毁的问题,DEMO比较简陋,请先进入login.jsp页面登陆。根据登陆名称判断推送目标,可登陆多个用户进行测试。
基于comet4j-tomcate7长链接的方式,完整的服务器推送消息demo
comet4j demo可运行war包,注意tomcat的server.xml要修改
Servlet3.0 异步处理 页面推送 Comet 实例
使用Comet技术实现HTML长连接,对Comet框架进行了一定的封装,允许对发送的结果进行自定义扩展,并实现Web即时通讯的例子
Comet4J是一个微型的即时推送框架,它分为服务端与客户端两部分,你只要将服务器端(JAR文件,目前仅支持Tomcat6、7)放入WEB-INF\lib,客户端(JavaScript文件)引入到页面,那么你的应用就具备了向客户端推送信息的...
PHP防Sina微薄无刷新服务器推送(comet)原理,防微薄无刷新
demo是采用comet的web推送技术,使用tomcat7做服务器,内含tomcat7上面配置说明,在MyEclipse、tomcat7上面完美运行,本人亲测!
JavaScript数据推送Comet技术详解_.docx
comet4j的简单demo项目,此项目在eclipse下创建,导入后参照附带的说明文件可直接运行。代码中注释详细,适用于初学者入门。 本项目使用的是comet4j-tomcat6.jar,所以请在tomcat6下运行。如果需要在tomcat7下运行,...
收集了8个消息推送的源码,可以参考
主要为大家详细介绍了JavaScript数据推送Comet技术,感兴趣的小伙伴们可以参考一下
comet4j,是服务端消息推送技术。直接可以运行