簡單嘗試了node下的ActiveMQ

1、下載apache-activemq-5.9.0，執行bat文件；

2、登錄http://localhost:8161/admin可查看其管理后臺；

3、安裝stomp客戶端 npm install stomp-client

4、修改基礎代碼如下：

var Stomp = require('stomp-client'); var readline = require('readline');
//創建兩個不同的topic var topic1 = '/topic/topic1'; var topic2 = '/topic/topic2';var rl = readline.createInterface({input : process.stdin,output : process.stdout,terminal : false });//1. publisher-subscribe 定義一個或者多個topic，然后給這些topic發送消息 //2. p2p 雙方通過一個quene來發送、接收消息,一個quene只有一個發送、一個接收 //3. request-response 雙方各有一個quene作為彼此的收發，相當于兩個p2pvar publisher = new Stomp('127.0.0.1', 61613, '', ''); //發布者 var subscriberA = new Stomp('127.0.0.1', 61613, '', ''); //訂閱者A var subscriberB = new Stomp('127.0.0.1', 61613, '', ''); //訂閱者Bpublisher.connect(function(sessionId) {rl.on('line', function(line) {switch (line.split(":")[0]) {case 'topic1':publisher.publish(topic1, line.split(":")[1]);break;case 'topic2':publisher.publish(topic2, line.split(":")[1]);break;default:console.log('commond error `' + line.trim() + '`');break;}rl.prompt();}).on('close', function() {console.log('close test project!');process.exit(0);}); });subscriberA.connect(function(sessionId) {subscriberA.subscribe(topic1, function(body, headers) {console.log('subscriberA From Topic1:', body);});subscriberA.subscribe(topic2, function(body, headers) {console.log('subscriberA From Topic2:', body);}); });subscriberB.connect(function(sessionId) {subscriberB.subscribe(topic1, function(body, headers) {console.log('subscriberB From Topic1:', body);});subscriberB.subscribe(topic2, function(body, headers) {console.log('subscriberB From Topic2:', body);}); });

輸入不同命令后，控制臺輸出如下：

同時在管理后臺的topic欄目下，查看創建的topic

轉載于:https://www.cnblogs.com/Fredric-2013/p/5783948.html

總結

以上是生活随笔為你收集整理的node(ActiveMq)的全部內容，希望文章能夠幫你解決所遇到的問題。

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