栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

springcloud(七) 消息队列

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

springcloud(七) 消息队列

一、将我们的压缩包传送到root目录里面

二、执行解压命令

unzip rocketmq-all-4.4.0-bin-release.zip

三、将解压后的文件移动到root/local目录下

四、 进入到rocketmq解压文件夹目录

查看bin目录

 执行如下命令:

 启动:tail -f /root/logs/rocketmqlogs/namesrv.log可以查看日志

查看日志:

扩展:(将文件夹改名)

NameServer概述
  • NameServer在RocketMQ中的主要职能是作为一个配置中心,broker启动后都会将路由信息注册到NameServer,这里说的路由信息包括broker服务器地址信息,以及所有topic信息等。
  • Producer和Consumer通过定时从NameServer拉取存储的路由信息,从而能将消息正确投递(消费)。

查看进程,表示正常运行

接下来修改文件中两个文件的内存大小

启动borker并查看日志

 可以看到注册成功!

再次jps可以看到nameserver和broker

测试RocketMQ

上面是消费者,下面是是提供者。

再次在发送提供者(生产者)这里发送消息可以看到两个窗口疯狂输出信息!

结果:通讯正常!

安装rocketmq的控制台:

解压并进入:C:Users85410Desktop课件rocketmq-externals-rocketmq-console-1.0.0rocketmq-externals-rocketmq-console-1.0.0rocketmq-console

修改配置文件:

执行cmd

进入控制台项目,将工程打成jar包

等待打包过程中:

 生成target目录:

执行命令启动控制台:

java -jar target/rocketmq-console-ng-1.0.0.jar

关闭软件

cd rocketmq/conf,
进入broker.conf文件,并编辑,vim broker.conf
在conf文件中加入两行(建议直接复制,然后再修改为自己的IP),一定是大写IP!!
namesrvAddr=127.0.0.1:9876
brokerIP1=192.168.165.129    #是大写的IP一定要注意!!!

执行好初始化操作,保证此时是 没有软件在运行的。

执行如下四个命令:

nohup sh ./bin/mqnamesrv &(启动nameserver)

nohup sh ./bin/mqbroker -n localhost:9876 -c ./conf/broker.conf &(启动broker)

tail -f nohup.out(查看nameserver日志)

tail -f /root/logs/rocketmqlogs/broker.log(查看broker日志)

 

注意点:一定要先启动namesrv,因为消息服务器是注册到命名服务器上的,不先启动命名服务器怎么注册

jps查看进程:可以看到nameserver和broker全部都启动起来了

 

接下来在cmd控制台启动rocketmq的控制台页面(端口7777)

java -jar target/rocketmq-console-ng-1.0.0.jar

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/886079.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号