"Hello World!"¶

Введение¶

RabbitMQ — это брокер сообщений: он принимает и пересылает сообщения. Можно сравнить его с почтовым отделением: когда вы опускаете письмо в почтовый ящик, вы можете быть уверены, что почтальон в конечном итоге доставит его адресату. В этой аналогии RabbitMQ — это почтовый ящик, почтовое отделение и почтальон.

Основное отличие RabbitMQ от почтового отделения заключается в том, что он не работает с бумагой, а принимает, хранит и пересылает двоичные блоки данных — «сообщения».

RabbitMQ, как и системы обмена сообщениями в целом, использует некоторый жаргон.

• Производство означает не что иное, как отправку. Программа, которая отправляет сообщения, является производителем:

  flowchart LR
      P((P))
      class P mermaid-producer

• Очередь — это название почтового ящика в RabbitMQ. Хотя сообщения проходят через RabbitMQ и ваши приложения, они могут храниться только в очереди. Очередь ограничена только объемом памяти и дискового пространства хоста, по сути, это большой буфер сообщений.

  Многие производители могут отправлять сообщения, которые поступают в одну очередь, а многие потребители могут пытаться получать данные из одной очереди.

  Так мы представляем очередь:

  flowchart LR
      Q[[queue_name]]
      class Q mermaid-queue

• Потребление имеет значение, схожее с получением. Потребитель — это программа, которая в основном ожидает получения сообщений:

  flowchart LR
      C((C))
      class C mermaid-consumer

Обратите внимание, что производитель, потребитель и брокер не обязательно должны находиться на одном хосте; в большинстве приложений это не так. Приложение может быть одновременно и производителем, и потребителем.

«Hello World»¶

В этой части учебника мы напишем две небольшие программы на Javascript: производителя, который отправляет одно сообщение, и потребителя, который принимает сообщения и выводит их на печать. Мы не будем вдаваться в подробности API amqp.node, сосредоточившись на этой очень простой задаче, чтобы начать работу. Это «Hello World» в области обмена сообщениями.

На схеме ниже «P» — наш производитель, а «C» — наш потребитель. Блок в середине — это очередь, буфер сообщений, который RabbitMQ хранит от имени потребителя.

flowchart LR
    P((P))
    Q[[hello]]
    C((C))

    P --> Q --> C

    class P mermaid-producer
    class Q mermaid-queue
    class C mermaid-consumer

1

npm install amqplib

Теперь, когда мы установили amqp.node, можем приступить к написанию кода.

Отправка¶

flowchart LR
    P((P)) --> Q[[hello]]

    class P mermaid-producer
    class Q mermaid-queue

Мы назовем наш производитель сообщений (отправитель) send.js, а наш потребитель сообщений (получатель) receive.js. Производитель подключится к RabbitMQ, отправит одно сообщение, а затем завершит работу.

В send.js нам сначала нужно подключить библиотеку:

1
2
3

#!/usr/bin/env node

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

затем подключимся к серверу RabbitMQ

1
2
3
4

amqp.connect('amqp://localhost', function (
    error0,
    connection
) {});

Далее мы создаем канал, в котором находится большая часть API для выполнения задач:

1
2
3
4
5
6
7
8
9

amqp.connect('amqp://localhost', function (
    error0,
    connection
) {
    if (error0) {
        throw error0;
    }
    connection.createChannel(function (error1, channel) {});
});

Чтобы отправить сообщение, мы должны объявить очередь, в которую мы будем отправлять сообщения; затем мы можем опубликовать сообщение в этой очереди:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

amqp.connect('amqp://localhost', function (
    error0,
    connection
) {
    if (error0) {
        throw error0;
    }
    connection.createChannel(function (error1, channel) {
        if (error1) {
            throw error1;
        }
        var queue = 'hello';
        var msg = 'Hello world';

        channel.assertQueue(queue, {
            durable: false,
        });

        channel.sendToQueue(queue, Buffer.from(msg));
        console.log(' [x] Sent %s', msg);
    });
});

Объявление очереди является идемпотентным — она будет создана только в том случае, если еще не существует. Содержимое сообщения представляет собой массив байтов, поэтому вы можете кодировать в нем все, что угодно.

Наконец, мы закрываем соединение и выходим:

1
2
3
4

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

Вот весь скрипт send.js.

Прием¶

На этом все для нашего издателя. Наш потребитель прослушивает сообщения от RabbitMQ, поэтому, в отличие от издателя, который публикует одно сообщение, мы будем держать потребителя в рабочем состоянии, чтобы он прослушивал сообщения и распечатывал их.

flowchart LR
    Q[[hello]] --> C((C))

    class Q mermaid-queue
    class C mermaid-consumer

Код (в receive.js) имеет тот же require, что и send.js:

1
2
3

#!/usr/bin/env node

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

Настройка такая же, как и у издателя: мы открываем соединение и канал, а также объявляем очередь, из которой будем потреблять данные. Обратите внимание, что она совпадает с очередью, в которую публикует sendToQueue.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

amqp.connect('amqp://localhost', function (
    error0,
    connection
) {
    if (error0) {
        throw error0;
    }
    connection.createChannel(function (error1, channel) {
        if (error1) {
            throw error1;
        }
        var queue = 'hello';

        channel.assertQueue(queue, {
            durable: false,
        });
    });
});

Обратите внимание, что мы также объявляем очередь здесь. Поскольку мы можем запустить потребителя раньше издателя, мы хотим убедиться, что очередь существует, прежде чем пытаться потреблять сообщения из нее.

Мы собираемся попросить сервер доставить нам сообщения из очереди. Поскольку он будет отправлять нам сообщения асинхронно, мы предоставляем обратный вызов, который будет выполняться, когда RabbitMQ отправляет сообщения нашему потребителю. Это то, что делает Channel.consume.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

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

Вот весь скрипт receive.js.

Сборка всего вместе¶

Теперь мы можем запустить оба скрипта. В терминале, из папки rabbitmq-tutorials/javascript-nodejs/src/, запустите издателя:

1

./send.js

затем запустите потребителя:

1

./receive.js

Потребитель будет печатать сообщение, полученное от издателя через RabbitMQ. Потребитель будет продолжать работать, ожидая сообщений (для остановки нажмите Ctrl+C), поэтому попробуйте запустить издателя из другого терминала.

1

sudo rabbitmqctl list_queues

1

rabbitmqctl.bat list_queues

Пришло время перейти к части 2 и создать простую очередь задач.

Источник — https://www.rabbitmq.com/tutorials/tutorial-one-javascript

Комментарии