主頁 > 後端開發 > 分布式服務治理框架Dubbo的前世今生及應用實戰

分布式服務治理框架Dubbo的前世今生及應用實戰

2021-12-07 15:17:37 後端開發

Dubbo前世今生

Dubbo的出現背景

Dubbo從開源到現在,已經出現了接近10年時間,在國內各大企業被廣泛應用, 它到底有什么魔力值得大家去追捧呢?本篇文章給大家做一個詳細的說明,

大規模服務化對于服務治理的要求

當企業開始大規模的服務化以后,遠程通信帶來的弊端就越來越明顯了,比如說

  1. 服務鏈路變長了,如何實作對服務鏈路的跟蹤和監控呢?

  2. 服務的大規模集群使得服務之間需要依賴第三方注冊中心來解決服務的發現和服務的感知問題

  3. 服務通信之間的例外,需要有一種保護機制防止一個節點故障引發大規模的系統故障,所以要有容錯機制

  4. 服務大規模集群會是的客戶端需要引入負載均衡機制實作請求分發

而這些對于服務治理的要求,傳統的RPC技術在這樣的場景中顯得有點力不從心,因此很多企業開始研發自己的RPC框架,比如阿里的HSF、Dubbo;京東的JSF框架、當當的dubbox、新浪的motan、螞蟻金服的sofa等等

有技術輸出能力的公司,都會研發適合自己場景的rpc框架,要么是從0到1開發,要么是基于現有的思想結合公司業務特色進行改造,而沒有技術輸出能力的公司,遇到服務治理的需求時,會優先選擇那些比較成熟的開源框架,而Dubbo就是其中一個

dubbo主要是一個分布式服務治理解決方案,那么什么是服務治理?服務治理主要是針對大規模服務化以后,服務之間的路由、負載均衡、容錯機制、服務降級這些問題的解決方案,而Dubbo實作的不僅僅是遠程服務通信,并且還解決了服務路由、負載、降級、容錯等功能,

Dubbo的發展歷史

Dubbo是阿里巴巴內部使用的一個分布式服務治理框架,2012年開源,因為Dubbo在公司內部經過了很多的驗證相對來說比較成熟,所以在很短的的還是件就被很多互聯網公司使用,再加上阿里出來的很多技術大牛進入各個創業公司擔任技術架構以后,都以Dubbo作為主推的RPC框架使得dubbo很快成為了很多互聯網公司的首要選擇,并且很多公司在應用dubbo時,會基于自身業務特性進行優化和改進,所以也衍生了很多版本,比如京東的JSF、比如新浪的Motan、比如當當的dubbox.

在2014年10月份,Dubbo停止了維護,后來在2017年的9月份,阿里宣布重啟Dubbo,并且對于Dubbo做好了長期投入的準備,并且在這段時間Dubbo進行了非常多的更新,目前的版本已經到了2.7.

2018年1月8日,Dubbo創始人之一梁飛在Dubbo交流群里透露了Dubbo 3.0正在動工的訊息,Dubbo 3.0內核與Dubbo2.0完全不同,但兼容Dubbo 2.0,Dubbo 3.0將支持可選Service Mesh

2018年2月份, Dubbo捐給了Apache,另外,阿里巴巴對于Spring Cloud Alibaba生態的完善,以及Spring Cloud團隊對于alibaba整個服務治理生態的支持,所以Dubbo未來依然是國內絕大部分公司的首要選擇,

Dubbo的整體架構

img

Dubbo的使用

首先,構建兩個maven專案

  • user-service
    • user-service-api
    • user-service-provider
  • user-service-consumer

user-service-api

user-service提供服務的公共契約,里面提供了user-service對外的服務,

public interface ILoginService {

    String login(String username,String password);
}

user-service-provider

在user-service-provider服務中,提供ILoginService的實作

public class LoginServiceImpl implements ILoginService{
    @Override
    public String login(String username, String password) {
        if(username.equals("admin")&&password.equals("admin")){
            return "SUCCESS";
        }
        return "FAILED";
    }
}

user-service-consumer

public class App 
{
    public static void main( String[] args ){
        ILoginService loginService=null;

        System.out.println(loginService.login("admin","admin"));
    }
}

問題來了,現在user-service-consumer作為服務消費者,如何去呼叫遠程服務user-service-provider呢?

按照前面對于服務遠程通信的原理來說,服務提供方必然需要將服務發布到網路上,并且提供對應的訪問協議,而服務消費端必然需要基于這個協議來進行訪問,

這個時候,dubbo這個中間件就派上用場了,它的最基本作用就是提供服務的發布和服務的遠程訪問,

