双剑合璧 Nacos 结合 Sentinel 实现流量安全控制 (2)

「注意」：启动 Sentinel 控制台需要 JDK 版本为 1.8 及以上版本。

❞

其中 -Dserver.port=8080 用于指定 Sentinel 控制台端口为 8080。

从 Sentinel 1.6.0 起，Sentinel 控制台引入基本的「登录」功能，默认用户名和密码都是 sentinel。可以参考 配置用户名和密码。

❝

注：若您的应用为 Spring Boot 或 Spring Cloud 应用，您可以通过 Spring 配置文件来指定配置，详情请参考 Spring Cloud Alibaba Sentinel 文档。

❞

为了方便启动，可以编写一个启动脚本 run.bat：

java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.7.2.jar pause 访问

访问：:8080/

输入默认用户名和密码 sentinel 点击登录。至此控制台就安装完成了。

环境准备

sentinel-demo 聚合工程。SpringBoot 2.3.0.RELEASE、Spring Cloud Hoxton.SR4。

Nacos 注册中心

product-service：商品服务，提供了 /product/{id} 接口

order-service-rest：订单服务，基于 Ribbon 通过 RestTemplate 调用商品服务

order-server-feign：订单服务，基于 Feign 通过声明式服务调用商品服务

客户端接入控制台

控制台启动后，客户端需要按照以下步骤接入到控制台：

添加依赖

定义资源

定义规则

先把可能需要保护的资源定义好，之后再配置规则。也可以理解为，只要有了资源，我们就可以在任何时候灵活地定义各种流量控制规则。在编码的时候，只需要考虑这个代码是否需要保护，如果需要保护，就将之定义为一个资源。

由于我们的项目是 Spring Cloud 项目，所以可以借助官方文档来进行学习。

Spring 官网文档：https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html

Github 文档：https://github.com/alibaba/spring-cloud-alibaba/wiki/Sentinel

添加依赖

父工程需要添加如下依赖：

<dependencyManagement> <dependencies> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-dependencies</artifactId> <version>2.1.0.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>

子工程需要添加如下依赖：

<!-- spring cloud alibaba sentinel 依赖 --> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId> </dependency> 配置文件

客户端需要启动 Transport 模块来与 Sentinel 控制台进行通信。

order-service-rest 的 application.yml

spring: cloud: # 配置 Sentinel sentinel: transport: port: 8719 dashboard: localhost:8080

这里的 spring.cloud.sentinel.transport.port 端口配置会在应用对应的机器上启动一个 Http Server，该 Server 会与 Sentinel 控制台做交互。比如 Sentinel 控制台添加了一个限流规则，会把规则数据 push 给这个 Http Server 接收，Http Server 再将规则注册到 Sentinel 中。

初始化客户端

「确保客户端有访问量」，Sentinel 会在「客户端首次调用的时候」进行初始化，开始向控制台发送心跳包。

简单的理解就是：访问一次客户端，Sentinel 即可完成客户端初始化操作，并持续向控制台发送心跳包。

访问

多次访问：:9090/order/1 然后查看控制台实时监控结果如下：

定义资源

「资源」 是 Sentinel 中的核心概念之一。我们说的资源，可以是任何东西，服务，服务里的方法，甚至是一段代码。最常用的资源是我们代码中的 Java 方法。Sentinel 提供了 @SentinelResource 注解用于定义资源，并提供了 AspectJ 的扩展用于自动定义资源、处理 BlockException 等。

只要通过 Sentinel API 定义的代码，就是资源，能够被 Sentinel 保护起来。大部分情况下，可以使用方法签名，URL，甚至服务名称作为资源名来标示资源。

官网文档：

注解支持

官网文档：https://github.com/alibaba/Sentinel/wiki/注解支持

OrderServiceImpl.java

package com.example.service.impl; import com.alibaba.csp.sentinel.annotation.SentinelResource; import com.alibaba.csp.sentinel.slots.block.BlockException; import com.example.pojo.Order; import com.example.service.OrderService; import com.example.service.ProductService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.Arrays; @Service public class OrderServiceImpl implements OrderService { @Autowired private ProductService productService; /** * 根据主键和订单编号查询订单 * * @param id * @param orderNo * @return */ @Override @SentinelResource(value = "selectOrderByIdAndOrderNo", blockHandler = "selectOrderByIdAndOrderNoBlockHandler", fallback = "selectOrderByIdAndOrderNoFallback") public Order selectOrderByIdAndOrderNo(Integer id, String orderNo) { return new Order(id, orderNo, "中国", 2666D, Arrays.asList(productService.selectProductById(1))); } // 服务流量控制处理，参数最后多一个 BlockException，其余与原函数一致。 public Order selectOrderByIdAndOrderNoBlockHandler(Integer id, String orderNo, BlockException ex) { // Do some log here. ex.printStackTrace(); return new Order(id, "服务流量控制处理-托底数据", "中国", 2666D, Arrays.asList(productService.selectProductById(1))); } // 服务熔断降级处理，函数签名与原函数一致或加一个 Throwable 类型的参数 public Order selectOrderByIdAndOrderNoFallback(Integer id, String orderNo, Throwable throwable) { System.out.println("order-service 服务的 selectOrderById 方法出现异常，异常信息如下：" + throwable); return new Order(id, "服务熔断降级处理-托底数据", "中国", 2666D, Arrays.asList(productService.selectProductById(1))); } }

ProductServiceImpl.java

package com.example.service.impl; import com.alibaba.csp.sentinel.annotation.SentinelResource; import com.alibaba.csp.sentinel.slots.block.BlockException; import com.example.pojo.Product; import com.example.service.ProductService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; /** * 商品管理 */ @Service public class ProductServiceImpl implements ProductService { @Autowired private RestTemplate restTemplate; /** * 根据主键查询商品 * * @param id * @return */ @SentinelResource(value = "selectProductById", blockHandler = "selectProductByIdBlockHandler", fallback = "selectProductByIdFallback") @Override public Product selectProductById(Integer id) { return restTemplate.getForObject("http://product-service/product/" + id, Product.class); } // 服务流量控制处理，参数最后多一个 BlockException，其余与原函数一致。 public Product selectProductByIdBlockHandler(Integer id, BlockException ex) { // Do some log here. ex.printStackTrace(); return new Product(id, "服务流量控制处理-托底数据", 1, 2666D); } // 服务熔断降级处理，函数签名与原函数一致或加一个 Throwable 类型的参数 public Product selectProductByIdFallback(Integer id, Throwable throwable) { System.out.println("product-service 服务的 selectProductById 方法出现异常，异常信息如下：" + throwable); return new Product(id, "服务熔断降级处理-托底数据", 1, 2666D); } } ❝