代码拉取完成，页面将自动刷新
本项目基于 Spring + Netty + Zookeeper + Protostuff 从零开始设计实现一个轻量级分布式 RPC 框架，内含详细设计思路以及开发教程，通过造轮子的方式来学习，深入理解 RPC 框架的底层原理。相比简历上一律的 xxxx 系统，造轮子很显然更能赢得面试官的青睐
当然，大家在实际项目中少造轮子，尽量去用现成的优秀框架
项目源码地址：
学习本项目，你需要下面这些技术储备：
Java 基础
Netty 4.x：使 NIO 编程更加容易，屏蔽了 Java 底层的 NIO 细节
Zookeeper：提供服务注册与发现功能，开发分布式系统的必备选择，具备天生的集群能力
Spring：最强大的依赖注入框架，业界的权威标准
使用 Spring 提供依赖注入与参数配置
集成 Spring 通过注解注册服务
集成 Spring 通过注解消费服务
使用 Netty 进行网络传输
使用 Zookeeper（ZkClient 客户端）实现服务注册和发现
本框架的核心功能模块：
rpc-common：包含封装 RPC 请求与响应（网络传输）的实体类/消息体 entity，Netty 编解码器 codec 以及序列化/反序列 serialize
rpc-server：Netty / RPC 服务端，处理并响应客户端的请求 / 消息体）rpc-client：Netty / RPC 客户端，向服务端发送请求 / 消息体 + 接收服务端的响应rpc-registry：定义服务注册与发现行为的接口rpc-registry-zookeeper：基于 Zookeeper 及其客户端 ZkClient 实现服务的注册与发现下述这三个模块展示了如何使用本框架：
rpc-sample-api：定义服务接口（RPC 接口）rpc-sample-server：实现服务接口（RPC 接口），启动 / 发布 RPC 服务rpc-sample-client：调用 RPC 服务（使用动态代理调用远程方法）框架的使用样例代码存放在 rpc-sample-xxx 包中。
要想使用这个框架，我们需要该框架的服务注册组件和 RPC 服务器注入进服务端包 rpc-sample-server 中，将服务发现组件和 RPC 客户端（代理）注入进客户端 rpc-sample-client 包中，下面详细讲解一下本框架的基本使用 ⬇️
参见 rpc-sample-api 模块
package com.cswiki.rpc.sample.api;
public interface HelloService {
String hello(String name);
}
将该模块打成 jar 包供其他项目使用，点击右边的 Maven 然后选择 install ，这样 jar 包就打好了：
需要将 RPC 接口与 RPC 实现分别存放在不同的模块中
👉 参见 rpc-sample-server 模块
<dependencies>
<!--RPC 接口所在模块的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-sample-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--RPC 服务端框架的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-server</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--注册中心所在模块的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-registry-zookeeper</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--Spring-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.3.1</version>
<scope>compile</scope>
</dependency>
</dependencies>
实现该接口：
@RpcService(HelloService.class) // 指定暴露服务的接口类型
public class HelloServiceImple implements HelloService {
@Override
public String hello(String name) {
return "Hello! " + name;
}
}
使用 RpcService 注解定义在服务接口的实现类上表示暴露该服务
若 RPC 接口拥有多个实现类，则需要在 RpcService 注解中指定 version 属性加以区分
/**
* HelloService 接口实现类 2（暴露该服务，需要指明 version）
*/
@RpcService(value = HelloService.class, version = "helloServiceImpl2") // 指定暴露服务的接口类型和版本
public class HelloServiceImpl2 implements HelloService {
@Override
public String hello(String name) {
return "Hello! " + name + ", I am helloServiceImpl2";
}
}
通过 Spring 注册相关组件：sping.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!--对 rpc.sample.server 这个包进行扫描，也就是说在这个包中去寻找客户端请求的方法-->
<context:component-scan base-package="com.cswiki.rpc.sample.server"></context:component-scan>
<!--服务器配置参数-->
<context:property-placeholder location="classpath:rpc.properties"></context:property-placeholder>
<!--配置服务注册组件 Zookeeper, 需提供 ZooKeeper 地址、系统名、实例号-->
<bean id = "serviceRegistry" class="com.cswiki.rpc.registry.zookeeper.ZooKeeperServiceRegistry">
<constructor-arg name="zkAddress" value="${rpc.registry_address}"></constructor-arg>
</bean>
<!--配置 RPC 服务器, 用于发布 RPC 服务，需要提供服务器端口-->
<bean id = "rpcServer" class="com.cswiki.rpc.server.RpcServer">
<!--服务地址 127.0.0.1:8000-->
<constructor-arg name = "serviceAddress" value="${rpc.service_address}"></constructor-arg>
<!--注册中心地址 127.0.0.1:2181-->
<constructor-arg name= "serviceRegistry" ref = "serviceRegistry"></constructor-arg>
</bean>
</beans>
serviceRegistry：用于服务注册（使用 ZooKeeper 实现），需提供 ZooKeeper 地址、系统名、实例号
注册到 ZooKeeper 中的 ZNode 路径为：registry/service/address，前 2 个节点是持久的，最后 1 个节点是临时的
rpcServer：用于发布 RPC 服务，需要提供服务器端口
以下配置表明：连接本地的 ZooKeeper 服务器，并在 8000 端口上发布 RPC 服务
# ZooKeeper 服务器(注册中心）
rpc.registry_address = 127.0.0.1:2181
# RPC 服务端
rpc.service_address = 127.0.0.1:8000
运行 RpcBootstrap 类，将对外发布 RPC 服务，同时进行服务注册（其实就是加载 Spring 配置文件）
package com.cswiki.rpc.sample.server;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* 启动服务器并发布服务（其实就是加载 spring 配置文件）
*/
public class RpcBootstrap {
public static void main(String[] args) {
// 加载 Spring 配置文件
new ClassPathXmlApplicationContext("spring.xml");
}
}
参见 rpc-sample-client 模块
<dependencies>
<!--RPC 客户端框架的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-client</artifactId>
<version>1.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<!--RPC 接口所在模块的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-sample-api</artifactId>
<version>1.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<!--注册中心所在模块的依赖-->
<dependency>
<groupId>com.cswiki</groupId>
<artifactId>rpc-registry-zookeeper</artifactId>
<version>1.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<!--Spring-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.3.1</version>
<scope>compile</scope>
</dependency>
</dependencies>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<context:property-placeholder location="classpath:rpc.properties"/>
<bean id="serviceDiscovery" class="com.cswiki.rpc.registry.zookeeper.ZooKeeperServiceDiscovery">
<constructor-arg name="zkAddress" value="${rpc.registry_address}"/>
</bean>
<bean id="rpcProxy" class="com.cswiki.rpc.client.RpcProxy">
<constructor-arg name="serviceDiscovery" ref="serviceDiscovery"/>
</bean>
</beans>
serviceDiscovery：用于服务发现（使用 ZooKeeper 实现），需提供 ZooKeeper 地址rpcProxy：用于获取 RPC 代理接口# ZooKeeper 服务器的地址（IP 地址与端口）
rpc.registry_address=127.0.0.1:2181
package com.cswiki.rpc.sample.client;
import com.cswiki.rpc.client.RpcProxy;
import com.cswiki.rpc.sample.api.HelloService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class HelloClient {
public static void main(String[] args) throws Exception {
// 加载 Spring 配置文件
ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
// 获取 RpcProxy 动态代理对象
RpcProxy rpcProxy = context.getBean(RpcProxy.class);
/**
* 测试 HelloService 接口的实现类 1
*/
// 调用 RpcProxy 对象的 create 方法来创建 RPC 代理接口
HelloService helloService = rpcProxy.create(HelloService.class);
// 调用 RPC 代理接口的方法(调用远程接口方法就像调用本地方法一样简单）
String result = helloService.hello("World");
System.out.println(result);
/**
* 测试 HelloService 接口的实现类 2
*/
HelloService helloServiceImpl2 = rpcProxy.create(HelloService.class, "helloServiceImpl2");
String result2 = helloServiceImpl2.hello("Java");
System.out.println(result2);
System.exit(0);
}
}
小白专属，大佬勿喷，逻辑并不难，对 Netty 和 RPC 较熟悉的大 🔥 直接上手撸代码就行
🔗 地址在此：编程满天星 - 手写 RPC 教程与面试精讲
🔗 地址在此：编程满天星 - 手写 RPC 教程与面试精讲
🔗 地址在此：编程满天星 - 手写 RPC 教程与面试精讲
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型