引入Dubbo發布服務

  • 引入dubbo依賴包

    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.7.8</version>
    </dependency>
    
  • 在/src/main/resource/META-INF/spring目錄下添加application.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="user-service"/>
        <!-- 使用multicast廣播注冊中心暴露服務地址 -->
        <dubbo:registry address="N/A" />
        <!-- 用dubbo協議在20880埠暴露服務 -->
        <dubbo:protocol name="dubbo" port="20880" />
        <!-- 宣告需要暴露的服務介面 -->
        <dubbo:service interface="com.gupaoedu.demo.ILoginService" ref="loginService" />
        <!-- 和本地bean一樣實作服務 -->
        <bean id="loginService"  />
    
    </beans>
    
  • 啟動服務

    public class App 
    {
        public static void main( String[] args ){
            Main.main(args);
        }
    }
    
  • 啟動成功后,會在控制臺看到如下日志

    資訊:  [DUBBO] Export dubbo service com.gupaoedu.demo.ILoginService to url dubbo://192.168.1.104:20880/com.gupaoedu.demo.ILoginService?anyhost=true&application=user-service&bind.ip=192.168.1.104&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&interface=com.gupaoedu.demo.ILoginService&methods=login&pid=24280&release=2.7.8&side=provider&timestamp=1596550697070, dubbo version: 2.7.8, current host: 192.168.152.1
    八月 04, 2020 10:18:17 下午 org.apache.dubbo.remoting.transport.AbstractServer info
    資訊:  [DUBBO] Start NettyServer bind /0.0.0.0:20880, export /192.168.1.104:20880, dubbo version: 2.7.8, current host: 192.168.152.1
    

通過上述步驟,就表示ILoginService已經發布到了網路上,基于NettyServer的形式,默認監聽20880埠

服務消費者引入dubbo

  • 添加jar包依賴

    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.7.8</version>
    </dependency>
    
  • 在/src/main/resources/META-INF/spring目錄下添加application.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="user-service-consumer"/>
        <!-- 使用multicast廣播注冊中心暴露服務地址 -->
        <dubbo:registry address="N/A" />
        <dubbo:reference id="loginService" interface="com.gupaoedu.demo.ILoginService"/>
    </beans>
    
  • 修改main方法

    • 通過ApplicationContext加載spring的組態檔
    • 從容器中獲得一個ILoginService的bean
    public class App 
    {
        public static void main( String[] args ){
            ILoginService loginService=null;
            ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:META-INF/spring/application.xml");
            loginService=applicationContext.getBean(ILoginService.class);
    
            System.out.println(loginService.login("admin","admin"));
        }
    }
    

指定服務提供端的url

在上述的配置完成之后,運行專案后發現會提示如下錯誤

IllegalStateException: No such any registry to reference com.gupaoedu.demo.ILoginService on the consumer 192.168.152.1 use dubbo version 2.7.8, please config <dubbo:registry address="..." /> to your spring config.

原因是,我們配置的dubbo:registry指定的注冊中心是N/A,表示沒有配置注冊中心,

其次,我們也沒有明確的指明服務提供者在什么位置,因此解決這個問題的方法有兩種

  • 指向服務提供者的地址
  • 配置服務注冊中心,把服務提供者注冊到注冊中心,然后服務消費者指向注冊中心從注冊中心獲取服務地址

修改方式如下,修改服務消費者中application.xml中的dubbo:reference,

 <dubbo:reference id="loginService" interface="com.gupaoedu.demo.ILoginService"
     url="dubbo://192.168.1.104:20880/com.gupaoedu.demo.ILoginService"/>

總結

簡單總結一下上面的整個程序,其實不難發現,Dubbo這個中間件為我們提供了服務遠程通信的解決方案,通過dubbo這個框架,可以開發者快速高效的構建微服務架構下的遠程通信實作,

不知道大家是否發現,我們在使用dubbo發布服務,或者消費服務的時候,全程都是采用spring的配置來完成的,這樣的好處是我們在學習或者使用dubbo時,如果你用過spring這個框架,那么對于它的學習難度會大大的降低,而且我們也可以看到,dubbo是完全集成Spring 的,因此后續我們去分析dubbo的原始碼時,還是會有一些和spring有關的內容,

而且如果大家之前學習過我手寫RPC的那節課,也基本能猜測到它的整個實作結構,大家不妨大膽的去猜測dubbo的一些實作細節,以助于后續在深度學習dubbo時更好的理解,

引入注冊中心

Dubbo并不僅僅只是一個RPC框架,他還是一個服務治理框架,它提供了對服務的統一管理、以及服務的路由等功能,

