资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/[译]RabbitMQ tutorials （一）[JavaScript]

[译]RabbitMQ tutorials （一）[JavaScript]

BlackHole1 / 1560人阅读

摘要：允许接收和转发消息。一个等待接收消息的程序是一个消费者。发送者会先连接到发送一条消息，然后退出。注意这里的是要和之前的名称一致。翻译日期另因为想入门第一次想着翻译，第一次然后希望多多提出不足。

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

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

原文

介绍

RabbitMQ 是一个消息代理，其主要思想比较简单。允许接收和转发消息。你可以把RabbitMQ想成是一个邮局，当你发一份邮件到邮箱，你相当确定邮递员最终会把这封信送到你的收件人那边。
使用这个比喻，RabbitMQ可以是一个邮箱，或一个邮局，或一个邮递员。
其与邮局主要的不同是实际上RabbitMQ并不处理内容，而是接收，存储然后转发二进制数据--消息（message）

在RabbitMQ的消息传递上，我们用一些术语来解释：

生产（Producing） 意味着只做发送的事情。一个发送消息（message）的程序可以作为一个生产者（producer）.图如下，代号‘P’

队列（queue）是一个邮箱的名字，存在在 RabbitMQ中。尽管消息（messages）是在RabbitMQ和你的应用中传递，但是它们只能被存到一个队列中。这个队列没有任何限制，可以存储你想要的任何多的消息，实际上，它就是一个无限的Buffer，大量生产者可以把消息发送到一个
队列中，消费者们可以尝试从一个队列中去接收数据。一个队列可以画成下图所示：上方是它的名字

消费（Consuming）和接收的意思类似。一个等待接收消息的程序是一个消费者（Consumer）。如下图所示，代号“C”：

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

在这个部分的引导中，我们会写两个Javascript小程序，一个生产者用来发送一条消息，一个消费者来接收消息并打印出来。考虑到这只是一个起步入门的小代码，消息传送一个‘hello world’
在途中，“P”是我们的生产者，“C”是我们的消费者，在中间的盒子是一个队列（queue）,一个RabiitMQ用来给消费者代理的buffer.

amqp.node 客户端库
RabbitMQ 支持多种协议，在引导中，使用AMQP 0-9-1,它是一个开源的，通用的消息传递协议。支持很多不同语言的RabbitMQ的客户端库，在这里我们使用amqp.node （Javascript）

在一开始，我们使用npm 来安装这个库
$ npm install amqplib

现在我们已经安装了amqp.node了，我们可以写一些代码了

发送（Sending）：

我们把消息发送者的文件取名send.js，同理，消息接收者的文件为receive.js。发送者会先连接到RabbitMQ,发送一条消息，然后退出。

在send.js中，我们先导入库

#!/usr/bin/env node

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

再连接到RabbitMQ服务器
amqp.connect("amqp://localhst), function(err, conn) {} )

接着我们创建一个通道(channel)，之后大部分的API会使用这个通道

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

去发送的时候，我们必需声明一个队列（queue）,然后把消息发布到这个队列中

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!"");
  });
});

声明一个队列是幂等的[2] -- 只有在不存在的时候才会被创建。消息（message）的内容是一个位数组，所以你可以使用你喜欢的编码。
最后，我们要关闭这个连接并且退出

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

接收（Receiving）
以上就是发送的代码。我们的接收者是从RabbitMQ接收推送消息的，所以不同与发送者只需要发布一条简单的消息，我们需要保持程序持续运行，去监听消息并打印出来

在receive.js中，require同理

#!/usr/bin/env node

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

基础设置和send.js一致，先创建连接和通道，然后再声明一个我们要去消费的队列（queue）。注意：这里的queue是要和之前sendToQueue的名称一致。

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

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

注意：我们在这里也同样需要声明queue，因为我们可能先启动接收（receiver）再启动发送（sender），我们要保证当我们去从队列中取消息的时候，这个队列是存在的。

我们将会告诉服务器，我们要从这个队列取消息。由于推送给我们消息是异步的，我们需要写一个回调函数（callback），当RabbitMQ给消费者推送消息的时候执行。
这就是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）

