wenfengsun

Archive for the ‘Tensteps’ Category

export svn to d:\tensteps; backup;

Advertisements

今天终于将一整套的Comet流程跑通,很兴奋!

这里主要使用了第一篇中的Kestrel队列和jetty+cometd的comet service;

jetty真是一个很好的开源项目,它不但提供了一个轻量级的java web server,而且还提供了诸如REST, Comet等Opensource。

我使用了Kestre 1.27作为队列服务,用xmemcache作为kestrel连接的java client。用jetty+cometd作为comet服务, 用spring的线程管理池作为了队列读取服务。

当一个用户发布一条message后,这条消息将会存储到kestrel队列中,队列读取程序读取到这个消息之后,将会更新缓存,并向comet服务器的指定频道发布数据;

当comet服务器收到发布频道的数据之后,将根据数据的不同分发给不同的订阅频道,订阅这些频道的客户端将会收到数据。当client收到这些数据之后,将根据传回的id等信息获取用户发布的message的详细信息并展现到页面上。

整个过程的效果就是,一个用户发布一条数据之后,另外一个用户将会在他的首页收到一条新的消息,并展现。

written by wenfengsun—-milestonev0.1——2011/04/09