摘要：主要介紹各接口和注解的使用方法。創(chuàng)建請(qǐng)求命令命令就是我們之前所說(shuō)的，他用來(lái)封裝具體的依賴服務(wù)調(diào)用邏輯。通過(guò)調(diào)用和可以返回對(duì)象，如下前者返回的是一個(gè)，該命令會(huì)在調(diào)用的時(shí)候立即執(zhí)行，當(dāng)每次被訂閱的時(shí)候都會(huì)重放它的行為。表示使用執(zhí)行方式。

主要介紹Hystrix各接口和注解的使用方法。

Hystrix命令就是我們之前所說(shuō)的HystrixCommand，他用來(lái)封裝具體的依賴服務(wù)調(diào)用邏輯。

首先通過(guò)代碼實(shí)現(xiàn)HystrixCommand

package cn.sh.ribbon.command;

import cn.sh.common.entity.User;
import com.netflix.hystrix.HystrixCommand;
import org.springframework.web.client.RestTemplate;

/**
 * @author sh
 */
public class UserCommand extends HystrixCommand {

    private RestTemplate restTemplate;

    private Long id;

    public UserCommand(Setter setter, RestTemplate restTemplate, Long id) {
        super(setter);
        this.restTemplate = restTemplate;
        this.id = id;
    }
    
    @Override
    protected User run() throws Exception {
        return restTemplate.getForObject("http://USER-SERVICE/users/{1}", User.class, id);
    }

}

通過(guò)上面實(shí)現(xiàn)的UserCommand，我們即可以實(shí)現(xiàn)請(qǐng)求的同步執(zhí)行也可以實(shí)現(xiàn)異步執(zhí)行，相關(guān)代碼如下：

package cn.sh.ribbon.service;

import cn.sh.common.entity.User;
import cn.sh.ribbon.command.UserCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

/**
 * @author sh
 */
@Service
public class HelloService {

    private static final Logger logger = LoggerFactory.getLogger(HelloService.class);

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 第一種使用命令的方式
     * @param id
     * @return
     */
    public User getUserById(Long id) {
        HystrixCommandGroupKey groupKey = HystrixCommandGroupKey.Factory.asKey("userKey");
        com.netflix.hystrix.HystrixCommand.Setter setter = com.netflix.hystrix.HystrixCommand.Setter.withGroupKey(groupKey);
        UserCommand userCommand = new UserCommand(setter, restTemplate, id);
        // 同步執(zhí)行獲取結(jié)果
//        return userCommand.execute();
        // 異步執(zhí)行獲取結(jié)果
        Future future = userCommand.queue();
        try {
            return future.get();
        } catch (Exception e) {
            logger.info("獲取結(jié)果發(fā)生異常", e);
        }
        return null;
    }

}

通過(guò)HystrixCommand注解可以更優(yōu)雅的實(shí)現(xiàn)Hystrix命令的定義，如下：

package cn.sh.ribbon.service;

import cn.sh.common.entity.User;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

/**
 * @author sh
 */
@Service
public class HelloService {

    private static final Logger logger = LoggerFactory.getLogger(HelloService.class);

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 通過(guò)注解方式獲取User
     * @param id
     * @return
     */
    @HystrixCommand
    public User findUserById(Long id) {
        return restTemplate.getForObject("http://USER-SERVICE/users/{1}", User.class, id);
    }
}

上述代碼雖然可以優(yōu)雅的實(shí)現(xiàn)Hystrix命令，但是上述獲取User的方式只是同步執(zhí)行的實(shí)現(xiàn)，如果需要實(shí)現(xiàn)異步執(zhí)行則需要進(jìn)行如下改造:

package cn.sh.ribbon.service;

import cn.sh.common.entity.User;
import cn.sh.ribbon.command.UserCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.command.AsyncResult;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import rx.Observable;
import rx.Subscription;
import rx.functions.Action1;

import java.util.concurrent.Future;

/**
 * @author sh
 */
@Service
public class HelloService {

    private static final Logger logger = LoggerFactory.getLogger(HelloService.class);

