Rocketmq官网:http://rocketmq.apache.org/,针对前4种 broker busy ,主要是由于 Broker 在追加消息时持有的锁时间超过了设置的1s,Broker 为了自我保护,会抛出错误,客户端会选择其他 broker 服务器进行重试。
本文从存储、顺序写、内存映射、刷盘策略、内存级读写分离等方面详细阐述了RocketMQ存储设计之精髓。
我们知道,高并发代表着大流量,高并发系统设计的魅力就在于我们能够凭借自己的聪明才智设计巧妙的方案,从而抵抗巨大流量的冲击,带给用户更好的使用体验。这些方案好似能操纵流量,让流量更加平稳得被系统中的服务和组件处理。
之前写过Java&Go高性能队列之LinkedBlockingQueue性能测试之后,就一直准备这这篇文章,作为准备内容的过程中也写过一些Disruptor高性能消息队列的应用文章:高性能队列Disruptor在测试中应用和千万级日志回放引擎设计稿。
使用RocketMQ进行发消息时,一般我们是必须要指定topic,此外topic必须要提前建立,但是topic的创建(自动或者手动方式)的设置有一个开关autoCreateTopicEnable,此部分主要会在broker节点的配置文件的时候进行设置,运行环境中会使用默认设置autoCreateTop
应一些小伙伴们的私信,希望可以介绍一下RocketMQ的基础,那么我们现在就从0开始,进入RocketMQ的基础学习及概念介绍,为学习和使用RocketMQ打好基础!
那么,今天围绕着商业版本的消息队列 RocketMQ和开源版本 RocketMQ 进行比较,并结合实践中场景全面展示大型分布式应用的上云最佳实践。
如果把常见的四大消息队列拉到一个群里,会碰出哪些火花呢?
摘要:本文通过分析鸿蒙轻内核队列模块的源码,掌握队列使用上的差异。
摘要:本文通过分析鸿蒙轻内核队列模块的源码,掌握队列使用上的差异。
摘要:本文带领大家一起剖析了鸿蒙轻内核的队列模块的QueueMail两个接口的源代码。
摘要:本文通过分析LiteOS队列模块的源码,掌握队列使用上的差异。
面试官:好了,聊完了ArrayBlockingQueue,我们接着说说LinkedBlockingQueue吧
组织在开发高质量产品过程中,可以将业务改进的焦点集中在:方法、人、工具三个方面。三者的粘合剂就是过程。过程需要高效的消息传递。
摘要:本文通过分析鸿蒙轻内核队列模块的源码,掌握队列使用上的差异。
摘要:本文通过分析鸿蒙轻内核队列模块的源码,掌握队列使用上的差异。
今天分享的主题是云原生消息事件流超融合平台 RocketMQ 5.0 初探,内容主要分为三个部分:带大家回顾业务消息领域首选 RocketMQ 4 发展历史以及 4.x 版本的演进与发展;详细介绍 RocketMQ 5.0 发展情况以及一些新特性;介绍 RocketMQ 5.0 的发展路线图。
摘要: Pulsar作为一个云原生的分布式消息流平台,越来越频繁地出现在人们的视野中,大有替代Kafka江湖地位的趋势。
Qunar由于业务上对 IM 系统的需求,结合市面上已有的 IM 的实现,实现了自己的一套完善的办公和客服 IM 系统。具备以下几个重要特点:实时性,可靠性,一致性,安全性,扩展性,高并发。 本文探讨了 Qunar 的 IM 系统完成过程。
本系列文章将重点讨论 Pulsar 与 Kafka 的延迟性,平台中其他两篇文章介绍了测试方法(下图绿色部分)与测试细节(下图蓝色内容)。
小伙伴们,国庆都过的开心吗?国庆后的第一个工作日是不是很多小伙伴还沉浸在假期的心情中,没有工作状态呢?
在生产中经常会有一些类似报表系统,需要做 MySQL 的 binlog 同步。比如订单系统要同步订单表的数据到大数据部门的 MySQL 库中用于报表统计分析,通常的做法是基于 Canal 这样的中间件去监听订单数据库的 binlog,然后把这些 binlog 发送到 MQ 中
LogI-KafkaManager是面向Kafka用户、Kafka运维人员打造的共享多租户Kafka云平台,专注于Kafka资源申请、运维管控、监控告警、资源治理等核心场景。免费体验地址:http://117.51.150.133:8080/kafka ,账户admin/admin,欢迎Star
本篇文章从分布式缓存架构、消息队列与异步架构、负载均衡架构三个方面进行知识点梳理与复习,对于分布式数据库的相关内容会在下周进行总结
分布式缓存,消息队列与异步架构、负载均衡、分布式数据库
缓存,消息队列,负载均衡,分布式数据库的知识要点和使用总结
作为一个有丰富经验的微服务系统架构师,经常有人问我,“应该选择RabbitMQ还是Kafka?”。基于某些原因, 许多开发者会把这两种技术当做等价的来看待。的确,在一些案例场景下选择RabbitMQ还是Kafka没什么差别,但是这两种技术在底层实现方面是有许多差异的
消息队列也叫 MQ(Message Queue)。Kafka作为消息队列中的优秀平台,被很多公司使用,是一种高吞吐量的分布式发布订阅消息系统,本篇给大家总结了27道Kafka知识点或者说面试题,都是基础的。持续更新中。。。
LogI-KafkaManager是面向Kafka用户、Kafka运维人员打造的共享多租户Kafka云平台,专注于Kafka资源申请、运维管控、监控告警、资源治理等核心场景。免费体验地址:http://117.51.150.133:8080/kafka ,账户admin/admin,欢迎Star
kafka2.8.0源码环境搭建
LogI-KafkaManager是面向Kafka用户、Kafka运维人员打造的共享多租户Kafka云平台,专注于Kafka资源申请、运维管控、监控告警、资源治理等核心场景。免费体验地址:http://117.51.150.133:8080/kafka ,账户admin/admin,欢迎Star
消息队列提供了什么特性? Redis 如何实现消息队列?是否满足存取需求?
使用 Docker 部署完 RabbitMQ 服务,到 /var/log/rabbitmq 目录下一看,空空如也,并没有日志文件生成。