Liferay 4.2 reverse ajax探索

为了使用Liferay中的chat功能,除了要建立一台jabber server之外,还需要启动两个属性

jabber.xmpp.server.enabled=true

reverse.ajax.enabled=true

jabber.xmpp.server.enabled比较好理解,reverse.ajax.enabled是什么?

在Liferay 4.2的chat有个特点。即使用户没有chat portlet的权限,当有其他人员向其发送chat消息时,会立即弹出一个chat消息框。

该消息框的实现就是用了reverse ajax。我们可以trace一下liferay的代码看看这个自动弹出的chatbox是如何实现的。

首先找到ajax.js 找到里面有

request: function() {

...

onComplete:ReverseAjax.response,

...

},

response: function(xmlHttpRequest) {

...

ReverseAjax.request();

...

},

写过点ajax的朋友都能猜出来,这两段是干什么的。一旦一个ajax请求发起,如果正常结束,那么在responnse方法中重新再发起一次请求。

吓人一跳,liferay不会那么没效率吧,当中都没有个延迟??

再找java代码ReverseAjaxAction.java 在不起眼的代码中,有这么一行 reqWait.waitForRequest();看看waitForRequest的定义

public synchronized void waitForRequest() throws InterruptedException {

intheartbeatCycle=GetterUtil.getInteger(PropsUtil.get(

PropsUtil.REVERSE_AJAX_HEARTBEAT));

_timedOut = true;

wait(heartbeatCycle); }

大有玄机!!找找notify是被谁调用的代码......

BinGo!!

RosterUpdateListener和MessageListener中有reqWait.notifyWait()

让我们重新理一下思路

两条主线

ajax.js中ReverseAjax.request()->ReverseAjaxAction.java->reqWait.waitForRequest()

RosterUpdateListener|MessageListener->reqWait.notifyWait()

在浏览器中一直有一个请求,但是当请求到服务端端时,被java阻塞了。 当有jabber消息返回时,则会notify前一个被阻塞的线程,最终使得浏览器端的ajax代码将chatbox显示出来。

最终,我们得出一个结论,liferay 中ReverseAjax是用poll来模拟push。但是poll过程中利用了java线程同步的技巧。

当然以上的分析还很粗糙。没有解释线程同步之间的资源和超时的设计,本文就算起个抛砖引玉的作用吧。

相关推荐