提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档

文章目录

  • 前言
  • 一、RocketMQ是什么?
  • 二、准备工作
    • 1.环境要求
    • 2.下载与解压
    • 3.启动MQ
    • 4. 测试是否成功启动
  • 三、安装管理端
    • 1. 代码下载
    • 2. 修改配置文件
    • 3. 启动MQ客户端jar包
  • 四、rocketMQ代码的使用入门
  • 五、问题记录
    • 1. 启动mqbroker.cmd没有反应
    • 2.消费者重复消费消息

前言

提示:这里可以添加本文要记录的大概内容:

例如:随着人工智能的不断发展,机器学习这门技术也越来越重要,很多人都开启了学习机器学习,本文就介绍了机器学习的基础内容。


提示:以下是本篇文章正文内容,下面案例可供参考

一、RocketMQ是什么?

RocketMQ是阿里开源的一款非常优秀中间件产品,脱胎于阿里的另一款队列技术MetaQ,后捐赠给Apache基金
会作为一款孵化技术,仅仅经历了一年多的时间就成为Apache基金会的顶级项目。并且它现在已经在阿里内部被
广泛的应用,并且经受住了多次双十一的这种极致场景的压力。(2017年的双十一,RocketMQ流转的消息量达
到了万亿级,峰值TPS达到5600万)。并且其内部通过Java语言开发,便于阅读与修改。

二、准备工作

1.环境要求

64位JDK 1.8+;
Maven 3.2.x;
64位操作系统系统,本文档在Windows上安装

2.下载与解压

下载地址:https://archive.apache.org/dist/rocketmq/4.5.1/

解压到一个无中文无空格的目录下,解压后目录如下:

3.启动MQ

3.1 更改配置
java的默认启动参数中,启动时堆内存的大小为2g,太大了,调整一下
切换路径到D:\rocketmq-all-4.5.1-bin-release\bin
打开runserver.cmd
把-Xms、-Xmx、-Xmn都设置成512m,将%CLASSPATH%增加"",不然启动时会找不到jdk

同理设置 runbroker.cmd

3.2 启动NameServer
双击mqnamesrv.cmd启动,如下显示则启动成功

3.3 启动broker
进入cmd命令窗口,切换到D:\rocketmq-all-4.5.1-bin-release\bin
执行

mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

如下显示则启动成功

4. 测试是否成功启动

4.1 监听消息
进入cmd命令窗口,切换到D:\rocketmq-all-4.5.1-bin-release\bin
执行:

set NAMESRV_ADDR=127.0.0.1:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer

4.2 发送消息
进入cmd命令窗口,切换到D:\rocketmq-all-4.5.1-bin-release\bin
执行:

set NAMESRV_ADDR=127.0.0.1:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer

三、安装管理端

1. 代码下载

我们进入到这个dashboard仓库:
前端代码地址下载

2. 修改配置文件

进入到解压的文件夹D:\rocketmq-dashboard-master\src\main\resources下修改 application.yml 文件

修改客户端的端口号以及MQ的地址和端口号

进入cmd命令窗口,切换到D:\rocketmq-dashboard-master,进行打包成jar包
执行:

mvn clean package -Dmaven.test.skip=true

如下显示则启动成功

在D:\rocketmq-dashboard-master\target路径下会生成对应jar包

3. 启动MQ客户端jar包

进入cmd命令窗口,切换到D:\rocketmq-dashboard-master\target,进行打包成jar包
执行:

java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar

如下显示则启动成功

在自己的浏览器中输入:http://localhost:8888/#/ 即可进入

到此,就已经开始愉快的玩耍了

四、rocketMQ代码的使用入门

后续补充

五、问题记录

1. 启动mqbroker.cmd没有反应

进入到C:\Users\DELL\store目录下删除底下的所有文件
然后再进行重新启动

2.消费者重复消费消息

最终排查发现,是因为消费者在处理消息的方法onMessage中有异常没有捕获到,导致异常上抛,被consumeMessage捕获并判定为消费失败,从而放到了重试队列当中进行重试。
总结:RocketMq中会引起消息重试的两种情况,内部异常和消费超时。
在Consumer中处理消息时,会在消费完消息后判断消费的总时长,如果 比超时时间要长则返回TIME_OUT,注意这里的超时是在consumeMessage内部逻辑处理完毕之后在进行判断的,如果内部逻辑处理成功,但耗时较长,那么也会被判断为超时。

