MiniRPC- 源码阅读

（5）源码细节

Netty框架（数据传输框架）

 <dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> </dependency>

Zookeeper（注册中心框架）

<dependency>                <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId></dependency>

Jackson （序列化框架-1）

<dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> </dependency>

hession （序列化框架-2）

<dependency> <groupId>com.caucho</groupId> <artifactId>hessian</artifactId> </dependency>

（6）学习到的技术点（思维导读 + 思考 +总结）

（1）Bean的生命周期

BeanFactoryPostProcessor 后置增强类，添加消费端的代理BeanDefinition

（2） netty 编解码

ByteToMessageDecoder

MiniRpcDecoder  解码器

MessageToByteEncoder

MiniRpcEncoder 编码器

（3）JDK动态代理

RpcInvokerProxy

代理Consumer消费端对象

（4） 策略模式

序列化算法中，通过消息头中类型指定

HessianSerialization

JsonSerialization

（5）Zookeeper开源客户端

Curator“Guava is to java  what Curator is to Zookeeper”

分布式锁

分布式ID生成器

注册中心使用 Dubbo

修改事件监听器

Zookeeper基础

Zookeeper

数据模型

发布订阅

ACL权限控制

序列化

Watch健康

（6） Redis开源客户端

Redisson\"Guava is to java what Redisson is to Redis\"

Redlock

FairLock

MultiLock

lock

Id generator

Bloom Filter

AtomicLong

序列化支持

Avro

JDK Serialization

MsgPack

Kryo

集合选项

Map

Set

List

SortedSet

Queue

Blocking Queue

Delayed Queue

并发工具类的分布式应用

Semaphore

CountDownLatch

ReadWriteLock

Redis基础

发布/订阅消息

集群

Single

Cluster

Sentinel

Master/slave

（7）自己动手撸一个          (践行实践)

延迟消息队列服务  (xiaoshu-mq-broker)

xiaoshu-mq-server

序列化实现

编解码Encoder  and Decoder

DelayQueue 延迟队列

心跳检测机制；heartbeat

xiaoshu-mq-provider

xiaoshu-mq-consumer

考虑问题点

编解码/序列化和反序列化

心跳检测机制-掉线通知-踢出功能实现

在线客户端数量，在线客户端信息

集群高可用

参数配置 性能提升

消息可靠性，如何保证消息不丢失（持久化）

消息队列的长度控制（消息积压怎么办 ）

消息拒绝策略

消息转发策略

消息的顺序性

功能性测试，是否符合功能需求

性能性测试，是否符合性能需求

代码优化

调整包结构

core包

基础工具类

Protocol包

协议制定

序列化和反序列化

编解码 Encoder 和 Decoder

message包

消息类型

消息格式定义信息

消息头信息

延迟队列实现抽象接口

使用DelayQueue实现

使用RabbitMQ等第三方消息队列实现

使用 Redis消息队列实现

消息的可靠性

消息的持久化处理

添加消息的Ack机制

消息质量 Qos等级

（8）学习总结    （输出教授）

想法-1

EMQX我是否可以写个插件，将消息同步到RabbitMQ中

想法-2

实现桥接，将接收所有EMQX的消息，并转发到其它第三方消息队列中

收获-1

边缘扩展原则：通过扩展自己的知识边界，了解更多知识点

收获-2

深度学习原则：通过实践&总结文档&教授给他人，提高知识留存率

收获-3

专注学习原则：专注于一件事情，时间越长，收获越大；

Mini-RPC

min-rpc

（1） 搭建环境

JDK1.8

Zookeeper 3.4.6 注册中心

Idea 2021.3

Maven 3.5.4

Git 下载代码

（2）包说明

rpc-consumer

功能：消费端方

服务消费者。使用动态代理发起 RPC 远程调用，帮助使用者来屏蔽底层网络通信的细节。

rpc-provider

功能：服务提供方 

服务提供者。负责发布 RPC 服务，接收和处理 RPC 请求。

rpc-facade

功能：接口声明

RPC 服务接口。包含服务提供者需要对外暴露的接口，本模块主要用于模拟真实 RPC 调用的测试。

rpc-protocol

功能：协议制定，序列化和反序列化

网络通信模块。包含 RPC 协议的编解码器、序列化和反序列化工具等。

rpc-registry

功能：注册信息，将服务注册到Zookeeper上面

注册中心模块。提供服务注册、服务发现、负载均衡的基本功能。

rpc-core

功能：基础公共功能，包含有请求和结果封装类

基础类库。提供通用的工具类以及模型定义，例如 RPC 请求和响应类、RPC 服务元数据类等。

（3） 使用到技术点

Serialization

RpcSerialization

编解码

Codec

MiniRpcEncoder

MinRpcDecoder

消息协议的制定

+---------------------------------------------------------------+| 魔数 2byte | 协议版本号 1byte | 序列化算法 1byte | 报文类型 1byte |+---------------------------------------------------------------+| 状态 1byte | 消息 ID 8byte | 数据长度 4byte |+---------------------------------------------------------------+| 数据内容 （长度不定） |+---------------------------------------------------------------+

BeanFactoryPostProcessor

Bean工程的后置处理类，针对BeanDefinition  注入消费端Service；

（4）设计模式

策略模式

协议中序列化方式： （1）JsonSerialization  （2）HessianSerialization

(RpcSerialization)(RegistryFactory)

代理模式

迭代器模式

RpcConsumerPostProcessor

单例模式

RegistryFactory.getInstance (懒汉模式)