现在我们可以运行我们的这两个脚本了，在终端，我们去跑这两个脚本

sender:

$ ./sender.js

receive:

$ ./receive.js

reciever 中会打印一条从RabbitMQ中获取到的消息，并会持续运行（使用 ctrl+c 停止运行），等待新的消息推送。所以，你可以在其他终端再跑一次sender。
如果你想查看队列中的内容，可以使用rabbitmqctl list_queues

Hello World

下一节，将会讲到去搭建一个简单的工作队列

[1]. amqplib API

[2]. 在编程中.一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。

小结： 消息队列从字面上就是一个管理消息的队列，存在消费者和生产者，缓存队列，他们可以订阅同一个queue。

翻译：Joursion

日期 ：2016/12/21

另: 因为想入门RabbitMQ, 第一次想着翻译，第一次...然后... 希望多多提出不足。 Thanks~

GPU云服务器 云服务器 Tutorials Tutorial RabbitMQ rabbitmq 事务消息

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/88112.html

相关文章

  • [译] RabbitMQ tutorials (2) ---- 'work queue&#

    摘要：这样的消息分发机制称作轮询。在进程挂了之后，所有的未被确认的消息会被重新分发。忘记确认这是一个普遍的错误，丢失。为了使消息不会丢失，两件事情需要确保，我们需要持久化队列和消息。 工作队列 showImg(https://segmentfault.com/img/remote/1460000008229494?w=332&h=111); 在第一篇中，我们写了一个程序从已经声明的队列中收发...

    joyvw 评论0 收藏0

  • [译] RabbitMQ tutorials (3) ---- 'Pub/Sub'

    摘要：生产者只能把消息发到交换器。是否要追加到一个特殊的队列是否要追加到许多的队列或者丢掉这条消息这些规则被定义为交换类型。有一点很关键，向不存在的交换器发布消息是被禁止的。如果仍然没有队列绑定交换器，消息会丢失。 发布与订阅 （Publish/Subscribe） 在之前的章节中，我们创建了工作队列，之前的工作队列的假设是每个任务只被分发到一个worker。在这一节中，我们会做一些完全不一...

    zzir 评论0 收藏0

  • JavaScript正则表达式进阶指南

    摘要：非贪婪匹配默认情况下，正则表达式的量词，都是进行贪婪匹配，即匹配尽可能多的字符。参考正则表达式关于专注于微信小程序微信小游戏支付宝小程序和线上应用实时监控。自从年双十一正式上线，累计处理了亿错误事件，付费客户有金山软件百姓网等众多品牌企业。 摘要：正则表达式是程序员的必备技能，想不想多学几招呢？ showImg(https://segmentfault.com/img/bV9L9n?w...

    xietao3 评论0 收藏0

  • 【译】RabbitMQ系列（二）-Work模式

    摘要：每个消费者会得到平均数量的。为了确保不会丢失，采用确认机制。如果中断退出了关闭了，关闭了，或是连接丢失了而没有发送，会认为该消息没有完整的执行，会将该消息重新入队。该消息会被发送给其他的。当消费者中断退出，会重新分派。 Work模式 原文地址showImg(https://segmentfault.com/img/bVbqlXr?w=694&h=252); 在第一章中，我们写了通过一个...

    lcodecorex 评论0 收藏0

  • 【译】RabbitMQ系列（五） - 主题模式

    摘要：主题模式在上一章我们改进了我们的日志系统，如果使用我们只能简单进行广播，而使用则允许消费者可以进行一定程度的选择。为的会同时发布到这两个。当为时，会接收所有的。当中没有使用通配符和时，的行为和一致。 主题模式 在上一章我们改进了我们的日志系统，如果使用fanout我们只能简单进行广播，而使用direct则允许消费者可以进行一定程度的选择。但是direct还是有其局限性，其路由不支持多个...

    pingan8787 评论0 收藏0

发表评论

登陆后可评论

0条评论

BlackHole1

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<