快速學會Dubbo的配置環境及相關配置

Posted on by

1. Dubbo相關概念

1.1 自動服務發現工作原理

2. 啟動文件

這裡指使用zookeeper作為註冊中心；並啟動相關dubbo監控；

2.1 zookeeper-3.4.11\bin\zkServer.cmd

可以在zookeeper-3.4.11\conf路徑下配置zookeeper客戶端的端口號以及data數據：

在zookeeper-3.4.11\bin目錄下運行cmd啟動zookeeper服務：

2.2 zookeeper-3.4.11\bin\zkCli.cmd

在zookeeper-3.4.11\bin目錄下運行cmd啟動zookeeper客戶端：

2.3 java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

可以在incubator-dubbo-ops-master\dubbo-admin\src\main\resources路徑下修改application.properties文件中修改DubboWeb界面的端口：

在項目根路徑下打開命令行，執行mvn clean package將項目打成jar包，再執行java -jar dubbo-admin-0.0.1-SNAPSHOT.jar命令運行Dubbo；


2.4 dubbo-monitor-simple-2.0.0\assembly.bin\start.bat

可以在dubbo-monitor-simple-2.0.0\conf路徑下的dubbo.properties文件配置監控頁端口：

在dubbo-monitor-simple-2.0.0\assembly.bin路徑下雙擊運行start.bat文件：

3. 修改項目文件

需要對項目文件做些修改；以開啟dubbo相關功能；

3.1 在pom.xml文件裡導入相關依賴

<!-- 引入dubbo -->
<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
<dependency>
	<groupId>com.alibaba</groupId>
	<artifactId>dubbo</artifactId>
	<version>2.6.2</version>
</dependency>
<!-- 註冊中心使用的是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、指定當前服務/應用的名字（同樣的服務名字相同，不要和別的服務同名） -->
	<dubbo:application name="user-service-provider"></dubbo:application>
	
	<!-- 2、指定註冊中心的位置 -->
	<!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
	
	<!-- 3、指定通信規則（name指定通信協議？通信端口） -->
	<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
	
	<!-- 4、暴露服務   ref：指向服務的真正的實現對象 -->
	<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>
	
	<!--統一設置服務提供方的規則  -->
	<dubbo:provider timeout="1000"></dubbo:provider>
	
	
	<!-- 服務的實現 -->
	<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>
	
	<!-- 連接監控中心 -->
	<dubbo:monitor protocol="registry"></dubbo:monitor>
	
</beans>

3.2.2 消費者

<?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>
	
	<!--  配置本地存根-->
	
	<!--聲明需要調用的遠程服務的接口；生成遠程服務代理  -->
	<!-- 
		1）、精確優先 (方法級優先，接口級次之，全局配置再次之)
		2）、消費者設置優先(如果級別一樣，則消費方優先，提供方次之)
	-->
	<!-- timeout="0" 默認是1000ms-->
	<!-- retries="":重試次數，不包含第一次調用，0代表不重試-->
	<!-- 冪等（設置重試次數）【查詢、刪除、修改】、非冪等（不能設置重試次數）【新增】 -->
	<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>
		
	<!-- 配置當前消費者的統一規則：所有的服務都不檢查 -->
	<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>

在進行SpringBoot整合Dubbo時，以上信息可以配置進application.properties文件裡；詳情請見《4.8 SpringBoot與Dubbo整合的三種方式》

3.3 使用註解開啟功能

註解 位置 功能
@EnableDubbo 開啟dubbo相關功能 主啟動類
@Service 暴露服務 服務提供者provider
@Reference 遠程調用 服務消費者consumer

4. 配置文件

Dubbo 的 XML Schema 配置參考手冊

dubbo:consumer 配置

4.1 配置文件的優先級

  • JVM 啟動 -D 參數優先；
  • XML 次之；
  • Properties 最後，相當於缺省值；

4.2 不同粒度配置的覆蓋關系

  • 越上面優先級越高；
  • 精確優先 (方法級優先，接口級次之，全局配置再次之)；
  • 消費者設置優先(如果級別一樣，則消費方優先，提供方次之)；

4.3 關閉啟動檢查check

提供者有三種關閉啟動檢查註冊中心的配置：

  • Spring配置文件
<!-- 關閉某個服務的啟動時檢查 (沒有提供者時報錯) -->
<dubbo:reference interface="com.foo.BarService" check="false" />
	
<!-- 關閉所有服務的啟動時檢查 (沒有提供者時報錯) -->
<dubbo:consumer check="false" />

<!-- 關閉註冊中心啟動時檢查 (註冊訂閱失敗時報錯) -->
<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 參數
java -Ddubbo.reference.com.foo.BarService.check=false
java -Ddubbo.reference.check=false
java -Ddubbo.consumer.check=false 
java -Ddubbo.registry.check=false

消費者有一種關閉啟動檢查服務提供者的配置：

<dubbo:reference check="false"/>

4.4 超時timeout

提供者：

<!-- 配置超時時間 -->
<dubbo:service interface="com.atguigu.gmall.service.UserService" 
	ref="userServiceImpl01" timeout="1000"">
	<dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
</dubbo:service>

消費者：

<!-- 配置超時時間 -->
<dubbo:reference interface="com.foo.BarService" 
	id="BarService" timeout="5000">
</dubbo:reference>

<!-- 還可以給具體方法配置超時時間(假設BarService裡有testMethod方法) -->
<dubbo:reference interface="com.foo.BarService" 
	id="BarService" timeout="5000">
	<dubbo:method name="testMethod" timeout="2000"></dubbo:method>
</dubbo:reference>

可以體現：

  • 精確優先 (方法級優先，接口級次之，全局配置再次之)；
  • 消費者設置優先(如果級別一樣，則消費方優先，提供方次之)；

4.5 重試次數retries

消費者：

<!-- retries="":重試次數，不包含第一次調用，0代表不重試-->
<!-- 冪等（設置重試次數）【查詢、刪除、修改】、非冪等（不能設置重試次數）【新增】 -->
<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>
<!-- 服務的實現 -->
<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>

消費者：

<!-- version指定用哪個版本，*表示隨機版本-->
<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遠程的代理對象
	 * @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;
	}
}

消費者：

<!--  配置本地存根-->
<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.導入dubbo-starter；在application.properties配置屬性；使用@Service暴露服務；使用@Reference引用服務；
  • 2.保留dubbo xml配置文件；導入dubbo-starter；使用@ImportResource導入dubbo的配置文件即可；

在主啟動類上@ImportResource(locations="classpath:provider.xml")；

  • 3.使用註解API的方式；將每一個組件手動創建到容器中，讓dubbo來掃描其他的組件；使用@Service暴露服務；

主啟動類上：@EnableDubbo(scanBasePackages="com.atguigu.gmall")；

在config包下進行如下配置：

@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");
		
		//配置每一個method的信息
		MethodConfig methodConfig = new MethodConfig();
		methodConfig.setName("getUserAddressList");
		methodConfig.setTimeout(1000);
		
		//將method的設置關聯到service配置中
		List<MethodConfig> methods = new ArrayList<>();
		methods.add(methodConfig);
		serviceConfig.setMethods(methods);
		
		//ProviderConfig
		//MonitorConfig
		return serviceConfig;
	}

}

到此這篇關於快速學會Dubbo的環境及相關配置配置的文章就介紹到這瞭,更多相關Dubbo 環境與配置內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：