從頭開始搭建一個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還有好多提供的最佳實踐，好比服務治理：

• 本地存根
• 本地假裝
• 結果緩存
• 多版本
• 服務降級
• ......