当前位置: 首页 > news >正文

ActiveMq工具之管理页面说明

文章目录

  • 安装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

二: 进入管理页面,主页

image-20230911113433034

各标题说明:

  • Home: 是ActiveMQ管理控制台的首页,提供了一些常用的管理功能,如停止Broker、查看Broker状态、查看所有Destination、查看网络连接情况等。
  • Queues: 显示所有队列的信息,包括队列名称、队列深度、已消费和未消费消息数量、消费者数量等,可以对队列进行删除、暂停、恢复等操作。
  • Topics: 显示所有主题的信息,包括主题名称、已发送和未发送消息数量、订阅者数量等,可以对主题进行删除、暂停、恢复等操作。
  • Subscribers: 显示所有订阅者的信息,包括订阅者ID、所订阅的主题、持久化状态、未消费和已消费的消息数量等,可以对订阅者进行删除、关闭、恢复等操作。
  • Connections: 显示所有连接到Broker的客户端连接信息,包括连接ID、客户端ID、连接时间、最后活动时间、消费者数量等,可以对连接进行强制关闭、重新连接等操作。
  • Network: 显示与其他Broker的网络连接信息,包括目标Broker、连接状态、发送和接收的消息数量等,可以对网络连接进行断开、重新连接等操作。
  • Scheduled: 显示所有已经被调度但是还没有被执行的任务,可以对任务进行删除、修改等操作。
  • Send: 提供发送消息的功能,可以选择目标队列或主题,填写消息内容、消息头等信息,进行消息的发送操作。

三: Queues页说明

image-20230911114215125

  • 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页说明

image-20230911114351788

  • Name: 队列的名称。
  • Number Of Consumers: 监听此队列的消费者数量。
  • Messages Enqueued: 已经放入到队列中但是还没有被消费者消费的消息数量。
  • Messages Dequeued: 已经被消费者消费掉的消息数量。
  • Operations: 针对队列执行的操作。
    • Send To:将消息发送到队列中。可以选择消息的类型(text 或者 bytes)以及消息的优先级。
    • Active Subscribers:显示当前订阅了该队列的消费者列表,可以查看它们的详细信息并断开连接。
    • Active Producers:显示当前向该队列发送消息的生产者列表,可以查看它们的详细信息并断开连接。
    • Delete:删除该队列。注意,删除队列将删除所有与之相关的消息,这是一个不可逆的操作。

五: Subscribers页说明

image-20230911114443659

  • 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过大则表示已经处理完成的消息数量过多,可能会导致内存占用过高,也可能会影响队列的性能。

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • kotlin 中 string array 怎么表示
  • 通信软件开发之业务知识:PON口割接什么意思?
  • 单例模式之饿汉式
  • 自定义控件之绘图篇(三)区域(Range)
  • CTFShow的RE题(三)
  • 2024年水利水电安全员考试题库及答案
  • python自动化办公之cryptography加密解密
  • 【论文解读】AGENTLESS:揭开基于LLM的软件工程代理的神秘面纱,重塑软件工程自动化新基线
  • 力扣139 单词拆分 Java版本
  • 本安防爆手机:危险环境下的安全通信解决方案
  • 剖析DeFi交易产品之UniswapV3:交易路由合约
  • MySQL架构和工作流程
  • uniapp video视频铺满容器,不显示控件
  • DDR3(三)
  • EtherCAT主站IGH-- 9 -- IGH之eoe_request.h/c文件解析
  • 【Linux系统编程】快速查找errno错误码信息
  • Android系统模拟器绘制实现概述
  • HTTP中GET与POST的区别 99%的错误认识
  • isset在php5.6-和php7.0+的一些差异
  • java第三方包学习之lombok
  • js操作时间(持续更新)
  • Traffic-Sign Detection and Classification in the Wild 论文笔记
  • Vue UI框架库开发介绍
  • 等保2.0 | 几维安全发布等保检测、等保加固专版 加速企业等保合规
  • 开发了一款写作软件(OSX,Windows),附带Electron开发指南
  • 新手搭建网站的主要流程
  • 用 Swift 编写面向协议的视图
  • 优秀架构师必须掌握的架构思维
  • 怎么把视频里的音乐提取出来
  • ​RecSys 2022 | 面向人岗匹配的双向选择偏好建模
  • # dbt source dbt source freshness命令详解
  • ###51单片机学习(1)-----单片机烧录软件的使用,以及如何建立一个工程项目
  • #etcd#安装时出错
  • #微信小程序:微信小程序常见的配置传旨
  • #预处理和函数的对比以及条件编译
  • $ is not function   和JQUERY 命名 冲突的解说 Jquer问题 (
  • (ctrl.obj) : error LNK2038: 检测到“RuntimeLibrary”的不匹配项: 值“MDd_DynamicDebug”不匹配值“
  • (Java入门)抽象类,接口,内部类
  • (附源码)springboot 个人网页的网站 毕业设计031623
  • (附源码)springboot课程在线考试系统 毕业设计 655127
  • (附源码)ssm基于微信小程序的疫苗管理系统 毕业设计 092354
  • (深度全面解析)ChatGPT的重大更新给创业者带来了哪些红利机会
  • (十)T检验-第一部分
  • (微服务实战)预付卡平台支付交易系统卡充值业务流程设计
  • (轉貼) UML中文FAQ (OO) (UML)
  • .net core 6 redis操作类
  • .net core IResultFilter 的 OnResultExecuted和OnResultExecuting的区别
  • .NET Core工程编译事件$(TargetDir)变量为空引发的思考
  • .NET IoC 容器(三)Autofac
  • .NET MVC之AOP
  • .net 使用ajax控件后如何调用前端脚本
  • .NET高级面试指南专题十一【 设计模式介绍,为什么要用设计模式】
  • .NET开源、简单、实用的数据库文档生成工具
  • .NET企业级应用架构设计系列之应用服务器
  • .net中的Queue和Stack