一、linux下rocketmq单机启动

下载:https://archive.apache.org/dist/rocketmq/

解压:我这里下的是rocketmq-all-4.9.4-bin-release

上传到linux服务器,cd进入rocketmq目录

下面两处是设置namesrv和broker的启动内存,如果太大就会启动失败!

修改bin/runserver.sh,将文件里面两处的启动内存修改为:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

修改bin/runbroker.sh,将文件里面一处的启动内存修改为:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"

修改conf/broker.conf,添加如下,这是为了对外ip开放,不然不能访问

autoCreateTopicEnable = false

namesrvAddr = {服务器期的对外ip}:9876

brokerIP1 = {服务器期的对外ip}

启动namesrv:nohup sh bin/mqnamesrv &

启动broker:nohup sh bin/mqbroker -c conf/broker.conf &

jps命令查看是否启动成功,正常应该如下:

5738 BrokerStartup

27482 NamesrvStartup

6095 Jps

rocketmq自带生产消费试验,cd进入rocketmq目录打开两个shell窗口分别执行:

生产:sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

消费:sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

二、部署rocketmq-dashboard

下载https://github.com/apache/rocketmq-dashboard

解压上传到linux服务器

修改application.yml,修改port、namesrvAddrs、 dataPath、loginRequired

修改users.properties,设置用户密码

进入项目,执行:mvn clean package -Dmaven.test.skip=true

编译完成后,拷贝target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar到其它目录

java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar

访问方式:http://{服务器期的对外ip}:8080

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