在上面的案例中,我們只是掩飾了Dubbo作為RPC通信的點對點服務,但是就像咱們前面在學習spring cloud的內容一樣,服務多了以后,如何管理和維護,以及動態發現呢?

而且,從Dubbo的架構圖中可以看到,Dubbo天然就支持服務注冊與發現,官方最早推薦的服務注冊中心是zookeeper,當然,目前dubbo能夠支持的注冊中心已經非常多了,比如

consul、etcd、nacos、sofa、zookeeper、eureka、redis等等,很顯然,Dubbo已經在往一個獨立微服務解決方案的生態在發展,

集成Zookeeper作為服務注冊中心

  • 添加zookeeper的jar包依賴

    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <version>2.7.8</version>
    </dependency>
    
  • 修改服務提供者和服務消費者的配置

    <dubbo:registry address="zookeeper://192.168.216.128:2181" />
    

集成Nacos作為服務注冊中心

  • 啟動nacos

    docker run --name nacos -d -p 8848:8848 --privileged=true --restart=always -e JVM_XMS=512m -e JVM_XMX=2048m -e MODE=standalone -e PREFER_HOST_MODE=hostname -v /home/nacos/logs:/home/nacos/logs nacos/nacos-server
    
    • privileged: 使用該引數,container內的root擁有真正的root權限,否則,container內的root只是外部的一個普通用戶權限,
    • 當 Docker 重啟時,容器自動重啟
    • PREFER_HOST_MODE: ip #如果支持主機名可以使用hostname,否則使用ip,默認也是ip
  • 添加依賴

    <dependency>
        <groupId>com.alibaba.nacos</groupId>
        <artifactId>nacos-client</artifactId>
        <version>1.2.1</version>
    </dependency>
    
  • 修改配置

    <dubbo:registry address="nacos://192.168.216.128:8848" timeout="10000" />
    

Dubbo Spring Cloud

既然我們講的是Spring Cloud Alibaba這個專題,那么我們就有必要去了解一下Dubbo是如何集成Spring Cloud去使用的,

Dubbo Spring Cloud是構建在原生的Spring Cloud之上,涵蓋了Spring Cloud原生特性,而且相對于Spring Cloud原生治理來說,Dubbo Spring Cloud提供了更加穩定和成熟的實作,

具體的特性對比如下:

![image-20200804224645852](E:\教研-課件\vip課程\第四輪\分布式微服務\5 第五章 Spring Cloud Alibaba微服務生態\01 第一節 微服務治理之Dubbo的基本認識\第一節 微服務治理之Dubbo的基本認識.assets\image-20200804224645852.png)

為什么叫Dubbo Spring Cloud,而不是Spring Cloud Dubbo呢,在我看來,Dubbo本身是自成一個生態體系,并且在本身的服務治理以及成熟度上要比Spring cloud 更加突出,

所以實際上Dubbo整合Spring Cloud,是Dubbo這個成熟的生態去擁抱spring cloud的標準體系,

Dubbo Spring Cloud 基于 Dubbo Spring Boot 2.7.1[1] 和 Spring Cloud 2.x 開發,無論開發人員是 Dubbo 用戶還是 Spring Cloud 用戶, 都能輕松地駕馭,并以接近“零”成本的代價使應用向上遷移

從 2.7.0 開始,Dubbo Spring Boot 與 Dubbo 在版本上保持一致

接下來,我們可以去利用Dubbo Spring Cloud來做一個簡單的案例實作

創建一個專案

  • 創建一個spring-cloud-dubbo-example的maven工程
  • 分別添加三個模塊
    • spring-cloud-dubbo-sample-api
    • spring-cloud-dubbo-sample-provider
    • spring-cloud-dubbo-sample-consumer

其中后面兩個模塊都是spring boot的應用,

修改spring-cloud-dubbo-sample-provider這個模塊中,

  • 將dependencyManagement部分的依賴移動到parent pom.xml

  • 修改spring-cloud-dubbo-sample-provider中的pom.xml,增加parent模塊的依賴

    <parent>
        <groupId>com.gupaoedu.dubbo</groupId>
        <artifactId>spring-cloud-dubbo-example</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    
  • 添加maven依賴

    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <dependency>
        <groupId>com.gupaoedu.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
        <artifactId>spring-cloud-dubbo-sample-api</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    

定義服務介面

在spring-boot-dubbo-sample-api模塊中,定義介面

public interface IHelloService {

    String sayHello();
}

實作服務

在spring-boot-dubbo-sample-provider中,實作IHelloService介面

