RPC原理及Dubbo入门

现在互联网公司没有不用分布式的，看看招聘岗位都要求着Dubbo，Spring Cloud等等。

关于Dubbo，不好意思去说，我所在的公司比较小，架构相对没有那么复杂，服务也没那么多，就没在生产环境用Dubbo，面试官问我用过Dubbo的时候，我心里好纠结啊，我只在本地做过Demo，不过不管有没有用过，能回答上有关Dubbo的问题，就能证明你懂这个。写篇入门文章，证明自己目前略懂Dubbo。

什么是RPC

RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

RPC简单理解就是在本地调用远端的程序，但是感觉好像是在调用本地的程序一样。毕竟代码都封装好了，只要代码功能正常，代码不一定要存放在本地，放在远端自己能运行也是一个效果。

RPC有助于系统的垂直拆分，使系统更易拓展。

面试题：
你了解哪些RPC框架？
答：Dubbo,Thift,RMI

RPC调用过程

image.png

1. 客户端以本地服务方式调用服务
2. client stub作为代理，然后处理调用与调用的参数
3. client stub发送调用到远端的系统，通过TCP或UDP
4. server stub处理client stub发过来的调用与参数
5. server stub调用真正提高的服务
6. server stub处理回复，然后发送给客户端

RPC调用一般会设计代理相关的内容

Dubbo

image.png

Dubbo是一个高性能的基于Java的RPC框架，底层基于Netty，通常与ZooKeeper配合使用，参考个人对ZooKeeper的愚见Zookeeper系列。

Dubbo 项目演示

在做分布式项目时，一般会进行分层处理，底层不可依赖高层，Dubbo的演示项目包含三个小项目：

• dubbo-api 定义API接口，形成统一的规范
• dubbo-provider api接口的实际实现着，服务提供方
• dubbo-consumer 调用api接口的客户端

代码

1. 父级的pom文件引入依赖关系

<?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>me.aihe</groupId>
    <artifactId>dubbodemo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>dubbo-api</module>
        <module>dubbo-provider</module>
        <module>dubbo-consumer</module>
    </modules>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>
        <!-- Dubbo依赖 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
        </dependency>
    </dependencies>

</project>

1. dubbo-api项目，定义接口

package me.aihe.dubbodemo;

/**
 * @author aihe 2018/7/11
 */
public interface DoSomeThingApi {
    String sayHello(String name);
}

1. dubbo-provider项目提供接口的实现

//dubbo-provider.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:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <dubbo:application name="provider" />

    <dubbo:registry address="multicast://224.5.6.7:1234" />
    <dubbo:protocol name="dubbo" port="20880" />
    <dubbo:service interface="me.aihe.dubbodemo.DoSomeThingApi" ref="doSomeThingService" />
    <bean id="doSomeThingService" class="me.aihe.dubbodemo.provider.DoSomeThingApiImpl" />

</beans>

//为了方便起见，把provider的启动程序也放在这里了
public class DoSomeThingApiImpl implements DoSomeThingApi {
    public String sayHello(String name) {
        return "Hello " + name;
    }

   public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-provider.xml");
        context.start();
        System.in.read(); // Press any key to ex
    }
}

1. dubbo-consumer的配置

<?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:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <dubbo:application name="consumer" />
    <dubbo:registry address="multicast://224.5.6.7:1234" />
    <dubbo:reference id="doSomeThingService" interface="me.aihe.dubbodemo.DoSomeThingApi"/>
</beans>

public class Consumer {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-consumer.xml");
        context.start();
        DoSomeThingApi doSomeThingApi = (DoSomeThingApi) context.getBean("doSomeThingService");
        String result = doSomeThingApi.sayHello("艾贺");
        System.out.println(result);
    }
}

分别运行provider项目，和consumer项目，即可查看结果。

image.png

注意：在使用多播的时候，可能会报Can't assign requested address错误，这时需要加上VM参数：-Djava.net.preferIPv4Stack=true

Dubbo常用配置

Dubbo常用配置

最后

Dubbo入门先讲到这里，先运行起基本的demo项目再深入源码

参考

• Dubbo 中文文档
• Dubbo英文文档