下载
去RocketMQ官网下载合适的版本。
第二步:上传
找到上面下载的rocketmq安装包,然后在文件夹栏输入cmd,进入cmd界面。
输入scp rocketmq-all-4.8.0-bin-release.zip root@119.91.194.100:/root
(上面这个命令的含义:把rocketmq-all-4.8.0-bin-release.zip上传到119.91.194.100服务器的root文件下)
连接
通过Linux连接软件,连接服务器。
第四步:解压
通过unzip rocketmq-all-4.8.0-bin-release.zip命令解压 。
第五步:配置
vim runserver.sh 修改路由 nameserver 的 runserver.sh。 :set nu ( 82 行,将原先的 4GB 、 4G 、 2G 、 128m 、 256m 改成最小内存 256m ,最大内存 256 , 新生代内存 128 ,原空间(方法区)最小 128 ,最大 128 ) :wq 保存一下。vim runbroker.sh 修改 runbroker.sh ,运行服务器的 broker。 :set nu ( 67 行,最小堆大小 256m ,最大堆大小 256m ,新生代大小 128m ) :wq保存一下。
cd conf vim broker.conf :set nu 添加 23 , 24 行,按 i 变成输入 INSERT 模式 brokerIP1 = 121.36.65.190 设置有几个 broker autoCreateTopicEnable = true 允许自动创建主题。 第六步:
启动
nohup sh ./bin/mqnamesrv -n localhost:9876 &按照要求,先启动 nameserver,声明地址:端口。
nohup sh ./bin/mqbroker -n localhost:9876 -c ./conf/broker.conf &把 broker 注册给 nameserver。
export NAMESRV_ADDR=localhost:9876 提前配置 tools 的变量 sh ./bin/tools.sh org.apache.rocketmq.example.quickstart.Producer 以生产者身份模拟发了很多 消息 ( 在 mq bin-release 目录下 ) ,打印了一大堆消息,证明生产者生产了消息。 sh ./bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer 尝试消费,又打印了一大堆 消息,证明消费者读到了刚刚的消息。 至此,跑通了 Ctrl+c 关闭 Consumer 的测试。


