一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

已將第二個服務提供者降級到0.25，此時再連續訪問

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

已將第二個服務提供者降級到0.25，此時再連續訪問

此時很明顯可以看到第二個服務接收的請求比第一個少很多，證明降級成功。

4、負載均衡

dubbo提供了三個基本的負載均衡策略，分別是 隨機訪問、輪詢、最少併發，從字面上也可以得知是什麼意思，在這裡我演示一下輪詢的負載均衡策略。在dubbo-admin中，選擇負載均衡功能，點擊新增，如下圖

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

已將第二個服務提供者降級到0.25，此時再連續訪問

此時很明顯可以看到第二個服務接收的請求比第一個少很多，證明降級成功。

4、負載均衡

dubbo提供了三個基本的負載均衡策略，分別是 隨機訪問、輪詢、最少併發，從字面上也可以得知是什麼意思，在這裡我演示一下輪詢的負載均衡策略。在dubbo-admin中，選擇負載均衡功能，點擊新增，如下圖

按下圖進行配置

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

已將第二個服務提供者降級到0.25，此時再連續訪問

此時很明顯可以看到第二個服務接收的請求比第一個少很多，證明降級成功。

4、負載均衡

dubbo提供了三個基本的負載均衡策略，分別是 隨機訪問、輪詢、最少併發，從字面上也可以得知是什麼意思，在這裡我演示一下輪詢的負載均衡策略。在dubbo-admin中，選擇負載均衡功能，點擊新增，如下圖

按下圖進行配置

老樣子，這次我們連續訪問網頁10次

"

一、Dubbo介紹

引用官方的一段介紹

Apache Dubbo (incubating) |ˈdʌbəʊ| is a high-performance, java based RPC framework open-sourced by Alibaba. As in many RPC systems, dubbo is based around the idea of defining a service, specifying the methods that can be called remotely with their parameters and return types. On the server side, the server implements this interface and runs a dubbo server to handle client calls. On the client side, the client has a stub that provides the same methods as the server.

Dubbo是阿里出的一個高性能的分佈式微服務框架，它的特點是性能高、界面友好、文檔齊全（特別是中文文檔），是很多中小型公司快速搭建微服務的首選技術。前段時間被阿里重新進行維護，並進入Apache孵化器。遷移到Apache後也推出了新的starter，簡單試用後感覺不錯，為此特地寫下這一系列筆記，用以記錄。（整個項目的源碼在最後一章，感興趣的童鞋可以下載自己搭建試試，也可以將其作為腳手架搭建你自己的微服務）

二、搭建註冊中心

在dubbo中，每一個服務都是分佈式的，消費者與提供者的關係並不是一對一的關係，而是一對多，並且服務提供者的實例位置是未知的，如果都由開發者使用靜態文件去維護這個關係顯示不合適的，一方面是徒增工作量，另一方面是靈活度不高，如果服務提供者更換了服務器地址，那麼需要重新配置等，所以目前比較推崇的方案是所有服務提供者均主動將自己的信息註冊到同個地方中，而消費者只要一律從這個地方取他需要的東西即可，這個地方就是所謂的註冊中心。目前dubbo可以選擇的註冊中心包括zookeeper、redis等，一般建議使用zookeeper，下面演示一下在windows中如何搭建zookeeper註冊中心。

1、下載zookeeper

直接在官網的鏡像站下 （https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/current/zookeeper-3.4.12.tar.gz）

2、解壓並配置zookeeper

為了演示，直接使用官方示例配置。把解壓出來的\\zookeeper-3.4.12\\conf\\zoo_sample.cfg 文件名改為zoo.cfg即可，如下圖：

3、運行zookeeper註冊中心

雙擊運行/zookeeper-3.4.12/bin/zkServer.cmd，出現以下窗口代表運行成功。

三、搭建Dubbo Admin

在Dubbo中，一大殺器就是它的可視化監控界面，在這個界面中可以查看服務者、提供者的數量、狀態等，並對服務降級、容錯、屏蔽等提供了可視化操作。下面演示如何搭建Dubbo Admin。

1、下載源碼並解壓

