前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >RocketMQ环境安装

RocketMQ环境安装

作者头像
青山师
发布2023-05-05 19:14:58
2350
发布2023-05-05 19:14:58
举报
文章被收录于专栏:IT当时语_青山师_JAVA技术栈

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

下载安装包

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

设置环境变量

设置 ROCKETMQ_HOME 环境变量。

启动NameSercer

在这里插入图片描述
在这里插入图片描述

启动Broker

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

set “JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%”

改为:

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

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

在这里插入图片描述
在这里插入图片描述

以可以自动创建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" 的主题。可以使用如下命令:

代码语言:javascript
复制
./mqadmin updateTopic -n localhost:9876  -b localhost:10911  -t tx-mq-TOPIC

运行第一个MQ程序

引入依赖

代码语言:javascript
复制
<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.MQConsumerDemo

事务消息生产者

示例代码参见: org.byron4j.cookbook.rocketmq.transaction.MQTransactionProducerDemo

事务消息消费者

示例代码参见: org.byron4j.cookbook.rocketmq.transaction.MQTransactionConsumerDemo

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

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2023-05-04,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • windows安装RocketMQ以及运行第一个MQ程序
    • 下载安装包
      • 设置环境变量
        • 启动NameSercer
          • 启动Broker
            • 以可以自动创建Topic方式启动
              • 手动创建topic
                • 运行第一个MQ程序
                  • 引入依赖
                  • 生产者发送消息
                  • 消费者消费消息
                  • 事务消息生产者
                  • 事务消息消费者
              领券
              问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档