public class HelloServiceImpl implements IHelloService{

    @Override
    public String sayHello() {
        return "Hello GuPao";
    }
}

添加@EnableDiscoveryClient注解

@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudDubboSampleProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudDubboSampleProviderApplication.class, args);
    }

}

配置dubbo服務發布

  • 在服務實作類中添加@Service注解

    @Service
    public class HelloServiceImpl implements IHelloService{
    
        @Override
        public String sayHello() {
            return "Hello GuPao";
        }
    }
    
  • 配置dubbo提供方資訊

    # dubbo 服務掃描基礎包路徑
    dubbo.scan.base-packages=com.gupaoedu.dubbo.springclouddubbosampleprovider
    
    dubbo.protocol.id=dubbo
    # Dubbo 服務暴露的協議配置,其中子屬性 name 為協議名稱,port 為協議埠( -1 表示自增埠,從 20880 開始)
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=-1
    
    spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848
    
    • dubbo.scan.base-packages : 指定 Dubbo 服務實作類的掃描基準包
    • dubbo.protocol : Dubbo 服務暴露的協議配置,其中子屬性 name 為協議名稱,port 為協議埠( -1 表示自增埠,從 20880 開始)
    • dubbo.registry : Dubbo 服務注冊中心配置,其中子屬性 address 的值 "spring-cloud://localhost",說明掛載到 Spring Cloud 注冊中心
    • spring.cloud.nacos.discovery : Nacos 服務發現與注冊配置,其中子屬性 server-addr 指定 Nacos 服務器主機和埠

版本規范

專案的版本號格式為 x.x.x 的形式,其中 x 的數值型別為數字,從 0 開始取值,且不限于 0~9 這個范圍,專案處于范訓器階段時,第一位版本號固定使用 0,即版本號為 0.x.x 的格式,

由于 Spring Boot 1 和 Spring Boot 2 在 Actuator 模塊的介面和注解有很大的變更,且 spring-cloud-commons 從 1.x.x 版本升級到 2.0.0 版本也有較大的變更,因此我們采取跟 SpringBoot 版本號一致的版本:

  • 1.5.x 版本適用于 Spring Boot 1.5.x
  • 2.0.x 版本適用于 Spring Boot 2.0.x
  • 2.1.x 版本適用于 Spring Boot 2.1.x
  • 2.2.x 版本適用于 Spring Boot 2.2.x

構建服務消費者

  • 添加jar包依賴

    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>com.gupaoedu.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
        <artifactId>spring-cloud-dubbo-sample-api</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
  • 添加組態檔

    spring.application.name=spring-cloud-dubbo-sample-consumer
    dubbo.application.name=spring-cloud-dubbo-sample-consumer
    
    dubbo.cloud.subscribed-services=spring-cloud-dubbo-sample-provider
    spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848
    

    除應用名稱 spring.application.name 存在差異外,spring-cloud-dubbo-client-sample 新增了屬性 dubbo.cloud.subscribed-services 的設定,并且該值為服務提供方應用 "spring-cloud-dubbo-sample-provider",

    它的主要作用是服務消費方訂閱服務提供方的應用名稱的串列,若需訂閱多應用,使用 "," 分割, 不推薦使用默認值為 "*",它將訂閱所有應用,

  • 撰寫測驗代碼

    @RestController
    @EnableDiscoveryClient
    @SpringBootApplication
    public class SpringCloudDubboSampleConsumerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringCloudDubboSampleConsumerApplication.class, args);
        }
        @Reference
        IHelloService helloService;
    
        @GetMapping("/say")
        public String say(){
            return helloService.sayHello();
        }
    
    }
    

多注冊中心的支持

dubbo相對于spring cloud來說,它的強大之處在于,提供了很多不同場景的功能支持,比如多注冊中心的支持,

所謂的多注冊中心,就是指dubbo可以同時配置多個注冊中心的地址,然后針對于不同型別的服務注冊到不同的注冊中心上,

Dubbo多注冊中心可以支持幾種場景

一個服務部署到多個注冊中心

