RocketMQ环境安装

末蓝、 2022-02-03 23:43 302阅读 0赞

# windows安装RocketMQ以及运行第一个MQ程序 #

## 下载安装包 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 1]

## 设置环境变量 ##

设置 **ROCKETMQ\_HOME** 环境变量。

## 启动NameSercer ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 2]

## 启动Broker ##

启动Broker需要注意的地方：将 `runbroker.cmd`中的

set “JAVA\_OPT=%JAVA\_OPT% -cp %CLASSPATH%”

改为：

`set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""`

删除C:\\Users\\”当前系统用户名”\\store目录下的所有文件。  
执行 `mqbroker.cmd`：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 3]

## 以可以自动创建Topic方式启动 ##

有可能会遇到 `org.apache.rocketmq.client.exception.MQClientException: No route info of this topic,`的错误，需要设置程序可以创建Topic属性：

`.\mqbroker -n localhost:9876 autoCreateTopicEnable=true`

## 手动创建topic ##

创建Topic使用的命令 `mqadmin updateTopic`。

比如，你想创建一个名为"tx-mq-TOPIC" 的主题。可以使用如下命令：

./mqadmin updateTopic -n localhost:9876  -b localhost:10911  -t tx-mq-TOPIC

## 运行第一个MQ程序 ##

### 引入依赖 ###

<dependency>
        <groupid>org.apache.rocketmq</groupid>
        <artfactid>rocketmq-client</artfactid>
        <version>4.3.0</version>
    </dependency>

### 生产者发送消息 ###

示例代码参见：[`org.byron4j.cookbook.rocketmq.MQProducerDemo`][org.byron4j.cookbook.rocketmq.MQProducerDemo]

### 消费者消费消息 ###

示例代码参见：[`org.byron4j.cookbook.rocketmq.MQConsumerDemo`][org.byron4j.cookbook.rocketmq.MQConsumerDemo]

### 事务消息生产者 ###

示例代码参见： [`org.byron4j.cookbook.rocketmq.transaction.MQTransactionProducerDemo`][org.byron4j.cookbook.rocketmq.transaction.MQTransactionProducerDemo]

### 事务消息消费者 ###

示例代码参见： [`org.byron4j.cookbook.rocketmq.transaction.MQTransactionConsumerDemo`][org.byron4j.cookbook.rocketmq.transaction.MQTransactionConsumerDemo]

在事务消息示例中，模拟了在生产者端发送标签为Transaction1的消息回滚，则该消息不会发送给消费者。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70]: /images/20220204/ce1f3d370e5547359f5f67ff533074e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 1]: /images/20220204/de75af56f01143ddbf263bbf9842ac2a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 2]: /images/20220204/b9d3d9ed433f4d9196e506ca834ce970.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3ppeGlhbzIxNw_size_16_color_FFFFFF_t_70 3]: /images/20220204/b4c6fc963f2e416f9b35db523a5857f9.png
[org.byron4j.cookbook.rocketmq.MQProducerDemo]: https://github.com/Byron4j/CookBook/blob/master/src/main/java/org/byron4j/cookbook/rocketmq/MQProducerDemo.java
[org.byron4j.cookbook.rocketmq.MQConsumerDemo]: https://github.com/Byron4j/CookBook/blob/master/src/main/java/org/byron4j/cookbook/rocketmq/MQConsumerDemo.java
[org.byron4j.cookbook.rocketmq.transaction.MQTransactionProducerDemo]: https://github.com/Byron4j/CookBook/blob/master/src/main/java/org/byron4j/cookbook/rocketmq/transaction/MQTransactionProducerDemo.java
[org.byron4j.cookbook.rocketmq.transaction.MQTransactionConsumerDemo]: https://github.com/Byron4j/CookBook/blob/master/src/main/java/org/byron4j/cookbook/rocketmq/transaction/MQTransactionConsumerDemo.java