欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Dubbo集群容错方案

程序员文章站 2022-05-07 14:29:06
...

在集群调用失败时,Dubbo 提供了多种容错方案,缺省为 failover 重试。

Failover Cluster

失败自动切换,当出现失败,重试其它服务器。通常用于读操作,但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)

重试次数配置如下:

<dubbo:service retries="2" />

<dubbo:reference retries="2" />

 
  1. <dubbo:reference>

  2.  
  3.     <dubbo:method name="findFoo" retries="2" />

  4.  
  5. </dubbo:reference>

Failfast Cluster

快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。

 

Failsafe Cluster

失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。

 

Failback Cluster

失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。

 

Forking Cluster

并行调用多个服务器,只要一个成功即返回。通常用于实时性要求较高的读操作,但需要浪费更多服务资源。可通过 forks="2" 来设置最大并行数。

 

Broadcast Cluster

广播调用所有提供者,逐个调用,任意一台报错则报错 [2]。通常用于通知所有提供者更新缓存或日志等本地资源信息。

 

集群模式配置

按照以下示例在服务提供方和消费方配置集群模式

<dubbo:service cluster="failsafe" />

<dubbo:reference cluster="failsafe" />

 

整合hystrix

Hystrix 旨在通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix具备拥有回退机制和断路器功能的线程和信号隔离,请求缓存和请求打包,以及监控和配置等功能

spring boot官方提供了对hystrix的集成,直接在服务提供者和消费者的pom.xml里加入依赖:

 
  1. <dependency>

  2. <groupId>org.springframework.cloud</groupId>

  3. <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>

  4. <version>1.4.4.RELEASE</version>

  5. </dependency>

然后在Application类上增加@EnableHystrix来启用hystrix starter:

 
  1. @SpringBootApplication

  2. @EnableHystrix

  3. public class ProviderApplication {

配置Provider端

在Dubbo的Provider上增加@HystrixCommand配置,这样子调用就会经过Hystrix代理。

 
  1. @Service(version = "1.0.0")

  2. public class HelloServiceImpl implements HelloService {

  3. @HystrixCommand(commandProperties = {

  4. @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),

  5. @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000") })

  6. @Override

  7. public String sayHello(String name) {

  8. // System.out.println("async provider received: " + name);

  9. // return "annotation: hello, " + name;

  10. throw new RuntimeException("Exception to show hystrix enabled.");

  11. }

  12. }

 

配置Consumer端

对于Consumer端,则可以增加一层method调用,并在method上配置@HystrixCommand。当调用出错时,会走到fallbackMethod = "reliable"的调用里。

 
  1. @Reference(version = "1.0.0")

  2. private HelloService demoService;

  3.  
  4. @HystrixCommand(fallbackMethod = "reliable")

  5. public String doSayHello(String name) {

  6. return demoService.sayHello(name);

  7. }

  8. public String reliable(String name) {

  9. return "hystrix fallback value";

  10. }

测试:

1 按照上述方法服务提供者和消费者的pom中确保加入hystrix依赖包:

Dubbo集群容错方案

Dubbo集群容错方案

2 在服务提供者的Application入口类加上注解@EnableHystrix

3 在需要容错的服务方法上加上注解@HystrixCommand

 
  1. @Override

  2. public List<User> getALlUsers(){

  3. System.out.println("getALlUsers in...");

  4. // try {

  5. // Thread.sleep(3000);

  6. // } catch (InterruptedException e) {

  7. // e.printStackTrace();

  8. // }

  9. if(Math.random() > 0.5) {

  10. throw new RuntimeException("查询所有用户接口调用失败!");

  11. }

  12. List<User> users = userMapper.getAllUsers();

  13. return users;

  14. }

我们让当随机数大于0.5就抛出异常!

启动服务提供者!

4 在服务消费者Application入口类上也加上注解@EnableHystrix

5 在服务消费者的调用方法上加上注解@HystrixCommand(fallbackMethod = "hello")

然后定义hello方法,当失败的时候就会进入此方法进行容错处理!

 
  1.  
  2. @Controller

  3. public class UserController {

  4.  
  5.  
  6. private final static Logger logger = LogManager.getLogger(UserController.class);

  7. //自动注入远程服务

  8. @Reference(loadbalance="random",timeout=1000)

  9. private UserService<User> userService;

  10.  
  11. @HystrixCommand(fallbackMethod = "hello")

  12. @RequestMapping(value = "/getAllUsers", method = RequestMethod.GET)

  13. public @ResponseBody Object getAllUsers() throws Exception {

  14. logger.debug("test in............");

  15. JsonDTo jsonDto = new JsonDTo();

  16. List<User> users = userService.getALlUsers();

  17. jsonDto.setData(users);

  18. return jsonDto;

  19. }

  20. /**

  21. * getAllUsers出错时会进入此方法

  22. * @return

  23. * @throws Exception

  24. */

  25. public @ResponseBody Object hello() throws Exception {

  26. logger.debug("test in............");

  27. JsonDTo jsonDto = new JsonDTo();

  28. List<User> users = new ArrayList<>();

  29. User user = new User();

  30. user.setName("jeffSheng");

  31. user.setAge(28);

  32. user.setRemark("码农");

  33. user.setSex(1);

  34. users.add(user);

  35. jsonDto.setData(users);

  36. return jsonDto;

  37. }

  38.  
  39.  
  40.  
  41. }

启动消费者!

调用接口:http://localhost:7777/getAllUsers,可以看到会返回两种结果,其中一种就是Hystrix容错的结果:

Dubbo集群容错方案

Dubbo集群容错方案

 

相关标签: dubbo