基于spring cloud的配置方式

  • 添加jar包依賴

    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <version>2.7.8</version>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
            <exclusion>
                <artifactId>log4j</artifactId>
                <groupId>log4j</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    
  • 修改application配置

    dubbo.registries.registry1.address=nacos://192.168.216.128:8848
    dubbo.registries.registry1.timeout=10000
    dubbo.registries.registry2.address=zookeeper://192.168.216.128:2181
    dubbo.registries.registry2.timeout=10000
    
    #spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848
    spring.cloud.nacos.discovery.register-enabled=false
    spring.cloud.nacos.discovery.watch.enabled=false
    spring.cloud.service-registry.auto-registration.enabled=false
    
    • spring.cloud.service-registry.auto-registration.enabled 關閉spring cloud的自動注冊
    • spring.cloud.nacos.discovery.watch.enabled/spring.cloud.nacos.discovery.register-enabled關閉nacos的服務注冊和監聽

    這么做的目的是,規避spring cloud本身的服務注冊發現機制,走dubbo本身的服務注冊與發現

  • 修改服務配置

    @Service(registry = {"registry1","registry2"})
    public class HelloServiceImpl implements IHelloService{
    
        @Override
        public String sayHello() {
            return "Hello GuPao";
        }
    }
    

多注冊中心的參考

  • 修改消費端的application.properties

    dubbo.registries.registry1.address=nacos://192.168.216.128:8848
    dubbo.registries.registry1.timeout=10000
    dubbo.registries.registry2.address=zookeeper://192.168.216.128:2181
    dubbo.registries.registry2.timeout=10000
    
    spring.cloud.nacos.discovery.register-enabled=false
    spring.cloud.nacos.discovery.watch.enabled=false
    spring.cloud.service-registry.auto-registration.enabled=false
    
  • 添加jar包依賴

    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <version>2.7.8</version>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
            <exclusion>
                <artifactId>log4j</artifactId>
                <groupId>log4j</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    

基于spring boot集成Dubbo方式

實際上,在dubbo spring cloud的使用方式中,對于配置多個服務注冊中心不是很友好而且還有一些潛在的問題, 畢竟dubbo和spring cloud兩個本質上是屬于完全不同的生態耦合在一起,必然會導致一些兼容問題,比如剛剛我們去配置的這些多注冊中心的支持,它需要去關閉spring cloud本身的服務自動注冊和發現的支持,本質上就是在兩個生態中選擇其中一個生態作為主要方式來使用,

所以,如果是在spring cloud的生態中,可以盡量減少對于dubbo本身靈活性的使用,擁抱spring cloud的標準生態,當然如果希望以dubbo作為獨立的生態來使用,大家可以采用spring boot+Dubbo來集成,

這里同樣也給大家快速構建一下,

另外,dubbo集成到spring boot中還有一個好處,就是它可以繼承spring boot本身的特性

  • 自動裝配(注解驅動、自動裝配)
  • production-ready(安全機制、健康檢測、外部化配置)

創建專案結構

創建基礎的專案結構

  • spring-boot-dubbo-example [maven]
    • spring-boot-dubbo-sample-api [maven]
    • spring-boot-dubbo-sample-provider [spring boot]
    • spring-boot-dubbo-sample-consumerp [spring-boot]

添加jar包依賴

從2.7開始,dubbo的版本和dubbo-spring-boot的版本是保持一致的,所以大家不用再去擔心版本的問題,

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.7</version>
</dependency>
<dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>1.2.1</version>
</dependency>

添加服務以及發布

@DubboService
public class SayHelloServiceImpl implements ISayHelloService{
    @Override
    public String sayHello() {
        return "Hello GuPaoEdu.com";
    }
}
spring.application.name=spring-boot-dubbo-sample-provider

dubbo.registry.address=nacos://192.168.216.128:8848
dubbo.scan.base-packages=com.gupaoedu.springboot.dubbo.springbootdubbosampleprovider.service

dubbo.protocol.name=dubbo
dubbo.protocol.port=-1

撰寫服務參考代碼

  • 添加jar包依賴

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>com.gupaoedu.com</groupId>
        <version>1.0-SNAPSHOT</version>
        <artifactId>spring-boot-dubbo-sample-api</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>2.7.7</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba.nacos</groupId>
        <artifactId>nacos-client</artifactId>
        <version>1.2.1</version>
    </dependency>
    
  • 添加web測驗類

    @DubboReference
    ISayHelloService sayHelloService;
    
    @GetMapping("/get")
    public String get(){
        return sayHelloService.sayHello();
    }
    
    dubbo.registry.address=nacos://192.168.216.128:8848
    

不同服務注冊到不同的注冊中心

從上面的配置可以發現,我們開可以針對不同的服務配置到不同的注冊中心,這個就不再浪費時間去演示了,

多個注冊中心的集群

如果一個服務消費者參考了多個注冊中心,那么這個時候服務消費者首先要做的就是先針對注冊中心的負載均衡,然后得到一個目標注冊中心之后,再從目標注冊中心上獲得服務提供者的地址串列再進行集群訪問,實作原理如下圖所示

image-20200805174638634

