快速學(xué)會(huì)Dubbo的配置環(huán)境及相關(guān)配置
1. Dubbo相關(guān)概念
1.1 自動(dòng)服務(wù)發(fā)現(xiàn)工作原理
2. 啟動(dòng)文件
這里指使用zookeeper作為注冊(cè)中心;并啟動(dòng)相關(guān)dubbo監(jiān)控;
2.1 zookeeper-3.4.11\bin\zkServer.cmd
可以在zookeeper-3.4.11\conf路徑下配置zookeeper客戶端的端口號(hào)以及data數(shù)據(jù):
在zookeeper-3.4.11\bin目錄下運(yùn)行cmd啟動(dòng)zookeeper服務(wù):
2.2 zookeeper-3.4.11\bin\zkCli.cmd
在zookeeper-3.4.11\bin目錄下運(yùn)行cmd啟動(dòng)zookeeper客戶端:
2.3 java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
可以在incubator-dubbo-ops-master\dubbo-admin\src\main\resources路徑下修改application.properties文件中修改DubboWeb界面的端口:
在項(xiàng)目根路徑下打開命令行,執(zhí)行mvn clean package
將項(xiàng)目打成jar包,再執(zhí)行java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
命令運(yùn)行Dubbo;
2.4 dubbo-monitor-simple-2.0.0\assembly.bin\start.bat
可以在dubbo-monitor-simple-2.0.0\conf路徑下的dubbo.properties文件配置監(jiān)控頁端口:
在dubbo-monitor-simple-2.0.0\assembly.bin路徑下雙擊運(yùn)行start.bat文件:
3. 修改項(xiàng)目文件
需要對(duì)項(xiàng)目文件做些修改;以開啟dubbo相關(guān)功能;
3.1 在pom.xml文件里導(dǎo)入相關(guān)依賴
<!-- 引入dubbo --> <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency> <!-- 注冊(cè)中心使用的是zookeeper,引入操作zookeeper的客戶端端 --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency>
3.2 在application.properties文件 / src/main/resources/provider.xml文件中配置dubbo
3.2.1 提供者
<?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://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 1、指定當(dāng)前服務(wù)/應(yīng)用的名字(同樣的服務(wù)名字相同,不要和別的服務(wù)同名) --> <dubbo:application name="user-service-provider"></dubbo:application> <!-- 2、指定注冊(cè)中心的位置 --> <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> --> <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry> <!-- 3、指定通信規(guī)則(name指定通信協(xié)議?通信端口) --> <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol> <!-- 4、暴露服務(wù) ref:指向服務(wù)的真正的實(shí)現(xiàn)對(duì)象 --> <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl01" timeout="1000" version="1.0.0"> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service> <!--統(tǒng)一設(shè)置服務(wù)提供方的規(guī)則 --> <dubbo:provider timeout="1000"></dubbo:provider> <!-- 服務(wù)的實(shí)現(xiàn) --> <bean id="userServiceImpl01" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean> <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl02" timeout="1000" version="2.0.0"> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service> <bean id="userServiceImpl02" class="com.atguigu.gmall.service.impl.UserServiceImpl2"></bean> <!-- 連接監(jiān)控中心 --> <dubbo:monitor protocol="registry"></dubbo:monitor> </beans>
3.2.2 消費(fèi)者
<?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://dubbo.apache.org/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!--啟用包掃描--> <context:component-scan base-package="com.atguigu.gmall.service.impl"></context:component-scan> <dubbo:application name="order-service-consumer"></dubbo:application> <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> <!-- 配置本地存根--> <!--聲明需要調(diào)用的遠(yuǎn)程服務(wù)的接口;生成遠(yuǎn)程服務(wù)代理 --> <!-- 1)、精確優(yōu)先 (方法級(jí)優(yōu)先,接口級(jí)次之,全局配置再次之) 2)、消費(fèi)者設(shè)置優(yōu)先(如果級(jí)別一樣,則消費(fèi)方優(yōu)先,提供方次之) --> <!-- timeout="0" 默認(rèn)是1000ms--> <!-- retries="":重試次數(shù),不包含第一次調(diào)用,0代表不重試--> <!-- 冪等(設(shè)置重試次數(shù))【查詢、刪除、修改】、非冪等(不能設(shè)置重試次數(shù))【新增】 --> <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="5000" retries="3" version="*"> <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> --> </dubbo:reference> <!-- 配置當(dāng)前消費(fèi)者的統(tǒng)一規(guī)則:所有的服務(wù)都不檢查 --> <dubbo:consumer check="false" timeout="5000"></dubbo:consumer> <dubbo:monitor protocol="registry"></dubbo:monitor> <!-- <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor> --> </beans>
在進(jìn)行SpringBoot整合Dubbo時(shí),以上信息可以配置進(jìn)application.properties文件里;詳情請(qǐng)見《4.8 SpringBoot與Dubbo整合的三種方式》
3.3 使用注解開啟功能
注解 | 位置 | 功能 |
---|---|---|
@EnableDubbo | 開啟dubbo相關(guān)功能 | 主啟動(dòng)類 |
@Service | 暴露服務(wù) | 服務(wù)提供者provider |
@Reference | 遠(yuǎn)程調(diào)用 | 服務(wù)消費(fèi)者consumer |
4. 配置文件
4.1 配置文件的優(yōu)先級(jí)
- JVM 啟動(dòng) -D 參數(shù)優(yōu)先;
- XML 次之;
- Properties 最后,相當(dāng)于缺省值;
4.2 不同粒度配置的覆蓋關(guān)系
- 越上面優(yōu)先級(jí)越高;
- 精確優(yōu)先 (方法級(jí)優(yōu)先,接口級(jí)次之,全局配置再次之);
- 消費(fèi)者設(shè)置優(yōu)先(如果級(jí)別一樣,則消費(fèi)方優(yōu)先,提供方次之);
4.3 關(guān)閉啟動(dòng)檢查check
提供者有三種關(guān)閉啟動(dòng)檢查注冊(cè)中心的配置:
- Spring配置文件
<!-- 關(guān)閉某個(gè)服務(wù)的啟動(dòng)時(shí)檢查 (沒有提供者時(shí)報(bào)錯(cuò)) --> <dubbo:reference interface="com.foo.BarService" check="false" /> <!-- 關(guān)閉所有服務(wù)的啟動(dòng)時(shí)檢查 (沒有提供者時(shí)報(bào)錯(cuò)) --> <dubbo:consumer check="false" /> <!-- 關(guān)閉注冊(cè)中心啟動(dòng)時(shí)檢查 (注冊(cè)訂閱失敗時(shí)報(bào)錯(cuò)) --> <dubbo:registry check="false" />
- dubbo.properties
dubbo.reference.com.foo.BarService.check=false dubbo.reference.check=false dubbo.consumer.check=false dubbo.registry.check=false
- 通過 -D 參數(shù)
java -Ddubbo.reference.com.foo.BarService.check=false java -Ddubbo.reference.check=false java -Ddubbo.consumer.check=false java -Ddubbo.registry.check=false
消費(fèi)者有一種關(guān)閉啟動(dòng)檢查服務(wù)提供者的配置:
<dubbo:reference check="false"/>
4.4 超時(shí)timeout
提供者:
<!-- 配置超時(shí)時(shí)間 --> <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl01" timeout="1000""> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service>
消費(fèi)者:
<!-- 配置超時(shí)時(shí)間 --> <dubbo:reference interface="com.foo.BarService" id="BarService" timeout="5000"> </dubbo:reference> <!-- 還可以給具體方法配置超時(shí)時(shí)間(假設(shè)BarService里有testMethod方法) --> <dubbo:reference interface="com.foo.BarService" id="BarService" timeout="5000"> <dubbo:method name="testMethod" timeout="2000"></dubbo:method> </dubbo:reference>
可以體現(xiàn):
- 精確優(yōu)先 (方法級(jí)優(yōu)先,接口級(jí)次之,全局配置再次之);
- 消費(fèi)者設(shè)置優(yōu)先(如果級(jí)別一樣,則消費(fèi)方優(yōu)先,提供方次之);
4.5 重試次數(shù)retries
消費(fèi)者:
<!-- retries="":重試次數(shù),不包含第一次調(diào)用,0代表不重試--> <!-- 冪等(設(shè)置重試次數(shù))【查詢、刪除、修改】、非冪等(不能設(shè)置重試次數(shù))【新增】 --> <dubbo:reference interface="com.foo.BarService" id="BarService" timeout="5000" retries="3" > </dubbo:reference>
4.6 多版本version
提供者:
<!-- 1.0.0版本--> <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl01" timeout="1000" version="1.0.0"> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service> <!-- 服務(wù)的實(shí)現(xiàn) --> <bean id="userServiceImpl01" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean> <!-- 2.0.0版本--> <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl02" timeout="1000" version="2.0.0"> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service> <bean id="userServiceImpl02" class="com.atguigu.gmall.service.impl.UserServiceImpl2"></bean>
消費(fèi)者:
<!-- version指定用哪個(gè)版本,*表示隨機(jī)版本--> <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="5000" retries="3" version="*"> <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> --> </dubbo:reference>
4.7 本地存根stub
提供者:
public class UserServiceStub implements UserService { private final UserService userService; /** * 傳入的是userService遠(yuǎn)程的代理對(duì)象 * @param userService */ public UserServiceStub(UserService userService) { super(); this.userService = userService; } @Override public List<UserAddress> getUserAddressList(String userId) { System.out.println("UserServiceStub....."); if(!StringUtils.isEmpty(userId)) { return userService.getUserAddressList(userId); } return null; } }
消費(fèi)者:
<!-- 配置本地存根--> <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="5000" retries="3" version="*" stub="com.*.UserServiceStub"> </dubbo:reference>
4.8 SpringBoot與Dubbo整合的三種方式
- 1.導(dǎo)入dubbo-starter;在application.properties配置屬性;使用
@Service
暴露服務(wù);使用@Reference
引用服務(wù); - 2.保留dubbo xml配置文件;導(dǎo)入dubbo-starter;使用
@ImportResource
導(dǎo)入dubbo的配置文件即可;
在主啟動(dòng)類上@ImportResource(locations="classpath:provider.xml")
;
- 3.使用注解API的方式;將每一個(gè)組件手動(dòng)創(chuàng)建到容器中,讓dubbo來掃描其他的組件;使用
@Service
暴露服務(wù);
主啟動(dòng)類上:@EnableDubbo(scanBasePackages="com.atguigu.gmall")
;
在config包下進(jìn)行如下配置:
@Configuration public class MyDubboConfig { @Bean public ApplicationConfig applicationConfig() { ApplicationConfig applicationConfig = new ApplicationConfig(); applicationConfig.setName("boot-user-service-provider"); return applicationConfig; } //<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry> @Bean public RegistryConfig registryConfig() { RegistryConfig registryConfig = new RegistryConfig(); registryConfig.setProtocol("zookeeper"); registryConfig.setAddress("127.0.0.1:2181"); return registryConfig; } //<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol> @Bean public ProtocolConfig protocolConfig() { ProtocolConfig protocolConfig = new ProtocolConfig(); protocolConfig.setName("dubbo"); protocolConfig.setPort(20882); return protocolConfig; } /** *<dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl01" timeout="1000" version="1.0.0"> <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> </dubbo:service> */ @Bean public ServiceConfig<UserService> userServiceConfig(UserService userService){ ServiceConfig<UserService> serviceConfig = new ServiceConfig<>(); serviceConfig.setInterface(UserService.class); serviceConfig.setRef(userService); serviceConfig.setVersion("1.0.0"); //配置每一個(gè)method的信息 MethodConfig methodConfig = new MethodConfig(); methodConfig.setName("getUserAddressList"); methodConfig.setTimeout(1000); //將method的設(shè)置關(guān)聯(lián)到service配置中 List<MethodConfig> methods = new ArrayList<>(); methods.add(methodConfig); serviceConfig.setMethods(methods); //ProviderConfig //MonitorConfig return serviceConfig; } }
到此這篇關(guān)于快速學(xué)會(huì)Dubbo的環(huán)境及相關(guān)配置配置的文章就介紹到這了,更多相關(guān)Dubbo 環(huán)境與配置內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java?EventBus手把手帶你實(shí)現(xiàn)
EventBus是Guava的事件處理機(jī)制,是設(shè)計(jì)模式中觀察者模式(生產(chǎn)/消費(fèi)者編程模型)的優(yōu)雅實(shí)現(xiàn)。本文就來和大家聊聊EventBus的使用,需要的可以參考一下2023-01-01SpringBoot+mybatis+thymeleaf實(shí)現(xiàn)登錄功能示例
這篇文章主要介紹了SpringBoot+mybatis+thymeleaf實(shí)現(xiàn)登錄功能示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07深入解析java中的靜態(tài)代理與動(dòng)態(tài)代理
本篇文章是對(duì)java中的靜態(tài)代理與動(dòng)態(tài)代理進(jìn)行了詳細(xì)的分析介紹,需要的朋友可以過來參考下,希望對(duì)大家有所幫助2013-10-10SpringMVC @RequestBody屬性名大寫字母注入失敗的解決
這篇文章主要介紹了SpringMVC @RequestBody屬性名大寫字母注入失敗的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-04-04SpringBoot在容器中創(chuàng)建實(shí)例@Component和@bean有什么區(qū)別
這篇文章主要介紹了SpringBoot在容器中創(chuàng)建實(shí)例@Component和@bean有什么區(qū)別,在Spring Boot中,@Component注解和@Bean注解都可以用于創(chuàng)建bean。它們的主要區(qū)別在于它們的作用范圍和創(chuàng)建方式2023-03-03