1. 程式人生 > >Springboot 整合 Dubbo/ZooKeeper 詳解 SOA 案例

Springboot 整合 Dubbo/ZooKeeper 詳解 SOA 案例

3.執行 springboot-dubbo-server Dubbo 服務提供者工程 右鍵執行 springboot-dubbo-server 工程 ServerApplication 應用啟動類的 main 函式。Console 中出現如下表示專案啟動成功: 這裡表示 Dubbo 服務已經啟動成功,並註冊到 ZK (ZooKeeper)中。 4.執行 springboot-dubbo-client Dubbo 服務消費者工程

右鍵執行 springboot-dubbo-client 工程 ClientApplication 應用啟動類的 main 函式。Console 中出現如下:

...
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='是我的故鄉'}
最後列印的城市資訊,就是通過 Dubbo 服務介面呼叫獲取的。順利執行成功,下面詳解下各個程式碼及配置。

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

1.詳解 springboot-dubbo-server Dubbo 服務提供者工程 springboot-dubbo-server 工程目錄結構
├── 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 配置
<?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>springboot</groupId>
<artifactId>springboot-dubbo-server</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springboot-dubbo 服務端:: 整合 Dubbo/ZooKeeper 詳解 SOA 案例</name>

<!-- Spring Boot 啟動父依賴 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.1.RELEASE</version>
</parent>

<properties>
<dubbo-spring-boot>1.0.0</dubbo-spring-boot>
</properties>

<dependencies>

<!-- Spring Boot Dubbo 依賴 -->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>${dubbo-spring-boot}</version>
</dependency>

<!-- Spring Boot Web 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<!-- Spring Boot Test 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<!-- Junit -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
</dependencies>
</project>

b.application.properties 配置

## Dubbo 服務提供者配置
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 配置的地址和埠,就是上面本機搭建的 ZK 。如果有自己的 ZK 可以修改下面的配置。配置解釋如下: spring.dubbo.application.name 應用名稱 spring.dubbo.registry.address 註冊中心地址 spring.dubbo.protocol.name 協議名稱 spring.dubbo.protocol.port 協議埠 spring.dubbo.scan dubbo 服務類包目錄 c.CityDubboServiceImpl.java 城市業務 Dubbo 服務層實現層類
// 註冊為 Dubbo 服務
@Service(version = "1.0.0")
public class CityDubboServiceImpl implements CityDubboService {

    public City findCityByName(String cityName) {
        return new City(1L,2L,"溫嶺","是我的故鄉");
    }
}
@Service 註解標識為 Dubbo 服務,並通過 version 指定了版本號。 d.City.java 城市實體類 實體類通過 Dubbo 服務之間 RPC 呼叫,則需要實現序列化介面。最好指定下 serialVersionUID 值。 2.詳解 springboot-dubbo-client Dubbo 服務消費者工程 springboot-dubbo-client 工程目錄結構
├── 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 沒有改動。Dubbo 消費者通過引入介面實現 Dubbo 介面的呼叫。 a.application.properties 配置
## 避免和 server 工程埠衝突
server.port=8081

## Dubbo 服務消費者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=org.spring.springboot.dubbo