點擊下面地址下載dubbo admin項目源碼 （https://codeload.github.com/apache/incubator-dubbo-ops/zip/master）

下載後解壓出來，如下圖：

2、打包

打開cmd，進入第一步解壓出來的dubbo-admin文件夾中，執行mvn clean package

(ps:要是提示未存在mvn命令，就把maven文件夾的bin目錄添加到系統環境變量PATH中）

3、配置dubbo admin

打開上面那步打出來的war包（\\incubator-dubbo-ops-master\\dubbo-admin\\target\\dubbo-admin-2.0.0.war），編輯WEB-INF文件夾中的dubbo.properties文件，如下圖

將紅框處的IP地址改為你的註冊中心的地址，由於我們的註冊中心是在本地運行的，故此處無需做修改。

4、運行Dubbo Admin

將war包改名為ROOT.war後放到tomcat的webapp目錄中，然後運行tomcat。使用瀏覽器打開http://127.0.0.1:8080，提示輸入賬號密碼，賬號和密碼默認均為root，登陸後的界面如下：

四、搭建API項目

由於Dubbo是採用RPC調用方式，這也是與Spring Cloud比較大的區別之一。在Spring Cloud中，服務通過HTTP接口提供給其它服務調用，對於調用者與被調用者來說，只要雙方保證滿足http接口的契約即可，但是在dubbo中，是嚴格要求調用接口的類路徑、參數等雙方一致。所以需要構建一個API項目，該項目裡面存放服務接口即公共實體，雙方依賴這個項目完成遠程調用。

pom.xml

<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>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <java.version>1.8</java.version>
 </properties>
</project>

公共實體-People.java

package com.czh.dubbo.common.entity;
import java.io.Serializable;
public class People implements Serializable {
 /**
 * 
 */
 private static final long serialVersionUID = 1415852192397895853L;
 // 人員編號
 private int id;
 // 姓名
 private String name;
 public int getId() {
 return id;
 }
 public void setId(int id) {
 this.id = id;
 }
 public String getName() {
 return name;
 }
 public void setName(String name) {
 this.name = name;
 }
 @Override
 public String toString() {
 return "People [id=" + id + ", name=" + name + "]";
 }
}

公共服務接口-PeopleService.java

package com.czh.dubbo.common.service;
import com.czh.dubbo.common.entity.People;
public interface PeopleService {
 People getPeople(People people);
}

五、搭建服務提供者

服務提供者就是被消費者所調用的，它需要實現公共服務接口，並通過dubbo把自己的服務暴露出來。

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-provider</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

com.alibaba.boot是遷移過後出的一個最新的dubbo spring boot starter，也是目前官方推薦使用的。值得注意的是，該starter不包含註冊中心客戶端，需要自己配置。一般推薦使用zookeeper作為註冊中心，所以需要手動引入zkclient。

application.properties

#web服務端口，由於我們不需要使用web服務，所以將其設為隨機端口
server.port=-1
#dubbo服務端口，我們無需知道dubbo服務運行在哪個端口，故也將其設為隨機端口
dubbo.protocol.port = -1
#dubbo服務名稱
dubbo.application.name = dubbo-provider
#dubbo服務所在包路徑
dubbo.scan.basePackages = com.czh.dubbo.provider.service
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#設置服務的日誌輸出級別為debug級
logging.level.com.czh.dubbo.provider.service=debug

服務實現類PeopleServiceImpl

package com.czh.dubbo.provider.service;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.dubbo.config.annotation.Service;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
//注意，這裡的service註解用的不是spring的註解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class PeopleServiceImpl implements PeopleService{
 private static final Logger logger = LoggerFactory.getLogger(PeopleServiceImpl.class);
 /**
 * 這個方法的作用是接收傳過來的People實體，將其ID賦為隨機數
 */
 @Override
 public People getPeople(People people) {
 people.setId(new Random().nextInt(10000));
 logger.debug("People:{},ID:{}",people.getName(),people.getId());
 return people;
 }
}

六、搭建服務消費者

pom.xml

