nacos集成Sentinel、gateway

忘是亡心i 2023-06-24 08:09 100阅读 0赞

（一）maven依赖

（1）父项目依赖

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>com.alibaba.cloud</groupId>
  8.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  9.         </dependency>
  10.         <dependency>
  11.             <groupId>com.alibaba.cloud</groupId>
  12.             <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
  13.         </dependency>
  15.         <dependency>
  16.             <groupId>com.alibaba.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
  18.         </dependency>
  20.     </dependencies>
  22.     <dependencyManagement>
  23.         <dependencies>
  24.             <dependency>
  25.                 <groupId>org.springframework.cloud</groupId>
  26.                 <artifactId>spring-cloud-dependencies</artifactId>
  27.                 <version>Greenwich.RELEASE</version>
  28.                 <type>pom</type>
  29.                 <scope>import</scope>
  30.             </dependency>
  31.             <!--<dependency>
  32.                 <groupId>org.springframework.cloud</groupId>
  33.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  34.                 <version>0.9.0.RELEASE</version>
  35.                 <type>pom</type>
  36.                 <scope>import</scope>
  37.             </dependency>-->
  38.             <dependency>
  39.                 <groupId>com.alibaba.cloud</groupId>
  40.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  41.                 <version>2.1.1.RELEASE</version>
  42.                 <type>pom</type>
  43.                 <scope>import</scope>
  44.             </dependency>
  45.         </dependencies>
  46.     </dependencyManagement>

（2）子项目service-privoder依赖

  1. <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-web</artifactId>
  4.         </dependency>
  6.         <dependency>
  7.             <groupId>com.alibaba.csp</groupId>
  8.             <artifactId>sentinel-datasource-nacos</artifactId>
  9.             <version>1.6.0</version>
  10.         </dependency>

（3）网关依赖

  1. <dependency>
  2.             <groupId>org.springframework.cloud</groupId>
  3.             <artifactId>spring-cloud-starter-gateway</artifactId>
  4.         </dependency>
  5.         <dependency>
  6.             <groupId>com.alibaba.cloud</groupId>
  7.             <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
  8.         </dependency>

（二）注册服务service-privoder到nacos并整合sentinel进行限流

（1）配置文件

1.bootstrap.yml配置

  1. spring:
  2.   application:
  3.     name: privoder-service
  4.   cloud:
  5.     nacos:
  6.       config:
  7.         server-addr: 127.0.0.1:8848
  8.       discovery:
  9.         server-addr: 127.0.0.1:8848
  10.     sentinel:
  11.       eager: true
  12.       transport:
  13.         dashboard: localhost:8080
  14.       datasource:
  15.         ds1:
  16.           nacos:
  17.             server-addr: 127.0.0.1:8848
  18.             dataId: ${spring.application.name}-flow-rules
  19.             data-type: json
  20.             rule-type: flow

2.application.yml配置

  1. spring:
  2.   profiles:
  3.     active: dev
  4. server:
  5.   port: 8082
  6. sleep: 1000

（2）添加发现微服务注解

  1. @EnableDiscoveryClient
  2. @SpringBootApplication
  3. public class PrivoderApp {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(PrivoderApp.class, args);
  6.     }
  7. }

（3）数据实体类

  1. public class Balance {
  2.     private int id;
  3.     private int diamond;
  4.     private int ticket;
  5.     private String message;
  7.     public Balance() {
  8.     }
  10.     public int getId() {
  11.         return id;
  12.     }
  14.     public Balance(int id, int diamond, int ticket) {
  15.         this(id, diamond, ticket, "OK");
  16.     }
  18.     public Balance(int id, int diamond, int ticket, String message) {
  19.         this.id = id;
  20.         this.diamond = diamond;
  21.         this.ticket = ticket;
  22.         this.message = message;
  23.     }
  25.     public void setId(int id) {
  26.         this.id = id;
  27.     }
  29.     public int getDiamond() {
  30.         return diamond;
  31.     }
  33.     public void setDiamond(int diamond) {
  34.         this.diamond = diamond;
  35.     }
  37.     public int getTicket() {
  38.         return ticket;
  39.     }
  41.     public void setTicket(int ticket) {
  42.         this.ticket = ticket;
  43.     }
  45.     public String getMessage() {
  46.         return message;
  47.     }
  49.     public void setMessage(String message) {
  50.         this.message = message;
  51.     }
  52. }

（4）控制层

  1. @RestController
  2. @RefreshScope
  3. public class BalanceController {
  5.     @Value("${sleep:0}")
  6.     private int sleep;
  8.     final static Map<Integer, Balance> balanceMap = new HashMap() {
  9.         {
  10.             put(1, new Balance(1, 10, 1000));
  11.             put(2, new Balance(2, 0, 10000));
  12.             put(3, new Balance(3, 100, 0));
  13.         }
  14.     };
  16.     @RequestMapping("/service")
  17.     @SentinelResource(value = "protected-resource", blockHandler = "handleBlock")
  18.     public Balance getBalance(Integer id) {
  19.         System.out.println("request: /service?id=" + id + ", sleep: " + sleep);
  20.         if (sleep > 0) {
  21.             try {
  22.                 Thread.sleep(sleep);
  23.             } catch (InterruptedException e) {
  24.                 e.printStackTrace();
  25.             }
  26.         }
  27.         if (id != null && balanceMap.containsKey(id)) {
  28.             return balanceMap.get(id);
  29.         }
  30.         return new Balance(0, 0, 0, "不存在");
  31.     }
  33.     public Balance handleBlock(Integer id, BlockException e) {
  34.         return new Balance(0, 0, 0, "限流");
  35.     }
  36. }

（5）nacos添加配置文件

Data ID:privoder-service-flow-rules
格式： json

  1. [
  2.   {
  3.     "resource": "protected-resource",
  4.     "controlBehavior": 2,
  5.     "count": 1,
  6.     "grade": 1,
  7.     "limitApp": "default",
  8.     "strategy": 0
  9.   }
  10. ]

（6）访问服务

访问localhost:8012/service?id=1
不断的刷新访问会出现限流提示

（三）网关

（1）application.yml配置

  1. server:
  2.   port: 8010
  4. spring:
  5.   application:
  6.     name: gateway-server
  7.   cloud:
  8.     nacos:
  9.       discovery:
  10.         server-addr: 127.0.0.1:8848
  11.     gateway:
  12.       enabled: true
  13.       discovery:
  14.         locator:
  15.           lower-case-service-id: true
  16.       routes:
  17.         # Add your routes here.
  18.         - id: college_route
  19.           uri: lb://provider-service
  20.           predicates:
  21.             - Path=/provider/**
  23.     sentinel:
  24.       transport:
  25.         dashboard: localhost:8011
  26.       datasource.ds1.file:
  27.         file: "classpath: gateway.json"
  28.         ruleType: gw-flow

（2）添加发现微服务注解

  1. @EnableDiscoveryClient
  2. @SpringBootApplication
  3. public class GatewayApplication {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(GatewayApplication.class, args);
  6.     }
  7. }

（3）resource添加gateway.json

  1. [
  2.   {
  3.     "resource": "college_route",
  4.     "count": 2
  5.   }
  6. ]

发表评论

表情：
评论列表 （有 0 条评论，100人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringBoot集成Nacos

    目录 简介 依赖 配置文件 代码 测试 简介： Nacos 是阿里巴巴的新开源项目，其核心定位是 “一个更易于帮助构建云原生应用的集注册中心与配置中心于一体的

    Dear 丶Dear 丶/ 0 赞/ 134 阅读