下载 wget https://archive.apache.org/dist/rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip 安装 unzip rocketmq-all-4.5.1-bin-release.zip 启动 cd rocketmq-a ...
分类:
编程语言 时间:
2021-01-13 11:00:51
阅读次数:
0
最近做了些基于redis stream做消息队列的工作,有人会问,为什么要用redis,而不是专用消息队列中间件来做呢? 好吧,一个是资源不足问题,另一个也是不想增加依赖项,最终导致了不用ons、rocketmq、rabbitmq来做。 曾经的概念里,用redis做消息队列都是不正统的,很脆弱的选择 ...
分类:
其他好文 时间:
2021-01-05 10:44:49
阅读次数:
0
方式?:Redis的setNX() , 做消息id去重 java版本?目前不不?支持设置过期时间//Redis中操作,判断是否已经操作过 TODOboolean flag = jedis.setNX(key);if(flag){//消费}else{//忽略略,重复消费}方式?:redis的 Incr ...
分类:
其他好文 时间:
2020-12-28 10:58:18
阅读次数:
0
1.MappedFile类属性说明 dubbo的核心是spi,看懂了spi那么duboo基本上也懂了,对于rmq来说,它的核心是broker,而broker的核心是commitlog、consumequeue、indexfile,而这些文件对应的最终都是MappedFile,那么搞明白了这个类,那么 ...
分类:
移动开发 时间:
2020-12-25 11:51:42
阅读次数:
0
2020 年双十一交易峰值达到 58.3W 笔/秒,消息中间件 RocketMQ 继续数年 0 故障丝般顺滑地完美支持了整个集团大促的各类业务平稳。
分类:
其他好文 时间:
2020-12-22 12:48:34
阅读次数:
0
在rocketmq中,nameserver充当了一个配置管理者的角色,看起来好似不太重要。然而它是一个不或缺的角色,没有了它的存在,各个broker就是一盘散沙,各自为战。 所以,实际上,在rocketmq中,nameserver也是一个领导者的角色。它可以决定哪个消息存储到哪里,哪个broker干 ...
分类:
其他好文 时间:
2020-12-18 12:41:19
阅读次数:
2
Hbase RIT故障修复 业务场景: RocketMQ+Storm+Hbase 组件版本: RocketMQ:3.4.6 Storm:1.2.1 Hbase:1.2.1 1. 问题描述 4月15号早上发现业务系统前一天数据量明显偏低,查看系统发现storm入Hbase的TPS很低,甚至为0。 2. ...
分类:
其他好文 时间:
2020-12-15 12:03:44
阅读次数:
1
Prerequisite The following softwares are assumed installed: 64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below) 64bit JDK 1.8+; Mav ...
分类:
系统相关 时间:
2020-12-09 11:57:43
阅读次数:
8
微信公众号:[中间件兴趣圈]作者简介:《RocketMQ技术内幕》作者;indexaliases,索引别名,有点类似名称映射,一个索引别名可以映射多个真实索引,索引别名在定义时还支持filter,构成同一个索引,不同的视图。思考:一个索引别名可以映射成多个索引,那如果向一个别名添加一个文档时,会在该别名下对应的所有索引下都创建一个文档?如何创建索引别名1POST/_aliases2{3"actio
分类:
其他好文 时间:
2020-12-08 12:48:40
阅读次数:
6
微信公众号:[中间件兴趣圈]作者简介:《RocketMQ技术内幕》作者方案背景背景:基于Dubbo服务的治理,是否可以支持业务级别的灰度发布、是否基于业务参数的路由转发。例如以GIS为例,当发布一个新版本时,是否可以以按照解析地址或合作伙伴来区分,版本发布之初,只希望地址为:广东省的解析请求发送到新版本,而其他的地址请求还是使用旧版;或者根据合作伙伴例如UCP(优享寄)的请求转发到新版本服务器,其
分类:
其他好文 时间:
2020-12-08 12:47:20
阅读次数:
5