Springboot 整合 Dubbo/ZooKeeper 實(shí)現(xiàn) SOA 案例解析

更新時(shí)間：2017年11月16日 09:56:57 投稿：mrr

這篇文章主要介紹了Springboot 整合 Dubbo/ZooKeeper 詳解 SOA 案例,需要的朋友可以參考下

一、為啥整合 Dubbo 實(shí)現(xiàn) SOA

Dubbo 不單單只是高性能的 RPC 調(diào)用框架，更是 SOA 服務(wù)治理的一種方案。

核心：

遠(yuǎn)程通信，向本地調(diào)用一樣調(diào)用遠(yuǎn)程方法。

集群容錯(cuò)

服務(wù)自動(dòng)發(fā)現(xiàn)和注冊，可平滑添加或者刪除服務(wù)提供者。

我們常常使用 Springboot 暴露 HTTP 服務(wù)，并走 JSON 模式。但慢慢量大了，一種 SOA 的治理方案。這樣可以暴露出 Dubbo 服務(wù)接口，提供給 Dubbo 消費(fèi)者進(jìn)行 RPC 調(diào)用。下面我們詳解下如何集成 Dubbo。

二、運(yùn)行 springboot-dubbo-server 和 springboot-dubbo-client 工程

運(yùn)行環(huán)境：JDK 7 或 8，Maven 3.0+

技術(shù)棧：SpringBoot 1.5+、Dubbo 2.5+、ZooKeeper 3.3+

1.ZooKeeper 服務(wù)注冊中心

ZooKeeper 是一個(gè)分布式的，開放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù)。它是一個(gè)為分布式應(yīng)用提供一致性服務(wù)的軟件，提供的功能包括：配置維護(hù)、域名服務(wù)、分布式同步、組服務(wù)等。

下載 ZooKeeper ，地址 http://www.apache.org/dyn/closer.cgi/zookeeper

解壓 ZooKeeper

tar zxvf zookeeper-3.4.8.tar.gz

在 conf 目錄新建 zoo.cfg ，照著該目錄的 zoo_sample.cfg 配置如下。

cd zookeeper-3.3.6/conf
vim zoo.cfg

zoo.cfg 代碼如下（自己指定 log 文件目錄）：

tickTime=2000
dataDir=/javaee/zookeeper/data 
dataLogDir=/javaee/zookeeper/log
clientPort=2181

在 bin 目錄下，啟動(dòng) ZooKeeper：

cd zookeeper-3.3.6/bin
./zkServer.sh start

2. git clone 下載工程 springboot-learning-example

項(xiàng)目地址見 GitHub - https://github.com/JeffLi1993/springboot-learning-example：

git clone git@github.com:JeffLi1993/springboot-learning-example.git

然后，Maven 編譯安裝這個(gè)工程：

cd springboot-learning-example
mvn clean install

3.運(yùn)行 springboot-dubbo-server Dubbo 服務(wù)提供者工程

右鍵運(yùn)行 springboot-dubbo-server 工程 ServerApplication 應(yīng)用啟動(dòng)類的 main 函數(shù)。Console 中出現(xiàn)如下表示項(xiàng)目啟動(dòng)成功。這里表示 Dubbo 服務(wù)已經(jīng)啟動(dòng)成功，并注冊到 ZK （ZooKeeper）中。

4.運(yùn)行 springboot-dubbo-client Dubbo 服務(wù)消費(fèi)者工程

右鍵運(yùn)行 springboot-dubbo-client 工程 ClientApplication 應(yīng)用啟動(dòng)類的 main 函數(shù)。Console 中出現(xiàn)如下：