windows10 的rocketMQ安装并测试相关推荐

  1. Win10下RocketMQ安装和测试

    1.点击RocketMQ官网下载地址 Downloading the Apache RocketMQ Releases - Apache RocketMQ 在Download页面中选择要下载的版本,这 ...

  2. Apache RocketMQ 安装、测试、报错解决

    1. 准备 前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. 64bit OS, Linux/Unix/Mac 64bit JDK 1.8+; Mav ...

  3. 手把手教你在Windows10环境下安装深度学习框架(pytorch or tensorflow)

    手把手教你在Windows10环境下安装深度学习框架(pytorch or tensorflow) 1. 安装Anaconda:(常用的python版本和各类包管理器) 1.1. 下载地址: 1.2. ...

  4. JavaEE:RocketMQ安装与使用

    一.RocketMQ安装: 1.Centos7系统上安装: 安装Java(x64):https://blog.csdn.net/a526001650a/article/details/10412245 ...

  5. Windows10+VS2017下安装和 编译openssl库

    windows10+VS2017下安装和编译openssl库 环境 windows10,64位 openssl解压目录:E:\mylib\openssl-1.0.2l openssl安装目录:E:\m ...

  6. RocketMQ安装

    RocketMQ安装 文章目录 RocketMQ安装 一.安装 1.1官网下载 1.2 解压缩 二.启动 1.1启动namesrv 1.2 修改JVM启动参数 1.3 启动broker 三.测试 生产 ...

  7. MQTT服务端安装与测试(emqx工具)

    MQTT服务端安装与测试(emqx工具) MQTT服务端安装与测试(emqx工具) 本文介绍一种快速布局MQTT服务器的方法,使用的工具软件为emqx. 下载地址: emqx-windows-4.3. ...

  8. Windows10中Emscripten 安装详解

    Windows10中Emscripten 安装详解 Emscripten编译器,是WebAssembly开发的重要工具之一,主要是通过emcc(Emscripten Compiler Frontend ...

  9. windows10下pip安装速度慢的解决办法

    windows10下pip安装速度慢的解决办法 pip修改源 我们这里使用的镜像源是清华大学的镜像源,使用方法有两种,第一种是临时使用: pip install -i https://pypi.tun ...

最新文章

  1. 实战SSM_O2O商铺_04自下而上逐步整合SSM
  2. marbin mysql_跨浏览器图像灰度(grayscale)解决方案
  3. scss里的继承操作符@extend
  4. SAP CRM Genil Text-for-Key-Codes vs SAP C4C只读字段
  5. 如何用git上传文件
  6. 五年了,别再把务虚会开 “虚” 了
  7. Spring boot web(2):web综合开发
  8. SP2-0734: 未知的命令开头 imp scott/... - 忽略了剩余的行。
  9. 虚拟机安装jdk步骤及命令
  10. 初识 Oracle 11g
  11. 从一个表查询数据插入另一个表
  12. 设计PSD分层素材模板|几何元素平面广告,在设计风格中占有一席之地
  13. FinCEN就非托管加密钱包报告规则征集意见时间将截至今日12时59分
  14. stackexchange.mysql_StackExchange.Redis加载Lua脚本进行模糊查询的批量删除和修改
  15. centos下java编程工具_centos下安装JAVA开发工具(4)------Redis
  16. Java实现鉴权失败达到一定次数锁定IP并释放到期IP
  17. Ubuntu18.04安装GPU显卡驱动
  18. D. Challenging Valleys
  19. RGB转HSI的代码优化
  20. matlab plot x y定义,plot是什么意思_matlab中plot(x)的是什么意思?

热门文章

  1. 蓝桥杯 2022 真题 纸张尺寸
  2. python爬虫知网实例-33个Python爬虫项目实战(推荐)
  3. 数学专业的学生的毕业论文是怎样的?
  4. 钢铁企业无组织废气排放管控势在必行-管控治一体化平台
  5. 八大误区,逐个击破(终篇):云难以扩展、定制性差,还会让管理员失去控制权?
  6. InstructGPT 精简总结:Training language models to follow instructions with human feedback
  7. 小米9什么时间升级android10,小米9/MIX 3 现在即可升级安卓10.0!升级指南戳这里...
  8. 新造车2.0时代,“滑板底盘”概念的加减法
  9. vue中tab标签页keep-alive二级路由+删除指定缓存页面
  10. 约爱同城IOS版本的用户们,如您需技术支持,可在此留言或通过以下联系方式联系到我们