一、启动RocketMQ
1)先启动NameServer
nohup sh mqnamesrv > ns.log 2>&1 &
实质启动的是com.alibaba.rocketmq.namesrv.NamesrvStartup对应的main()
备注runserver.sh 是一堆JVM参数
2)再启动Broker,默认端口9876
nohup sh mqbroker -n IP:Port > bk.log 2>&1 &
实质启动的是com.alibaba.rocketmq.broker.BrokerStartup对应的main()
备注runbroker.sh 是一堆JVM参数
总结：一步到位启动只需要运行 sh play.sh即可
[root@master bin]# sh play.sh
Start Name Server and Broker Successfully, 192.168.1.103:9876
二、查看帮助
[root@master bin]# sh mqadmin
The most commonly used mqadmin commands are:
updateTopic Update or create topic
deleteTopic Delete topic from broker and NameServer.
updateSubGroup Update or create subscription group
deleteSubGroup Delete subscription group from broker.
updateBrokerConfig Update broker's config
topicRoute Examine topic route info
topicStatus Examine topic Status info
brokerStatus Fetch broker runtime status data
queryMsgById Query Message by Id
queryMsgByKey Query Message by Key
queryMsgByOffset Query Message by offset
printMsg Print Message Detail
producerConnection Query producer's socket connection and client version
consumerConnection Query consumer's socket connection, client version and subscription
consumerProgress Query consumers's progress, speed
consumerStatus Query consumer's internal data structure
cloneGroupOffset clone offset from other group.
clusterList List all of clusters
topicList Fetch all topic list from name server
updateKvConfig Create or update KV config.
deleteKvConfig Delete KV config.
wipeWritePerm Wipe write perm of broker in all name server
resetOffsetByTime Reset consumer offset by timestamp(without client restart).
updateOrderConf Create or update or delete order conf
cleanExpiredCQ Clean expired ConsumeQueue on broker.
startMonitoring Start Monitoring
checkMsg Check Message Store
statsAll Topic and Consumer tps stats
syncDocs Synchronize wiki and issue to github.com
See 'mqadmin help <command>' for more information on a specific command.
1）查看Topic列表
[root@master bin]# sh mqadmin help topicList
usage: mqadmin topicList [-c] [-h] [-n <arg>]
-c,--clusterModel clusterModel
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin topicList -n 192.168.1.103:9876
BenchmarkTest
TopicTest
DefaultCluster
SELF_TEST_TOPIC
%RETRY%please_rename_unique_group_name_4
TBW102
master
OFFSET_MOVED_EVENT
[root@master bin]#
2）创建Topic
[root@master bin]# sh mqadmin help updateTopic
usage: mqadmin updateTopic [-b <arg>] [-c <arg>] [-h] [-n <arg>] [-o <arg>] [-p <arg>] [-r <arg>] [-s <arg>]
-t <arg> [-u <arg>] [-w <arg>]
-b,--brokerAddr <arg> create topic to which broker
-c,--clusterName <arg> create topic to which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-o,--order <arg> set topic's order(true|false
-p,--perm <arg> set topic's permission(2|4|6), intro[2:R; 4:W; 6:RW]
-r,--readQueueNums <arg> set read queue nums
-s,--hasUnitSub <arg> has unit sub (true|false
-t,--topic <arg> topic name
-u,--unit <arg> is unit topic (true|false
-w,--writeQueueNums <arg> set write queue nums
[root@m bin]# sh mqadmin updateTopic -n 192.168.1.103:9876 -b 192.168.1.103:10911 -t gaojingsong
create topic to 192.168.1.103:10911 success.
TopicConfig [topicName=gaojingsong, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]
[root@master bin]# sh mqadmin topicList -n 192.168.1.103:9876
BenchmarkTest
TopicTest
DefaultCluster
SELF_TEST_TOPIC
%RETRY%please_rename_unique_group_name_4
TBW102
gaojingsong
master
OFFSET_MOVED_EVENT
3）统计Topic信息
[root@master bin]# sh mqadmin help topicStatus
usage: mqadmin topicStatus [-h] [-n <arg>] -t <arg>
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin topicStatus -n 192.168.1.103:9876 -t gaojingsong
#Broker Name #QID #Min Offset #Max Offset #Last Updated
master 0 0 0
master 1 0 0
master 2 0 0
master 3 0 0
master 4 0 0
master 5 0 0
master 6 0 0
master 7 0 0
[root@master bin]#
4）查看topicRoute信息
[root@master bin]# sh mqadmin help topicRoute
usage: mqadmin topicRoute [-h] [-n <arg>] -t <arg>
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin topicRoute -n 192.168.1.103:9876 -t gaojingsong
{
"brokerDatas":[
{
"brokerAddrs":{0:"192.168.1.103:10911"
},
"brokerName":"master"
}
],
"filterServerTable":{},
"queueDatas":[
{
"brokerName":"master",
"perm":6,
"readQueueNums":8,
"topicSynFlag":0,
"writeQueueNums":8
}
]
}
[root@master bin]#
4）查看所有Topic信息
[root@master bin]# sh mqadmin help statsAll
usage: mqadmin statsAll [-a] [-h] [-n <arg>]
-a,--activeTopic print active topic only
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin statsAll -n 192.168.1.103:9876
#Topic #Consumer Group #InTPS #OutTPS #InMsg24Hour #OutMsg24Hour
BenchmarkTest 0.00 0 NO_CONSUMER
TopicTest please_rename_unique_group_name_ 0.00 0.00 0 0
DefaultCluster 0.00 0 NO_CONSUMER
SELF_TEST_TOPIC 0.00 0 NO_CONSUMER
TBW102 0.00 0 NO_CONSUMER
gaojingsong 0.00 0 NO_CONSUMER
master 0.00 0 NO_CONSUMER
OFFSET_MOVED_EVENT 0.00 0 NO_CONSUMER
[root@master bin]#
5）查看所有clusterList信息
[root@master bin]# sh mqadmin help clusterList
usage: mqadmin clusterList [-h] [-m] [-n <arg>]
-h,--help Print help
-m,--moreStats Print more stats
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
[root@master bin]# sh mqadmin clusterList -n 192.168.1.103:9876
#Cluster Name #Broker Name #BID #Addr #Version #InTPS #OutTPS
DefaultCluster master 0 192.168.1.103:10911 V3_2_6 0.00 0.00
[root@master bin]#
5）Delete相关的Topic
[root@master bin]# sh mqadmin help deleteTopic
usage: mqadmin deleteTopic -c <arg> [-h] [-n <arg>] -t <arg>
-c,--clusterName <arg> delete topic from which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin deleteTopic -n 192.168.1.103:9876 -t TopicTest
usage: mqadmin deleteTopic -c <arg> [-h] [-n <arg>] -t <arg>
-c,--clusterName <arg> delete topic from which cluster
-h,--help Print help
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-t,--topic <arg> topic name
[root@master bin]# sh mqadmin deleteTopic -n 192.168.1.103:9876 -c DefaultCluster -t TopicTest
delete topic [TopicTest] from cluster [DefaultCluster] success.
delete topic [TopicTest] from NameServer success.
[root@master bin]# sh mqadmin statsAll -n 192.168.1.103:9876
#Topic #Consumer Group #InTPS #OutTPS #InMsg24Hour #OutMsg24Hour
BenchmarkTest 0.00 0 NO_CONSUMER
DefaultCluster 0.00 0 NO_CONSUMER
SELF_TEST_TOPIC 0.00 0 NO_CONSUMER
TBW102 0.00 0 NO_CONSUMER
gaojingsong 0.00 0 NO_CONSUMER
master 0.00 0 NO_CONSUMER
OFFSET_MOVED_EVENT 0.00 0 NO_CONSUMER
[root@master bin]#
相关推荐
sdad
本课程设计是某公司的工资管理系统。在这个计算机快速发展的世界里,计算机为信息处理提供了物美价廉的手段，对于推动我国管理信息处理现代化起到了重要作用。工资管理是一项琐碎、复杂而又十分细致的工作，工资计算、发放、核算的工作量很大,一般不允许出错，如果实行手工操作，每月发放工资须手工填制大量的表格,这就会耗费工作人员大量的时间和精力,计算机进行工资发放工作，不仅能够保证工资核算准确无误、快速输出，而且还可以利用计算机对有关工资的各种信息进行统计，既方便又快捷地完成员工工资的发放。 本课程设计过程中根据设计中的需求及对工资管理系统采用了模块化的设计思想，在机房我们在Windows XP 操作系统环境下,采用 myeclipse7作为开发工具，主要连接 Access 数据库来实现公司的工资管理系统的主要功能。在设计过程中，我们首先小组首先对整体的思路进行分析，然后进行分工。对数据库和类进行设计，实现了工资管理系统的功能。其功能主要包括公司用户管理、人员管理、部门管理、工资管理等功能.。内容来源于网络分享，如有侵权请联系我删除。另外如果没有积分的同学需要下载，请私信我。
YOLO系列算法目标检测数据集，包含标签，可以直接训练模型和验证测试，数据集已经划分好，包含数据集配置文件data.yaml，适用yolov5,yolov8,yolov9,yolov7,yolov10,yolo11算法； 包含两种标签格:yolo格式（txt文件）和voc格式（xml文件），分别保存在两个文件夹中，文件名末尾是部分类别名称; yolo格式：<class> <x_center> <y_center> <width> <height>， 其中： <class> 是目标的类别索引（从0开始）。 <x_center> 和 <y_center> 是目标框中心点的x和y坐标，这些坐标是相对于图像宽度和高度的比例值，范围在0到1之间。 <width> 和 <height> 是目标框的宽度和高度，也是相对于图像宽度和高度的比例值； 【注】可以下拉页面，在资源详情处查看标签具体内容；
基于鸟鸣声识别的鸟类分类系统项目源代码全套技术资料.zip
1、嵌入式物联网单片机项目开发例程，简单、方便、好用，节省开发时间。 2、代码使用IAR软件开发，当前在CC2530上运行，如果是其他型号芯片，请自行移植。 3、软件下载时，请注意接上硬件，并确认烧录器连接正常。 4、有偿指导v：wulianjishu666; 5、如果接入其他传感器，请查看账号发布的其他资料。 6、单片机与模块的接线，在代码当中均有定义，请自行对照。 7、若硬件有差异，请根据自身情况调整代码，程序仅供参考学习。 8、代码有注释说明，请耐心阅读。 9、例程具有一定专业性，非专业人士请谨慎操作。
毕业设计前后端分离博客项目源代码.zip
Eclipse+MySql+JavaSwing选课成绩管理系统，原文博客在https://blog.csdn.net/qq_50062694/article/details/124649345?spm=1001.2014.3001.5502。内容来源于网络分享，如有侵权请联系我删除。另外如果没有积分的同学需要下载，请私信我。
什么是流程挖掘？为什么需要流程挖掘？流程挖掘面向的部门是哪些？流程挖掘之后做什么？如果想知道这些，请阅读此文。
### Android程序开发初级教程（一）：初识Android **平台概述** Google推出的Android操作系统平台已经正式亮相，这是一个基于Linux内核的开源操作系统。对于开发者而言，了解其架构和支持的开发语言至关重要。以下是Android平台的架构概览： **平台架构及功能** 1. **应用框架（Application Framework）**：包含可重用和可替换的组件，确保所有软件在该层面上的平等性。 2. **Dalvik虚拟机（Dalvik Virtual Machine）**：一个基于Linux的虚拟机，为Android应用提供运行环境。 3. **集成浏览器（Integrated Browser）**：基于开源WebKit引擎的浏览器，位于应用层。 4. **优化图形（Optimized Graphics）**：包括自定义的2D图形库和遵循OpenGL ES 1.0标准的3D实现。 5. **SQLite数据库**：用于数据存储。 6. **多媒体支持（Media Support）**：支持通用音频、视频以及多种图片格式（如MPEG4, H.264
项目包含完整前后端源码和数据库文件 环境说明： 开发语言：Java 框架：ssm，mybatis JDK版本：JDK1.8 数据库：mysql 5.7 数据库工具：Navicat11 开发软件：eclipse/idea Maven包：Maven3.3 服务器：tomcat7
212) Outgrid - 多用途 Elementor WordPress 主题 v2.0.0.zip
weixin138社区互助养老+ssm(论文+源码)_kaic.zip
深圳建筑安装公司“高处作业安全技术操作规程”
【项目简介】 代码主干网络采用Swin-Transformer 家族系列，包括【tiny、small、base】三种模型。pretrained和freeze_layers参数为是否采用官方预训练模型和是否仅训练分类头。为了做对比消融试验，优化器采用了Adam和SGD、AdamW三种。损失函数采用多类别的交叉熵、学习率优化策略采用cos余弦退火算法 【评估网络】 评估的指标采用loss和准确率（accuracy），分别会在训练集和验证集上进行评估、输出、绘制曲线图像。同时会在训练集、验证集进行一系列评估，包含混淆矩阵、recall、precision、F1 score等等曲线图像，以及recall、precision、F1 score、特异度的输出信息等等。 【具体各类别的指标在json文件中查看】 【如果想要更换数据集训练，参考readme文件】 【本项目为8种番茄病害图片（约4k张数据），包含数据集和标签，可以一键运行】
城市公交查询功能描述 城市公交查询系统的主要目的是为市民提供便捷的公交信息查询服务，帮助用户快速获取公交线路、站点、时刻表等信息，从而提高出行效率。以下是该系统可能具备的功能描述： 1. 公交线路查询 线路搜索：用户可以通过输入公交线路编号或线路名称，快速查询到该线路的详细信息。 线路详情：展示所选线路的起点、终点、途经站点、首末班车时间、发车间隔等信息。 线路图展示：提供线路的可视化地图，显示线路走向及各个站点位置。 2. 站点查询 站点搜索：用户可以通过输入站点名称或编号，查询该站点的相关信息。 站点详情：展示所选站点的上下车线路、周边设施、换乘信息等。 实时到站信息：提供该站点即将到达的公交车信息，包括预计到达时间和车牌号。 3. 实时公交信息 实时位置追踪：用户可以查看公交车的实时位置，了解公交车的行驶状态。 到站预测：根据实时数据，预测公交车到达各个站点的时间，帮助用户合理安排出行。 4. 换乘查询 换乘方案推荐：用户输入起点和终点后，系统提供最佳的换乘方案，包括所需的公交线路、换乘站点及步行距离。 换乘时间估算：计算并展示换乘所需的总时间，包括等车时间和步行时间。 5.
交通旅游订票功能描述 交通旅游订票系统是为了简化旅游出行过程，提升用户的预定体验。该系统通常集成了机票、火车票、汽车票、船票、景区门票等多种交通和旅游产品的预订、支付及管理功能。以下是该系统可能具备的功能描述： 1. 用户管理 用户注册与登录：提供游客注册与登录功能，支持邮箱、手机号等多种方式注册，保证用户信息安全。 个人信息管理：用户可以查看和编辑个人信息，如身份证号、联系方式、常用地址等。 乘客信息保存：可保存常用乘客信息，如身份证、护照、儿童票信息，方便快速预定。 2. 交通票务管理 票务查询：提供交通工具的实时查询功能，支持机票、火车票、汽车票、船票等的查询，包含出发时间、到达时间、票价、座位情况等信息。 多种票务类型支持：支持单程票、往返票、联程票、团体票等多种票种，满足不同用户需求。 票价比较：根据日期、交通工具等条件，自动比较票价，帮助用户选择最合适的票务。 票务预订与支付：提供便捷的在线预订和支付功能，支持多种支付方式（如银行卡、支付宝、微信等）。 票务改签与退票：用户可以在线申请改签和退票，并查看相关费用及政策。 3. 旅游产品预订 景点门票预订：用户可以在线选择
企业数据管理系统项目源代码.zip
项目包含完整前后端源码和数据库文件 环境说明： 开发语言：Java 框架：ssm，mybatis JDK版本：JDK1.8 数据库：mysql 5.7 数据库工具：Navicat11 开发软件：eclipse/idea Maven包：Maven3.3 服务器：tomcat7
基于plc的污水处理，组态王动画仿真，带PLC源代码,组态王源代码，图纸，IO地址分配
SINAMICS S120驱动第三方直线永磁同步电机系列视频_配置和优化.mp4