<?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>com.czh</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>dubbo-consumer</name>
 <description>Demo project for Spring Boot</description>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.5.12.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>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
 <dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.1.0</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
 <dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.10</version>
 </dependency>
 <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.47</version>
 </dependency>
 <dependency>
 <groupId>com.czh.dubbo</groupId>
 <artifactId>dubbo-common</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

application.properties

#web服務端口
server.port=80
#消費者名稱
dubbo.application.name=dubbo-consumer
#需要使用到提供者服務的包路徑
dubbo.scan.base-packages=com.czh.dubbo.consumer.controller
#註冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

控制器PeopleController

package com.czh.dubbo.consumer.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.dubbo.config.annotation.Reference;
import com.czh.dubbo.common.entity.People;
import com.czh.dubbo.common.service.PeopleService;
@RestController
public class PeopleController {
 @Reference
 private PeopleService peopleService;
 @GetMapping("/people/{name}")
 public People getPeople(@PathVariable("name") String name) {
 People people = new People();
 people.setName(name);
 return peopleService.getPeople(people);
 }
}

至此，整個項目便搭建完畢，三個項目的項目結構如下

七、上線運行

1、打包運行

安裝API項目到本地maven倉庫

在dubbo-common項目的pom.xml文件上點擊右鍵，Run as - Maven install

打包服務提供者與服務消費者

在這兩個項目的pom.xml文件執行以下操作：點擊右鍵，Run as - Maven build… 在彈出的選項框中Golas 填寫：clean package，如下圖

點擊run，打包成功後如下圖：

將兩個項目的target文件夾中拿出打好的jar包放到某個文件夾下備用，如下圖

使用java -jar 命令依次運行dubbo-provider 與dubbo-consumer，順序不能搞錯，並且得確保provider啟動完成後再啟動consumer，否則後期會出現空指針異常。

至此，我們總共啟動了四個服務，分別是zookeeper註冊中心、dubbo-admin、dubbo-provider、dubbo-consumer，如下圖：

打開dubbo監控網頁檢查服務消費者和提供者是否已經註冊成功：

可以看到，提供者與消費者已成功註冊到註冊中心

2、基本調用

使用瀏覽器訪問此地址http://127.0.0.1/people/test，觀察服務提供者的控制檯輸出內容

後臺控制檯已輸出日誌了，證明調用成功，那麼瀏覽器是否能夠拿到數據呢？

可以看到瀏覽器也拿到數據了，證明已經成功完成調用了。

3、容錯與屏蔽

容錯

顧名思義就是當服務提供者出現異常時，消費者是否能夠正常處理，在這裡，我們關閉掉服務提供者，再進行調用，觀察是否會報錯

可以觀察到前端報異常了。我們進入dubbo-admin在消費者中把服務容錯開啟，如下

再進行調用可以看到

可以看到此時調用後返回確實為空，證明容錯生效。

屏蔽

當對某個服務啟動屏蔽時，此時消費者調用該服務時均會返回空對象。首先我們需要確保提供者與消費者均已啟動，然後在消費者中對提供者進行屏蔽，如下圖

再進行服務調用

可以看到此時調用後返回確實為空，證明屏蔽生效。

其實屏蔽與容錯還有更高級的玩法，最基本的屏蔽是返回空對象，我們甚至可以自定義返回內容。

進入動態配置，選擇新增

編輯紅框處的內容如下圖：

再訪問網頁

可以看到確實屏蔽成功，並返回我們自定義的內容，注意，此時並未調用到提供者服務。

3、服務降級

為了測試服務降級，我們需要再啟動一個服務提供者

可以看到目前兩個服務提供者

然後我們再連續多次訪問網頁

兩個服務接收到的請求數量是差不多的，此時我們對第二個服務進行降級，為了測試明顯，這裡我們連續降兩次級，將其降到0.25，再連續調用，觀察結果

已將第二個服務提供者降級到0.25，此時再連續訪問

此時很明顯可以看到第二個服務接收的請求比第一個少很多，證明降級成功。

4、負載均衡

