springcloud(七) 消息队列
一、将我们的压缩包传送到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
标签:
相关文章
-
无相关信息