...
2017-03-01 16:31:38.473 INFO 9896 --- [      main] o.s.j.e.a.AnnotationMBeanExporter    : Registering beans for JMX exposure on startup
2017-03-01 16:31:38.538 INFO 9896 --- [      main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8081 (http)
2017-03-01 16:31:38.547 INFO 9896 --- [      main] org.spring.springboot.ClientApplication : Started ClientApplication in 6.055 seconds (JVM running for 7.026)
City{id=1, provinceId=2, cityName='溫嶺', description='是我的故鄉(xiāng)'}

最后打印的城市信息，就是通過 Dubbo 服務(wù)接口調(diào)用獲取的。順利運(yùn)行成功，下面詳解下各個(gè)代碼及配置。

三、springboot-dubbo-server 和 springboot-dubbo-client 工程配置詳解

代碼都在 GitHub 上， https://github.com/JeffLi1993/springboot-learning-example。

1.詳解 springboot-dubbo-server Dubbo 服務(wù)提供者工程

springboot-dubbo-server 工程目錄結(jié)構(gòu)

├── pom.xml
└── src
  └── main
    ├── java
    │  └── org
    │    └── spring
    │      └── springboot
    │        ├── ServerApplication.java
    │        ├── domain
    │        │  └── City.java
    │        └── dubbo
    │          ├── CityDubboService.java
    │          └── impl
    │            └── CityDubboServiceImpl.java
    └── resources
      └── application.properties

a.pom.xml 配置

pom.xml 中依賴了 spring-boot-starter-dubbo 工程，該項(xiàng)目地址是 https://github.com/teaey/spring-boot-starter-dubbo。

pom.xml 配置如下

4.0.0  springboot  springboot-dubbo-server  0.0.1-SNAPSHOT  springboot-dubbo 服務(wù)端:: 整合 Dubbo/ZooKeeper 詳解 SOA 案例  
      org.springframework.boot    spring-boot-starter-parent    1.5.1.RELEASE        1.0.0        
          io.dubbo.springboot      spring-boot-starter-dubbo      ${dubbo-spring-boot}        
          org.springframework.boot      spring-boot-starter-web        
          org.springframework.boot      spring-boot-starter-test      test        
          junit      junit      4.12

b.application.properties 配置

## Dubbo 服務(wù)提供者配置
spring.dubbo.application.name=provider
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=org.spring.springboot.dubbo

這里 ZK 配置的地址和端口，就是上面本機(jī)搭建的 ZK 。如果有自己的 ZK 可以修改下面的配置。配置解釋如下：

spring.dubbo.application.name 應(yīng)用名稱
spring.dubbo.registry.address 注冊中心地址
spring.dubbo.protocol.name 協(xié)議名稱
spring.dubbo.protocol.port 協(xié)議端口
spring.dubbo.scan dubbo 服務(wù)類包目錄
c.CityDubboServiceImpl.java 城市業(yè)務(wù) Dubbo 服務(wù)層實(shí)現(xiàn)層類
// 注冊為 Dubbo 服務(wù)
@Service(version = "1.0.0")
public class CityDubboServiceImpl implements CityDubboService {
  public City findCityByName(String cityName) {
    return new City(1L,2L,"溫嶺","是我的故鄉(xiāng)");
  }
}
@Service 注解標(biāo)識為 Dubbo 服務(wù)，并通過 version 指定了版本號。

d.City.java 城市實(shí)體類

實(shí)體類通過 Dubbo 服務(wù)之間 RPC 調(diào)用，則需要實(shí)現(xiàn)序列化接口。最好指定下 serialVersionUID 值。

2.詳解 springboot-dubbo-client Dubbo 服務(wù)消費(fèi)者工程

springboot-dubbo-client 工程目錄結(jié)構(gòu)
├── pom.xml
└── src
  └── main
    ├── java
    │  └── org
    │    └── spring
    │      └── springboot
    │        ├── ClientApplication.java
    │        ├── domain
    │        │  └── City.java
    │        └── dubbo
    │          ├── CityDubboConsumerService.java
    │          └── CityDubboService.java
    └── resources
      └── application.properties

pom.xml 、 CityDubboService.java、City.java 沒有改動(dòng)。Dubbo 消費(fèi)者通過引入接口實(shí)現(xiàn) Dubbo 接口的調(diào)用。

a.application.properties 配置

## 避免和 server 工程端口沖突
server.port=8081
## Dubbo 服務(wù)消費(fèi)者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=org.spring.springboot.dubbo

因?yàn)?springboot-dubbo-server 工程啟動(dòng)占用了 8080 端口，所以這邊設(shè)置端口為 8081。

b.CityDubboConsumerService.java 城市 Dubbo 服務(wù)消費(fèi)者

@Component
public class CityDubboConsumerService {
  @Reference(version = "1.0.0")
  CityDubboService cityDubboService;
  public void printCity() {
    String cityName="溫嶺";
    City city = cityDubboService.findCityByName(cityName);
    System.out.println(city.toString());
  }
}

@Reference(version = “1.0.0”) 通過該注解，訂閱該接口版本為 1.0.0 的 Dubbo 服務(wù)。

這里將 CityDubboConsumerService 注入 Spring 容器，是為了更方便的獲取該 Bean，然后驗(yàn)證這個(gè) Dubbo 調(diào)用是否成功。

c.ClientApplication.java 客戶端啟動(dòng)類

@SpringBootApplication
public class ClientApplication {
  public static void main(String[] args) {
    // 程序啟動(dòng)入口
    // 啟動(dòng)嵌入式的 Tomcat 并初始化 Spring 環(huán)境及其各 Spring 組件
    ConfigurableApplicationContext run = SpringApplication.run(ClientApplication.class, args);
    CityDubboConsumerService cityService = run.getBean(CityDubboConsumerService.class);
    cityService.printCity();
  }
}

解釋下這段邏輯，就是啟動(dòng)后從 Bean 容器中獲取城市 Dubbo 服務(wù)消費(fèi)者 Bean。然后調(diào)用該 Bean 方法去驗(yàn)證 Dubbo 調(diào)用是否成功。

四、小結(jié)

還有涉及到服務(wù)的監(jiān)控，治理。這本質(zhì)上和 SpringBoot 無關(guān)，這邊不做一一介紹。

總結(jié)

以上所述是小編給大家介紹的Springboot 整合 Dubbo/ZooKeeper 實(shí)現(xiàn) SOA 案例解析，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！

您可能感興趣的文章: