rocketmq初体验

落日映苍穹つ 2023-02-25 11:28 2阅读 0赞

> 用户说明书

[用户说明书][Link 1]

#### 下载安装 ####

当前最新版本4.7.1，下载binary版本然后解压得到文件夹`rocketmq-all-4.7.1-bin-release`  
conf文件夹得到以下三种方式的broker配置文件、logback日志配置文件等![在这里插入图片描述][20200712223047421.jpg]

#### 启动命令 ####

找到启动和关闭的脚本mqbroker，mqshutdown和mqnamesrv  
NameServer需要先于Broker启动，且如果在生产环境使用，为了保证高可用，建议一般规模的集群启动3个NameServer，各节点的启动命令相同

*  1、启动Name Server

#首先启动Name Server
    nohup sh mqnamesrv &
     
    # 验证Name Server 是否启动成功
    tail -f ../logs/rocketmqlogs/namesrv.log
    
    #停止Name Server
    sh mqshutdown namesrv

*  2、启动mqbroker

# 在机器A，启动第一个Master，例如NameServer的IP为：192.168.1.1
    $ nohup sh mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-noslave/broker-a.properties &
     
    # 在机器B，启动第二个Master，例如NameServer的IP为：192.168.1.1
    $ nohup sh mqbroker -n 192.168.1.1:9876 -c $ROCKETMQ_HOME/conf/2m-noslave/broker-b.properties &

如上启动命令是在单个NameServer情况下使用的。对于多个NameServer的集群，Broker启动命令中-n后面的地址列表用分号隔开即可，例如 192.168.1.1:9876;192.161.2:9876。

依次启动NameServer和Broker后，可以到相应的日志文件中看是否启动成功，也可以通过任务查看命令：jobs查看。

#### 应用依赖包 ####

<dependency>
    	<groupId>com.alibaba.rocketmq</groupId>
    	<artifactId>rocketmq-client</artifactId>
    	<version>3.2.6</version>
    </dependency>
    <dependency>
    	<groupId>com.alibaba.rocketmq</groupId>
    	<artifactId>rocketmq-tools</artifactId>
    	<version>3.2.6</version>
    </dependency>
    <dependency>
    	<groupId>com.alibaba.rocketmq</groupId>
    	<artifactId>rocketmq-all</artifactId>
    	<version>3.2.6</version>
    	<type>pom</type>
    </dependency>

#### 控制台 ####

1、下载地址

https://github.com/apache/rocketmq-externals/archive/rocketmq-console-1.0.0.zip

2、解压到本地，dos进入到rocketmq-console文件夹下，执行命令

mvn clean package -DskipTests

3、修改application.properties文件

rocketmq.config.namesrvAddr=192.168.27.6:9876

4、target目录下执行命令

java -jar rocketmq-console-ng-1.0.0.jar

[Link 1]: https://github.com/apache/rocketmq/tree/master/docs/cn
[20200712223047421.jpg]: /images/20230209/1b16f43f7c8540328a9eaf45c69499bf.png