X5集成ActiveMQ+WebSocket实现消息推送

jholy

1、首先下载并安装ActiveMQ
    http://www.apache.org/dyn/closer.cgi?path=/activemq/apache-activemq/5.9.0/apache-activemq-5.9.0-bin.zip

    1）解压后，将webapps-demo目录下的demo复制到webapps目录下
    2）执行bin/activemq.bat，启动ActiveMQ服务
    3）打开http://localhost:8161/demo，运行自带的Web sockets example进行测试

2、在X5中创建应用demo/activeMQ

    1）编写用于发送ActiveMQ消息的动作

        下载http://central.maven.org/maven2/org/apache/activemq/activemq-all/5.9.0/activemq-all-5.9.0.jar
        放入/BIZ/demo/activeMQ/logic/code/lib文件夹中

        编写动作代码（动作模型文件参见/BIZ/demo/activeMQ/logic/action/activeMQ.action.m）

1. import org.apache.activemq.transport.stomp.StompConnection;
   
2. 
   
3. public class ActiveMQ {
   
4. 
   
5.         public static void activeMQSendMessage(String message) throws Exception {
   
6.                 StompConnection conn = new StompConnection();
   
7.                 try {
   
8.                         conn.open("127.0.0.1", 61613);
   
9.                         conn.connect("guest", "guest");
   
10.                         conn.begin("StompTransaction");
    
11.                         conn.send("/topic/test", message);
    
12.                         conn.commit("StompTransaction");
    
13.                 } finally {
    
14.                         conn.close();
    
15.                 }
    
16.         }
    
17. }

复制代码

    2）创建功能process，引用上面的动作，并创建功能页面
        功能页面实现两个功能：
            发送消息
                    编辑框+按钮，调用上面的动作实现消息发送

1. mainActivity.btnSendClick = function(event){
   
2.         if ($("#inputText").val() == "") return;
   
3.         
   
4.         var params = new justep.Request.ActionParam();
   
5.         params.setString("message", window.escape($("#inputText").val()));
   
6.         justep.Request.sendBizRequest2({
   
7.                 "action": "activeMQSendMessage",
   
8.                 "parameters": params,
   
9.                 "callback": function(callbackData) {
   
10.                         callbackData.ignoreError = false;
    
11.                         if (callbackData.state) {
    
12.                                 $("#inputText").val("");
    
13.                         }
    
14.                 }
    
15.         });
    
16. };
    

复制代码

            接收消息

引用ActiveMQ WebSocket案例中自带的stomp.js，stomp.js 是使用 HTML5 Web Socket API 实现的 Stomp 客户端。   

页面中用Stomp实现消息接收

1. mainActivity.model1Load = function(event){
   
2.         var client = Stomp.client("ws://localhost:61614/stomp");
   
3. 
   
4.         client.connect("guest", "guest", function(frame) {
   
5.                 client.subscribe("/topic/test", function(msg) {
   
6.                         $("#textReceiver").val(window.unescape(msg.body) + "\n" + $("#textReceiver").val());
   
7.                 });
   
8.         });
   
9.         
   
10.         $("#textReceiver").val("Receiving.....\n");
    
11. };
    

复制代码

注意：ActiveMQ需要jdk 1.6，而X5开发版自带的是jdk 1.5，需要下载 32位的jdk1.6 替换X5中的jdk
由于jdk版本问题，动作的代码在studio中编译会报错，但是运行时编译运行都是正常的。


请用IE10以上版本或Chrome、Firefox浏览器


X5_DEMO_activeMQ.zip (12.18 KB, 下载次数: 3384)

2014-1-14 14:29 上传

点击文件名下载附件
示例资源

由于附件大小限制，示例资源中没有包含lib下的activemq-all-5.9.0.jar

ecoolper

不错，支持

67886387

学习了！

rzport_lq0

请问下，这种实现方式，平台只是转发了下消息，请问应用服务器能用nodejs代替tomcat吧？

jholy

rzport_lq0 发表于 2014-1-25 09:57
请问下，这种实现方式，平台只是转发了下消息，请问应用服务器能用nodejs代替tomcat吧？ ...

没明白你问什么？
这个案例里面，消息的分发是由ActiveMQ完成的。
ActiveMQ和X5都是基于java的，只能用在Java的容器里。

是手机端APP推送功能吗？（推送信息了，就在客户端直接像QQ、微信那样信息提示？）
不用Android服务端的SDK？iphone端的证书？

X5版可以用？还是只有X5EE可以用？

FIRE

我现在遇到一个问题，就是手机端一直断线，请问这个怎么解决，也就是监听者会断线 练级连接不上，请问x5有没有断线重连的方法。

mxdeson

其实直接用workman就可以了，没有这么复杂

dudemonkey

好帖，mark