RabbitMQ: примеры rabbitmqctl, rabbitmqadmin и хранение сообщений при рестарте сервера

Задача — запустить RabbitMQ сервер и создать сообщение, но таким образом, что бы оно сохранилось при рестарте сервера.

Документация по хранению данных — тут>>>.

В частности, в ней указано, что на диск будут сохранены любые типы сообщений, если RabbitMQ начинает особождать память (см. Memory Alarms), но нам требуется, что бы сообщения всегда синхронизировались в базу на диске.

Кроме того, для примера работы с rabbitmqctl и rabbitmqadmin выполним:

создадим vhost
создадим пользователя с доступом к этому вхосту
создадим очередь в этом виртуалхосте
создадим exchange для этой queue
создадим binding

Содержание

Подготовка RabbitMQ

RabbitMQ vhost

Документация — тут>>>.

Создаём виртуалхост:

root@ip-172-31-18-246:/home/admin# rabbitmqctl add_vhost examplevhost

Creating vhost "examplevhost" ...

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqctl list_vhosts
Listing vhosts ...
/
examplevhost

RabbitMQ user

Документация — тут>>>.

Создаём пользователя:

root@ip-172-31-18-246:/home/admin# rabbitmqctl add_user exampleuser examplepass

Creating user "exampleuser" ...

И права на созданный хост:

root@ip-172-31-18-246:/home/admin# rabbitmqctl set_permissions -p examplevhost exampleuser ".*" ".*" ".*"

Setting permissions for user "exampleuser" in vhost "examplevhost" ...

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass list queues

*** Access refused: /api/queues?columns=name,messages

Эм…

То же.

Проверяем лог — /var/log/rabbitmq/rabbit\@ip-172-31-18-246.log:

=WARNING REPORT==== 4-Dec-2018::15:18:26 ===
HTTP access denied: user ‘exampleuser’ — Not management user

Ах, да.

Добавляем тег «administrator«:

root@ip-172-31-18-246:/home/admin# rabbitmqctl set_user_tags exampleuser administrator

Setting tags for user "exampleuser" to [administrator] ...

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass list vhosts
+--------------+----------+
|     name     | messages |
+--------------+----------+
| /            | 1        |
| examplevhost |          |
+--------------+----------+

И очереди в нашем виртуахосте:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues

No items

RabbitMQ queues

Документация тут>>>, и хороший обзор — тут>>>.

Создаём очередь:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass declare queue --vhost=examplevhost name=examplequeue

queue declared

Ещё раз проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues
+--------------+----------+
|     name     | messages |
+--------------+----------+
| examplequeue | 0        |
+--------------+----------+

RabbitMQ exchanges

Примеры — тут>>>, описание тут>>>.

Создаём exchange:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass declare exchange --vhost=examplevhost name="exampleexchange" type="direct"

exchange declared

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list exchanges
+--------------------+---------+
|        name        |  type   |
+--------------------+---------+
|                    | direct  |
| amq.direct         | direct  |
| amq.fanout         | fanout  |
| amq.headers        | headers |
| amq.match          | headers |
| amq.rabbitmq.trace | topic   |
| amq.topic          | topic   |
| exampleexchange    | direct  |
+--------------------+---------+

RabbitMQ bindings

См. тут>>> и тут>>>.

Проверяем биндинги — сейчас тут один, дефолтный, который перенаправляет все сообщения с routing_key == examplequeue в очередь с именем examplequeue:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list bindings
+--------+--------------+--------------+
| source | destination  | routing_key  |
+--------+--------------+--------------+
|        | examplequeue | examplequeue |
+--------+--------------+--------------+

Добавляем новый:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass declare binding --vhost=examplevhost source="exampleexchange" destination_type="queue" destination="examplequeue" routing_key="examplekey"

binding declared

Что бы как-то отличать работу нашего биндинга от дефолтного — используем значение routing_key == examplekey.

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list bindings
+-----------------+--------------+--------------+
|     source      | destination  | routing_key  |
+-----------------+--------------+--------------+
|                 | examplequeue | examplequeue |
| exampleexchange | examplequeue | examplekey   |
+-----------------+--------------+--------------+

Отправляем сообщение:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass publish exchange=exampleexchange routing_key=examplekey payload="hello, world"

Message published

Проверяем очередь:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues
+--------------+----------+
|     name     | messages |
+--------------+----------+
| examplequeue | 1        |
+--------------+----------+

Получаем сообщение:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass get queue=examplequeue requeue=true
+-------------+-----------------+---------------+--------------+---------------+------------------+------------+-------------+
| routing_key |    exchange     | message_count |   payload    | payload_bytes | payload_encoding | properties | redelivered |
+-------------+-----------------+---------------+--------------+---------------+------------------+------------+-------------+
| examplekey  | exampleexchange | 0             | hello, world | 12            | string           |            | False       |
+-------------+-----------------+---------------+--------------+---------------+------------------+------------+-------------+

Используем тут параметр requeue=true, что бы сообщение осталось в очереди.

Хранение сообщений при рестарте

А теперь — перезапускаем сервер:

root@ip-172-31-18-246:/home/admin# systemctl restart rabbitmq-server

И проверяем очередь пещё раз:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues
+--------------+----------+
|     name     | messages |
+--------------+----------+
| examplequeue | 0        |
+--------------+----------+

Или с дополнительными полями:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues vhost name messages
+--------------+--------------+----------+
|    vhost     |     name     | messages |
+--------------+--------------+----------+
| examplevhost | examplequeue | 0        |
+--------------+--------------+----------+

Сообщений == 0.

Что бы RabbitMQ сохранял сообщения — необходимо два изменения.

Первое — объявить очередь как durable:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass declare queue --vhost=examplevhost name=examplequeue durable=true

queue declared

Проверяем.

Добавляем -f (format) long, и -d (depth) 2:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass list queues -f long -d 2
--------------------------------------------------------------------------------
vhost: examplevhost
name: examplequeue
...
durable: True
...

Или через RabbitMQ WebUI:

Следующим — добавляем сообщение, но указываем delivery_mode == 2:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass publish exchange=exampleexchange routing_key=examplekey payload="hello, world" properties="{\"delivery_mode\": 2}"

Message published

Проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass list queues
+--------------+----------+
|     name     | messages |
+--------------+----------+
| examplequeue | 1        |
+--------------+----------+

Ребутаем RabbitMQ:

root@ip-172-31-18-246:/home/admin# systemctl restart rabbitmq-server

Ещё раз проверяем:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -u exampleuser -p examplepass list queues
+--------------+----------+
|     name     | messages |
+--------------+----------+
| examplequeue | 1        |
+--------------+----------+

Получаем его:

root@ip-172-31-18-246:/home/admin# rabbitmqadmin -V examplevhost -u exampleuser -p examplepass get queue=examplequeue requeue=true
+-------------+-----------------+---------------+--------------+---------------+------------------+-------------+
| routing_key |    exchange     | message_count |   payload    | payload_bytes | payload_encoding | redelivered |
+-------------+-----------------+---------------+--------------+---------------+------------------+-------------+
| examplekey  | exampleexchange | 0             | hello, world | 12            | string           | False       |
+-------------+-----------------+---------------+--------------+---------------+------------------+-------------+

Всё на месте.