2024-01-16  阅读(209)
原文作者:Java 充电社 原文地址:http://www.itsoku.com/course/21/353

1、准备工作

1.1、软硬件需求

系统要求是64位的,JDK要求是1.8及其以上版本的。

202401162112022211.png

1.2、下载RocketMQ安装包

202401162112033142.png

202401162112042183.png

将下载的安装包上传到Linux,并解压

    [root@test001 mysoft]# ls
    rocketmq-all-4.8.0-bin-release.zip
    [root@test001 mysoft]# unzip rocketmq-all-4.8.0-bin-release.zip 
    [root@test001 mysoft]# ls
    rocketmq-all-4.8.0-bin-release  rocketmq-all-4.8.0-bin-release.zip
    [root@test001 mysoft]# cd rocketmq-all-4.8.0-bin-release/
    [root@test001 rocketmq-all-4.8.0-bin-release]# ll
    总用量 40
    drwxr-xr-x. 2 root root   102 12月  9 2020 benchmark
    drwxr-xr-x. 3 root root  4096 12月  4 2020 bin
    drwxr-xr-x. 6 root root   211 12月  4 2020 conf
    drwxr-xr-x. 2 root root  4096 12月  9 2020 lib
    -rw-r--r--. 1 root root 17336 10月 23 2020 LICENSE
    -rw-r--r--. 1 root root  1338 12月  4 2020 NOTICE
    -rw-r--r--. 1 root root  5132 12月  4 2020 README.md

2、修改初始内存

2.1、修改runserver.sh

这里修改jvm参数,目前我们是做测试,机器没有这么多内存,所以调小点。

使用vim命令打开bin/runserver.sh文件,现将这些值修改为如下

202401162112052344.png

2.2、修改runbroker.sh

使用vim命令打开bin/runbroker.sh文件。现将这些值修改为如下

202401162112061275.png

3、启动

3.1、启动NameServer

    nohup sh bin/mqnamesrv &
    tail -f ~/logs/rocketmqlogs/namesrv.log

202401162112069856.png

3.2、启动broker

    nohup sh bin/mqbroker -n localhost:9876 &
    tail -f ~/logs/rocketmqlogs/broker.log

202401162112082227.png

4、发送/接收消息测试

4.1、发送消息

    export NAMESRV_ADDR=localhost:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

4.2、接收消息

    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

5、关闭Server

无论是关闭name server还是broker,都是使用bin/mqshutdown命令

    sh bin/mqshutdown namesrv
    sh bin/mqshutdown broker
阅读全文
  • 点赞