一、OSI七层模型 OSI七层协议模型主要是：应用层（Application）、表示层（Presentation）、会话层（Session）、传输层（Transport）、网络层（Network）、 ...

TCP/IP概述 TCP/IP起源于1969年美国国防部（DOD：The United States Department Of Defense）高级研究项目管理局（APRA:Ad ...

broker 1. broker的启动 brker的启动 Broker向namesrv注册 Topic在broker文件上的存储json格式 Nam ...

Netty 超时机制的介绍 Netty 的超时类型 IdleState 主要分为： ALL_IDLE : 一段时间内没有数据接收或者发送 READER_IDLE ： 一段时间内没有数据接 ...

微服务架构解决了很多问题，但是同时引入了很多问题。本文要探讨的是如何解决下面这几个问题。 有大量的同步 RPC 依赖，如何保证自身的可靠性？ 依赖的微服务调用失败了，我应该失败，还是 ...

producer producer 1.启动流程 Producer如何感知要发送消息的broker即brokerAddrTable中的值是怎么获得的， ...

consumer 1.启动 有别于其他消息中间件由broker做负载均衡并主动向consumer投递消息，RocketMq是基于拉模式拉取消息，consumer做负载均衡并通过长轮询向brok ...

Netty 是一个 Java NIO 客户端服务器框架，使用它可以快速简单地开发网络应用程序，比如服务器和客户端的协议。Netty 大大简化了网络程序的开发过程比如 TCP 和 UDP 的 socke ...

摘要: 在JAVA NIO相关的组件中，ByteBuffer是除了Selector、Channel之外的另一个很重要的组件，它是直接和Channel打交道的缓冲区，通常场景或是从ByteBuffer写 ...

分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： 消息的顺序问题 消息的重复问题 R ...