240 投稿
收录了24篇文章 · 8人关注
  • Kafka的零拷贝技术

    kafka中的消费者在读取服务端的数据时,需要将服务端的磁盘文件通过网络发送到消费者进程,网络发送需要经过几种网络节点。如下图所示: 传统的读取...

  • Resize,w 360,h 240
    深入分析Kafka高可用性

    本文主要内容:①kafka复制机制②分区leader副本宕掉怎么选新的leader③高水位与leader epoch的详细分析。④一些相关配置 ...

  • RocketMQ MappedFile 预热原理解析

    创建 MappedFile 文件 创建 MappedFile 文件实现如下: 从代码中可以看出,只有 MappedFile 的大小等于或大于 C...

    1.2 jijs 1 8
  • Resize,w 360,h 240
    聊聊Java消息

    消息在开发过程中多次用到,在分布式系统中也是高频使用的一项技术,特写该片文章以作总结。 一、消息使用场景 1.1 常见的使用场景 系统解耦 异步...

  • Resize,w 360,h 240
    消息中间件面试题:消息中间件的高可用

    接着上一篇面试题的扩展。 面试题 如何保证消息队列的高可用? 消息中间件各种面试题:消息中间件面试题:消息丢失怎么办?消息中间件面试题:消息队列...

    5.1 jsbintask 0 51
  • Resize,w 360,h 240
    RocketMQ 底层通信机制 源码分析

    概述 RocketMQ 底层通讯是使用Netty来实现的。下面我们通过源码分析下RocketMQ是怎么利用Netty进行通讯的。 本文分析的是R...

    0.2 jijs 0 7
  • 怎样保证消息处理的顺序?

    1. 流水消息:没有顺序要求。 2. 状态消息:有顺序要求。消息增加版本号作为乐观锁控制,接收方只处理版本号大于当前的消息。 3. 连锁消息:有...

  • Resize,w 360,h 240
    高并发架构系列:如何从0到1设计一个MQ消息队列

    消息队列作为系统解耦,流量控制的利器,成为分布式系统核心组件之一。 如果你对消息队列背后的实现原理关注不多,其实了解消息队列背后的实现非常重要。...

  • RocketMQ源码阅读(四)-消息存储三

    前文已经介绍了消息存储中使用到的充要对象, 本文分析一下消息介绍的主流程. 另外, 此篇主要分析消息存储主流程的代码, 不影响主流程的代码先不看...

  • RocketMQ源码阅读(四)-消息存储二

    RocketMQ的消息存储过程非常复杂, 本文先介绍存储模块中几个重要对象. 1. MappedFile 对MappedByteBuffer的封...

专题公告

MQ