七、Dubbo配置

Dubbo目录

七、Dubbo配置

1、配置原则2、启动时检查3、超时时间 与重试次数4、XML 配置覆盖关系5、多版本6、本地存根7、配置 与SpringBoot整合的三种方式8、详细代码

所有的配置在官方文档都有介绍

dubbo配置官网参考 ：Schema 配置参考手册 | Apache Dubbo 、用法示例 | Apache Dubbo

在于SpringBoot整合的配置文件 application.properties 中的配置，和这些标签是一一对应的，所有标签均可在配置文件中进行配置。

Duboo 对这些配置，让其生效，有三种策略：

JVM 启动 -D 参数优先，这样可以使用户在部署和启动时进行参数重写，比如在启动时需改变协议的端口。

XML 次之，如果在 XML 中有配置，则 dubbo.properties 中的相应配置项无效。

Properties 最后，相当于缺省值，只有 XML 没有配置时，dubbo.properties 的相应配置项才会生效，通常用于共享公共配置，比如应用名。

启动时检查 | Apache Dubbo

在启动时检查依赖的服务是否可用

Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题，默认 check="true"。

可以通过 check="false" 关闭检查，比如，测试时，有些服务不关心，或者出现了循环依赖，必须有一方先启动。

另外，如果你的 Spring 容器是懒加载的，或者通过 API 编程延迟引用服务，请关闭 check，否则服务临时不可用时，会抛出异常，拿到 null 引用，如果 check="false"，总是会返回引用，当服务恢复时，能自动连上。

操作示例：

在consumer.xml中修改配置：

关闭某个服务的启动时检查 (没有提供者时报错)：

关闭所有服务的启动时检查 (没有提供者时报错)：

关闭注册中心启动时检查 (注册订阅失败时报错)：

超时时间的配置：由于网络或服务端不可靠，会导致调用出现一种不确定的中间状态（超时）。为了避免超时导致客户端资源（线程）挂起耗尽，必须设置超时时间。

重试次数的配置：失败自动切换，当出现失败，重试其它服务器（如果有的话），但重试会带来更长延迟。可通过 retries=“2” 来设置重试次数(不含第一次)。

XML 配置 | Apache Dubbo

以 timeout 为例，下图显示了配置的查找顺序，其它 retries, loadbalance, actives 等类似：

方法级优先，接口级次之，全局配置再次之。如果级别一样，则消费方优先，提供方次之。

其中，服务提供方配置，通过 URL 经由注册中心传递给消费方。

dubbo推荐在Provider上尽量多配置Consumer端属性：

1、作服务的提供者，比服务使用方更清楚服务性能参数，如调用的超时时间，合理的重试次数，等等

2、在Provider配置后，Consumer不配置则会使用Provider的配置值，即Provider配置可以作为Consumer的缺省值。否则，Consumer会使用Consumer端的全局设置，这对于Provider不可控的，并且往往是不合理的

多版本 | Apache Dubbo

在 Dubbo 中为同一个服务配置多个版本

当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。

可以按照以下的步骤进行版本迁移：

在低压力时间段，先升级一半提供者为新版本再将所有消费者升级为新版本然后将剩下的一半提供者升级为新版本

provider.xml：

consumer.xml：指定哪个版本的服务，这样在启动时，就会调用对应的方法

如果不需要区分版本，可以按照以下的方式配置 ：version="*"，它会随机选择版本服务。提示：2.2.0 以上版本支持

本地存根 | Apache Dubbo

远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑，比如：做 ThreadLocal 缓存，提前验证参数，调用失败后伪造容错数据等等，此时就需要在 API 中带上 Stub，客户端生成 Proxy 实例，会把 Proxy 通过构造函数传给 Stub 1，然后把 Stub 暴露给用户，Stub 可以决定要不要去调 Proxy。

我们这是在消费者中配置：（在生产中应该在公共接口层对接口进行配置）

增加UserServiceStub：

package com.wlw.dubbo.service.impl;

import com.wlw.dubbo.bean.UserAddress;
import com.wlw.dubbo.service.UserService;
import org.springframework.util.StringUtils;

import java.util.List;


public class UserServiceStub implements UserService {

    private final UserService userService;

    
    public UserServiceStub(UserService userService) {
        this.userService = userService;
    }

    @Override
    public List getUserAddressList(String userId) {
        System.out.println("UserServiceStub..............");
        if(!StringUtils.isEmpty(userId)) {
            return userService.getUserAddressList(userId);
        }
        return null;
    }
}

consumer.xml：增加配置：

测试结果：

第一种（也就是六、Dubbo与SpringBoot整合）使用的方式：

导入依赖配置文件 application.properties 中增加配置提供者：暴漏服务，通过注解(com.alibaba.dubbo.config.annotation.Service) 来实现；消费者：远程引用指定的服务，注解：com.alibaba.dubbo.config.annotation.Reference;启动类开启Dubbo，注解：@EnableDubbo

第二种（保留Dubbo 相关的xml配置文件，这样就可以做到方法级别的配置，上面第一种是不行的）：

导入依赖

保留Dubbo 相关的xml配置文件

在启动类使用注解@importResource导入Dubbo的xml配置文件：

@importResource(locations="classpath:provider.xml")

这种情况下，就不需要注解(com.alibaba.dubbo.config.annotation.Service) 来暴漏服务了

第三种，使用 注解API的方式，可以实现方法级配置：

将每一个组件手动配置到容器中，让dubbo来扫描其他的组件

这种情况是需要注解(com.alibaba.dubbo.config.annotation.Service) 来暴漏服务了

在启动类中添加注解：@EnableDubbo(scanbasePackages = “com.wlw.dubbo”)

配置类

package com.wlw.dubbo.config;

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

import com.wlw.dubbo.service.UserService;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.MethodConfig;
import com.alibaba.dubbo.config.MonitorConfig;
import com.alibaba.dubbo.config.ProtocolConfig;
import com.alibaba.dubbo.config.ProviderConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.ServiceConfig;


@Configuration
public class MyDubboConfig {

	//
	@Bean
	public ApplicationConfig applicationConfig() {
		ApplicationConfig applicationConfig = new ApplicationConfig();
		applicationConfig.setName("boot-user-service-provider");
		return applicationConfig;
	}
	
	//
	@Bean
	public RegistryConfig registryConfig() {
		RegistryConfig registryConfig = new RegistryConfig();
		registryConfig.setProtocol("zookeeper");
		registryConfig.setAddress("127.0.0.1:2181");
		return registryConfig;
	}
	
	//
	@Bean
	public ProtocolConfig protocolConfig() {
		ProtocolConfig protocolConfig = new ProtocolConfig();
		protocolConfig.setName("dubbo");
		protocolConfig.setPort(20880);
		return protocolConfig;
	}
	
	
	@Bean
	public ServiceConfig userServiceConfig(UserService userService){
		ServiceConfig 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 methods = new ArrayList<>();
		methods.add(methodConfig);
		serviceConfig.setMethods(methods);

		return serviceConfig;
	}

	//ProviderConfig
	//MonitorConfig
}

启动类：

package com.wlw.dubbo;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.importResource;

//@EnableDubbo
//@importResource(locations = "classpath:provider.xml")
@EnableDubbo(scanbasePackages = "com.wlw.dubbo")
@SpringBootApplication
public class BootUserServiceProviderApplication {

	public static void main(String[] args) {
		SpringApplication.run(BootUserServiceProviderApplication.class, args);
	}
}

详细代码：具体的配置操作，都是提交记录：wlw/dubboDemo (gitee.com)