Spring boot 之 dubbo 無xml 簡單入門

 Dubbo簡介

 

Dubbo框架設計一共劃分了10個層，而最上面的Service層是留給實際想要使用Dubbo開發分佈式服務的開發者實現業務邏輯的接口層。圖中左邊淡藍背景的爲服務消費方使用的接口，右邊淡綠色背景的爲服務提供方使用的接口， 位於中軸線上的爲雙方都用到的接口。
下面，結合Dubbo官方文檔，咱們分別理解一下框架分層架構中，各個層次的設計要點：

1. 服務接口層（Service）：該層是與實際業務邏輯相關的，根據服務提供方和服務消費方的業務設計對應的接口和實現。
2. 配置層（Config）：對外配置接口，以ServiceConfig和ReferenceConfig爲中心，能夠直接new配置類，也能夠經過spring解析配置生成配置類。
3. 服務代理層（Proxy）：服務接口透明代理，生成服務的客戶端Stub和服務器端Skeleton，以ServiceProxy爲中心，擴展接口爲ProxyFactory。
4. 服務註冊層（Registry）：封裝服務地址的註冊與發現，以服務URL爲中心，擴展接口爲RegistryFactory、Registry和RegistryService。可能沒有服務註冊中心，此時服務提供方直接暴露服務。
5. 集羣層（Cluster）：封裝多個提供者的路由及負載均衡，並橋接註冊中心，以Invoker爲中心，擴展接口爲Cluster、Directory、Router和LoadBalance。將多個服務提供方組合爲一個服務提供方，實現對服務消費方來透明，只須要與一個服務提供方進行交互。
6. 監控層（Monitor）：RPC調用次數和調用時間監控，以Statistics爲中心，擴展接口爲MonitorFactory、Monitor和MonitorService。
7. 遠程調用層（Protocol）：封將RPC調用，以Invocation和Result爲中心，擴展接口爲Protocol、Invoker和Exporter。Protocol是服務域，它是Invoker暴露和引用的主功能入口，它負責Invoker的生命週期管理。Invoker是實體域，它是Dubbo的核心模型，其它模型都向它靠擾，或轉換成它，它表明一個可執行體，可向它發起invoke調用，它有多是一個本地的實現，也多是一個遠程的實現，也可能一個集羣實現。
8. 信息交換層（Exchange）：封裝請求響應模式，同步轉異步，以Request和Response爲中心，擴展接口爲Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。
9. 網絡傳輸層（Transport）：抽象mina和netty爲統一接口，以Message爲中心，擴展接口爲Channel、Transporter、Client、Server和Codec。
10. 數據序列化層（Serialize）：可複用的一些工具，擴展接口爲Serialization、 ObjectInput、ObjectOutput和ThreadPool。

從上圖能夠看出，Dubbo對於服務提供方和服務消費方，從框架的10層中分別提供了各自須要關心和擴展的接口，構建整個服務生態系統（服務提供方和服務消費方自己就是一個以服務爲中心的）。
根據官方提供的，對於上述各層之間關係的描述，以下所示：

• 在RPC中，Protocol是核心層，也就是隻要有Protocol + Invoker + Exporter就能夠完成非透明的RPC調用，而後在Invoker的主過程上Filter攔截點。
• 圖中的Consumer和Provider是抽象概念，只是想讓看圖者更直觀的瞭解哪些類分屬於客戶端與服務器端，不用Client和Server的緣由是Dubbo在不少場景下都使用Provider、Consumer、Registry、Monitor劃分邏輯拓普節點，保持統一律念。
• 而Cluster是外圍概念，因此Cluster的目的是將多個Invoker假裝成一個Invoker，這樣其它人只要關注Protocol層Invoker便可，加上Cluster或者去掉Cluster對其它層都不會形成影響，由於只有一個提供者時，是不須要Cluster的。
• Proxy層封裝了全部接口的透明化代理，而在其它層都以Invoker爲中心，只有到了暴露給用戶使用時，才用Proxy將Invoker轉成接口，或將接口實現轉成Invoker，也就是去掉Proxy層RPC是能夠Run的，只是不那麼透明，不那麼看起來像調本地服務同樣調遠程服務。
• 而Remoting實現是Dubbo協議的實現，若是你選擇RMI協議，整個Remoting都不會用上，Remoting內部再劃爲Transport傳輸層和Exchange信息交換層，Transport層只負責單向消息傳輸，是對Mina、Netty、Grizzly的抽象，它也能夠擴展UDP傳輸，而Exchange層是在傳輸層之上封裝了Request-Response語義。
• Registry和Monitor實際上不算一層，而是一個獨立的節點，只是爲了全局概覽，用層的方式畫在一塊兒。

 