dubbo提供了三個基本的負載均衡策略，分別是 隨機訪問、輪詢、最少併發，從字面上也可以得知是什麼意思，在這裡我演示一下輪詢的負載均衡策略。在dubbo-admin中，選擇負載均衡功能，點擊新增，如下圖

按下圖進行配置

老樣子，這次我們連續訪問網頁10次

可以看到兩個服務剛好各均分了五個請求，負載均衡成功！

八、寫在最後

相比於spring cloud，個人認為dubbo提供的功能相對簡單，但每個功能又很實用，且使用起來十分方便（因為有可視化的web界面操作），更適合中小型公司進行微服務搭建。

附錄-源碼分享

（轉發+關注 留下你的郵箱。發送源碼給你）一定要先關注啊。老鐵！！！

"

相關推薦

'千萬不要在《我的世界》召喚100000顆鑽石，MC：給你點顏色看看'

"背景：一位ID名為“okthennoobs”的小夥子，突發奇想：在《我的世界》裡"/give"自己100000跟骨頭，於是發生了一個令他後悔終生的決定。​所以基於此次事件的背景下，在社區裡，有掀起了“你敢給自己10萬顆鑽石麼？”的挑戰！挑戰：給自己10萬顆鑽石，究竟會發生...

我的世界 Qwodeshijie 鑽石 Java 蛋糕 人工智能 2019-09-16

'有了它還要啥自行車？專為網絡存儲設計的WD RED輕鬆搭建私有云'

"​​因工作性質和個人愛好上的需求平時存儲量挺大，加上電腦上的的存儲空間有限，而且電腦一旦出現了故障，尤其是硬盤損壞的話就會在工作和生活當中惹上了不少的麻煩。之前公司就因為硬盤的損壞導致部分重要資料的丟失，後來公司採用了服務器主機來存儲和備份數據，的確對數據安全和性能方面確...

西部數據 設計 固態硬盤 電腦 操作系統 軟件 自行車 硬件 Windows 我想靜靜 技術 臺式電腦 超微半導體 三星集團 瑞昱半導體 微星科技 2019-09-12

'你不要鬧了，快點做好個人信息保護，就這樣，聽我的'

"前幾期，小福妹給大家介紹了CTF及網絡安全方面的知識《親愛的，熱愛的》背景揭祕：帶你走進CTF，顯然，網絡安全的重要性毋庸置疑。我國於2017年6月正式施行《網絡安全法》，其中不少內容針對網絡安全隱患如個人信息洩露等，第四章“網絡信息安全”更是針對個人信息收集和保護提出相...

信息安全 網絡安全 黑客 Wi-Fi 瀏覽器 電腦 雲計算 軟件 騰訊QQ 陳情令最心疼角色 2019-09-06

'微信的聊天記錄刪除了怎麼恢復？這招你可千萬別用'

"微信的聊天記錄刪除了怎麼恢復？現在網絡上流傳著許多微信聊天記錄恢復教程，好像以前要恢復一段聊天記錄是難於登天的一件事，現在變得易如反掌了。小編個人也很是好奇，於是測試了下網絡上各種推銷好用的恢復方法，是不是真的那麼有效在此小編總結了三個最簡單有效的辦法給大家~方法一：re...

微信 軟件 瀏覽器 電腦 騰訊QQ 2019-09-04

'家裡電腦開不了？不用花錢修，你先檢查這幾個地方'

"大家好，今天分享一篇來源小白一鍵重裝網（xiaobaixitong.com）關於解答：電腦開機出現英文字母開不了機怎麼辦？對於不懂電腦修理的用戶來說，電腦開機出現一大串的英文字母，沒點英語水平都不知道上面寫什麼，估計也不知道如何解決了，下面小白給您詳細解決下遇到這樣的情況...

電腦 操作系統 硬件 U盤 英語 軟件 Windows 7 Windows 2019-09-01

'免費看片下歌，不限速度盤，這些神器我都給你找來了'

"小雷似乎很長一段時間，沒推薦過實用的App、軟件了。想必機友們早已怨聲載道：你這小破雷，咋還不安利App、教好用的技能，說好的搞機小能手、機圈飆車王呢？行行行，今天小雷就開輛東風大卡車。拉出一大波壓箱底多年的“大寶貝”，讓你們好好爽一爽，直奔西方極樂世界。閒話不多說，《小...

