美文网首页程序员
二、dubbo 之 RPC

二、dubbo 之 RPC

作者: cqzhangjian | 来源:发表于2018-09-18 11:51 被阅读22次

    dubbo 提供了面向接口代理的高性能RPC调用

    1. 什么是 PRC ?

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

    网络7层模型

    2. 为什么要用 PRC ?

    由于业务快速的增加,流量快速增加,需要针对业务域的不同拆成不同的系统、甚至不同的系统相同的基础服务需要抽取出来做成基础服务的时候,就需要 RPC 技术来解耦不同的系统、或者服务之间的调用,从而进行消息通讯。

    3.PRC 框架

    有很多实现了RPC 功能的框架,它们被称为RPC框架:有CORBAR、Thrift、Dubbo 等等。它们有两类,一种跨语言、一种单一语言

    dubbo就是一个分布式的跨语言的高性能的 RPC 框架

    4. 注册中心

    Dubbo 支持多种注册中心:
    Multicast 注册中心
    Zookeeper 注册中心
    Redis 注册中心
    Simple 注册中心

    dubbo 推荐使用 Zookeeper 作为 注册中心 上篇文章已经介绍了安装 Zookeeper

    Zookeeper 简单介绍: Zookeeper 是 Apache Hadoop 项目的一个子项目发展过来,现在已经作为了 Apache 的顶级项目,为分布式应用提供了高效及可靠的服务协调。诸如:统一命名服务、配置管理、分布式锁等分布式基础服务功能,在解决分布式数据的时候采用了 ZAB 的一致性协议

    5.开发服务应用

    5.1 服务接口应用 dubbo-zj-demo-api

    public interface DemoService {
    
        String sayHello(String name);
    }
    

    5.2 服务提供者 dubbo-zj-demo-provider

    工程结构
    • 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>org.zj.dubbo.demo</groupId>
        <artifactId>dubbo-zj-demo-consumer</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
    
        <name>dubbo-zj-demo-consumer</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.5.RELEASE</version>
            <relativePath /> <!-- lookup parent from repository -->
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.3</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.11.1</version>
            </dependency>
            <dependency>
                <groupId>org.zj.dubbo.demo</groupId>
                <artifactId>dubbo-zj-demo-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
        </dependencies>
    </project>
    
    • 服务注册
    public class DubboZjDemoProviderApplication {
    
        public static void main(String[] args) throws IOException {
              ServiceConfig<DemoService> serviceConfig = new ServiceConfig<DemoService>();
                    // 定义服务名
                serviceConfig.setApplication(new ApplicationConfig("first-dubbo-provider"));
                  // 向 zookeeper 注册中心注册服务
                serviceConfig.setRegistry(new RegistryConfig("zookeeper://192.168.1.188:2181"));
                  // 定义 PRC 协议
                serviceConfig.setProtocol(new ProtocolConfig("dubbo", 20880));
                // 发布服务接口
                serviceConfig.setInterface(DemoService.class);
              // 发布服务接口实现
                serviceConfig.setRef(new DemoServiceImpl());
                //  发布服务
                serviceConfig.export();
                System.in.read();
        }
    }
    

    5.3 服务调用者(消费) dubbo-zj-demo-consumer

    工程结构
    • 服务注册
    public class DubboZjDemoConsumerApplication {
    
        public static void main(String[] args) {
            
        ReferenceConfig<DemoService> referenceConfig = new ReferenceConfig<DemoService>();
            referenceConfig.setApplication(new ApplicationConfig("first-dubbo-consumer"));
            referenceConfig.setRegistry(new RegistryConfig("zookeeper://192.168.1.188:2181"));
            referenceConfig.setInterface(DemoService.class);
           // 调用服务
            DemoService greetingService = referenceConfig.get();
            System.out.println(greetingService.sayHello("world"));
        }
        
    }
    
    

    6 下载源码: https://github.com/cqzhangjian/dubbo-rpc.git

    7.管理控制台安装

    管理控制台下载地址:https://github.com/cqzhangjian/incubator-dubbo-ops.git

    管理控制台

    相关文章

      网友评论

        本文标题:二、dubbo 之 RPC

        本文链接:https://www.haomeiwen.com/subject/qrgynftx.html