写了一个webmq

最近在做一些实时web相关的项目，实时web相对传统web来说，很多方面都是格格不入的，要在传统的web server上直接支持实时web会比较麻烦，当然最近很多web server也在做这方面的工作，但我始终觉得这类需求较为特别，做成一独立的服务较为合适，于是开发了一个基于web的message queue，也就是在浏览器端可能直接订阅和发送信息。

项目特点:
1.支持websocket(基于浏览器原生支持或flash socket)、httpstreaming(基于hidden ifame)、longpolling(基于jsonp script tag)。
2.较为全面 的浏览器支持，做过测试的浏览器：IE6、IE8、FF3.6、chrome5、chrome6、safari5，还有一些浏览器没做过测试，有时间再补上。
3.准实时信息交互，从发送到接收一般都在20ms以内，当然这个还看网络状况。
4.高并发的tcp连接支持，轻松上十万甚至百万并发连接，只要内存足够大。
5.支持两种消息模式:topic和queue。
6.支持嵌入式开发
7.消息非持久化
8.开源的
使用例子请看

http://42.121.57.116:8080/sample.html(默认使用websocket)
http://42.121.57.116:8080/sample.html?(使用httpstreaming)
http://42.121.57.116:8080/sample.html?uselp(使用longpolling)

如果你想在你的网站里使用webmq服务来实现一些实时web推送功能（比如：webIM、webGame、web协作、实时监控系统等），使用非常简单，以下就是一个使用的例子。

使用简介
1.
在你的html页面引用 以下的JS:

<script type="text/javascript" src="http://42.121.57.116/static?webmq.all.js"></script>

2.
创建webmq的客户端，指定ip与端口，还有domain，domain是用来区分不同使用站点，原来想把它做成一个通用独立服务 ，

var webmq = new Webmq("42.121.57.116", "80", "test.com");

3.
指定要监听的queue或topic和相关的回调函数

webmq.subscribe("destName", function(message) {alert(message.message);}, "queue");

4.
发送消息到指定的queue或topic

webmq.publish("destName", "test-message", "queue");

5.
注销监听的queue或topic

webmq.unSubscribe("destName", "queue");

6.
不用的时候关闭

webmq.close();

下一步的计划
1.webmq server支持scale out和failover,解决高并发下的可扩展性的问题
2.提供一种可靠的消息确收机制，提高消息传输可靠性
3.解决基于flash的websocket的事件通知延迟的问题和提供一个无flash依赖的可选版本
4.提供安全认证机制
5.提供可插拨的消息存储机制，默认提供基于kahadb(activeMQ5.x默认使用的)
6.详细的网络通信接口文档说明

最近项目动态请关注作者微博:http://weibo.com/1462962703

评论

28 楼 wst302 2011-05-12  

好东西，有开源吗，我想用看看

27 楼 凯旋人生 2010-12-01  

楼主这个东东很好呀，期望server端早日开源，拜读一下。

26 楼 kellersoon 2010-11-30  

不错，关注下！ 问下，你是xiaosong吗？

25 楼 janrn 2010-11-17  

能下载试用吗, 这个东西提供只有JS还是包括服务端,如果我们要使用,使用方法步骤是怎样的

24 楼 ravi_zhou 2010-10-21  

真恐怖！哎~不说不说

23 楼 javatim 2010-10-21  

看不懂，不会用，我用下最土的办法写一个，哈！

22 楼 linkerlin 2010-10-20  

能不能和CometD框架比较下？

21 楼 afei1689 2010-10-18  

mercyblitz 写道

请教一下，我感兴趣的是streaming，实现的方式是不是采用NIO的事件HTTP响应?

我看了一下Chrome和Opera浏览器在不停地等待下一个输出（响应）。

longpolling、streaming、websocket都是用nio的，用的是jboss的netty的nio框架。

20 楼 mercyblitz 2010-10-18  

afei1689 写道

最近在做一些实时web相关的项目，实时web相对传统web来说，很多方面都是格格不入的，要在传统的web server上直接支持实时web会比较麻烦，当然最近很多web server也在做这方面的工作，但我始终觉得这类需求较为特别，做成一独立的服务较为合适，于是开发了一个基于web的message queue，也就是在浏览器端可能直接订阅和发送信息。

