1.Dubbo和Spring Boot整合
- 提供者
依赖关系:
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
--------------------------------------------------------------------------------
服务:
@Service//基于dubbo的注解,将服务注册到zookeeper中
@Component
public class UserServiceImpl implements UserService {
@Override
public List<UserAddress> getUserAddressList(String userId) {
UserAddress address1 = new UserAddress(1, "北京", "1", "笨蛋", "123456", "Y");
UserAddress address2 = new UserAddress(2, "南京", "1", "钢蛋", "123457", "N");
return Arrays.asList(address1,address2);
}
}
------------------------------------------------------------------------
配置:
dubbo.application.name=user-service-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
-------------------------------------------------------------
启动:
@EnableDubbo//开启基于注解的dubbo
@SpringBootApplication
public class BootUserServiceProviderApplication {
public static void main(String[] args) {
SpringApplication.run(BootUserServiceProviderApplication.class, args);
}
}
- 消费者
依赖关系:
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
--------------------------------------------------------------------------------
消费:
@Service
public class OrderServiceImpl implements OrderService {
@Reference//去zookeeper中消费服务
UserService userService;
@Override
public List<UserAddress> initOrder(String userId) {
// TODO Auto-generated method stub
System.out.println("用户id:" + userId);
//1、查询用户的收货地址
List<UserAddress> addressList = userService.getUserAddressList(userId);
return addressList;
}
}
-------------------------------------------------------------------------
渲染:
@Controller
public class OrderController {
@Autowired
OrderService orderService;
@ResponseBody
@RequestMapping("/initOrder")
public List<UserAddress> initOrder(@RequestParam("uid") String userId){
return orderService.initOrder(userId);
}
}
-------------------------------------------------------------------------
配置:
dubbo.application.name=boot-order-service-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
-------------------------------------------------------------------------
启动:
@EnableDubbo
@SpringBootApplication
public class BootOrderServiceConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
}
}
需要注意的是,基于注解的dubbo标签,@Service和@Reference分别表示从zookeeper中暴露和消费服务。
2.dubbo覆盖关系
- 方法级优先,接口级次之,全局配置再次之。
-
如果级别一样,则消费方优先,提供方次之。
下图展示了配置覆盖关系的优先级,从上到下优先级依次降低:
3.dubbo常用设置
- 启动检查
Dubbo 缺省会在启动时检查依赖的服务是否可用,不可用时会抛出异常,阻止 Spring 初始化完成,以便上线时,能及早发现问题,默认 check="true"。
可以通过 check="false" 关闭检查,比如,测试时,有些服务不关心,或者出现了循环依赖,必须有一方先启动。
另外,如果你的 Spring 容器是懒加载的,或者通过 API 编程延迟引用服务,请关闭 check,否则服务临时不可用时,会抛出异常,拿到 null 引用,如果 check="false",总是会返回引用,当服务恢复时,能自动连上。
关闭所有服务的启动时检查 (没有提供者时报错):
<dubbo:consumer check="false" />
关闭某个服务的启动时检查 (没有提供者时报错):
<dubbo:reference interface="com.foo.BarService" check="false" />
关闭注册中心启动时检查 (注册订阅失败时报错):
<dubbo:registry check="false" />
- 超时属性
缺省使用<dubbo:consumer>的timeout,默认1000毫秒
- 重试次数
缺省使用<dubbo:consumer>的retries,需要考虑相同服务的多个服务器个数来决定重试次数
- 多版本
当一个接口实现,出现不兼容升级时,可以用版本号过渡,版本号不同的服务相互间不引用。
可以按照以下的步骤进行版本迁移:
- 1)在低压力时间段,先升级一半提供者为新版本
- 2)再将所有消费者升级为新版本
- 3)然后将剩下的一半提供者升级为新版本
老版本服务提供者配置:
<dubbo:service interface="com.foo.BarService" version="1.0.0" />
新版本服务提供者配置:
<dubbo:service interface="com.foo.BarService" version="2.0.0" />
老版本服务消费者配置:
<dubbo:reference id="barService" interface="com.foo.BarService" version="1.0.0" />
新版本服务消费者配置:
<dubbo:reference id="barService" interface="com.foo.BarService" version="2.0.0" />
如果不需要区分版本,可以按照以下的方式配置
<dubbo:reference id="barService" interface="com.foo.BarService" version="*" />
-
本地存根
远程服务后,客户端通常只剩下接口,而实现全在服务器端,但提供方有些时候想在客户端也执行部分逻辑,比如:做 ThreadLocal 缓存,提前验证参数,调用失败后伪造容错数据等等,此时就需要在 API 中带上 Stub,客户端生成 Proxy 实例,会把 Proxy 通过构造函数传给 Stub,然后把 Stub 暴露给用户,Stub 可以决定要不要去调 Proxy。
在 spring 配置文件中按以下方式配置:
<dubbo:service interface="com.foo.BarService" stub="true" />
或
<dubbo:service interface="com.foo.BarService" stub="com.foo.BarServiceStub" />
提供 Stub 的实现:
package com.foo;
public class BarServiceStub implements BarService {
private final BarService barService;
// 构造函数传入真正的远程代理对象
public BarServiceStub(BarService barService){
this.barService = barService;
}
public String sayHello(String name) {
// 此代码在客户端执行, 你可以在客户端做ThreadLocal本地缓存,或预先验证参数是否合法,等等
try {
return barService.sayHello(name);
} catch (Exception e) {
// 你可以容错,可以做任何AOP拦截事项
return "容错数据";
}
}
}
4.springboot整合dubbo属性
一共有三种方式
1)基于注解的springboot配置,导入dubbo-starter依赖,通过application.properties配置dubbo属性,通过@service和@reference来暴露和使用服务,通过EnableDubbo注解开启dubbo。
2)保留dubbo.xml配置文件,导入dubbo-starter依赖,通过@ImportResource导入配置文件
3)通过java代码编写dubbo配置类,springboot通过加载配置类实现dubbo的属性配置(感觉会很麻烦!)