RocketMQ基础

组成结构
图片说明
1.Prodecer Cluster:消息生产者群;负责发送消息,一般由业务系统负责产生消息。
2.Consumer Cluster:消息消费者群;负责消费消息,一般是后台系统负责异步消费。
3.NameServer:名称服务器;收集关于broker的信息;相当于broker的注册中心,不负责处理消息。
4.Broker:消息服务器;MQ核心,负责消息的接收存储发送等。需要定时更新状态发送到NameServer中。

RocketMQ初步测试(windows系统)
1.解压MQ压缩包图片说明
2.更改bin目录下的配置(调整默认内存大小)
runserver.cmd:-server -Xms512m -Xmx512m -Xmn512m -XX:MetaspaceSize=128m XX:MaxMetaspaceSize=320m
runbroker.cmd:-server -server -Drocketmq.broker.diskSpaceWarningLevelRatio=0.98 -Xms512m Xmx512m -Xmn512m
3.启动NameServer;
图片说明
4.启动broker。需要制定nameServer的地址
进入cmd窗口,执行命名行bin/mqbroker.cmd -n 127.0.0.1:9876
5.测试
发送消息:
(1)设置nameserver地址,set NAMESRV_ADDR=127.0.0.1:9876
(2)发送消息,tools.cmd org.apache.rocketmq.example.quickstart.Producer
图片说明
接收消息:
(1)设置nameserver地址,set NAMESRV_ADDR=127.0.0.1:9876
(2)接收消息,tools.cmd org.apache.rocketmq.example.quickstart.Consumer图片说明

安装可视化管理端
1.解压UI压缩包(maven项目)
图片说明
2.修改配置
修改rocketmq-console\src\main\resources\application.properties
图片说明
3.打包
进入rocketmq-console目录下,执行cmd语句mvn clean package -Dmaven.test.skip=true
图片说明
4.启动(运行jar包的形式)
进入/rocketmq-console/target,执行cmd命令,java -jar rocketmq-console-ng-1.0.1.jar --server.port=9877 --rocketmq.config.namesrvAddr=127.0.0.1:9876
图片说明
5.访问http://127.0.0.1:9877
图片说明

全部评论

相关推荐

Twilight_m...:表格简历有点难绷。说说个人看法: 1.个人基本情况里好多无意义信息,什么婚姻状况、健康状况、兴趣爱好、户口所在地、身份证号码、邮政编码,不知道的以为你填什么申请表呢。 2.校内实践个人认为对找工作几乎没帮助,建议换成和测开有关的项目,实在没得写留着也行。 3.工作经历完全看不出来是干什么的,起码看着和计算机没啥关系,建议加强描述,写点你在工作期间的实际产出、解决了什么问题。 4.个人简述大而空,看着像AI生成,感觉问题最大。“Python,C,C++成为我打造高效稳定服务的得力工具”、“我渴望凭借自身技术知识与创新能力,推动人工智能技术的应用发展,助力社会实现智能化转型”有种小学作文的美感。而且你确定你个人简述里写的你都会嘛?你AI这块写的什么“深入研究”,发几篇顶会的硕博生都不一定敢这么写。而且你AI这块的能力和软测也完全无关啊。个人简述建议写你对哪些技术栈、哪些语言、哪些生产工具的掌握,写的有条理些,而且最好是和测开强相关的。
点赞 评论 收藏
分享
06-12 16:00
天津大学 Java
牛客30236098...:腾讯坏事做尽,终面挂是最破防的 上次被挂了后我连简历都不刷了
点赞 评论 收藏
分享
看到这个内容真是闹麻了。。。。。。现在有了AI以后很多人面试都会作弊吗? 那对老老实实面试的人岂不是不公平....
程序员牛肉:公平那是对小孩子讲的童话故事,成年人的世界只有能不能接受失败的后果。 你要是能接受面试作弊被发现之后多家公司联合永久拉黑的后果,你就搞。
你找工作的时候用AI吗?
点赞 评论 收藏
分享
评论
点赞
1
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务