/сluster/bus/<CLUSTER>/ — команды управления кластерами с ролью bus
В данном разделе представлены команды управления кластерами с ролью BUS.
<NODE> — имя ноды.
<CLUSTER> — имя кластера с ролью BUS.
list
Команда просмотра списка AMQP-объектов на брокере.
Путь команды:
/cluster/bus/<CLUSTER>/list
Синтаксис:
list [<OBJECT>]
Параметры:
<OBJECT> — AMQP-объект.
Пример:
admin@mycelium1@ecss1:/$ cluster/bus/testnew/list ┌─┬────────────┬──────┐ │#│ Object │Number│ ├─┼────────────┼──────┤ │1│Session │241 │ │2│Queue │595 │ │3│Subscription│1339 │ │4│Exchange │25 │ │5│Binding │783 │ │6│Connections │184 │ │7│Nodes │2 │ └─┴────────────┴──────┘ [exec at: 09.03.2021 21:15:06, exec time: 55ms, nodes: mycelium1@ecss1 v.3.14.8.22]
ping
Команда измерения латентности взаимодействия с AMQP-брокером.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/ping
Синтаксис:
ping [<TestNum> [<Timeout>]]
Параметры:
<TestNum> — количество ping-запросов;
<Timeout> — время между отправкой повторных ping-запросов.
Пример:
admin@mycelium1@ecss1:/$ cluster/bus/testnew/ping 4 total=3174 net=2092 route=14 qu=87 session=981 total=2732 net=1710 route=14 qu=56 session=952 total=2602 net=1720 route=14 qu=80 session=788 total=2763 net=1800 route=12 qu=50 session=901 --- ping statistics --- 4 messages transmitted, 4 messages received, 0 messages loss avarage: total=2817 net=1830 route=13 qu=68 session=905 [exec at: 09.03.2021 21:15:52, exec time: 4s 25ms, nodes: mycelium1@ecss1 v.3.14.8.22]
reset_stat
Команда для сброса статистики AMQP-объекта на брокере.
Путь команды:
/cluster/bus/<CLUSTER>/reset_stat [--force]
Синтаксис:
reset_stat <QUEUE> where <WHERE_CONDITION>
Параметры:
<QUEUE> — имя очереди;
<WHERE_CONDITION> — условия отбора записи;
--force — выполнение команды без запроса подтверждения.
Пример:
admin@mycelium1@ecss1:/$ cluster/bus/testnew/reset_stat queue where name = acp.sip.064f4889f2a0b987.1.q
[reset_stat] You are going reset statistic data to 1 queue(s) forever.
Selected queues:
acp.sip.064f4889f2a0b987.1.q
Are you sure?: [n]/y ?> y
One object has been reset
[exec at: 09.03.2021 21:25:44, exec time: 4s 761ms, nodes: mycelium1@ecss1 v.3.14.8.22]
show
Команда просмотра параметров AMQP-объекта на брокере.
Путь команды:
/cluster/bus/<CLUSTER>/show
Синтаксис:
show message <Qu> <MsgId> — просмотр информации об определенном сообщении в очереди;
show rejected <Node>/<MsgId> — просмотр информации об определенном сообщении, которое было отклонено;
show queue <Qu> — просмотр информации об определенной очереди;
show dropped <Node>/<MsgId> — просмотр информации об определенном сообщении, которое было потеряно;
show queue_info <Qu> — Print info about specified queue
Параметры:
<Qu> — очередь AMQP;
<MsgId> — идентификатор сообщения;
<Node> — имя ноды.
Пример:
Информация об очереди::
admin@mycelium1@ecss1:/$ cluster/bus/testnew/show queue_info ccn.node.core1.ecss1 Name ccn.node.core1.ecss1 Alternate exchange - Durable no Exclusive yes Exclusive owner ccn.node.core1.ecss1 Auto delete yes Pid <0.2638.0> drop_type drop arrived message Warning on overlow yes shuffle_subs no GC period (ms) never Lifetime interval (ms) 60000 Maximum possible depth undefined QDepth current/max 0/0 MDepth current/max 0/5 Subscription number 1 Messages in/out 306/306 drop_num 0 incoming_traffic 424473 total_traffic 0 Message per second current/max 0/8 Acceptance time 0 Maximum acceptance time 27'139 Uptime 0d 00:40:24 [exec at: 09.03.2021 21:18:47, exec time: 7ms, nodes: mycelium1@ecss1 v.3.14.8.22]