一、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.12confzoo_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-masterdubbo-admintargetdubbo-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);
 }
}

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