Dubbo服務容錯（整合hystrix）

簡介：Hystrix旨在通過控制那些訪問遠程系統、服務和第三方庫的節點從而對延遲和故障提供更強大的容錯能力，Hystrix具備擁有回退機制和斷路器功能的線程和信號隔離、請求緩存和請求打包以及監控和配置等功能。

1）、在pom文件中導入依賴（服務提供者和服務消費者都需要導入）

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

2）、在主程序啟動類上添加@EnableHystrix注解開啟服務容錯（服務提供者和服務消費者都需要添加）

package cn.coreqi;

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

@SpringBootApplication
@EnableDubbo
@EnableHystrix  //開啟服務容錯
public class SpringbootdubboserviceproviderApplication {

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

}

3）、在服務提供者實現類中方法上添加@HystrixCommand注解

package cn.coreqi.service.impl;

import cn.coreqi.entities.User;
import cn.coreqi.service.UserService;
import com.alibaba.dubbo.config.annotation.Service;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

@Component  //org.springframework.stereotype.Component
@Service    //com.alibaba.dubbo.config.annotation.Service
public class UserServiceImpl implements UserService {

    private static List<User> users = new ArrayList<>();

    static {
        users.add(new User(1,"fanqi","123456",1));
        users.add(new User(2,"zhangsan","123456",1));
        users.add(new User(3,"lisi","123456",1));
        users.add(new User(4,"wangwu","123456",1));
    }

    @HystrixCommand
    @Override
    public void addUser(User user) {
        users.add(user);
    }

    @HystrixCommand
    @Override
    public void delById(Integer id) {
        for (User s:users){
            if(s.getId() == id){
                users.remove(s);
                break;
            }
        }
    }

    @HystrixCommand
    @Override
    public void modifyUser(User user) {
        delById(user.getId());
        addUser(user);
    }

    @HystrixCommand
    @Override
    public User getById(Integer id) {
        for (User s:users){
            if(s.getId() == id){
                return s;
            }
        }
        return null;
    }

    @HystrixCommand
    @Override
    public List<User> getList() {
        return users;
    }
}

4）、在服務消費者調用服務提供者的方法上添加@HystrixCommand注解並指定fallbackMethod屬性，重寫fallbackMethod指定的方法。

package cn.coreqi.controller;

import cn.coreqi.entities.User;
import cn.coreqi.service.UserService;
import com.alibaba.dubbo.config.annotation.Reference;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.List;

@Controller
public class UserController {

    @Reference()
    private UserService userService;

    @HystrixCommand(fallbackMethod = "test1")
    @ResponseBody
    @RequestMapping("/users")
    public List<User> getUsers(){
        return userService.getList();
    }

    public List<User> test1(){
        return null;
    }
}