整合hystrix

Dubbo提供了，集群容錯機制
可以通過配置，進行使用

在實際開發中
一般，都是通過整合hystrix，進行集群容錯

Hystrix

是Spring cloud中，默認整合的服務容錯解決方案
通過，控制那些訪問遠程系統、服務和第三方庫的節點
從而，對延遲和故障提供更強大的容錯能力

Hystrix
具備擁有回退機制和斷路器功能的線程和信號隔離
請求緩存和請求打包，以及監控和配置等功能

使用方式

服務提供者、消費者
導入Hystrix場景啟動器
配置spring-cloud-starter-netflix-hystrix

spring boot官方提供了對hystrix的集成
可以直接在pom.xml里加入依賴

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

啟用Hystrix

通過注解，啟動Hystrix功能

在Application類上增加@EnableHystrix
啟用hystrix starter

@EnableHystrix //開啟服務容錯 @SpringBootApplication public class BootUserServiceProviderApplication {public static void main(String[] args) {

服務提供者

在Dubbo的Provider上，增加@HystrixCommand配置
這樣，調用就會經過Hystrix代理

在方法上，通過@HystrixCommand注解
開啟Hystrix異常

@Service//暴露服務 @Component public class UserServiceImpl implements UserService {@HystrixCommand@Overridepublic List<UserAddress> getUserAddressList(String userId) {

服務消費者

在Dubbo的Provider上，增加@HystrixCommand配置
這樣，調用就會經過Hystrix代理

在方法上，通過@HystrixCommand注解
開啟Hystrix異常

通過fallbackMethod屬性
配置發生異常，執行的方法

@Service public class OrderServiceImpl implements OrderService {//@Autowired@Reference(loadbalance="roundrobin") UserService userService;@HystrixCommand(fallbackMethod="hello")@Overridepublic List<UserAddress> initOrder(String userId) {// TODO Auto-generated method stubSystem.out.println("用戶id："+userId);//1、查詢用戶的收貨地址List<UserAddress> addressList = userService.getUserAddressList(userId);return addressList;}public List<UserAddress> hello(String userId) {// TODO Auto-generated method stubreturn Arrays.asList(new UserAddress(10, "測試地址", "1", "測試", "測試", "Y"));}}

總結

以上是生活随笔為你收集整理的Dubbo整合hystrix的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。