dubbo-admin 安裝

https://github.com/alibaba/dubbo 

  解壓incubator-dubbo-dubbo-2.6.0.zip, 進入dubbo-admin 目錄，執行mvn install -Dmaven.test.skip=true ，在dubbo-admin/target下找到dubbo-admin-2.6.0.war，扔到tomcat/webapps下便可運行。

 

服務端和客戶端代碼：

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>study-dubbo-server</groupId>
	<artifactId>study-dubbo-server</artifactId>
	<version>1.0-SNAPSHOT</version>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
		<relativePath /> <!-- lookup parent from repository -->
	</parent>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<springfox.version>2.2.2</springfox.version>
		<skipTests>true</skipTests>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		 <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>fastjson</artifactId>
			<version>1.2.47</version>
		</dependency>
		<!-- https://mvnrepository.com/artifact/com.google.protobuf/protobuf-java -->
		<dependency>
			<groupId>com.google.protobuf</groupId>
			<artifactId>protobuf-java</artifactId>    
			<version>2.6.1</version>
		</dependency>
		<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
	<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
		<dependency>
		    <groupId>com.alibaba</groupId>
		    <artifactId>dubbo</artifactId>
		    <version>2.6.0</version>
		</dependency>
		<dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.8</version>
        </dependency>
         <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>
	<repositories>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>
</project>

 服務端

@Service(version = "1.0.0")

import java.util.ArrayList;
import java.util.List;

import com.study.center.emtity.Student;
import com.study.center.service.IStudentService;
 
import com.alibaba.dubbo.config.annotation.Service; 
@Service(version = "1.0.0")
public class StudentServiceImpl  implements IStudentService  {
	  public List<Student> getAll(){
		  
		  List<Student> reult=new ArrayList<Student>();
		  reult.add(new Student(1L,"aaa",22));
		  reult.add(new Student(2L,"aaa",22));
		  reult.add(new Student(3L,"aaa",22));
		  return reult;
	  }
}

配置文件

server.port=7063
spring.application.name=study-dubbo-server

spring.dubbo.application.name=study-dubbo-server
spring.dubbo.registry.address=zookeeper://192.168.200.238:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=com.study.center.service

 

消費端

@Reference(version = "1.0.0")

package com.study.center.controller;

import java.util.List;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.alibaba.dubbo.config.annotation.Reference;
import com.study.center.emtity.Student; 
import com.study.center.service.IStudentService;

@RestController
public class StudentController {

	@Reference(version = "1.0.0")
	IStudentService studentService;

    @RequestMapping("/test")
	public void getAll() {
		List<Student> students= studentService.getAll();
		for (int i = 0; i < students.size(); i++) {
			System.out.println(students.get(i).getName());
		}
	}
}

　　

配置文件

 

server.port=7055
spring.application.name=study-dubbo-server

spring.dubbo.application.name=study-dubbo-client
spring.dubbo.registry.address=zookeeper://192.168.200.238:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=com.study.center.controller

 

注意項：

1.配置中 spring.dubbo.scan，服務端和客戶端註解所在包是不一樣的，否則消費端會報空異常

2.服務端和消費端 接口定義的包路徑須要一致（

dubbo://192.168.20.70:20880/com.study.center.service.IStudentService?anyhost=true&application=study-dubbo-server&dubbo=2.6.0&generic=false&interface=com.study.center.service.IStudentService&methods=getAll&pid=1652&revision=1.0.0&side=provider×tamp=1535696412672&version=1.0.0

）