Obtenir l'exception d'échec dans la méthode de remplacement @HystrixCommand

Est-il un moyen d'obtenir la raison pour laquelle un HystrixCommand a échoué lors de l'utilisation de la @HystrixCommand annotation à l'intérieur d'un Printemps de Démarrage de l'application? C'est comme si vous implémentez votre propre HystrixCommandvous avez accès à la getFailedExecutionException mais comment pouvez-vous accéder à ce lors de l'utilisation de l'annotation? Je voudrais être capable de faire des choses différentes dans le secours de la méthode basée sur le type d'exception s'est produite. Est-ce possible?

J'ai vu un note sur HystrixRequestContext.initializeContext() mais la HystrixRequestContext ne vous donne pas accès à rien, est-il une autre façon d'utiliser ce contexte pour obtenir l'accès aux exceptions?

source d'informationauteur Andrew Serff

  1. 32

    Il suffit d'ajouter un Throwable paramètre de secours de la méthode et il recevra l'exception de la commande d'origine produit.

    De https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-javanica

        @HystrixCommand(fallbackMethod = "fallback1")
    User getUserById(String id) {
        throw new RuntimeException("getUserById command failed");
    }

    @HystrixCommand(fallbackMethod = "fallback2")
    User fallback1(String id, Throwable e) {
        assert "getUserById command failed".equals(e.getMessage());
        throw new RuntimeException("fallback1 failed");
    }
  2. 9

    Je n'ai pas trouvé un moyen d'obtenir de l'exception avec des Annotations, mais la création de mon propre Commande a fonctionné pour moi:

    public static class DemoCommand extends HystrixCommand<String> {

    protected DemoCommand() {
        super(HystrixCommandGroupKey.Factory.asKey("Demo"));
    }

    @Override
    protected String run() throws Exception {
        throw new RuntimeException("failed!");
    }

    @Override
    protected String getFallback() {
        System.out.println("Events (so far) in Fallback: " + getExecutionEvents());
        return getFailedExecutionException().getMessage();
    }

}

    J'espère que cela aide quelqu'un d'autre.

  3. 2

    Je ne pouvais pas trouver un moyen d'obtenir de l'exception avec les annotations, mais j'ai trouvé HystrixPlugins , avec qui vous pouvez enregistrer un HystrixCommandExecutionHook et vous pouvez obtenir le exacte exception comme ceci : 

    HystrixPlugins.getInstance().registerCommandExecutionHook(new HystrixCommandExecutionHook() {
            @Override
            public <T> void onFallbackStart(final HystrixInvokable<T> commandInstance) {

            }
        });

    L'instance de commande est un GenericCommand.

  4. 1

    La plupart du temps à l'aide de getFailedExecutionException().getMessage() m'a donné les valeurs null. 

       Exception errorFromThrowable = getExceptionFromThrowable(getExecutionException());
   String errMessage = (errorFromThrowable != null) ? errorFromThrowable.getMessage()

    cela me donne de meilleurs résultats tout le temps.

  5. 0

    Comme dit dans la documentation Hystrix-documentation getFallback() méthode sera levée lors de l':

    1. Chaque fois qu'une exécution de la commande échoue: lorsqu'une exception est levée par construct() ou run()
    2. Lorsque la commande est en court-circuit car le circuit est ouvert
    3. Lorsque la commande du pool de threads et de la file d'attente ou sémaphore à capacité
    4. Lorsque la commande a dépassé sa durée du délai d'attente.

    De sorte que vous pouvez facilement obtenir ce soulevées secours méthode appelée par l'affectation de l'exécution d'exception pour un Throwable objet.

    En supposant que votre HystrixCommand retourne une Chaîne de caractères

    public class ExampleTask extends HystrixCommand<String> {
   //Your class body
}

    procédez comme suit:

    @Override
    protected ErrorCodes getFallback() {
        Throwable t = getExecutionException();
        if (circuitBreaker.isOpen()) {
            //Log or something
        } else if (t instanceof RejectedExecutionException) {
            //Log and get the threadpool name, could be useful
        } else {
            //Maybe something else happened
        }
        return "A default String"; //Avoid using any HTTP request or ypu will need to wrap it also in HystrixCommand
    }

    Plus d'infos ici