[譯]RabbitMQ tutorials （一）[JavaScript]

BlackHole1 發(fā)布于2019-08-21 15:08 / 1572人閱讀

摘要：允許接收和轉(zhuǎn)發(fā)消息。一個(gè)等待接收消息的程序是一個(gè)消費(fèi)者。發(fā)送者會(huì)先連接到發(fā)送一條消息，然后退出。注意這里的是要和之前的名稱一致。翻譯日期另因?yàn)橄肴腴T第一次想著翻譯，第一次然后希望多多提出不足。

gitBook https://joursion.gitbooks.io/...

Title: RabbitMQ tutorials ---- "Hello World" (Javascript)

原文

介紹

RabbitMQ 是一個(gè)消息代理，其主要思想比較簡單。允許接收和轉(zhuǎn)發(fā)消息。你可以把RabbitMQ想成是一個(gè)郵局，當(dāng)你發(fā)一份郵件到郵箱，你相當(dāng)確定郵遞員最終會(huì)把這封信送到你的收件人那邊。
使用這個(gè)比喻，RabbitMQ可以是一個(gè)郵箱，或一個(gè)郵局，或一個(gè)郵遞員。
其與郵局主要的不同是實(shí)際上RabbitMQ并不處理內(nèi)容，而是接收，存儲(chǔ)然后轉(zhuǎn)發(fā)二進(jìn)制數(shù)據(jù)--消息（message）

在RabbitMQ的消息傳遞上，我們用一些術(shù)語來解釋：

生產(chǎn)（Producing）意味著只做發(fā)送的事情。一個(gè)發(fā)送消息（message）的程序可以作為一個(gè)生產(chǎn)者（producer）.圖如下，代號‘P’

隊(duì)列（queue）是一個(gè)郵箱的名字，存在在 RabbitMQ中。盡管消息（messages）是在RabbitMQ和你的應(yīng)用中傳遞，但是它們只能被存到一個(gè)隊(duì)列中。這個(gè)隊(duì)列沒有任何限制，可以存儲(chǔ)你想要的任何多的消息，實(shí)際上，它就是一個(gè)無限的Buffer，大量生產(chǎn)者可以把消息發(fā)送到一個(gè)
隊(duì)列中，消費(fèi)者們可以嘗試從一個(gè)隊(duì)列中去接收數(shù)據(jù)。一個(gè)隊(duì)列可以畫成下圖所示：上方是它的名字

消費(fèi)（Consuming）和接收的意思類似。一個(gè)等待接收消息的程序是一個(gè)消費(fèi)者（Consumer）。如下圖所示，代號“C”：

"Hello World" (使用amqp.node[1] 客戶端)

在這個(gè)部分的引導(dǎo)中，我們會(huì)寫兩個(gè)Javascript小程序，一個(gè)生產(chǎn)者用來發(fā)送一條消息，一個(gè)消費(fèi)者來接收消息并打印出來?？紤]到這只是一個(gè)起步入門的小代碼，消息傳送一個(gè)‘hello world’
在途中，“P”是我們的生產(chǎn)者，“C”是我們的消費(fèi)者，在中間的盒子是一個(gè)隊(duì)列（queue）,一個(gè)RabiitMQ用來給消費(fèi)者代理的buffer.

amqp.node 客戶端庫
RabbitMQ 支持多種協(xié)議，在引導(dǎo)中，使用AMQP 0-9-1,它是一個(gè)開源的，通用的消息傳遞協(xié)議。支持很多不同語言的RabbitMQ的客戶端庫，在這里我們使用amqp.node （Javascript）

在一開始，我們使用npm 來安裝這個(gè)庫
$ npm install amqplib

現(xiàn)在我們已經(jīng)安裝了amqp.node了，我們可以寫一些代碼了

發(fā)送（Sending）：

我們把消息發(fā)送者的文件取名send.js，同理，消息接收者的文件為receive.js。發(fā)送者會(huì)先連接到RabbitMQ,發(fā)送一條消息，然后退出。

在send.js中，我們先導(dǎo)入庫

#!/usr/bin/env node

var amqp = require("amqplib/callback_api");

再連接到RabbitMQ服務(wù)器
amqp.connect("amqp://localhst), function(err, conn) {} )

接著我們創(chuàng)建一個(gè)通道(channel)，之后大部分的API會(huì)使用這個(gè)通道

amqp.connect("amqp://localhost", function(err, conn) {
    conn.createChannel(function(err, ch) {});
});

去發(fā)送的時(shí)候，我們必需聲明一個(gè)隊(duì)列（queue）,然后把消息發(fā)布到這個(gè)隊(duì)列中

amqp.connect("amqp://localhost", function(err, conn) {
    conn.createChannel(function(err, ch) {
        var q = "hello";

        ch.assertQueue(q, {durable: false});  
        // Note: on Node 6 Buffer.from(msg) should be used
        ch.sendToQueue(q, new Buffer("Hello World!"));
        console.log(" [x] Sent "Hello World!"");
  });
});

聲明一個(gè)隊(duì)列是冪等的[2] -- 只有在不存在的時(shí)候才會(huì)被創(chuàng)建。消息（message）的內(nèi)容是一個(gè)位數(shù)組，所以你可以使用你喜歡的編碼。
最后，我們要關(guān)閉這個(gè)連接并且退出

setTimeout(function() { conn.close(); process.exit(0) }, 500);

接收（Receiving）
以上就是發(fā)送的代碼。我們的接收者是從RabbitMQ接收推送消息的，所以不同與發(fā)送者只需要發(fā)布一條簡單的消息，我們需要保持程序持續(xù)運(yùn)行，去監(jiān)聽消息并打印出來

在receive.js中，require同理

#!/usr/bin/env node

var amqp = require("amqplib/callback_api");

基礎(chǔ)設(shè)置和send.js一致，先創(chuàng)建連接和通道，然后再聲明一個(gè)我們要去消費(fèi)的隊(duì)列（queue）。注意：這里的queue是要和之前sendToQueue的名稱一致。

amqp.connect("amqp://localhost", function(err, conn) {
    conn.createChannel(function(err, ch) {
        var q = "hello"; //和之前的要一致，

        ch.assertQueue(q, {durable: false});
    });
});

注意：我們在這里也同樣需要聲明queue，因?yàn)槲覀兛赡芟葐?dòng)接收（receiver）再啟動(dòng)發(fā)送（sender），我們要保證當(dāng)我們?nèi)年?duì)列中取消息的時(shí)候，這個(gè)隊(duì)列是存在的。