    @Autowired
    private RestTemplate restTemplate;
    
    /**
     * 通過(guò)注解方式異步執(zhí)行獲取User
     * @param id
     * @return
     */
    @HystrixCommand
    public Future asyncFindUserFutureById(Long id) {
        return new AsyncResult() {
            @Override
            public User invoke() {
                return restTemplate.getForObject("http://USER-SERVICE/users/{1}", User.class, id);
            }
        };
    }
}

除了傳統(tǒng)的同步執(zhí)行與異步執(zhí)行之外，我們還可以將HystrixCommand通過(guò)Observable來(lái)實(shí)現(xiàn)響應(yīng)式執(zhí)行方式。通過(guò)調(diào)用observe()和toObservable()可以返回Observable對(duì)象， 如下:

Observable observe = userCommand.observe();
Observable observe = userCommand.toObservable();

前者返回的是一個(gè)Hot Observable，該命令會(huì)在observe調(diào)用的時(shí)候立即執(zhí)行，當(dāng)Observable每次被訂閱的時(shí)候都會(huì)重放它的行為。

后者返回的是一個(gè)Cold Observable，toObservable()執(zhí)行之后，命令不會(huì)被立即執(zhí)行，只有當(dāng)所有訂閱者都訂閱他之后才會(huì)執(zhí)行。

HystrixCommand具備了observe()和toObservable()的功能，但是它的實(shí)現(xiàn)有一定的局限性，它返回的Observable只能發(fā)射一次數(shù)據(jù)，所以Hystrix提供了另外的一個(gè)特殊命令封裝HysrtixObservableCommand，通過(guò)命令可以發(fā)射多次的Observable

相關(guān)代碼如下:

package cn.sh.ribbon.command;

import cn.sh.common.entity.User;
import com.netflix.hystrix.HystrixObservableCommand;
import org.springframework.web.client.RestTemplate;
import rx.Observable;

/**
 * @author sh
 */
public class UserObservableCommand extends HystrixObservableCommand {

    private RestTemplate restTemplate;

    private Long id;

    public UserObservableCommand (Setter setter, RestTemplate restTemplate, Long id) {
        super(setter);
        this.restTemplate = restTemplate;
        this.id = id;
    }

    @Override
    protected Observable construct() {
        return Observable.create(subscriber -> {
            if (!subscriber.isUnsubscribed()) {
                User user = restTemplate.getForObject("http://USER-SERVICE/users/{1}", User.class, id);
                subscriber.onNext(user);
                subscriber.onCompleted();
            }
        });
    }
}

相關(guān)代碼如下：

package cn.sh.ribbon.service;

import cn.sh.common.entity.User;
import cn.sh.ribbon.command.UserCommand;
import cn.sh.ribbon.command.UserObservableCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.command.AsyncResult;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import rx.Observable;
import rx.Observer;
import rx.Subscriber;
import rx.Subscription;

/**
 * @author sh
 */
@Service
public class HelloService {

    private static final Logger logger = LoggerFactory.getLogger(HelloService.class);

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 使用注解實(shí)現(xiàn)響應(yīng)式命令
     * @param id
     * @return
     */
    @HystrixCommand
    public Observable observableGetUserId(Long id) {
        return Observable.create(subscriber -> {
            if (!subscriber.isUnsubscribed()) {
                User user = restTemplate.getForObject("http://USER-SERVICE/users/{1}", User.class, id);
                subscriber.onNext(user);
                subscriber.onCompleted();
            }
        });
    }

}

使用@HystrixCommand注解實(shí)現(xiàn)響應(yīng)式命令，可以通過(guò)observableExecutionMode參數(shù)來(lái)控制是使用observe()還是toObservable()的執(zhí)行方式。該參數(shù)有下面兩種設(shè)置方式：

@HystrixCommand(observableExecutionMode = ObservableExecutionMode.EAGER): EAGER是該參數(shù)的模式值，表示使用observe()執(zhí)行方式。

@HystrixCommand(observableExecutionMode = ObservableExecutionMode.LAZY): 表示使用toObservable()執(zhí)行方式。

spring-cloud-example