從頭開始搭建一個dubbo+zookeeper平臺

本篇主要是來分享從頭開始搭建一個dubbo+zookeeper平臺的過程，其中會簡要介紹下dubbo服務的做用。

首先，看下通常網站架構隨着業務的發展，邏輯愈來愈複雜，數據量愈來愈大，交互愈來愈多以後的常規方案演進歷程。

其次，當服務愈來愈多以後，咱們須要作哪些服務治理？

最後，是dubbo的架構圖

註冊中心的選擇

dubbo支持多種類型的註冊中心：

Multicast註冊中心

Zookeeper註冊中心

Redis註冊中心

Simple註冊中心

這裏咱們選擇zookeeper，其實類型的優勢缺點可詳細查看文檔。

1:zookeeper的安裝,仍是採用docker這一招鮮的run命令來安裝zookeeper

docker run -dit --name zookeeper --hostname zookeeper-host -v /data:/data -p 2181:2181 jplock/zookeeper:latest

2:安裝zkui，能夠參考zkui的項目地址來安裝，它提供了一個管理界面，能夠針對zookeepr的節點值進行CRUD操做，同時也提供了安全認證，按照以下幾步就能夠完成安裝。

mvn clean install，執行前須要安裝java環境，maven環境，執行成功後會生成一個jar文件。

將config.cfg複製到上一步生成的jar文件所在目錄，而後修改配置文件中的zookeeper地址。

執行 jar. ( nohup java -jar zkui-2.0-SNAPSHOT-jar-with-dependencies.jar & )，注意後面的那個&，是指不退出的意思。

測試，http://localhost:9090，如能看到以下頁面則表明zookeeper安裝運行正常。

下面是建立dubbo服務以及使用dubbo服務的過程：

dubbo提供者，建立一個java工程，注意如下幾點：

包依賴，引入以下三個主要的包就能夠了，主要是spring,dubbo以及zkclient

<dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-context</artifactId>

<version>${spring-framework.version}</version>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<version>2.4.10</version>

<exclusions>

<exclusion>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<dependency>

<groupId>com.101tec</groupId>

<artifactId>zkclient</artifactId>

<version>0.3</version>

</dependency>

定義接口，這裏爲了演示，簡單定義了一個返回產品名稱的接口。

public interface IProduct {

String getProductName();

}

接口實現

@Service

public class ProductService implements IProduct{

public String getProductName() {

return "jim";

}

}

服務啓動函數

加載配置文件

調用context.start()

執行一個不退出程序的操做，這裏有不少種作法。

public class App {

private final static Logger logger = LoggerFactory.getLogger(App.class);

public static void main(String[] args) {

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(

"classpath*:applicationContext.xml");

context.start();

logger.info("dubbo service begin to start");

try {

System.in.read();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

服務配置文件，這裏須要指出的是：

dubbo:service的定義配合了dubbo:annotation，ref="productService",是指定的一個id，實際的實現類經過註解掃描來完成的，並無在配置文件中指定實現類，後面的消費者配置文件中會有所體現。

dubbo:application中，能夠指定logger的實現接口。

dubbo:protocol中，能夠指定是否啓動訪問日誌，這個對有時排查線上問題很是有幫助。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:util="http://www.springframework.org/schema/util"

xmlns:aop="http://www.springframework.org/schema/aop"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context.xsd

http://www.springframework.org/schema/util

http://www.springframework.org/schema/util/spring-util.xsd"

>

<context:property-placeholder location="classpath*:config.properties"/>

<dubbo:application name="jim" logger="slf4j" />

<dubbo:registry protocol="zookeeper" address="192.168.21.128:2181" />

<dubbo:protocol accesslog="true" name="dubbo" port="20880" />

<dubbo:annotation package="jim" />

<dubbo:service interface="jim.IProduct" ref="productService"/>

<context:component-scan base-package="jim" />

<import resource="redis-context.xml"/>

</beans>

dubbo消費者

消費者配置文件，它的配置相對提供者要簡單不少：

指定消費者的名稱，這個能夠隨意，不須要與提供者作任務相關聯的匹配。

指定協定類型，zookeeper地址。

指定引用的服務接口，注意這裏的id就與服務提供者定義的ref值相同。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<dubbo:application name="consumer-of-jim-app" />

<dubbo:registry protocol="zookeeper" address="192.168.21.128:2181"/>

<dubbo:reference interface="jim.IProduct" id="productService" />

</beans>

接口註解定義以及接口調用

@Controller

public class HomeController {

private static final Logger logger = LoggerFactory.getLogger(HomeController.class);

@Autowired

private IProduct productService;

@RequestMapping(value = "/", method = RequestMethod.GET)

public String home(Locale locale, Model model) {

logger.info("Welcome home! The client locale is {}.", locale);

String productName=this.productService.getProductName();

model.addAttribute("name", productName);

return "home";

}

}

dubbo admin

有一個UI工具能夠針對dubbo服務進行管理，惋惜我沒有在官方文檔提供的連接中下載成功，隨後從其它地方雖然下載完成了，但在安裝部署方面暫時遇到了必定的問題，須要手續研究解決。

正常應該能夠看到以下界面：

管理提供者

管理消費者

服務治理

通過上面的步驟後，就能夠啓動服務端以及客戶端來驗證了。上面只是簡單的搭建了dubbo環境以及實現了一個hello world的服務接口，要想使用好dubbo還有好多提供的最佳實踐，好比服務治理：

本地存根

本地假裝

結果緩存

多版本

服務降級

......