RocketMq搭建demo
1.在linux上安装RocketMq
1.1安装git
yum updateyum install gitgit --version
1.2安装wget依赖包
yum install wget
1.3安装jdk
yum install java-1.8.0-openjdk* -y
1.4安装maven
yum install maven
1.5安装RocketMQ
#使用git拉取源代码,这里选择的是当前最新的4.4.0版本git clone -b release-4.4.0 https://github.com/apache/incubator-rocketmq.git#切换到文件的目录cd incubator-rocketmq# 使用maven编译,等待结束即可mvn -Prelease-all -DskipTests clean install -U
2.修改配置启动RocketMq
#切换到启动目录cd distribution/target/apache-rocketmq/bin#修改nameserver启动的jvm设置vim runserver.sh#跑个demo 50m内存就够了,设置这么大dev服务器根本启动不了JAVA_OPT="${JAVA_OPT} -server -Xms100m -Xmx100m -Xmn50m -XX:MetaspaceSize=20m -XX:MaxMetaspaceSize=40m"
#同理修改broker设置vim runbroker.shJAVA_OPT="${JAVA_OPT} -server -Xms100m -Xmx100m -Xmn50m"
2.1启动name Server
#启动nohup sh mqnamesrv &#日志位置在~/logs/rocketmqlogs/namesrv.log,或者直接查看当前目录下面的nohup.out文件vim nohup.out
出现
The Name Server boot success. serializeType=JSON
即为成功
2.2启动Broker
先设置启动的ip,不然在多网卡环境下很容易报错
cd ../confvim broker.conf#添加你的本机ipbrokerIP1=1.1.1.1#返回bin目录cd ../bin# 以指定配置文件和前面启动的nameserver启动brokernohup sh mqbroker -n localhost:9876 -c ../conf/broker.conf &# 日志位置在~/logs/rocketmqlogs/broker.log,或者直接查看当前目录下面的nohup.out文件vim nohup.out
出现
The broker[broker-a, 1.1.1.1:10911] boot success. serializeType=JSON and name server is localhost:9876
即代表启动成功
2.3关闭RcocketMQ相关服务
# 停止broker服务sh mqshutdown broker# 停止nameserver服务sh mqshutdown namesrv
3.创建基于springboot的demo
3.1下载代码
https://gitee.com/SuddenTwilightt/rocketmq_learning_project
这里直接提供了简单的demo git地址,欢迎点个star
3.2导入到本地
把此处修改为你的namesrv地址即可
3.3启动测试
默认设置在8081端口启动,自行修改即可
打开http://localhost:8081/push?msg=hi测试
控制台出现
即为连接成功
具体代码查看内部service即可~
矫情吗；*
忘是亡心i
系统管理员
还没有评论，来说两句吧...