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的属性配置（感觉会很麻烦！）
