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)

import org.apache.activemq.transport.stomp.StompConnection;

public class ActiveMQ {

public static void activeMQSendMessage(String message) throws Exception {

StompConnection conn = new StompConnection();

try {

conn.open("127.0.0.1", 61613);

conn.connect("guest", "guest");

conn.begin("StompTransaction");

conn.send("/topic/test", message);

conn.commit("StompTransaction");

} finally {

conn.close();

}

}

}

2)創建功能process，引用上面的動作，并創建功能頁面

功能頁面實現兩個功能：

發送消息

編輯框+按鈕，調用上面的動作實現消息發送

mainActivity.btnSendClick = function(event){

if ($("#inputText").val() == "") return;

var params = new justep.Request.ActionParam();

params.setString("message", window.escape($("#inputText").val()));

justep.Request.sendBizRequest2({

"action": "activeMQSendMessage",

"parameters": params,

"callback": function(callbackData) {

callbackData.ignoreError = false;

if (callbackData.state) {

$("#inputText").val("");

}

}

});

};

接收消息

引用ActiveMQ WebSocket案例中自帶的stomp.js，stomp.js 是使用 HTML5 Web Socket API 實現的 Stomp 客戶端。

頁面中用Stomp實現消息接收

mainActivity.model1Load = function(event){

var client = Stomp.client("ws://localhost:61614/stomp");

client.connect("guest", "guest", function(frame) {

client.subscribe("/topic/test", function(msg) {

$("#textReceiver").val(window.unescape(msg.body) + "\n" + $("#textReceiver").val());

});

});

$("#textReceiver").val("Receiving.....\n");

};

注意：ActiveMQ需要jdk 1.6，而X5開發版自帶的是jdk 1.5，需要下載 32位的jdk1.6 替換X5中的jdk

由于jdk版本問題，動作的代碼在studio中編譯會報錯，但是運行時編譯運行都是正常的。

請用IE10以上版本或Chrome、Firefox瀏覽器

本文由WeX5君整理，WeX5一款開源免費的html5開發工具，H5 App開發就用WeX5!

總結

以上是生活随笔為你收集整理的java socket wex5_WeX5集成ActiveMQ+WebSocket实现消息推送的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。