基于Java语言实现的RPC框架

1.理论篇

概念
RPC:Remote Procedure Call,即远程过程调用
是分布式系统常见的一种通信方法,从跨进程到跨物理机已经有几十年历史
跨进程交互形式:RESTful WebService HTTP 基于DB做数据交换 基于MQ做数据交换 以及RPC
图解交互形式

现有框架对比

核心原理(整体架构)

• Server: Provider,暴露服务,服务提供方
• Client: Consumer,服务消费,调用远程服务
• Registry: 服务注册与发现
  

技术栈:

• 基础知识:JavaCore,Maven,反射
• 动态代理(生成client存根实际调用对象)
  • Java的动态代理
• 序列化(Java对象与二进制数据互转)
  • fastjson
  • 序列号:Java对象转为二进制数组
  • 反序列化:二进制数组转为Java对象
• 网络通信(传输序列化后的数据)
  • jetty,URLConnection

2.实战篇

1.类图

2.创建工程

引入依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zhn</groupId>
    <artifactId>zhn-RPC</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>zhn-rpc-common</module>
        <module>zhn-rpc-codec</module>
        <module>zhn-rpc-client</module>
        <module>zhn-rpc-proto</module>
        <module>zhn-rpc-server</module>
        <module>zhn-rpc-transport</module>
    </modules>

    <properties>
        <java.version>1.8</java.version>
        <commons.version>2.5</commons.version>
        <jetty.version>9.4.19.v20190610</jetty.version>
        <fastjson.version>1.2.44</fastjson.version>
        <lombok.version>1.18.8</lombok.version>
        <slf4j.version>1.7.26</slf4j.version>
        <junit.version>4.12</junit.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>commons-io</groupId>
                <artifactId>commons-io</artifactId>
                <version>${commons.version}}</version>
            </dependency>
            <dependency>
                <groupId>org.eclipse.jetty</groupId>
                <artifactId>jetty-servlet</artifactId>
                <version>${jetty.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>${fastjson.version}}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>${junit.version}</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>${lombok.version}</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>${slf4j.version}</version>
        </dependency>
    </dependencies>


    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.3</version>
                <configuration>
                    <source>${java.version}</source>
                    <target>${java.version}</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>