Dubbo 面试之应用

简介

【简单】Dubbo 是什么？为什么使用 Dubbo？

Dubbo 是一款高性能、轻量级的开源 Java RPC 框架。

Dubbo 提供了三大核心能力：

• 面向接口的远程过程调用（RPC）：提供高性能的基于代理的远程调用能力，服务以接口为粒度，为开发者屏蔽远程调用底层细节。
• 智能容错和负载均衡：内置多种负载均衡策略，智能感知下游节点健康状况，显著减少调用延迟，提高系统吞吐量。
• 服务自动注册和发现：支持多种注册中心服务，服务实例上下线实时感知。

Dubbo 面试之服务治理

服务注册和发现

【中等】什么是服务注册与发现？Dubbo 如何实现？

服务注册与发现是微服务的核心基础设施，通过解耦服务地址硬编码，实现动态扩缩容和故障自动恢复。

• 服务注册（Registration）：服务提供者（Provider）启动时，将自己的 IP、端口、接口名 等信息上报到注册中心（如 Zookeeper/Nacos）。举例：订单服务启动后，向注册中心注册："order-service: 192.168.1.100:8080"。
• 服务发现（Discovery）：服务消费者（Consumer）从注册中心 拉取可用服务列表，并基于负载均衡策略选择目标实例。举例：支付服务需要调用订单服务时，从注册中心获取所有可用的order-service节点列表。

《Kafka 核心技术与实战》笔记

开篇词 为什么要学习 Kafka？

消息引擎系统 ABC

消息引擎系统的作用：

• 消息引擎传输的对象是消息；
• 如何传输消息属于消息引擎设计机制的一部分。

Kafka 面试

Kafka 简介

【简单】Kafka 是什么？

Apache Kafka 是一款开源的消息引擎系统，也是一个分布式流计算平台，此外，还可以作为数据存储。

RPC 面试

RPC 简介

【基础】什么是 RPC？RPC 有什么用？

Dubbo 面试之架构

调用流程

【简单】Dubbo 支持哪些序列化方式？

• Hessian（默认）
  • 特点：二进制格式，速度较快，体积较小
  • 适用场景：通用 RPC 调用（Dubbo 默认方案）
  • 缺点：对复杂对象支持有限
• JSON
  • 特点：文本格式，可读性强，跨语言支持好
  • 适用场景：前后端交互、多语言系统
  • 缺点：性能较差，数据体积大
• Java 原生序列化
  • 特点：JDK 内置，使用简单
  • 适用场景：Java 单体应用调试
  • 缺点：性能差，体积大，仅限 Java
• Kryo
  • 特点：高性能二进制，速度极快，体积小
  • 适用场景：高并发、低延迟场景
  • 缺点：API 复杂，需注册类
• Protobuf（推荐）
  • 特点：Google 出品，高效跨语言，可扩展
  • 适用场景：微服务跨语言通信
  • 缺点：需预定义。proto 文件
• FST
  • 特点：类似 Kryo，高性能二进制
  • 适用场景：替代 Hessian 的高性能需求
  • 缺点：兼容性较弱

《Dubbo 源码解读与实战》笔记

开篇词 深入掌握 Dubbo 原理与实现，提升你的职场竞争力

Apache Dubbo是一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：

• 面向接口的远程方法调用；
• 可靠、智能的容错和负载均衡；
• 服务自动注册和发现能力。

Dubbo 是一个分布式服务框架，致力于提供高性能、透明化的 RPC 远程服务调用方案以及服务治理方案，以帮助我们解决微服务架构落地时的问题。

《RocketMQ 技术内幕》笔记

读源代码前的准备

RocketMQ 源代码的目录结构

• broker：broker 模块（broker 启动进程） 。
• client：消息客户端，包含生产者、消息消费者相关类。
• common：公共包。
• dev：开发者信息（非源代码） 。
• distribution：部署实例文件夹（非源代码） 。
• example：RocketMQ 示例代码。
• filter：消息过滤相关基础类。
• filter：消息过滤服务器实现相关类（Filter 启动进程） 。
• logappender：日志实现相关类。
• namesrv：N ameServer 实现相关类（Names 巳 rver 启动进程） 。
• openmessaging：消息开放标准，正在制定中。
• remoting：远程通信模块，基于 Netty 。
• srvutil：服务器工具类。
• store：消息存储实现相关类。
• style：checkstyle 相关实现。
• test：测试相关类。
• tools：工具类，监控命令相关实现类。

RocketMQ FAQ

API 问题

connect to <172.17.0.1:10909> failed

启动后，Producer 客户端连接 RocketMQ 时报错：

org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1:10909> failed
    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:357)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:343)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:327)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:290)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:688)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendSelectImpl(DefaultMQProducerImpl.java:901)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:878)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:873)
    at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:369)
    at com.emrubik.uc.mdm.sync.utils.MdmInit.sendMessage(MdmInit.java:62)
    at com.emrubik.uc.mdm.sync.utils.MdmInit.main(MdmInit.java:2149)

RocketMQ 基本原理

原理

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

1. 消息的顺序问题
2. 消息的重复问题

顺序消息

第一种模型

假如生产者产生了 2 条消息：M1、M2，要保证这两条消息的顺序，应该怎样做？你脑中想到的可能是这样：