Dubbo簡介
Dubbo是一款高性能的Java RPC框架,其前身是阿里巴巴公司開源的一個高性能、輕量級的開源Java RPC框架,可以和Spring框架無縫集成,
Dubbo官網
特性
- 面向介面代理的高性能RPC呼叫
- 智能負載均衡
- 服務自動注冊與發現
- 高度可擴展能力
- 運行期間流量調度
- 可視化的服務治理與運維
Dubbo的設計架構

、
| 節點 | 角色名稱 |
|
Provider |
服務提供者 |
| Registry | 注冊中心 |
| Consumer | 服務消費者 |
| Container | 框架容器 |
| Monitor | 監控中心 |
虛線是異步訪問,實線是同步訪問,
0、1、2是在啟動時完成的功能,3、4、5是在程式運行中執行的功能,
呼叫流程
- 服務容器負責啟動,加載,運行服務提供者,
- 服務提供者在啟動時,向注冊中心注冊自己提供的服務,
- 服務消費者在啟動時,向注冊中心訂閱自己所需的服務,
- 注冊中心回傳服務提供者地址串列給消費者,如果有變更,注冊中心將基于長連接推送變更資料給消費者,
- 服務消費者,從提供者地址串列中,基于負載均衡演算法,選臺提供者進行呼叫,如果呼叫失敗,再選另一臺呼叫,
- 服務消費者和提供者,在記憶體中累計呼叫次數和呼叫時間,定時每分鐘發送一次統計資料到監控中心,
Dubbo部署
配置注冊中心
zokeeper說明檔案
zokeeper下載
- 下載zokeeper
- zokeeper組態檔,路徑:zokeeper/conf/zoo_sample.cfg
1 # Client-Server通信心跳時間 2 tickTime=2000 3 # Leader-Follower初始通信時限 4 initLimit=10 5 # Leader-Follower同步通信時限 6 syncLimit=5 7 # 資料檔案目錄 8 dataDir=../data 9 # 客戶端連接埠 10 clientPort=2181
- 可執行檔案,路徑:zokeeper/bin/zkEnv.cmd
1 REM 與conf下的組態檔名稱一致 2 set ZOOCFG=%ZOOCFGDIR%\zoo_sample.cfg
- 啟動zookeeper服務,路徑:zokeeper/bin/zkServer.cmd
專案部署
公共服務介面
- 創建一個公共介面工程
- 創建一個HelloService介面
1 package com.tankang.service; 2 3 /** 4 * @program: dubbo 5 * @description: 提供者服務層介面 6 * @author: 譚康 7 * @create: 2020-08-30 13:45 8 **/ 9 public interface HelloService { 10 String sayHello(String name); 11 }
服務提供者
- 創建一個服務提供者工程
- 匯入maven坐標
1 <?xml version="1.0" encoding="UTF-8"?> 2 <project xmlns="http://maven.apache.org/POM/4.0.0" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 7 <groupId>com.tankang</groupId> 8 <artifactId>dubbodemo_provider</artifactId> 9 <version>1.0-SNAPSHOT</version> 10 <packaging>war</packaging> 11 12 <properties> 13 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 14 <maven.compiler.source>1.8</maven.compiler.source> 15 <maven.compiler.target>1.8</maven.compiler.target> 16 <spring.version>5.0.5.RELEASE</spring.version> 17 </properties> 18 <dependencies> 19 <dependency> 20 <groupId>org.springframework</groupId> 21 <artifactId>spring-context</artifactId> 22 <version>${spring.version}</version> 23 </dependency> 24 <dependency> 25 <groupId>org.springframework</groupId> 26 <artifactId>spring-beans</artifactId> 27 <version>${spring.version}</version> 28 </dependency> 29 <dependency> 30 <groupId>org.springframework</groupId> 31 <artifactId>spring-webmvc</artifactId> 32 <version>${spring.version}</version> 33 </dependency> 34 <dependency> 35 <groupId>org.springframework</groupId> 36 <artifactId>spring-jdbc</artifactId> 37 <version>${spring.version}</version> 38 </dependency> 39 <dependency> 40 <groupId>org.springframework</groupId> 41 <artifactId>spring-aspects</artifactId> 42 <version>${spring.version}</version> 43 </dependency> 44 <dependency> 45 <groupId>org.springframework</groupId> 46 <artifactId>spring-jms</artifactId> 47 <version>${spring.version}</version> 48 </dependency> 49 <dependency> 50 <groupId>org.springframework</groupId> 51 <artifactId>spring-context-support</artifactId> 52 <version>${spring.version}</version> 53 </dependency> 54 <!-- dubbo相關 --> 55 <dependency> 56 <groupId>com.alibaba</groupId> 57 <artifactId>dubbo</artifactId> 58 <version>2.6.0</version> 59 </dependency> 60 <dependency> 61 <groupId>org.apache.zookeeper</groupId> 62 <artifactId>zookeeper</artifactId> 63 <version>3.4.7</version> 64 </dependency> 65 <dependency> 66 <groupId>com.github.sgroschupf</groupId> 67 <artifactId>zkclient</artifactId> 68 <version>0.1</version> 69 </dependency> 70 <dependency> 71 <groupId>javassist</groupId> 72 <artifactId>javassist</artifactId> 73 <version>3.12.1.GA</version> 74 </dependency> 75 <dependency> 76 <groupId>com.alibaba</groupId> 77 <artifactId>fastjson</artifactId> 78 <version>1.2.47</version> 79 </dependency> 80 <!-- 匯入公共抽取介面坐標 --> 81 <dependency> 82 <groupId>com.tankang</groupId> 83 <artifactId>dubbodemo_interface</artifactId> 84 <version>1.0-SNAPSHOT</version> 85 </dependency> 86 </dependencies> 87 <build> 88 <plugins> 89 <plugin> 90 <groupId>org.apache.maven.plugins</groupId> 91 <artifactId>maven-compiler-plugin</artifactId> 92 <version>2.3.2</version> 93 <configuration> 94 <source>1.8</source> 95 <target>1.8</target> 96 </configuration> 97 </plugin> 98 <!-- tomcat插件 --> 99 <plugin> 100 <groupId>org.apache.tomcat.maven</groupId> 101 <artifactId>tomcat7-maven-plugin</artifactId> 102 <configuration> 103 <!-- 指定埠 --> 104 <port>8082</port> 105 <!-- 請求路徑 --> 106 <path>/</path> 107 </configuration> 108 </plugin> 109 </plugins> 110 </build> 111 </project>
- 創建提供者實作類
1 package com.tankang.service.impl; 2 3 import com.alibaba.dubbo.config.annotation.Service; 4 import com.tankang.service.HelloService; 5 6 /** 7 * @program: dubbo 8 * @description: 提供者實作類 9 * @author: 譚康 10 * @create: 2020-08-30 13:58 11 **/ 12 @Service 13 public class HelloServiceImpl implements HelloService { 14 @Override 15 public String sayHello(String name) { 16 return "Hello," + name + "!"; 17 } 18 }
- 配置web.xml
1 <?xml version="1.0" encoding="UTF-8"?> 2 <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd" 5 version="4.0"> 6 <context-param> 7 <param-name>contextConfigLocation</param-name> 8 <param-value>classpath:provida.xml</param-value> 9 </context-param> 10 <listener> 11 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 12 </listener> 13 </web-app>
- 用Spring配置宣告暴露服務,provida.xml
<?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="hello-world-app" /> <!-- 使用注冊中心暴露服務地址 --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- 用dubbo協議在20880埠暴露服務 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 組件掃描,加入@Service注解的類會被發布為服務 --> <dubbo:annotation package="com.tankang.service.impl" /> </beans>
服務消費者
- 創建一個服務消費者工程
- 匯入坐標
1 <?xml version="1.0" encoding="UTF-8"?> 2 <project xmlns="http://maven.apache.org/POM/4.0.0" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <modelVersion>4.0.0</modelVersion> 6 7 <groupId>com.tankang</groupId> 8 <artifactId>dubbodemo_consumer</artifactId> 9 <version>1.0-SNAPSHOT</version> 10 <packaging>war</packaging> 11 12 <properties> 13 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 14 <maven.compiler.source>1.8</maven.compiler.source> 15 <maven.compiler.target>1.8</maven.compiler.target> 16 <spring.version>5.0.5.RELEASE</spring.version> 17 </properties> 18 <dependencies> 19 <dependency> 20 <groupId>org.springframework</groupId> 21 <artifactId>spring-context</artifactId> 22 <version>${spring.version}</version> 23 </dependency> 24 <dependency> 25 <groupId>org.springframework</groupId> 26 <artifactId>spring-beans</artifactId> 27 <version>${spring.version}</version> 28 </dependency> 29 <dependency> 30 <groupId>org.springframework</groupId> 31 <artifactId>spring-webmvc</artifactId> 32 <version>${spring.version}</version> 33 </dependency> 34 <dependency> 35 <groupId>org.springframework</groupId> 36 <artifactId>spring-jdbc</artifactId> 37 <version>${spring.version}</version> 38 </dependency> 39 <dependency> 40 <groupId>org.springframework</groupId> 41 <artifactId>spring-aspects</artifactId> 42 <version>${spring.version}</version> 43 </dependency> 44 <dependency> 45 <groupId>org.springframework</groupId> 46 <artifactId>spring-jms</artifactId> 47 <version>${spring.version}</version> 48 </dependency> 49 <dependency> 50 <groupId>org.springframework</groupId> 51 <artifactId>spring-context-support</artifactId> 52 <version>${spring.version}</version> 53 </dependency> 54 <!-- dubbo相關 --> 55 <dependency> 56 <groupId>com.alibaba</groupId> 57 <artifactId>dubbo</artifactId> 58 <version>2.6.0</version> 59 </dependency> 60 <dependency> 61 <groupId>org.apache.zookeeper</groupId> 62 <artifactId>zookeeper</artifactId> 63 <version>3.4.7</version> 64 </dependency> 65 <dependency> 66 <groupId>com.github.sgroschupf</groupId> 67 <artifactId>zkclient</artifactId> 68 <version>0.1</version> 69 </dependency> 70 <dependency> 71 <groupId>javassist</groupId> 72 <artifactId>javassist</artifactId> 73 <version>3.12.1.GA</version> 74 </dependency> 75 <dependency> 76 <groupId>com.alibaba</groupId> 77 <artifactId>fastjson</artifactId> 78 <version>1.2.47</version> 79 </dependency> 80 <!-- 匯入公共抽取介面坐標 --> 81 <dependency> 82 <groupId>com.tankang</groupId> 83 <artifactId>dubbodemo_interface</artifactId> 84 <version>1.0-SNAPSHOT</version> 85 </dependency> 86 </dependencies> 87 <build> 88 <plugins> 89 <plugin> 90 <groupId>org.apache.maven.plugins</groupId> 91 <artifactId>maven-compiler-plugin</artifactId> 92 <version>2.3.2</version> 93 <configuration> 94 <source>1.8</source> 95 <target>1.8</target> 96 </configuration> 97 </plugin> 98 <!-- tomcat插件 --> 99 <plugin> 100 <groupId>org.apache.tomcat.maven</groupId> 101 <artifactId>tomcat7-maven-plugin</artifactId> 102 <configuration> 103 <!-- 指定埠 --> 104 <port>8083</port> 105 <!-- 請求路徑 --> 106 <path>/</path> 107 </configuration> 108 </plugin> 109 </plugins> 110 </build> 111 </project>
- 通過Spring配置參考遠程服務,consumer.xml
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 4 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"> 5 <!-- 消費方應用名,用于計算依賴關系,不是匹配條件,不要與提供方一樣 --> 6 <dubbo:application name="consumer-of-helloworld-app" /> 7 8 <!-- 連接服務注冊中心zookeeper,ip為zookeeper所在服務器的ip地址--> 9 <dubbo:registry address="zookeeper://127.0.0.1:2181"/> 10 11 <!-- 組件掃描,掃描的方式暴露介面 --> 12 <dubbo:annotation package="com.tankang.controller" /> 13 14 <!--超時全域設定--> 15 <!-- 16 timeout:時間(10分鐘) 17 check:是否檢查服務提供方(true|false),開發階段建議設定為false 18 true啟動時不檢查服務提供方 19 false啟動時檢查服務提供方,如果服務提供方沒有啟動則報錯 20 --> 21 <dubbo:consumer timeout="600000" check="false"/> 22 </beans>
- 撰寫消費者類
1 package com.tankang.controller; 2 3 import com.alibaba.dubbo.config.annotation.Reference; 4 import com.tankang.service.HelloService; 5 import org.springframework.web.bind.annotation.RequestMapping; 6 import org.springframework.web.bind.annotation.RestController; 7 8 /** 9 * @program: dubbo 10 * @description: 消費者類 11 * @author: 譚康 12 * @create: 2020-08-30 14:21 13 **/ 14 @RestController 15 @RequestMapping("/hello") 16 public class HelloController { 17 @Reference 18 private HelloService helloService; 19 20 @RequestMapping("/sayHello") 21 public String sayHello(String name){ 22 String str = helloService.sayHello(name); 23 return str; 24 } 25 }
- 配置web.xml
1 <?xml version="1.0" encoding="UTF-8"?> 2 <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd" 5 version="4.0"> 6 <!-- 配置前端控制器 --> 7 <servlet> 8 <servlet-name>DispatcherServlet</servlet-name> 9 <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> 10 <!-- 指定加載的組態檔,通過引數contextConfigLocation加載 --> 11 <init-param> 12 <param-name>contextConfigLocation</param-name> 13 <param-value>classpath:consumer.xml</param-value> 14 </init-param> 15 <load-on-startup>1</load-on-startup> 16 </servlet> 17 <servlet-mapping> 18 <servlet-name>DispatcherServlet</servlet-name> 19 <url-pattern>/</url-pattern> 20 </servlet-mapping> 21 </web-app>
測驗訪問
- 啟動zokeeper服務,路徑:zokeeper/bin/zkServer.cmd
- 啟動提供者tomcat服務,路徑:Maven -> dubbodemo_provider -> Plugins -> tomcat7 -> tomcat7:run
- 啟動消費者tomcat服務,路徑:Maven -> dubbodemo_consumer -> Plugins -> tomcat7 -> tomcat7:run
- 測驗資源訪問,訪問地址:http://localhost:8083/hello/sayHello?name=張三
Dubbo負載均衡
Dubbo提供了四種負載均衡策略