當然,有三種方式來指定注冊中心的負載均衡配置

  • 指定優先級

    <!-- 來自 preferred=“true” 注冊中心的地址將被優先選擇,只有該中心無可用地址時才 Fallback 到其他注冊中心 -->
    <dubbo:registry address="zookeeper://${zookeeper.address1}" preferred="true" />
    
  • 同zone優先

    <!-- 選址時會和流量中的 zone key 做匹配,流量會優先派發到相同 zone 的地址 -->
    <dubbo:registry address="zookeeper://${zookeeper.address1}" zone="beijing" />
    
  • 權重輪詢

    <!-- 來自北京和上海集群的地址,將以 10:1 的比例來分配流量 -->
    <dubbo:registry id="beijing" address="zookeeper://${zookeeper.address1}" weight=”100“ />
    <dubbo:registry id="shanghai" address="zookeeper://${zookeeper.address2}" weight=”10“ />
    

介面多版本支持

平時我們在開發介面的時候,可能會面臨到一個介面的修改,但是這個時候因為線上會有一些專案正在使用這個介面,如果直接修改,很可能會對線上的服務造成比較大的影響,

因此對于這種情況,dubbo提供了介面版本的支持,

具體的配置方式

  • 服務端針對同一個介面提供不同版本的實作

  • 并在dubboservice注解中配置版本的宣告

    @DubboService(registry = {"registry1","registry2"},version = "1.0")
    
  • 服務消費端指定消費版本號

    @DubboReference(registry = {"registry1","registry2"},version = "2.0")
    ISayHelloService sayHelloService;
    

多協議的支持

當公司原本采用其他的rpc框架,這個時候如果想遷移到dubbo這個框架上來,那么Dubbo提供的多協議支持就能夠提供幾乎零成本的遷移,

對于一個服務,可以同時發布多種不同協議的介面,也可以針對不同的介面發布不同的協議型別,并且從2.7開始,dubbo對于一些主流的協議做了支持,目前已經支持的協議有

dubbo協議、hessian協議、http協議、thrift、rmi、webservice、grpc、rest等,初次之外,dubbo還提供了非常靈活的可擴展性機制,對于有定制化需求或者目前正在使用的協議,dubbo不支持的公司,是可以自己去進行擴展,

整體的靈活性以及可插拔性的特性,相比spring cloud來說,更加強大,

JAX-RS協議說明

Dubbo中的REST(表述性資源轉移)支持,是基于JAX-RS2.0(Java API for RESTful Web Services)來實作的,

REST是一種架構風格,簡單來說就是對于api介面的約束,基于URL定位資源,使用http動詞(GET/POST/DELETE)來描述操作

REST很早就提出來了,在早期開發人員為了實作REST,會使用各種工具來實作,比如Servlets就經常用來開發RESTful的程式,隨著REST被越來越多的開發人員采用,所以JCP(Java community process)提出了JAX-RS規范,并且提供了一種新的基于注解的方式來開發RESTful服務,有了這樣的一個規范,使得開發人員不需要關心通訊層的東西,只需要關注資源以以及資料物件,

JAX-RS規范的實作有:Apache CXF、Jersey(由Sun公司提供的JAX-RS的參考實作)、RESTEasy(jboss實作)等,

而Dubbo里面實作的REST就是基于Jboss提供的RESTEasy框架來實作的

SpringMVC中的RESTful實現我們用得比較多,它也是JAX-RS規范的一種實作

添加REST支持

  • 添加jar包依賴

    <dependency>
        <groupId>org.jboss.resteasy</groupId>
        <artifactId>resteasy-jaxrs</artifactId>
        <version>3.13.0.Final</version>
    </dependency>
    <dependency>
        <groupId>org.jboss.resteasy</groupId>
        <artifactId>resteasy-client</artifactId>
        <version>3.13.0.Final</version>
    </dependency>
    <dependency>
        <groupId>org.eclipse.jetty</groupId>
        <artifactId>jetty-server</artifactId>
        <version>9.4.19.v20190610</version>
    </dependency>
    <dependency>
        <groupId>org.eclipse.jetty</groupId>
        <artifactId>jetty-servlet</artifactId>
        <version>9.4.19.v20190610</version>
    </dependency>
    
  • 修改組態檔

    dubbo.protocols.dubbo.name=dubbo
    dubbo.protocols.dubbo.port=-1
    
    dubbo.protocols.rest.name=rest
    dubbo.protocols.rest.port=8888
    dubbo.protocols.rest.server=jetty
    
  • 修改api的介面定義

    @Path("/")
    public interface ISayHelloService {
    
        @GET
        @Path("say")
        String sayHello();
    
    }
    

