如何在前端上監(jiān)聽到RabbitMQ發(fā)送消息并完成數(shù)據(jù)監(jiān)控，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

創(chuàng)新互聯(lián)公司為企業(yè)級客戶提高一站式互聯(lián)網(wǎng)+設(shè)計服務(wù)，主要包括成都做網(wǎng)站、成都網(wǎng)站建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)、App定制開發(fā)、重慶小程序開發(fā)、宣傳片制作、LOGO設(shè)計等，幫助客戶快速提升營銷能力和企業(yè)形象，創(chuàng)新互聯(lián)各部門都有經(jīng)驗豐富的經(jīng)驗，可以確保每一個作品的質(zhì)量和創(chuàng)作周期，同時每年都有很多新員工加入，為我們帶來大量新的創(chuàng)意。 

如何在前端實現(xiàn)對RabbitMQ發(fā)送消息的實時監(jiān)控，而這也涉及到了小編的知識盲區(qū)，于是就開始了學(xué)習(xí)的道路，接下來就跟著小編一起來學(xué)習(xí)一下這關(guān)于如何在前端監(jiān)聽到RabbitMQ發(fā)送消息，以便實現(xiàn)自己項目中的功能吧。

RabbitMQ支持的協(xié)議

stomp協(xié)議

stomp協(xié)議即Simple (or Streaming) Text Orientated Messaging  Protocol，簡單(流)文本定向消息協(xié)議，它提供了一個可互操作的連接格式，允許STOMP客戶端與任意STOMP消息代理(Broker)進(jìn)行交互。STOMP協(xié)議由于設(shè)計簡單，易于開發(fā)客戶端，因此在多種語言和多種平臺上得到廣泛地應(yīng)用。

而我們在接下來的文章里面主要講stomp如何對RabbitMQ實現(xiàn)監(jiān)聽。

stomp協(xié)議的前身是TTMP協(xié)議(一個簡單的基于文本的協(xié)議)，專為消息中間件設(shè)計。

這句話就說出了，專門為了消息中間件設(shè)計的，其實他并不是針對RabbitMQ在前端使用的，而是針對整個消息中間件的使用。

2.mqtt協(xié)議

還有一種經(jīng)常使用的，就是mqtt協(xié)議了，mqtt協(xié)議全稱(Message Queuing Telemetry  Transport，消息隊列遙測傳輸協(xié)議)，是一種基于發(fā)布/訂閱(Publish/Subscribe)模式的輕量級通訊協(xié)議，該協(xié)議構(gòu)建于TCP/IP協(xié)議上，由IBM在1999年發(fā)布，目前最新版本為v3.1.1。

mqtt協(xié)議是屬于在應(yīng)用層協(xié)議的，這樣也就是說只要是支持TCP/IP協(xié)議棧的地方，都可以使用mqtt.

RabbitMQ開通stomp協(xié)議

安裝RabbitMQ的教程阿粉就不再給大家講了，畢竟百度上有很多文章來告訴大家如何去安裝RabbitMQ，不管是Linux還是Windows的，大家只要注意的一點就是，首先先安裝erlang  語言支持，不然你安裝RabbitMQ是安裝不上的。

開通Stomp協(xié)議：

rabbitmq-plugins enable rabbitmq_web_stomp rabbitmq-plugins enable rabbitmq_web_stomp_examples #重啟 service rabbitmq-server stop && service rabbitmq-server start

當(dāng)我們開啟之后，在我們的RabbitMQ中使能夠看到的，如圖：

大家可以看到，我們正確開啟之后，在RabbitMQ的控制臺上，我們能夠看到http/web-stomp 的端口是15674。

接下來我們就要開始寫一個案例進(jìn)行測試。

前端Stomp監(jiān)聽RabbitMQ

如果這個時候我們發(fā)送一條消息到消息隊列，那么接下來他就會在頁面上展示出我們需要的內(nèi)容。

我們看看代碼是怎么寫的吧。

if (typeof WebSocket == 'undefined') {        console.log('不支持websocket')    }     // 初始化 ws 對象     var ws = new WebSocket('ws://localhost:15674/ws');     // 獲得Stomp client對象    var client = Stomp.over(ws);     // 定義連接成功回調(diào)函數(shù)    var on_connect = function(x) {        //data.body是接收到的數(shù)據(jù)        client.subscribe("/Fanout_Exchange/testMessage", function(data) {            var msg = data.body;            alert("收到數(shù)據(jù)：" + msg);        });    };     // 定義錯誤時回調(diào)函數(shù)    var on_error =  function() {        console.log('連接錯誤，請重試');    };     // 連接RabbitMQ    client.connect('guest', 'guest', on_connect, on_error, '/');    console.log(">>>RabbitMQ已連接，測試正式開始");

而這里面寫的內(nèi)容就比較有意思了，因為之前很多人都會發(fā)現(xiàn)，不管怎么寫，都是不行，那是因為沒有完全的理解，阿粉最后總結(jié)了一下關(guān)于Stomp的使用。

總結(jié)

1./exchange/(exchangeName)

• 對于 SUBCRIBE frame，destination 一般為/exchange/(exchangeName)/[/pattern] 的形式。該  destination 會創(chuàng)建一個唯一的、自動刪除的、名為(exchangeName)的 queue，并根據(jù) pattern 將該 queue 綁定到所給的  exchange，實現(xiàn)對該隊列的消息訂閱。

• 對于 SEND frame，destination 一般為/exchange/(exchangeName)/[/routingKey]  的形式。這種情況下消息就會被發(fā)送到定義的 exchange 中，并且指定了 routingKey。

2./queue/(queueName)

• 對于 SUBCRIBE frame，destination 會定義(queueName)的共享 queue，并且實現(xiàn)對該隊列的消息訂閱。

• 對于 SEND frame，destination 只會在第一次發(fā)送消息的時候會定義(queueName)的共享 queue。該消息會被發(fā)送到默認(rèn)的  exchange 中，routingKey 即為(queueName)。

3./amq/queue/(queueName)

• 這種情況下無論是 SUBCRIBE frame 還是 SEND frame 都不會產(chǎn)生 queue。但如果該 queue 不存在，SUBCRIBE  frame 會報錯。

• 對于 SUBCRIBE frame，destination 會實現(xiàn)對隊列(queueName)的消息訂閱。

• 對于 SEND frame，消息會通過默認(rèn)的 exhcange 直接被發(fā)送到隊列(queueName)中。

4./topic/(topicName)

• 對于 SUBCRIBE frame，destination 創(chuàng)建出自動刪除的、非持久的 queue 并根據(jù) routingkey  為(topicName)綁定到 amq.topic exchange 上，同時實現(xiàn)對該 queue 的訂閱。

• 對于 SEND frame，消息會被發(fā)送到 amq.topic exchange 中，routingKey 為(topicName)。

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)的支持。

網(wǎng)站欄目：如何在前端上監(jiān)聽到RabbitMQ發(fā)送消息并完成數(shù)據(jù)監(jiān)控
路徑分享：http://www.chinadenli.net/article46/gocshg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供、電子商務(wù)、網(wǎng)站排名、定制網(wǎng)站、定制開發(fā)、企業(yè)建站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)