With no more updates from Hystrix, the Alibaba tech team proposes Sentinel as an alternative. This is part of the Sentinel Open Source series. As microservices become more popular, the stability between services becomes more and more important. Technologies such as flow control, fault tolerance, and system load protection are widely used in microservice systems to improve the robustness of the system and guarantee the stability of the business, and to minimize system outages caused by excessive access traffic and heavy system load. Hystrix, an open source latency and fault tolerance library of Netflix, has recently announced on its GitHub homepage that new features are no longer under development. It is recommended that developers use other open source projects that are still active.So what are the alternaives? Last time we introduced Resilience4j and Sentinel: Two Open-Source Alternatives to Netflix Hystrix This article will help you migrate from Hystrix to Sentinel and help you get up to speed on using Sentinel. HystrixCommand The execution model of Hystrix is designed with command pattern that encapsulates the business logic and fallback logic into a single command object ( / ). A simple example: HystrixCommand HystrixObservableCommand public class SomeCommand extends HystrixCommand<String> { public SomeCommand() {  
    super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("SomeGroup"))  
        // command key  
        .andCommandKey(HystrixCommandKey.Factory.asKey("SomeCommand"))  
        // command configuration  
        .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()  
            .withFallbackEnabled(true)  
        ));  
}

@Override  
protected String run() {  
    // business logic  
    return "Hello World!";  
} } // The execution model of Hystrix// sync mode:String s = new SomeCommand().execute();// async mode (managed by Hystrix):Observable<String> s = new SomeCommand().observe(); Sentinel does not specify an execution model, nor does it care how the code is executed. In Sentinel, what you should do is just to wrap your code with Sentinel API to define resources: Entry entry = null;try {entry = SphU.entry("resourceName");// your business logic herereturn doSomeThing();} catch (BlockException ex) {// handle rejected} finally {if (entry != null) {entry.exit();}} In Hystrix, you usually have to configure rules when the command is defined. In Sentinel, resource definitions and rule configurations are separate. Users first define resources for the corresponding business logic through the Sentinel API, and then configure the rules when needed. For details, please refer to . the document Thread Pool Isolation The advantage of thread pool isolation is that the isolation is relatively thorough, and it can be processed for the thread pool of a resource without affecting other resources. But the drawback is that the number of threads is large, and the overhead of thread context switching is very large, especially for low latency invocations. Sentinel does not provide such a heavy isolation strategy, but provides a relatively lightweight isolation strategy — thread count flow control as semaphore isolation. Semaphore Isolation Hystrix’s semaphore isolation is configured at Command definition, such as： public class CommandUsingSemaphoreIsolation extends HystrixCommand<String> { private final int id;

public CommandUsingSemaphoreIsolation(int id) {  
    super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("SomeGroup"))  
        .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()  
            .withExecutionIsolationStrategy(ExecutionIsolationStrategy.SEMAPHORE)  
            .withExecutionIsolationSemaphoreMaxConcurrentRequests(8)));  
    this.id = id;  
}

@Override  
protected String run() {  
    return "result\_" + id;  
} } In Sentinel, semaphore isolation is provided as a mode of flow control (thread count mode), so you only need to configure the flow rule for the resource: FlowRule rule = new FlowRule("doSomething") // resource name.setGrade(RuleConstant.FLOW_GRADE_THREAD) // thread count mode.setCount(8); // max concurrencyFlowRuleManager.loadRules(Collections.singletonList(rule)); // load the rules If you are using Sentinel dashboard, you can also easily configure the rules in dashboard. Circuit Breaking Hystrix circuit breaker supports error percentage mode. Related properties: : the threshold circuitBreaker.errorThresholdPercentage : the sleep window when circuit breaker is open circuitBreaker.sleepWindowInMilliseconds For example: public class FooServiceCommand extends HystrixCommand<String> { protected FooServiceCommand(HystrixCommandGroupKey group) {  
    super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("OtherGroup"))  
        // command key  
        .andCommandKey(HystrixCommandKey.Factory.asKey("fooService"))  
        .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()  
            .withExecutionTimeoutInMilliseconds(500)  
            .withCircuitBreakerRequestVolumeThreshold(5)  
            .withCircuitBreakerErrorThresholdPercentage(50)  
            .withCircuitBreakerSleepWindowInMilliseconds(10000)  
        ));  
}

