Comet初步研究与实践 – PHP到C#应用程序的数据推送DEMO

zhangsanfeng88

Comet初步研究与实践 – PHP到C#应用程序的数据推送DEMO
 
 
前段时间小接触了一下comet，关于其基本原理和代码示例请参考我之前的博文《与comet的一次亲密接触——基于ajax的http的长连接技术》
 
这次我们稍微系统的实现一个由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发送指令，控制推送