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

Failover Cluster

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

重试次数配置如下：

<dubbo:service retries="2" />

或

<dubbo:reference retries="2" />

或

   

<dubbo:reference>
     <dubbo:method name="findFoo" retries="2" />
</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里加入依赖：

 <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
       <version>1.4.4.RELEASE</version>
 </dependency>

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

    @SpringBootApplication
    @EnableHystrix
    public class ProviderApplication {

 

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

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

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

        @Override
        @HystrixCommand
        public List<User> getALlUsers(){
            System.out.println("getALlUsers in...");
 
            if(Math.random() > 0.5) {
                throw new RuntimeException("查询所有用户接口调用失败！");
            }
            List<User> users = userMapper.getAllUsers();
            return users;
        }

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

启动服务提供者！

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

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

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

 @Controller
    public class UserController {
     
        private final static Logger logger = LogManager.getLogger(UserController.class);
        //自动注入远程服务
        @Reference(loadbalance="random",timeout=1000)
        private UserService<User> userService;
     
        @HystrixCommand(fallbackMethod = "hello")
        @RequestMapping(value = "/getAllUsers", method = RequestMethod.GET)
        public @ResponseBody Object getAllUsers() throws Exception {
            logger.debug("test in............");
            JsonDTo jsonDto = new JsonDTo();
            List<User> users = userService.getALlUsers();
            jsonDto.setData(users);
            return jsonDto;
        }
        /**
         * getAllUsers出错时会进入此方法
         * @return
         * @throws Exception
         */
        public @ResponseBody Object hello() throws Exception {
            logger.debug("test in............");
            JsonDTo jsonDto = new JsonDTo();
            List<User> users = new ArrayList<>();
            User user = new User();
            user.setName("jeffSheng");
            user.setAge(28);
            user.setRemark("码农");
            user.setSex(1);
            users.add(user);
            jsonDto.setData(users);
            return jsonDto;
        }      
     
    }

     
   

启动消费者！

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

 


————————————————
版权声明：本文为CSDN博主「Jeff.Sheng」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/shengqianfeng/article/details/82354400