Dubbo 高性能 RPC 框架實踐

作者：老鄭 2022-08-15 08:01:35

開發架構

Apache Dubbo 是一款微服務框架，為大規模微服務實踐提供高性能 RPC 通信、流量治理、可觀測性等解決方案，涵蓋 Java、Golang 等多種語言 SDK 實現。

?Dubbo 介紹

Dubbo 是什么？

介紹：Apache Dubbo 是一款微服務框架，為大規模微服務實踐提供高性能 RPC 通信、流量治理、可觀測性等解決方案，涵蓋 Java、Golang 等多種語言 SDK 實現。

特征：RPC 通訊框架，服務注冊中心，支持原生云（Dubbo3.0）

主流版本：2.7.x , 3.0 **SDK: **官方 SDK 支持開發語言：Java、Golang

使用廠家：阿里巴巴、餓了么、釘釘、工商銀行、小米等

注：本文后續主要基于 2.7.x 版本展開。

Dubbo 和 Eureka 對比

對比	Dubbo	Eureka（Spring-Cloud-Netflix）
注冊中心	ZK	Eureka
CAP	CP	AP
容錯機制	支持	通過 Hytrix 支持
負載均衡	支持	通過 Ribbon 支持
服務注冊和發現協議	封裝 NettyClient 實現	使用 HttpClient
社區支持	Apache	不更新

總結：Dubbo 對比 Eureka 來說的話，其實一個打包的微服務中間件，并且定制化了 RPC 通訊 dubbo 協議對比 HTTP 協議來說性能上會有一定的提高。但是我們對于微服務本身來說應該是一個細粒度的，可以定制的組件對于 Eureka 來說這方面更強。

Dubbo 使用案例

下面是一個通過 dubbo 作為 RPC 通訊的一個例子，一般在生產中會使用 zk 或者 redis 等，作為服務注冊中心來保存服務信息。一個大致的交互圖如下：

三個角色

Zookeeper 作為一個服務注冊中心，管理和維護服務列表；
Provider 服務提供者，發布服務；
Consumer 服務消費者，通過 API stub 可以像調用本地方法一樣調用遠程的方法；

服務提供者

服務接口定義

public interface OrderService {
    String createOrder(String request);
}

服務提供者實現

public class OrderServiceImpl implements OrderService {

    @Override
    public String createOrder(String request) {
        return "create order success, request : " + request;
    }
}

服務啟動類

public class RpcDubboProvidorApp {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"classpath:dubbo.xml"});
        context.start();
        System.in.read(); // 按任意鍵退出
    }
}

配置文件

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

    <!-- 提供方應用信息，用于計算依賴關系 -->
    <dubbo:application name="rpc-dubbo-provider"/>

    <!-- 使用 zookeeper 注冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- 聲明需要暴露的服務接口 -->
    <dubbo:service interface="io.zhengsh.rpc.api.OrderService" ref="orderService" />

    <!-- 和本地bean一樣實現服務 -->
    <bean id="orderService" class="io.zhengsh.rpc.provider.OrderServiceImpl" />

</beans>

服務消費者

服務配置

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

    <!-- 配置應用名稱 -->
    <dubbo:application name="rpc-dubbo-consumer" />

    <!-- 配置 zookeeper 注冊中心的位置 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

    <!-- 配置dubbo的通訊方式,即使用的協議及使用的端口 -->
    <dubbo:protocol name="dubbo" port="20890" />

    <!-- 生成遠程服務代理，可以和本地bean一樣使用 orderService -->
    <dubbo:reference id="orderService" interface="io.zhengsh.rpc.api.OrderService" />

</beans>

服務調用方代碼

public class RpcDubboConsumerApp {
    public static void main(String[] args) {

        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"classpath:dubbo.xml"});
        context.start();
        // 獲取遠程服務代理
        OrderService demoService = (OrderService) context.getBean("orderService");
        // 執行遠程方法
        String hello = demoService.createOrder("iPhone 19");
        // 顯示調用結果
        System.out.println(hello);
    }
}