騰訊視頻 瀏覽器 愛奇藝 創作者來直播 優酷土豆 電視劇 Bilibili 軟件 週末綜藝指南 音樂 咒怨 2019-09-01

'如果我不說，你知道響應式網站就是一個坑嗎？'

"導讀：5G的到來將促使大批的手機網站更新，未來的手機網站，應該屬於第四代，它的特點是：版塊化集中展示＋獨立編輯＋內容簡約＋豎屏設計＋諮詢成交頁面前置。伴隨智能手機的普及，數以億計的訪客在手機端，搜索他們想要的東西，但是，傳統手機網站的架構規劃、設計表現形式、交互體驗和閱讀...

設計 智能手機 百度 電腦 我的第一部5G手機 技術 瀏覽器 搜索引擎 2019-09-01

'為什麼你家孩子越來越不愛學習了？4個小竅門，幫父母保護孩子的求知慾'

"我女兒幼兒園畢業，畢業典禮上孩子們要演講《我的理想》，當老師詢問孩子們的理想時，班級2/3的孩子的理想是當科學家。回想我們小時候，當老師佈置作文題目《我的理想》時，班級裡的小朋友們夢想當科學家的也是佔大多數。那為什麼隨著年齡增長，我們的科學夢卻幻滅了呢？是什麼扼殺了我們孩...

不完美媽媽 幼兒園 跳槽那些事兒 物理 發現佩奇 地理 瀏覽器 化學 2019-09-01

'誰把這麼合理的電腦配置單扔掉了，你不用我來用，現成的不煩神'

"剛剛一位客戶來我店裡購買Z370主板，我好奇的問他為何只買一片主板，一般單買主板的客戶比較少，再說我怕他不懂電腦，主板買回去和他電腦CPU不匹配而造成一系列的麻煩事，客戶跟我說了一個比較稀奇的事，他說他在路上撿到一張被人扔掉的電腦配置單，這張電腦配置單上面的各類描述都與他...

電腦 硬件 組裝電腦 中央處理器 威剛科技 微星科技 固態硬盤 西部數據 設計 Windows 2019-08-30

'​跨境電商賣家沒有SSL證書？你連谷歌廣告都做不了？'

"近來，你是否有遇到過這些情況，例如 google shopping 推廣審核不通過;外貿網站被顯示為鏈接不安全；又或是此頁面上部分內容不安全等類似的問題，這會嚴重影響到消費者對網站的信任度。其實出現這些問題大部分不是技術上的原因，而是一個SSL證書引起的風波。SSL證書大...

Google 電子商務 信用卡 信息安全 瀏覽器 技術 金融 銀行 Go Daddy 頭號大贏家| 理財大賽第二季 文章 2019-08-29

'程序員：你聽我解釋！Python：我不聽！我不聽！你根本不瞭解我'

"現在很多人想學習Python卻沒有很好的途徑，我這裡的話整理了一些關於Python的學習資料，從入門基礎到實戰項目都有，有需要的朋友可以關注並私信我“01”免費獲取~~~~在1991年，荷蘭人Guido van Rossum ，他發明了 Python，語法選擇的靈感來源自...

Python 程序員 Java 編程語言 六貫棋 Guido 2019-08-29

'你還不知道嗎？靠轉型大數據漲薪的日子已經一去不復返了'

"前言前兩天我和朋友突然聊起這個話題，經過一番討論還是想寫下自己的觀點，其實我個人認為大數據還是值得轉型的，但是想著只靠一個技能翻身的機會沒了在 2013 年，大數據剛剛嶄露頭角，有一大批程序員，在那個時間點，踏上了靠轉型大數據升職加薪的日子。在那個時候，只要稍微懂一點點 ...

大數據 工程師 Scala 算法 技術 Hadoop 數據挖掘 機器學習 跳槽那些事兒 Python Java Linux Hive 可視化技術 SQL 人生第一份工作 OpenCV 腳本語言 程序員 MySQL Storm HBase Java虛擬機 Spark 深度學習 MapReduce 2019-08-25