| 類 | 說明 |
| RandomLoadBalance | 隨機呼叫(默認) |
| RoundRobinLoadBlance | 輪詢呼叫 |
| LeastActiveLoadBlance | 最少活躍數呼叫 |
| ConsistentHashLoadBalance | 一致性Hash演算法 |
使用方法
@Service(loadbalance = "負載均衡策略")
1 package com.tankang.service.impl; 2 3 import com.alibaba.dubbo.config.annotation.Service; 4 import com.tankang.service.HelloService; 5 6 /** 7 * @program: dubbo 8 * @description: 提供者實作類 9 * @author: 譚康 10 * @create: 2020-08-30 13:58 11 **/ 12 @Service(loadbalance = "random") 13 public class HelloServiceImpl implements HelloService { 14 @Override 15 public String sayHello(String name) { 16 return "Hello," + name + "!"; 17 } 18 }
Dubbo事務解決方案
問題:在使用dubbo 2.5.3之前的版本@Service來發布服務時,當該服務中有@Transactional,是無法正常發布的?
解決方案:
-
因為事務TransactionManagement默認是使用了jdk的代理即基于介面的代理,必須改成基于類的代理,@service才會生效,所以必須修改代理方式,如果是javaconfig來配置,加上 @EnableTransactionManagement(proxyTargetClass=true) ,如果是xml配置,加上 <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" /> ,
-
進行了第一步之后,發現仍然不能發布服務,因為dubbo的@Service原始碼@Inherited,所以沒有是不能被代理類繼承的,所以還需要修改dubbo @Service的原始碼,在annotation上加入@Inherited,這樣代理類就會繼承了這個注解,(注:目前dubbo的master的分支已經修復了這個問題,但是沒有發正式的版本,)
- 雖然已經發布了,但是會發現發布的服務是spring的代理SpringProxy(可以通過dubbo-admin看到,或者啟動日志),不是你想要的,無法正常參考,因為必須在@Service中指定interfaceName,指定發布的服務的名稱,例: @Service(version = "1.0.0",interfaceName = "com.zl.dubbotest.api.HelloService") ,
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/30812.html
標籤:Java
上一篇:物件和類