著作權宣告:本博客所有文章除特別宣告外,均采用 CC BY-NC-SA 4.0 許可協議,轉載請注明來自 Mic帶你學架構
如果本篇文章對您有幫助,還請幫忙點個關注和贊,您的堅持是我不斷創作的動力,歡迎關注「跟著Mic學架構」公眾號公眾號獲取更多技術干貨!

轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/375120.html

標籤:Java

上一篇:Flowable - 6.6.0 更新說明 (主流作業流引擎)

下一篇:Python游戲開發,pygame模塊,Python實作貪吃蛇小游戲

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C#(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 【C++】Microsoft C++、C 和匯編程式檔案

    ......

    uj5u.com 2020-09-10 00:57:23 more
  • 例外宣告

    相比于斷言適用于排除邏輯上不可能存在的狀態,例外通常是用于邏輯上可能發生的錯誤。 例外宣告 Item 1:當函式不可能拋出例外或不能接受拋出例外時,使用noexcept 理由 如果不打算拋出例外的話,程式就會認為無法處理這種錯誤,并且應當盡早終止,如此可以有效地阻止例外的傳播與擴散。 示例 //不可 ......

    uj5u.com 2020-09-10 00:57:27 more
  • Codeforces 1400E Clear the Multiset(貪心 + 分治)

    鏈接:https://codeforces.com/problemset/problem/1400/E 來源:Codeforces 思路:給你一個陣列,現在你可以進行兩種操作,操作1:將一段沒有 0 的區間進行減一的操作,操作2:將 i 位置上的元素歸零。最終問:將這個陣列的全部元素歸零后操作的最少 ......

    uj5u.com 2020-09-10 00:57:30 more
  • UVA11610 【Reverse Prime】

    本人看到此題沒有翻譯,就附帶了一個自己的翻譯版本 思考 這一題,它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。 我們應該需要質數篩篩選1~$10^{7}$的所有數,這里就不慢慢介紹了。但是,重讀題,我們突然發現反向質數都是 $7$ 位,而將它反過來后的數字卻是 $6$ 位數,這就說明 ......

    uj5u.com 2020-09-10 00:57:36 more
  • 統計區間素數數量

    1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......

    uj5u.com 2020-09-10 00:57:47 more
  • C/C++編程筆記:C++中的 const 變數詳解,教你正確認識const用法

    1、C中的const 1、區域const變數存放在堆疊區中,會分配記憶體(也就是說可以通過地址間接修改變數的值)。測驗代碼如下: 運行結果: 2、全域const變數存放在只讀資料段(不能通過地址修改,會發生寫入錯誤), 默認為外部聯編,可以給其他源檔案使用(需要用extern關鍵字修飾) 運行結果: ......

    uj5u.com 2020-09-10 00:58:04 more
  • 【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID

    1. 首先在資源視圖中,添加資源 2. 點擊新添加的資源,復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案,編輯,使用整個專案搜索和替換的方式快速替換 宏宣告 4. Ctrl+Shift+F 全域搜索,點擊查找全部,然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......

    uj5u.com 2020-09-10 00:59:11 more
  • 【C++犯錯記錄】VS2019 MFC不懂的批量添加資源

    1. 打開資源頭檔案Resource.h,在其中預先定義好宏 ID(不清楚其實ID值應該設定多少,可以先新建一個相同的資源項,再在這個資源的ID值的基礎上遞增即可) 2. 在資源視圖中選中專案資源,按F7編輯資源檔案,按 ID 型別 相對路徑的形式添加 資源。(別忘了先把檔案拷貝到專案中的res檔案 ......

    uj5u.com 2020-09-10 01:00:19 more
  • C/C++編程筆記:關于C++的參考型別,專供新手入門使用

    今天要講的是C++中我最喜歡的一個用法——參考,也叫別名。 參考就是給一個變數名取一個變數名,方便我們間接地使用這個變數。我們可以給一個變數創建N個參考,這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間,占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名,但 ......

    uj5u.com 2020-09-10 01:00:22 more
  • 【C/C++編程筆記】從頭開始學習C ++:初學者完整指南

    眾所周知,C ++的學習曲線陡峭,但是花時間學習這種語言將為您的職業帶來奇跡,并使您與其他開發人員區分開。您會更輕松地學習新語言,形成真正的解決問題的技能,并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣(即清晰一致的編碼風格,在撰寫代碼時注釋代碼,并限制類內部的可見性),并且由 ......

    uj5u.com 2020-09-10 01:00:41 more
最新发布
  • Rust中的智能指標:Box<T> Rc<T> Arc<T> Cell<T> RefCell<T> Weak

    Rust中的智能指標是什么 智能指標(smart pointers)是一類資料結構,是擁有資料所有權和額外功能的指標。是指標的進一步發展 指標(pointer)是一個包含記憶體地址的變數的通用概念。這個地址參考,或 ” 指向”(points at)一些其 他資料 。參考以 & 符號為標志并借用了他們所 ......

    uj5u.com 2023-04-20 07:24:10 more
  • Java的值傳遞和參考傳遞

    值傳遞不會改變本身,參考傳遞(如果傳遞的值需要實體化到堆里)如果發生修改了會改變本身。 1.基本資料型別都是值傳遞 package com.example.basic; public class Test { public static void main(String[] args) { int ......

    uj5u.com 2023-04-20 07:24:04 more
  • [2]SpinalHDL教程——Scala簡單入門

    第一個 Scala 程式 shell里面輸入 $ scala scala> 1 + 1 res0: Int = 2 scala> println("Hello World!") Hello World! 檔案形式 object HelloWorld { /* 這是我的第一個 Scala 程式 * 以 ......

    uj5u.com 2023-04-20 07:23:58 more
  • 理解函式指標和回呼函式

    理解 函式指標 指向函式的指標。比如: 理解函式指標的偽代碼 void (*p)(int type, char *data); // 定義一個函式指標p void func(int type, char *data); // 宣告一個函式func p = func; // 將指標p指向函式func ......

    uj5u.com 2023-04-20 07:23:52 more
  • Django筆記二十五之資料庫函式之日期函式

    本文首發于公眾號:Hunter后端 原文鏈接:Django筆記二十五之資料庫函式之日期函式 日期函式主要介紹兩個大類,Extract() 和 Trunc() Extract() 函式作用是提取日期,比如我們可以提取一個日期欄位的年份,月份,日等資料 Trunc() 的作用則是截取,比如 2022-0 ......

    uj5u.com 2023-04-20 07:23:45 more
  • 一天吃透JVM面試八股文

    什么是JVM? JVM,全稱Java Virtual Machine(Java虛擬機),是通過在實際的計算機上仿真模擬各種計算機功能來實作的。由一套位元組碼指令集、一組暫存器、一個堆疊、一個垃圾回收堆和一個存盤方法域等組成。JVM屏蔽了與作業系統平臺相關的資訊,使得Java程式只需要生成在Java虛擬機 ......

    uj5u.com 2023-04-20 07:23:31 more
  • 使用Java接入小程式訂閱訊息!

    更新完微信服務號的模板訊息之后,我又趕緊把微信小程式的訂閱訊息給實作了!之前我一直以為微信小程式也是要企業才能申請,沒想到小程式個人就能申請。 訊息推送平臺🔥推送下發【郵件】【短信】【微信服務號】【微信小程式】【企業微信】【釘釘】等訊息型別。 https://gitee.com/zhongfuch ......

    uj5u.com 2023-04-20 07:22:59 more
  • java -- 緩沖流、轉換流、序列化流

    緩沖流 緩沖流, 也叫高效流, 按照資料型別分類: 位元組緩沖流:BufferedInputStream,BufferedOutputStream 字符緩沖流:BufferedReader,BufferedWriter 緩沖流的基本原理,是在創建流物件時,會創建一個內置的默認大小的緩沖區陣列,通過緩沖 ......

    uj5u.com 2023-04-20 07:22:49 more
  • Java-SpringBoot-Range請求頭設定實作視頻分段傳輸

    老實說,人太懶了,現在基本都不喜歡寫筆記了,但是網上有關Range請求頭的文章都太水了 下面是抄的一段StackOverflow的代碼...自己大修改過的,寫的注釋挺全的,應該直接看得懂,就不解釋了 寫的不好...只是希望能給視頻網站開發的新手一點點幫助吧. 業務場景:視頻分段傳輸、視頻多段傳輸(理 ......

    uj5u.com 2023-04-20 07:22:42 more
  • Windows 10開發教程_編程入門自學教程_菜鳥教程-免費教程分享

    教程簡介 Windows 10開發入門教程 - 從簡單的步驟了解Windows 10開發,從基本到高級概念,包括簡介,UWP,第一個應用程式,商店,XAML控制元件,資料系結,XAML性能,自適應設計,自適應UI,自適應代碼,檔案管理,SQLite資料庫,應用程式到應用程式通信,應用程式本地化,應用程式 ......

    uj5u.com 2023-04-20 07:22:35 more