@Override  
protected String run() throws Exception {  
    return "some\_result";  
} } In Sentinel, you only need to configure circuit breaking rules for resources that want to be automatically degraded. For example, the rules corresponding to the Hystrix example above: DegradeRule rule = new DegradeRule("fooService").setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO) // exception ratio mode.setCount(0.5) // ratio threshold (0.5 -> 50%).setTimeWindow(10); // sleep window (10s)// load the rulesDegradeRuleManager.loadRules(Collections.singletonList(rule)); If you are using , you can also easily configure the circuit breaking rules in dashboard. Sentinel dashboard In addition to the exception ratio mode, Sentinel also supports automatic circuit breaking based on average response time and minute exceptions. Annotation Support Hystrix provides annotation support to encapsulate command and configure it. Here is an example of Hystrix annotation: // original method@HystrixCommand(fallbackMethod = "fallbackForGetUser")User getUserById(String id) {throw new RuntimeException("getUserById command failed");} // fallback methodUser fallbackForGetUser(String id) {return new User("admin");} Hystrix rule configuration is bundled with command execution. We can configure rules for command in the property of the , such as: commandProperties @HystrixCommand annotation @HystrixCommand(commandProperties = {@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50")})public User getUserById(String id) {return userResource.getUserById(id);} Using Sentinel annotations is similar to Hystrix, as follows: Add the annotation support dependency: and register the aspect as a Spring bean (if you are using then the bean will be injected automatically); sentinel-annotation-aspectj Spring Cloud Alibaba Add the annotation to the method that needs flow control and circuit breaking. You can set or functions in the annotation; @SentinelResource fallback blockHandler Configure rules For the details, you can refer to . An example for Sentinel annotation: the annotation support document // original method@SentinelResource(fallback = "fallbackForGetUser")User getUserById(String id) {throw new RuntimeException("getUserById command failed");} // fallback method (only invoked when the original resource triggers circuit breaking); If we need to handle for flow control / system protection, we can set `blockHandler` methodUser fallbackForGetUser(String id) {return new User("admin");} Then configure the rules: via API (e.g. method) DegradeRuleManager.loadRules(rules) DegradeRule rule = new DegradeRule("getUserById").setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO) // exception ratio mode.setCount(0.5) // ratio threshold (0.5 -> 50%).setTimeWindow(10); // sleep window (10s)// load the rulesDegradeRuleManager.loadRules(Collections.singletonList(rule)); via Sentinel dashboard Integrations Sentinel has integration modules with Web Servlet, Dubbo, Spring Cloud and gRPC. Users can quickly use Sentinel by introducing adapter dependencies and do simple configuration. If you have been using Spring Cloud Netflix before, you may consider migrating to the . Spring Cloud Alibaba Dynamic Configuration Sentinel provides dynamic rule data-source support for dynamic rule management. The and interfaces provided by Sentinel are easy to use. ReadableDataSource WritableDataSource The Sentinel dynamic rule data-source provides extension module to integrate with popular configuration centers and remote storage. Currently, it supports many dynamic rule sources such as Nacos, ZooKeeper, Apollo, and Redis, which can cover many production scenarios. (Original article by Zhao Yihao赵奕豪) Alibaba Tech First hand and in-depth information about Alibaba’s latest technology → Facebook: . Twitter: . “Alibaba Tech” “AlibabaTech”

Flow

Apache

Facebook

Netflix

Super

Twitter

DevOps Makes Inefficient Development for Search a Thing of the Past

Writing Sky-high Applications: A Guide to Cloud Native Development

Follow us on Facebook!

Read My Stories

Too Long; Didn't Read

Flow Control for Your Microservices: Migration from Hystrix to Sentinel

Flow Control for Your Microservices: Migration from Hystrix to Sentinel

About Author

Comments

TOPICS

THIS ARTICLE WAS FEATURED IN

Related Stories

A Brief History of Flink: Tracing the Big Data Engine’s Open-source Development

Java bits: 0xFF and 0xFFL

10 Things You Didn't Know You Could Do With Google Keep

10 Things to check on Android code reviews

10 Mistakes In Mobile App Development That Make You Look Dumb

10 good rules for bad App

A Brief History of Flink: Tracing the Big Data Engine’s Open-source Development

Java bits: 0xFF and 0xFFL

10 Things You Didn't Know You Could Do With Google Keep

10 Things to check on Android code reviews

10 Mistakes In Mobile App Development That Make You Look Dumb

10 good rules for bad App

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps