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
图片说明

全部评论

相关推荐

风中翠竹:真的真的真的没有kpi。。。面试官是没有任何kpi的,捞是真的想试试看这个行不行,碰碰运气,或者是面试官比较闲现在,没事捞个人看看。kpi算HR那边,但是只有你入职了,kpi才作数,面试是没有的。
双非有机会进大厂吗
点赞 评论 收藏
分享
06-13 17:33
门头沟学院 Java
顺序不记了,大致顺序是这样的,有的相同知识点写分开了1.基本数据类型2.基本数据类型和包装类型的区别3.==和equals区别4.ArrayList与LinkedList区别5.hashmap底层原理,put操作时会发生什么6.说出几种树型数据结构7.B树和B+树区别8.jvm加载类机制9.线程池核心参数10.创建线程池的几种方式11.callable与runnable区别12.线程池怎么回收线程13.redis三剑客14.布隆过滤器原理,不要背八股,说说真正使用时遇到了问题没有(我说没有,不知道该怎么回答了)15.堆的内存结构16.自己在写项目时有没有遇见过oom,如何处理,不要背八股,根据真实经验,我说不会17.redis死锁怎么办,watchdog机制如何发现是否锁过期18.如何避免redis红锁19.一个表性别与年龄如何加索引20.自己的项目的QPS怎么测的,有没有真正遇到大数量表21.说一说泛型22.springboot自动装配原理23.springmvc与springboot区别24.aop使用过嘛?动态代理与静态代理区别25.spring循环依赖怎么解决26.你说用过es,es如何分片,怎么存的数据,1000万条数据怎么写入库中27.你说用limit,那么在数据量大之后,如何优化28.rabbitmq如何批次发送,批量读取,答了延迟队列和线程池,都不对29.计网知不知道smtp协议,不知道写了对不对,完全听懵了30.springcloud知道嘛?只是了解反问1.做什么的?短信服务,信息量能到千万级2.对我的建议,基础不错,但是不要只背八股,多去实际开发中理解。面试官人不错,虽然没露脸,但是中间会引导我回答问题,不会的也只是说对我要求没那么高。面完问我在济宁生活有没有困难,最快什么时候到,让人事给我聊薪资了。下午人事打电话,问我27届的会不会跑路,还在想办法如何使我不跑路,不想扣我薪资等。之后我再联系吧,还挺想去的😭,我真不跑路哥😢附一张河科大幽默大专图,科大就是大专罢了
查看30道真题和解析
点赞 评论 收藏
分享
评论
点赞
1
分享

创作者周榜

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