-
Notifications
You must be signed in to change notification settings - Fork 0
rabbitmq
Luke Chen edited this page Jan 30, 2021
·
10 revisions
https://www.rabbitmq.com/download.html
$ sudo service rabbitmq-server stop
$ sudo service rabbitmq-server start
https://www.rabbitmq.com/monitoring.html#health-checks
$ sudo service rabbitmq-server status
● rabbitmq-server.service - RabbitMQ broker
Loaded: loaded (/lib/systemd/system/rabbitmq-server.service; enabled; ven>
Active: active (running) since Tue 2020-12-29 00:35:05 EST; 47s ago
Main PID: 31113 (beam.smp)
Status: "Initialized"
Tasks: 87 (limit: 9454)
Memory: 75.6M
CGroup: /system.slice/rabbitmq-server.service
├─31113 /usr/lib/erlang/erts-11.1.5/bin/beam.smp -W w -K true -A >
├─31233 erl_child_setup 32768
├─31259 /usr/lib/erlang/erts-11.1.5/bin/epmd -daemon
├─31282 inet_gethost 4
└─31283 inet_gethost 4
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: ########## Licensed under th>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Doc guides: https://rabbitmq.>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Support: https://rabbitmq.>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Tutorials: https://rabbitmq.>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Monitoring: https://rabbitmq.>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Logs: /var/log/rabbitmq/rabbi>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: /var/log/rabbitmq/rabbi>
Dec 29 00:35:04 ubuntu rabbitmq-server[31113]: Config file(s): (none)
Dec 29 00:35:05 ubuntu rabbitmq-server[31113]: Starting broker... completed >
Dec 29 00:35:05 ubuntu systemd[1]: Started RabbitMQ broker.
$ systemctl |grep rabbitmq-server
rabbitmq-server.service loaded active running RabbitMQ broker
rabbitmqctl and rabbitmq-diagnostics
$ sudo rabbitmq-diagnostics ping
Will ping rabbit@ubuntu. This only checks if the OS process is running and registered with epmd. Timeout: 60000 ms.
Ping succeeded
$ sudo rabbitmq-diagnostics status
Status of node rabbit@ubuntu ...
Runtime
OS PID: 31113
OS: Linux
Uptime (seconds): 749
Is under maintenance?: false
RabbitMQ version: 3.8.9
Node name: rabbit@ubuntu
Erlang configuration: Erlang/OTP 23 [erts-11.1.5] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:64]
Erlang processes: 279 used, 1048576 limit
Scheduler run queue: 1
Cluster heartbeat timeout (net_ticktime): 60
Plugins
Enabled plugin file: /etc/rabbitmq/enabled_plugins
Enabled plugins:
Data directory
Node data directory: /var/lib/rabbitmq/mnesia/rabbit@ubuntu
Raft data directory: /var/lib/rabbitmq/mnesia/rabbit@ubuntu/quorum/rabbit@ubuntu
Config files
Log file(s)
* /var/log/rabbitmq/rabbit@ubuntu.log
* /var/log/rabbitmq/rabbit@ubuntu_upgrade.log
Alarms
(none)
Memory
Total memory used: 0.0812 gb
Calculation strategy: rss
Memory high watermark setting: 0.4 of available memory, computed to: 3.328 gb
code: 0.0291 gb (35.83 %)
other_proc: 0.0233 gb (28.65 %)
other_system: 0.0124 gb (15.29 %)
reserved_unallocated: 0.0066 gb (8.12 %)
allocated_unused: 0.0046 gb (5.63 %)
other_ets: 0.0029 gb (3.56 %)
atom: 0.0014 gb (1.68 %)
plugins: 0.0005 gb (0.58 %)
metrics: 0.0002 gb (0.24 %)
binary: 0.0002 gb (0.22 %)
mnesia: 0.0001 gb (0.1 %)
quorum_ets: 0.0 gb (0.06 %)
msg_index: 0.0 gb (0.04 %)
connection_channels: 0.0 gb (0.0 %)
connection_other: 0.0 gb (0.0 %)
connection_readers: 0.0 gb (0.0 %)
connection_writers: 0.0 gb (0.0 %)
mgmt_db: 0.0 gb (0.0 %)
queue_procs: 0.0 gb (0.0 %)
queue_slave_procs: 0.0 gb (0.0 %)
quorum_queue_procs: 0.0 gb (0.0 %)
File Descriptors
Total: 2, limit: 32671
Sockets: 0, limit: 29401
Free Disk Space
Low free disk space watermark: 0.05 gb
Free disk space: 86.7532 gb
Totals
Connection count: 0
Queue count: 0
Virtual host count: 1
Listeners
Interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
Interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
sudo rabbitmq-diagnostics environment
$ sudo rabbitmqctl list_queues
[sudo] password for lchen154:
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
name messages
hello 2
https://www.rabbitmq.com/getstarted.html
https://www.rabbitmq.com/tutorials/tutorial-one-python.html
python -m pip install pika --upgrade
- Looks like newly added worker doesn't immediately handle existing tasks in queue. But have to wait for new tasks to be added. https://github.com/lukechendev/purecoding/blob/master/workspace_systemdesign/rabbitmq/a02_multi_tasks.py https://github.com/lukechendev/purecoding/blob/master/workspace_systemdesign/rabbitmq/a02_worker.py