首页 > 其他分享 >RocketMQ 使用注意事项

RocketMQ 使用注意事项

时间:2023-11-07 17:34:43浏览次数:31  
标签:订阅 消费 队列 注意事项 https 使用 RocketMQ

场景:

  最近公司项目要用Rocket MQ,但是之前我没用过。所以在使用过程中遇到一些问题,做个记录。这篇主要是将注意事项,不涉及底层实现原理(还没学透)。

  而且这里用的RocketMQ是指Apache的4.X,不是阿里云的,注意两者的不同。

解决:

  1.保持订阅关系一致:订阅关系一致指的是同一消费者组下所有消费者订阅的topic、tag必须完全一致,不然就会出现消费混乱。(看参考的第一篇官方文档有详细介绍,阿里云的RocketMQ是支持订阅统一topic,不同tag的)

  2.RocketMQ 控制台上创建Topic时,要保持读、写队列一致。比如,读8个,写4个。则会创建8个队列,0-7可以读,但只有0-3可以写。只要读写不一致,就可能会出现消费问题。

    之所以这么设计,是为了方便扩容或者缩容时,不会造成消息丢失。

  3.Onmessage中进行消息消费时,如果出现RuntimeException类的异常(比如空指针异常等,就是这个类型的异常),会导致消费失败。这个消息会进入重试阶段,默认重试16次,还是无法消费就会进入死信队列。

参考:

  官方文档: https://rocketmq.apache.org/zh/docs/4.x/bestPractice/07subscribe/

  https://blog.csdn.net/qian_348840260/article/details/108975241

  https://zhuanlan.zhihu.com/p/290886627

  https://blog.csdn.net/weixin_35973945/article/details/118298429

标签:订阅,消费,队列,注意事项,https,使用,RocketMQ
From: https://www.cnblogs.com/chenzibai/p/17815448.html

相关文章

  • Golang简单使用wasm
    go代码packagemainimport( "syscall/js")funcaddxxxx(thisjs.Value,args[]js.Value)interface{}{ iflen(args)!=2{ return"Invalidnumberofarguments.Expected2." } num1:=args[0].Float() num2:=args[1].Float() res......
  • 使用RTSP接入安防监控EasyCVR平台,如何配置系统参数以减少起播时间?
    安防视频监控/视频集中存储/云存储/磁盘阵列EasyCVR平台可拓展性强、视频能力灵活、部署轻快,可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等,以及支持厂家私有协议与SDK接入,包括海康Ehome、海大宇等设备的SDK等。平台可拓展性强、视频能力灵活,能对外分发RTMP、RTSP、HTTP-F......
  • NProgress 使用
    简单使用案例一一、安装NProgress包方法一:npminstall--savenprogerss方法二:yarnaddnprogress方法三:在图形化界面中搜索nprogress安装运行依赖方法四:直接引入js、css或者通过cdn引入。<scriptsrc='nprogress.js'></script><linkrel='stylesheet'href='nprogress.css�......
  • vue中使用Loading这个加载工具
    在src/theme文件夹中建立loading.scss文件,内容如下:.loading-next{ width:100%; height:100%;}.loading-next.loading-next-box{ position:absolute; top:50%; left:50%; transform:translate(-50%,-50%);}.loading-next.loading-next-box-warp{ width:80px......
  • 安防监控EasyCVR视频汇聚平台使用海康SDK播放时,画面播放缓慢该如何解决?
    视频云存储/安防监控EasyCVR视频汇聚平台基于云边端智能协同,支持海量视频的轻量化接入与汇聚、转码与处理、全网智能分发、视频集中存储等。安防视频平台EasyCVR拓展性强,视频能力丰富,具体可实现视频监控直播、视频轮播、视频录像、云存储、回放与检索、智能告警、服务器集群、语音......
  • 安防监控EasyCVR视频汇聚平台使用海康SDK播放时,画面播放缓慢该如何解决?
    视频云存储/安防监控EasyCVR视频汇聚平台基于云边端智能协同,支持海量视频的轻量化接入与汇聚、转码与处理、全网智能分发、视频集中存储等。安防视频平台EasyCVR拓展性强,视频能力丰富,具体可实现视频监控直播、视频轮播、视频录像、云存储、回放与检索、智能告警、服务器集群、语音......
  • Base64编码、解码 C语言例子(使用OpenSSL库)
    #include<stdio.h>#include<string.h>#include<unistd.h>#include<openssl/pem.h>#include<openssl/bio.h>#include<openssl/evp.h>intbase64_encode(char*in_str,intin_len,char*out_str){BIO*b64,*bio;......
  • 使用RTMP推流到安防监控平台LiteCVR,FLV视频无法播放的原因排查 
    众所周知,在安防监控领域中,远程视频监控技术的应用非常广泛。在工地监控中,它可以帮助监管部门和工程项目管理者及时掌握现场施工情况,发现是否存在违规、危险行为,保障工人安全和现场施工质量。安防监控视频平台LiteCVR基于云边端一体化架构,具有强大的数据接入、处理及分发能力,可......
  • 云存储/视频监控管理平台EasyCVR,使用sqlite数据库出现卡顿该如何优化?
    视频集中存储/云存储/视频监控管理平台EasyCVR能在复杂的网络环境中,将分散的各类视频资源进行统一汇聚、整合、集中管理,实现视频资源的鉴权管理、按需调阅、全网分发、智能分析等。AI智能大数据视频分析EasyCVR平台已经广泛应用在工地、工厂、园区、楼宇、校园、仓储等场景中。有用......
  • python 播放语音使用 playsound -注意事项
    https://github.com/TaylorSMarks/playsoundpipinstallplaysound>>>fromplaysoundimportplaysound>>>playsound('/path/to/a/sound/file/you/want/to/play.mp3')try:playsound("test.wav")exceptExceptionase:p......