素材巴巴 > 程序开发 >

springcloud(七) 消息队列

程序开发 2023-09-04 06:06:05

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

二、执行解压命令

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

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

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

查看bin目录

 执行如下命令:

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

查看日志:

扩展:(将文件夹改名)

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


标签:

素材巴巴 Copyright © 2013-2021 http://www.sucaibaba.com/. Some Rights Reserved. 备案号:备案中。