Dubbo和SpringBoot

建议大家看看官方文档
springboot对应dubbo版本关系

springboot整合Dubbo

灰度发布：指的是新功能发布，部分用户尝试使用，一部分用户继续使用旧的功能，尝试稳定后，慢慢恢复！

服务提供者

pom.xml引入dubbo，由于我使用的是springboot2.1,所以 dubbo必须使用0.2.0

<dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.2.0</version>
</dependency>

代替原先的provider.xml,同样的配置写在application.yml中
之前我们对外暴露接口是xml配置，由于以后对外暴露接口太多，
为了方便我们使用@Service (import com.alibaba.dubbo.config.annotation.Service);

dubbo:
  application:
    name: boot-service-provider
  registry:
    address: zookeeper:127.0.0.1:2181
  protocol:
    name: dubbo
    port: 20880 # 通信规则
# 连接监控中心
  monitor:
    protocol: register

然后启动时，千万别忘了开启dubbo注解配置

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

@EnableDubbo // 开启注解的dubbo功能
@SpringBootApplication
public class BootServiceProvider {

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

}

服务消费者

pom.xml和服务提供者的相同
然后使用application.yml替代原先的consumer.xml配置
以前我们使用@Autowired,现在我们使用@Reference加载接口

dubbo:
  application:
    name: boot-service-consumer
  registry:
    address: 127.0.0.1
    protocol: zookeeper
  monitor:
    protocol: register

然后启动时，千万别忘了开启dubbo注解配置

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

@EnableDubbo
@SpringBootApplication
public class BootServiceConsumer {

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

然后运行成功！

Dubbo属性配置加载顺序

规则：（方法级优先，接口级次之，全局配置再次之，如果级别一样，消费方优先，提供方次之）
官网告诉我们有三种可以dubbo属性配置的方法，它们互补，优先级顺序为：

Dubbo启动时检查

很多时候，注册中心没有对应的服务的时候，消费者就已经启动了，往往会报错，原因:dubbo默认启动时检查
我们可以在yml关闭启动时检查()

1
2
3

dubbo:
  reference:
     check: false

关闭所有服务的不检查

1
2
3

dubbo:
  consumer:
    check: false

在启动的时候，如果没有注册中心，会报错，但是我们可以关闭

1
2
3

dubbo:
  registry:
    check: false

消费者全局配置(dubbo.provider)

1
2
3

dubbo:
  provider:
    timeout: 2000  # 单位秒

timeout retries

它们两个配合使用，timeout

dubbo:
  consumer:
    timeout: 1000 # 单位毫秒，默认是1000 访问大于1秒就会报错
    retries: 3 # 第一次尝试失败不算，总共尝试三次

dubbo多版本

就是我们上面提到的灰度发布,我们使用 version版本来控制版本

1
2
3

dubbo:
  provider:
    version: 0.0.2

我们在消费者使用时使用*的方式,会随机切换

本地存根

客户端一般只有接口，具体的实现都在服务器端，但是有时候我们想要做参数的提前校验，以及做缓存之类的
这个时候我们只需要在客户端创建类实现远程调用接口，然后里面必须有一个构造函数

import com.itcast.gmall.bean.UserAddress;
import com.itcast.gmall.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;
	}

	// 构造函数传入真正的远程代理对象

	public List<UserAddress> getUserAddressList(String userId) {
		//如果参数不为空就返回
		if(!StringUtils.isEmpty(userId)){
			List<UserAddress> userAddressList = userService.getUserAddressList(userId);
			return userAddressList;
		}
		return null;
	}
}

然后我们需要在消费者端使用stub来设置

1	<dubbo:reference interface="com.itcast.gmall.service.UserService" id="userService" stub="gmall.service.impl.UserServiceStub"></dubbo:reference>

只有当我们的stub验证通过后，才会执行服务器端的代码(在开发中，我们通常把存根放在接口工程中)