Springboot 整合 Dubbo/ZooKeeper 詳解 SOA 案例
阿新 • • 發佈:2018-12-22
3.執行 springboot-dubbo-server Dubbo 服務提供者工程
右鍵執行 springboot-dubbo-server 工程 ServerApplication 應用啟動類的 main 函式。Console 中出現如下表示專案啟動成功:
這裡表示 Dubbo 服務已經啟動成功,並註冊到 ZK (ZooKeeper)中。
4.執行 springboot-dubbo-client Dubbo 服務消費者工程
最後列印的城市資訊,就是通過 Dubbo 服務介面呼叫獲取的。順利執行成功,下面詳解下各個程式碼及配置。
a.pom.xml 配置
右鍵執行 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='是我的故鄉'}
三、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
<?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.propertiespom.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