/сluster/bus/<CLUSTER>/ - команды управления кластерами с ролью bus
В данном разделе представлены команды управления кластерами с ролью BUS.
<NODE> - имя ноды.
<CLUSTER> - имя кластера с ролью BUS.
list
Команда просмотра списка AMQP-объектов на брокере.
Путь команды:
/cluster/bus/<CLUSTER>/list
Синтаксис:
list [<OBJECT>]
Параметры:
<OBJECT> - AMQP-объект.
Пример:
admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/list ┌─┬────────────┬──────┐ │#│ Object │Number│ ├─┼────────────┼──────┤ │1│Session │238 │ │2│Queue │399 │ │3│Subscription│754 │ │4│Exchange │25 │ │5│Binding │569 │ │6│Connections │168 │ │7│Nodes │2 │ └─┴────────────┴──────┘ [exec at: 05.02.2019 22:57:21, exec time: 91ms, nodes: mycelium1@ecss1]
ping
Команда измерения латентности взаимодействия с AMQP-брокером.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/ping
Синтаксис:
ping [<TestNum> [<Timeout>]]
Параметры:
<TestNum> - количество ping-запросов;
<Timeout> - время между отправкой повторных ping-запросов.
Пример:
admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/ping 4 total=1595 net=1061 route=9 qu=48 session=477 total=1288 net=852 route=6 qu=22 session=408 total=1304 net=830 route=6 qu=82 session=386 total=7664 net=823 route=6 qu=23 session=6812 --- ping statistics --- 4 messages transmitted, 4 messages received, 0 messages loss avarage: total=2962 net=891 route=6 qu=43 session=2020 [exec at: 05.02.2019 22:26:39, exec time: 4s 84ms, nodes: mycelium1@ecss1]
reset_stat
Команда для сброса статистики AMQP-объекта на брокере.
Путь команды:
/cluster/bus/<CLUSTER>/reset_stat [--force]
Синтаксис:
reset_stat <QUEUE> where <WHERE_CONDITION>
Параметры:
<QUEUE> - имя очереди;
<WHERE_CONDITION> - условия отбора записи;
--force - выполнение команды без запроса подтверждения.
Пример:
admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/reset_stat queue where pid = 1628
[reset_stat] You are going reset statistic data to 1 queue(s) forever.
Selected queues:
ccn.group.ecss_cm.68270355E388B6D65ED8B13B7F4274D4
Are you sure?: [n]/y ?> y
One object has been reset
[exec at: 05.02.2019 22:45:04, exec time: 5s 624ms, nodes: mycelium1@ecss1]
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/amqp2/show rejected mycelium1@ecss1/0
┌─────────┬──────────────────────────────────────────────────────────────────────────────┐
│ Key │ Value │
├─────────┼──────────────────────────────────────────────────────────────────────────────┤
│Id │mycelium1@ecss1/0 │
│Time │05.02.2019 21:50:45 │
│Reason │rejected │
│From │<<"dds.bus.7.sip1.ecss1">> │
│Cmd │{'message.transfer',<<"ecss.storage.ex">>,0,0} │
│Headers │{'message.transfer_header', │
│ │ {'message.delivery_properties',false,false,false,4,1,5000,undefined, │
│ │ undefined,undefined,<<"ecss.storage.req">>,undefined,undefined}, │
│ │ undefined, │
│ │ {'message.message_properties',undefined,undefined,undefined, │
│ │ {'message.reply_to',<<"ecss.storage.ex">>,<<"dds.bus.7.sip1.ecss1">>},│
│ │ undefined,undefined,undefined,undefined,undefined}} │
│Body size│143B │
│Body │[{'rtop-req',rtop_cluster,cluster_by_node, │
│ │ [sip1@ecss1,adapter], │
│ │ 5000, │
│ │ {<41737.2293.0>,#Ref<41737.1289111833.3967025154.27639>}, │
│ │ 0}] │
└─────────┴──────────────────────────────────────────────────────────────────────────────┘
[exec at: 05.02.2019 22:28:55, exec time: 58ms, nodes: mycelium1@ecss1]
Информация об очереди:
admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/show queue_info acp.core.core1.0.init.q Name acp.core.core1.0.init.q Alternate exchange acp.core.init.alt.ex Durable no Exclusive no Exclusive owner - Auto delete no Pid <41399.2026.0> drop_type drop arrived message Warning on overlow yes shuffle_subs no GC period (ms) never Lifetime interval (ms) 1000 Maximum possible depth 1000 QDepth current/max 0/0 MDepth current/max 0/1 Subscription number 16 Messages in/out 3/3 drop_num 0 incoming_traffic 1687 total_traffic 0 Message per second current/max 0/0 Acceptance time 0 Maximum acceptance time 0 Uptime 0d 00:42:03 [exec at: 05.02.2019 22:33:32, exec time: 66ms, nodes: mycelium1@ecss1]