RPC原理及Dubbo入门

  1. 云栖社区>
  2. 博客>
  3. 正文

RPC原理及Dubbo入门

艾贺 2018-07-11 20:43:00 浏览1224
展开阅读全文

现在互联网公司没有不用分布式的,看看招聘岗位都要求着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调用过程

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

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

Dubbo

img_7170e8174d9e6431503cbeb9236612fc.png
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项目,即可查看结果。


img_eaabd43125c153c895764dd988daa7fa.png
image.png

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

Dubbo常用配置

img_64e945ab9f874b7e4a6eb12d372591c6.png
Dubbo常用配置

最后

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

参考

网友评论

登录后评论
0/500
评论
艾贺
+ 关注