Hystrix命令入門使用

Maxiye 發(fā)布于2019-08-19 11:05 / 2667人閱讀

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

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

創(chuàng)建請求命令

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

繼承方式實現(xiàn)HystrixCommand

首先通過代碼實現(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);
    }

}

通過上面實現(xiàn)的UserCommand，我們即可以實現(xiàn)請求的同步執(zhí)行也可以實現(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;
    }

}

注解方式使用HystrixCommand

通過HystrixCommand注解可以更優(yōu)雅的實現(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;

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

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

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;
    
    /**
     * 通過注解方式異步執(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);
            }
        };
    }
}

響應(yīng)執(zhí)行

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

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

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

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

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

響應(yīng)執(zhí)行自定義命令

相關(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();
            }
        });
    }
}

響應(yīng)執(zhí)行使用注解@HystrixCommand

相關(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;

    /**
     * 使用注解實現(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注解實現(xiàn)響應(yīng)式命令，可以通過observableExecutionMode參數(shù)來控制是使用observe()還是toObservable()的執(zhí)行方式。該參數(shù)有下面兩種設(shè)置方式：

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

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

代碼地址

spring-cloud-example

GPU云服務(wù)器云服務(wù)器 Hystrix linux命令入門 linux入門命令 linux入門基礎(chǔ)命令

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/76981.html

發(fā)表評論

登陸后可評論

0條評論

Maxiye

男|高級講師

我要關(guān)注我要私信

TA的文章

C語言小游戲之掃雷

閱讀 2509·2021-11-15 11:38
DediPath：獨立服務(wù)器和Hybrid Server5折促銷，美國洛杉磯獨服 E3-1231v3

閱讀 1958·2021-11-05 09:37
BuyVM 流媒體專用VPS主機方案選擇及配置IP地址方法

閱讀 2280·2021-10-08 10:12
CSS瀏覽器兼容性的4個解決方案：瀏覽器CSS樣式初始化、瀏覽器私有屬性，CSS hack語法和自動

閱讀 2816·2019-08-30 15:55
Web設(shè)計流程優(yōu)化：網(wǎng)頁效果圖設(shè)計新思路

閱讀 2117·2019-08-30 15:52
短標(biāo)題自動兩端對齊

閱讀 1230·2019-08-29 13:24
移動端適配

閱讀 469·2019-08-26 18:27
#Javascript# 事件的傳播機制

閱讀 1480·2019-08-26 18:27

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Hystrix命令入門使用

相關(guān)文章

**Spring Cloud Hystrix入門和Hystrix命令原理分析**

Hystrix基礎(chǔ)入門和特性講解

兩年了，我寫了這些干貨！

Hystrix使用

發(fā)表評論

0條評論

Maxiye

男|高級講師

TA的文章

C語言小游戲之掃雷

DediPath：獨立服務(wù)器和Hybrid Server5折促銷，美國洛杉磯獨服 E3-1231v3

BuyVM 流媒體專用VPS主機方案選擇及配置IP地址方法

CSS瀏覽器兼容性的4個解決方案：瀏覽器CSS樣式初始化、瀏覽器私有屬性，CSS hack語法和自動

Web設(shè)計流程優(yōu)化：網(wǎng)頁效果圖設(shè)計新思路

短標(biāo)題自動兩端對齊

移動端適配

#Javascript# 事件的傳播機制

最新活動