项目特点:
1.支持websocket(基于浏览器原生支持或flash socket)、httpstreaming(基于hidden ifame)、longpolling(基于jsonp script tag)。
2.较为全面 的浏览器支持，做过测试的浏览器：IE6、IE8、FF3.6、chrome5、chrome6、safari5，还有一些浏览器没做过测试，有时间再补上。
3.准实时信息交互，从发送到接收一般都在20ms以内，当然这个还看网络状况。
4.高并发的tcp连接支持，轻松上十万甚至百万并发连接，只要内存足够大。
5.支持两种消息模式:topic和queue。
6.支持嵌入式开发
7.消息非持久化
8.准备开源

使用例子请看

http://122.224.72.222:8080/webmq/sample.html(默认使用websocket)
http://122.224.72.222:8080/webmq/sample.html?(使用httpstreaming)
http://122.224.72.222:8080/webmq/sample.html?uselp(使用longpolling)

使用简介
1.
在你的html页面引用 以下的JS:

<script type="text/javascript" src="http://122.224.72.222:7777/static?webmq.all.js"></script>

2.
创建webmq的客户端，指定ip与端口，还有domain，domain是用来区分不同使用站点，原来把它做成一个通用独立服务 ，

var webmq = new Webmq("122.224.72.222", "7777", "webmq.com");

3.
指定要监听的queue或topic和相关的回调函数

webmq.subscribe("destName", function(message) {alert(message.message);}, "queue");

4.
发送消息到指定的queue或topic

webmq.publish("destName", "test-message", "queue");

5.
注销监听的queue或topic

webmq.unSubscribe("destName", "queue");

6.
不用的时候关闭

webmq.close();

下一步的计划
1.webmq server支持scale out和failover,解决高并发下的可扩展性的问题
2.提供一种可靠的消息确收机制，提高消息传输可靠性
3.解决基于flash的websocket的事件通知延迟的问题和提供一个无flash依赖的可选版本
4.提供安全认证机制
5.提供可插拨的消息存储机制，默认提供基于kahadb(activeMQ5.x默认使用的)
6.详细的网络通信接口文档说明

请教一下，我感兴趣的是streaming，实现的方式是不是采用NIO的事件HTTP响应?

我看了一下Chrome和Opera浏览器在不停地等待下一个输出（响应）。

19 楼 argan 2010-10-14  

不错的，期待下文详解

18 楼 shaomeng95 2010-10-14  

现在大家研究的都很先进啊 不错

17 楼 melin 2010-09-25  

activemq ajax

16 楼 agapple 2010-09-25  

这个得顶顶，关注下

15 楼 jiang0620 2010-09-17  

大虾afei的作品改天一定拜读，并期待你的下一步计划

14 楼 罗卜头 2010-09-17  

不错啊~~

13 楼 afei1689 2010-09-17  

Hooopo 写道

报bug:received from topic[test],message:测试消息,time:-4075ms

时间的计算是在js里做的，这种情况可能是两台电脑的时间不同步造成。

12 楼 tedeyang 2010-09-17  

测试下了，第三种可以。
第二种首次打开时，queue无效，队列名称改为test1，一下子就收到多条消息。
看来你的sample应该在页面上随机生成一个queue name，呵呵。

11 楼 Hooopo 2010-09-17  

报bug:received from topic[test],message:测试消息,time:-4075ms

10 楼 tedeyang 2010-09-17  

afei1689 写道

tedeyang 写道

报bug：我在win7、ff 3.6.8下，后两种模式的queue模式无法获取消息，其余很正常，速度为100ms左右。

这个应该不是bug，queue模式是消息是一对一的，你发的消息可能被同时也监听这个queue的其他在线用户消费了，你换个其他名字的queue试试看

嗯，我也想到了这一点，所以后来又把其他页面都关闭了，测试结果仍然如此。可能socket仍然没有关闭。
我再测试一下，这次先打开后两个页面。

9 楼 rockysz 2010-09-17  

支持梦大师！