'表弟高考620分，我不建議學計算機，親戚：你不希望別人好'

"一名程序員在互聯網匿名社區吐槽起來，其自己家裡的親戚高考估分650分，放榜620分，找他推薦專業，推薦了臨床醫學與口腔醫學，不讓他們報考計算機，結果他們覺得我在害他們孩子，不希望別人好！私聊得知放榜分數620看到這裡，師長勸慰樓主，碰到這樣的事最好不要管，每個人都有自己的...

電腦 高考 不完美媽媽 臨床醫學 Java 程序員 2019-08-13

'Java架構師筆記-記住：永遠不要在MySQL中使用UTF8，請用utf8mb4'

"最近我遇到了一個bug，我試著通過Rails在以“utf8”編碼的MariaDB中保存一個UTF-8字符串，然後出現了一個離奇的錯誤：Incorrect string value: ‘\\\\xF0\\\\x9F\\\\x98\\\\x83 <…’ for colu...

MySQL Java 電腦 MariaDB 數據庫 Git 2019-08-12

'這是我見過最好的大項目微服務架構設計教程+免費領取'

"根據目前產品存在的問題，針對快速開發、海量用戶、大量數據、低延遲等互聯網應用的實際需要，通過對業務架構、系統架構、基礎架構、技術架構進行分析，採用先進實用的微服務SOA架構重構智慧校園、數字化校園等產品，徹底解決系統解耦、性能低下等問題，而且支持雲計算部署，可以滿足高併發...

設計 SaaS 數據庫 Java 雲計算 技術 市場營銷 IaaS 2019-08-03

'我的世界：你一定不會相信，時隔2年，網易這次真的“更新”了'

"說出來你肯定不信，《我的世界》網易的JAVA版本，真的更新到了1.14！你的第一反應一定是，騙誰呢？時隔2年，網易終於更新了！​最初我也是看到有人給我留言，開始我是不信的，長達2年的版本停滯，《我的世界》網易怎麼可能更新呢？這要麼是基岩版，要麼是P圖，恩，一定是這樣！然而...

我的世界 網易 Java Qwodeshijie Mojang 開源軟件 2019-07-29

'我的世界：就在今天，時隔2年網易真的更新了！玩家：你騙誰呢？'

"說出來你肯定不信，《我的世界》網易的JAVA版本，真的更新到了1.14！你的第一反應一定是，騙誰呢？時隔2年，網易終於更新了！​最初我也是看到有人給我留言，開始我是不信的，長達2年的版本停滯，《我的世界》網易怎麼可能更新呢？這要麼是基岩版，要麼是P圖，恩，一定是這樣！然而...

我的世界 網易 Java Qwodeshijie Mojang 開源軟件 2019-07-28

'不會代碼如何打造個人博客？你需要這個簡單、免費的搭建工具'

"每當看到其他設計師或者設計工作室的網站的時候，總想著能有一個屬於自己的網頁，可以做一些關於個人生活的記錄、筆記，還可以同步自己的設計、繪畫、攝影作品，那麼求職的時候發過去自己的網頁，還有什麼比這個更讚的嗎？今天我們分享的就是通過《Gridea》打造個人博客。懶人目錄 博客...

GitHub 軟件 騰訊QQ Markdown QQ空間 設計 文章 堅果雲 Windows iCloud 網易 Mac電腦 新浪 Dropbox 攝影 設計師 社交網絡 技術 2019-07-27

'面試官：你解釋一下什麼是JVM？什麼是JDK？什麼是JRE？我懵了'

"JVM ：JVM是Java Virtual Machine（Java虛擬機）的縮寫，它是整個java實現跨平臺的最核心的部分，所有的java程序會首先被編譯為.class的類文件，這種類文件可以在虛擬機上執行，也就是說class並不直接與機器的操作系統相對應，而是經過虛擬...

Java虛擬機 Java 虛擬機 操作系統 中央處理器 編譯器 集成開發環境 Eclipse Sun公司 硬件 人生第一份工作 2019-07-26

推薦中...