侧边栏壁纸
博主头像
coydone博主等级

记录学习,分享生活的个人站点

  • 累计撰写 306 篇文章
  • 累计创建 51 个标签
  • 累计收到 0 条评论

目 录CONTENT

文章目录

Dubbo整合Hystrix

coydone
2022-06-03 / 0 评论 / 0 点赞 / 462 阅读 / 3,180 字 / 正在检测是否收录...
温馨提示:
本文最后更新于 2022-04-27,若内容或图片失效,请留言反馈。部分素材来自网络,若不小心影响到您的利益,请联系我们删除。

Hystrix概述

Hystrix:它是一个服务熔断,服务降级的非常好的解决方案。

服务降级当服务里面某一个方法出现柱塞。大量请求进来。会影响运行很快的方法。当服务器压力剧增的情况下,根据实际业务情况及流量,对一些服务和页面有策略的不处理或换种简单的方式处理,从而释放服务器资源以保证核心交易正常运作或高效运作。可以通过服务降级功能临时屏蔽某个出错的非关键服务,并定义降级后的返回策略。在网站并发高时,可以暂时屏蔽一些对业不影响的服务,如广告服务。

容错机制:在消费者端把A服务器屏蔽。再去请求,此时发现不会做远程调用,直接返回了null。

服务熔断:类似于这有用的保险丝,如果并发太大,可以熔断。

集群容错:在集群调用失败时,Dubbo 提供了多种容错方案,缺省为 failover 重试。

集群容错模式

Failover Cluster

失败自动切换,当出现失败,重试其它服务器。通常用于读操作,但重试会带来更长延迟。可通过 retries=“2” 来设置重试次数(不含第一次)。

重试次数配置如下:

<dubbo:service retries="2" />
或
<dubbo:reference retries="2" />
或
<dubbo:reference>
  <dubbo:method name="getUserAddressList" retries="2" />
</dubbo:reference>

Failfast Cluster

快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。

Failsafe Cluster

失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。

Failback Cluster

失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。

Forking Cluster

并行调用多个服务器,只要一个成功即返回。通常用于实时性要求较高的读操作,但需要浪费更多服务资源。可通过 forks=“2” 来设置最大并行数。

Broadcast Cluster

广播调用所有提供者,逐个调用,任意一台报错则报错 [2]。通常用于通知所有提供者更新缓存或日志等本地资源信息。

集群模式配置

按照以下示例在服务提供方和消费方配置集群模式:

<dubbo:service cluster="failsafe" />
<dubbo:reference cluster="failsafe" />

整合hystrix

Hystrix 旨在通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix具备拥有回退机制和断路器功能的线程和信号隔离,请求缓存和请求打包,以及监控和配置等功能。

1、配置spring-cloud-starter-netflix-hystrix

SpringBoot官方提供了对Hystrix的集成,直接在pom.xml里加入依赖:

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

2、然后在Application类上增加@EnableHystrix来启用hystrix starter:

@EnableDubbo//开启注解的dubbo功能
@SpringBootApplication
@EnableHystrix
public class BootEgoUserServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootEgoUserServiceProviderApplication.class, args);

    }
}

3、配置Provider端

在Dubbo的Provider上增加@HystrixCommand配置,这样子调用就会经过Hystrix代理。

@Service//暴露服务
public class UserServiceImpl implements UserService{
    public static List<UserAddress> address=new ArrayList<>();
    static {
        address.add(new UserAddress(1, "湖北省武汉市东湖高新区", "aaa"));
        address.add(new UserAddress(2, "湖北省武汉市洪山区", "bbb"));
    }
    @HystrixCommand
    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        System.out.println("UserServiceImpl----20082-3");
        //讲道理要是去数据库里面去查询的
        if(Math.random()>0.5) {
            throw new RuntimeException();
        }
        return address;
    }
}

4、配置Consumer端

对于Consumer端,则可以增加一层method调用,并在method上配置@HystrixCommand。当调用出错时,会走到fallbackMethod = "reliable"的调用里。

5、启动类

@SpringBootApplication
@EnableDubbo //启动dubbo
@EnableHystrix
public class BootEgoOrderServiceConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootEgoOrderServiceConsumerApplication.class, args);
    }
}

6、消费类

@Service
public class OrderServiceImpl implements OrderService {
    @Reference
    UserService userService;
    
    //如果出错就调用hello方法
    @HystrixCommand(fallbackMethod="hello")
    @Override
    public List<UserAddress> initOrder(String userId) {
        System.out.println("用户id:"+userId);
        //1、查询用户的收货地址
        List<UserAddress> addressList = userService.getUserAddressList(userId);
        return addressList;
    }

    //出错之后的回调方法
    public List<UserAddress> hello(String userId) {
        return Arrays.asList(new UserAddress(3, "出错啦", "1"));
    }
}
0

评论区