常见命令 插件管理 开启某个插件:rabbitmq-plugins enable xxx 关闭某个插件:rabbitmq-plugins disable xxx 注意:重启服务器后生效。 用户管理 新建用户:rabbitmqctl add_user xxxpwd 删除用户: rabbitmqctl ...
分类:
其他好文 时间:
2021-01-07 12:24:14
阅读次数:
0
一、什么是消息中间件 消息队列中间件是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。它一般有两种传递模式:点对点模式和发布/订阅模式。 消息中间件能够在不同平台之间进行通信,它常用来屏蔽各种平台及协议之间的特性,实现应用程序之间的协同,其优点在于能够在客 ...
分类:
其他好文 时间:
2021-01-06 12:05:00
阅读次数:
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
各类消息中间件对顺序消息实现的做法是将具有顺序性的一类消息发往相同的主题分区中,只需要将这类消息设置相同的 Key 即可,而 Kafka 会在任意时刻保证一个消费组同时只能有一个消费者监听消费,因此可在消费时按分区进行顺序消费,保证每个分区的消息具备局部顺序性。由于需要确保分区消息的顺序性,并不能并 ...
分类:
编程语言 时间:
2020-12-15 12:04:52
阅读次数:
6
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