我們將會(huì)告訴服務(wù)器，我們要從這個(gè)隊(duì)列取消息。由于推送給我們消息是異步的，我們需要寫一個(gè)回調(diào)函數(shù)（callback），當(dāng)RabbitMQ給消費(fèi)者推送消息的時(shí)候執(zhí)行。
這就是Channel.consume所作的

console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
ch.consume(q, function(msg) {
    console.log(" [x] Received %s", msg.content.toString());
}, {noAck: true});

下邊是完整的receive.js的代碼

#!/usr/bin/env node

var amqp = require("amqplib/callback_api");

amqp.connect("amqp://localhost", function(err, conn) {
  conn.createChannel(function(err, ch) {
    var q = "hello";

    ch.assertQueue(q, {durable: false});
    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
    ch.consume(q, function(msg) {
      console.log(" [x] Received %s", msg.content.toString());
    }, {noAck: true});
  });
});

整合（Putting it all together）

現(xiàn)在我們可以運(yùn)行我們的這兩個(gè)腳本了，在終端，我們?nèi)ヅ苓@兩個(gè)腳本

sender:

$ ./sender.js

receive:

$ ./receive.js

reciever 中會(huì)打印一條從RabbitMQ中獲取到的消息，并會(huì)持續(xù)運(yùn)行（使用 ctrl+c 停止運(yùn)行），等待新的消息推送。所以，你可以在其他終端再跑一次sender。
如果你想查看隊(duì)列中的內(nèi)容，可以使用rabbitmqctl list_queues

Hello World

下一節(jié)，將會(huì)講到去搭建一個(gè)簡單的工作隊(duì)列

[1]. amqplib API

[2]. 在編程中.一個(gè)冪等操作的特點(diǎn)是其任意多次執(zhí)行所產(chǎn)生的影響均與一次執(zhí)行的影響相同。

小結(jié)：消息隊(duì)列從字面上就是一個(gè)管理消息的隊(duì)列，存在消費(fèi)者和生產(chǎn)者，緩存隊(duì)列，他們可以訂閱同一個(gè)queue。

翻譯：Joursion

日期：2016/12/21

另: 因?yàn)橄肴腴TRabbitMQ, 第一次想著翻譯，第一次...然后... 希望多多提出不足。 Thanks~

云服務(wù)器 GPU云服務(wù)器 Tutorials Tutorial RabbitMQ rabbitmq 事務(wù)消息

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/88112.html

發(fā)表評論

登陸后可評論

0條評論

BlackHole1

男|高級講師

我要關(guān)注我要私信

TA的文章

#閃購#RackNerd：4核8G內(nèi)存100G SSD硬盤5TB流量，$89/年，洛杉磯DC02機(jī)房

閱讀 2529·2021-09-24 10:29
怎么創(chuàng)建虛擬主機(jī)-如何創(chuàng)建虛擬主機(jī)？

閱讀 3810·2021-09-22 15:46
操作符sizeof與函數(shù)strlen哪些事

閱讀 2580·2021-09-04 16:41
前端每日實(shí)戰(zhàn)：56# 視頻演示如何用純 CSS 描述程序員的生活

閱讀 2986·2019-08-30 15:53
移動(dòng)端項(xiàng)目的注意點(diǎn)

閱讀 1265·2019-08-30 14:24
JavaScript實(shí)現(xiàn)簡單的購物車

閱讀 3058·2019-08-30 13:19
CSS中選擇器的權(quán)重值

閱讀 2174·2019-08-29 14:17
使用jQuery監(jiān)聽掃碼槍輸入并禁止手動(dòng)輸入的實(shí)現(xiàn)方法

閱讀 3526·2019-08-29 12:55

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

[譯]RabbitMQ tutorials （一）[JavaScript]

相關(guān)文章

**[譯] RabbitMQ tutorials (2) ---- 'work queue&#**

**[譯] RabbitMQ tutorials (3) ---- 'Pub/Sub'**

JavaScript正則表達(dá)式進(jìn)階指南

**【譯】RabbitMQ系列（二）-Work模式**

**【譯】RabbitMQ系列（五） - 主題模式**

發(fā)表評論

0條評論

BlackHole1

男|高級講師

TA的文章

#閃購#RackNerd：4核8G內(nèi)存100G SSD硬盤5TB流量，$89/年，洛杉磯DC02機(jī)房

怎么創(chuàng)建虛擬主機(jī)-如何創(chuàng)建虛擬主機(jī)？

操作符sizeof與函數(shù)strlen哪些事

前端每日實(shí)戰(zhàn)：56# 視頻演示如何用純 CSS 描述程序員的生活

移動(dòng)端項(xiàng)目的注意點(diǎn)

JavaScript實(shí)現(xiàn)簡單的購物車

CSS中選擇器的權(quán)重值

使用jQuery監(jiān)聽掃碼槍輸入并禁止手動(dòng)輸入的實(shí)現(xiàn)方法

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

[譯]RabbitMQ tutorials （一）[JavaScript]

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動(dòng)

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！