文章目錄
- 安裝ActiveMQ
- 一: 訪問管理頁面
- 二: 進入管理頁面,主頁
- 三: Queues頁說明
- 四: Topics頁說明
- 五: Subscribers頁說明
安裝ActiveMQ
wget https://archive.apache.org/dist//activemq/5.13.3/apache-activemq-5.13.3-bin.tar.gz
wget https://mirrors.huaweicloud.com/java/jdk/8u201-b09/jdk-8u201-linux-x64.tar.gz# 配置Java環境
tar xf jdk-8u201-linux-x64.tar.gz
cat >> /etc/profile << 'EOF'
export JAVA_HOME=/usr/local/src/jdk1.8.0_201/
export PATH=$PATH:$JAVA_HOME/bin
EOF
source /etc/profile
java -version # 測試一下可以查看到jdk環境么# 安裝ActiveMQ
tar xf apache-activemq-5.13.3-bin.tar.gz
cd apache-activemq-5.13.3/bin
./activemq start|stop|restart|status# 修改ActiveMQ jvm大小
apache-activemq-5.13.3/bin/env
# Set jvm memory configuration (minimal/maximum amount of memory)
ACTIVEMQ_OPTS_MEMORY="-Xms8192M -Xmx8192M"./activemq restarthttps://blog.csdn.net/huxiaodong1994/article/details/100050942
# 通過system管理activemq
cat /usr/lib/systemd/system/activemq.service[Unit]
Description=ActiveMQ service
After=network.target[Service]
Type=forking
ExecStart=/data/apache-activemq-5.13.3/bin/activemq start
ExecStop=/data/apache-activemq-5.13.3/bin/activemq stop
User=root
Group=root
Restart=always
RestartSec=9
StandardOutput=syslog
StandardError=syslog
SyslogIdentifier=activemq[Install]
WantedBy=multi-user.target
一: 訪問管理頁面
http://服務器IP地址:8161/admin/
Login: admin
Passwort: admin
二: 進入管理頁面,主頁
各標題說明:
- Home: 是ActiveMQ管理控制臺的首頁,提供了一些常用的管理功能,如停止Broker、查看Broker狀態、查看所有Destination、查看網絡連接情況等。
- Queues: 顯示所有隊列的信息,包括隊列名稱、隊列深度、已消費和未消費消息數量、消費者數量等,可以對隊列進行刪除、暫停、恢復等操作。
- Topics: 顯示所有主題的信息,包括主題名稱、已發送和未發送消息數量、訂閱者數量等,可以對主題進行刪除、暫停、恢復等操作。
- Subscribers: 顯示所有訂閱者的信息,包括訂閱者ID、所訂閱的主題、持久化狀態、未消費和已消費的消息數量等,可以對訂閱者進行刪除、關閉、恢復等操作。
- Connections: 顯示所有連接到Broker的客戶端連接信息,包括連接ID、客戶端ID、連接時間、最后活動時間、消費者數量等,可以對連接進行強制關閉、重新連接等操作。
- Network: 顯示與其他Broker的網絡連接信息,包括目標Broker、連接狀態、發送和接收的消息數量等,可以對網絡連接進行斷開、重新連接等操作。
- Scheduled: 顯示所有已經被調度但是還沒有被執行的任務,可以對任務進行刪除、修改等操作。
- Send: 提供發送消息的功能,可以選擇目標隊列或主題,填寫消息內容、消息頭等信息,進行消息的發送操作。
三: Queues頁說明
- Name:消息隊列的名稱。
- Number Of Pending Messages:等待消費者處理的消息數量。
- Number Of Consumers:當前連接到消息隊列的消費者數量。
- Messages Enqueued:消息隊列收到的消息總數。
- Messages Dequeued:消費者處理的消息總數。
- Views:查看隊列詳細信息的鏈接,例如消息的詳細信息、歷史消息等。
- Browse:查看隊列中的所有消息,可以按照不同的排序方式對消息進行排序,也可以對消息進行刪除或重新發送等操作。
- Active Consumers:查看當前正在消費該隊列的所有消費者信息,包括消費者的ID、連接信息、消費狀態等。
- Active Producers:查看當前正在向該隊列發送消息的所有生產者信息,包括生產者的ID、連接信息、發送狀態等。
- Operations:執行隊列操作的鏈接,例如刪除隊列、重新啟動隊列等。
- Send To:可以向選定的隊列發送消息。可以選擇發送的消息的類型,例如文本或字節消息,并設置消息屬性和有效期。
- Purge:可以清空選定隊列的所有消息,這個操作是不可逆的,請慎重使用。
- Delete:可以刪除選定的隊列。刪除隊列時,所有該隊列的消息將被刪除,并且無法恢復。請確保在刪除隊列之前已經備份了所需的消息數據。
- Pause:可以暫停選定隊列的消息傳遞。這個操作可以讓你在不刪除隊列的情況下停止消費消息,等到問題解決后再繼續消費。
四: Topics頁說明
- Name: 隊列的名稱。
- Number Of Consumers: 監聽此隊列的消費者數量。
- Messages Enqueued: 已經放入到隊列中但是還沒有被消費者消費的消息數量。
- Messages Dequeued: 已經被消費者消費掉的消息數量。
- Operations: 針對隊列執行的操作。
- Send To:將消息發送到隊列中。可以選擇消息的類型(text 或者 bytes)以及消息的優先級。
- Active Subscribers:顯示當前訂閱了該隊列的消費者列表,可以查看它們的詳細信息并斷開連接。
- Active Producers:顯示當前向該隊列發送消息的生產者列表,可以查看它們的詳細信息并斷開連接。
- Delete:刪除該隊列。注意,刪除隊列將刪除所有與之相關的消息,這是一個不可逆的操作。
五: Subscribers頁說明
- Client ID:訂閱的客戶端ID。
- Subscription Name:訂閱的名稱。
- Connection ID:訂閱所屬的連接ID。
- Destination:訂閱的目的地,即所訂閱的隊列或主題。
- Selector:訂閱的消息過濾器。
- Pending Queue Size:尚未分發的消息數,表示等待處理的消息數量,即還沒有被消費者消費的消息數量。
- Dispatched Queue Size:已經分發但還沒有被消費的消息數,表示已經被調度(分發)給消費者處理的消息數量,但尚未被消費者
- 確認處理完成的消息數量。
- Dispatched Counter:已經成功分發并被消費的消息數,表示已經被消費者確認處理完成的消息數量。
- Enqueue Counter:已經被加入隊列的消息數。
- Dequeue Counter:已經被消費的消息數。
- Operations:可對訂閱進行的操作,包括刪除、恢復、暫停等。
注意事項:
Pending Queue Size,dispatched queue size,dispatched counter
這三個指標都是用來衡量ActiveMQ消息隊列中消息處理的情況的:
- Pending Queue Size:表示等待處理的消息數量,即還沒有被消費者消費的消息數量。
- Dispatched Queue Size:表示已經被調度(分發)給消費者處理的消息數量,但尚未被消費者確認處理完成的消息數量。
- Dispatched Counter:表示已經被消費者確認處理完成的消息數量。
其中,Dispatched Queue Size和Dispatched Counter都是用來跟蹤消息處理的進度的,Pending Queue Size則表示隊列的積壓情況。
Pending Queue Size
過大時,會導致隊列中的消息堆積,可能會影響系統性能和可用性。Dispatched Queue Size
過大則表示已經分發但尚未確認處理完成的消息太多,可能會導致消費者處理不過來,從而影響系統吞吐量和延遲。Dispatched Counter
過大則表示已經處理完成的消息數量過多,可能會導致內存占用過高,也可能會影響隊列的性能。