Sentinel流量控制与熔断降级：提升系统稳定性的关键技术解析-北单过滤日记

Sentinel流量控制与熔断降级：提升系统稳定性的关键技术解析

abc350826712 54 2025-01-04 05:05:58

网络传输中的流量控制至关重要，同时也相当复杂。它在调整数据发送过程中扮演着核心角色。然而，为了保证系统稳定，还需关注处理请求的速度。随机出现的请求与系统有限的处理能力之间产生了矛盾。因此，流量控制需要介入进行资源调配，同时还要对链路中的不稳定因素进行断开处理。

流量控制内涵

网络传输中，流量控制是一个常见的术语。举例来说，当网络数据包的流量超出预设的限制时，就需要通过特定的算法来调整。在实际操作中，我们可以在系统设置中的“流控规则”部分添加新的流量控制规则，这样做是确保网络稳定传输的关键。流量控制的调整需要考虑系统的承载能力等因素，这就像资金有限的项目需要根据预算来控制材料采购量一样。

网络流量管理对网络性能有显著影响，在众多大型数据传输场合中，它扮演着不可或缺的角色。以云计算数据中心为例，那里每日进行着巨量的数据交换，若缺乏有效的流量管理，数据拥堵和系统崩溃的风险将大大增加。

熔断的意义

链路结构相当复杂。若链路中的某个环节出现波动，便可能引发请求拥堵，进而造成连锁错误。这时，熔断机制便应运而生。一旦检测到链路中某个资源表现不佳，比如响应时间过长或异常比例增加，熔断机制便会限制对该资源的访问。



    com.alibaba.cloud
    spring-cloud-starter-alibaba-sentinel
    2.2.5.RELEASE

这在网上很多应用场景中都是必须的。比如，在电商平台的促销时段，大量订单查询和交易服务若出现问题未能及时中断，可能会让整个交易系统陷入瘫痪。根据以往的经历，不少平台都曾遭遇过此类危机，这才开始更加重视熔断机制的重要性。

/****
     * 司机信息
     */
@SentinelResource(value = "info",blockHandler = "blockExHandler")
@RequestMapping(value = "/info/{id}")
public Driver info(@PathVariable(value = "id")String id) throws BlockException {
    log.info("当前服务占用的端口为:{}",port);
    Driver driver = driverService.findById(id);
    if (driver==null) {
        //throw new RuntimeException("司机id="+id+"不存在");
        throw new SystemBlockException("info", "司机id="+id+"不存在",null); // 抛出BlockException
    }
    return driver;
}
/**
     * info资源出现BlockException后的降级处理
     */
public Driver blockExHandler(String id,BlockException e) {
    Driver driver = new Driver();
    driver.setId(id);
    driver.setName("系统繁忙,稍后再试");
    return driver;
}

系统自适应限流

@Component
public class DriverFeignFallback implements DriverFeign {
    /**
     * status()降级处理方法
     */
    @Override
    public Driver status(String id, Integer status) {
        Driver driver = new Driver();
        driver.setId(id);
        driver.setStatus(status);
        driver.setName("系统比较繁忙，请您稍后再试！");
        return driver;
    }
}

系统对应用入口的流量实施自适应控制，从全局视角出发。它整合了多个监控指标，比如应用的负载、CPU利用率等。运用自适应方法，确保入口流量与系统负载相协调。这样做既保证了系统的稳定运行，又实现了最大的数据吞吐量。

@FeignClient(name = "hailtaxi-driver",fallback = DriverFeignFallback.class)
public interface DriverFeign {
    @PutMapping(value = "/driver/status/{id}/{status}")
    Driver status(@PathVariable(value = "id")String id, @PathVariable(value = "status")Integer status);
}

以某些游戏服务器为例，在玩家数量达到高峰时，若缺乏自适应限流，很可能会因玩家大量涌入而导致资源超负荷。这可能导致游戏卡顿、延迟，甚至服务器崩溃。而引入这一机制后，可以有效避免此类问题，确保游戏体验的稳定性。

@Component
public class DriverFeignFallbackFactory implements FallbackFactory {
    @Override
    public DriverFeign create(Throwable throwable) {
        return new DriverFeign() {
            /**
             * status()降级处理方法
             */
            @Override
            public Driver status(String id, Integer status) {
                Driver driver = new Driver();
                driver.setId(id);
                driver.setStatus(status);
                driver.setName("系统比较繁忙，请您稍后再试！");
                return driver;
            }
        };
    }
}

访问控制的黑白名单

@FeignClient(name = "hailtaxi-driver",fallback = DriverFeignFallbackFactory.class)
public interface DriverFeign {
    @PutMapping(value = "/driver/status/{id}/{status}")
    Driver status(@PathVariable(value = "id")String id, @PathVariable(value = "status")Integer status);
}

限制资源调用需遵循访问控制，可通过黑白名单机制实现。若启用白名单，仅允许名单内来源的请求通行。若采用黑名单，则名单内来源的请求将被阻止。

公司内部系统中，对某些机密资源板块的访问权限，仅对特定部门开放，这可以通过建立白名单来实现。同时，对于曾经恶意攻击系统的IP地址，也可以将其加入黑名单，以阻止其访问。