IT评测·应用市场-qidao123.com技术社区

标题: 5.2.Spring Cloud Alibaba生态 [打印本页]
作者: 惊落一身雪    时间: 昨天 06:00
标题: 5.2.Spring Cloud Alibaba生态
目次

一、Spring Cloud Alibaba生态全景概览

二、服务注册与设置中心：Nacos

三、分布式流量治理：Sentinel

四、分布式事务：Seata

五、分布式消息通讯：RocketMQ

六、API网关：Spring Cloud Gateway与Alibaba整合

七、进阶实战与性能调优

八、求职口试专题突破

一、Spring Cloud Alibaba生态全景概览

1. 生态定位与核心优势

1.1 与Spring Cloud Netflix的深度对比

功能覆盖差异

  1. ```java
  2. // 典型配置差异示例
  3. @Configuration
  4. // Netflix方式
  5. @EnableCircuitBreaker  
  6. // Alibaba方式
  7. @EnableSentinel  
  8. public class ResilienceConfig {}
复制代码
功能维度Netflix方案Alibaba方案优势比较服务发现Eureka(AP)Nacos(AP/CP可切换)支持设置中心一体化熔断降级Hystrix(线程池隔离)Sentinel(信号量隔离)更低资源消耗分布式设置Config+BusNacos内置支持及时推送(<1s) 社区支持现状

• Netflix：2020年后停止重大更新，Spring官方保举迁移 • Alibaba：一连迭代（2023年发布2.2.10版本），中文文档完善
1.2 阿里系中间件整合价值

双十一验证的技能矩阵

  1. [/code] 高并发
  2. Nacos百万级实例注册
  3. Sentinel百万QPS限流
  4. RocketMQ万亿级消息堆积
  5. [size=2][b]企业级加强特性[/b][/size]
  7. • [b]Nacos[/b]：
  9. [list]
  10. [*] 设置版本回滚（类似Git的版本控制）
  11. [*] 监听查询（精确追踪设置变更汗青）
  12. [/list] [code]-- Nacos配置历史表结构
  13. SELECT * FROM his_config_info
  14. WHERE data_id='order-service.yml'
  15. ORDER BY id DESC LIMIT 5;
复制代码
2. 核心组件矩阵与选型指南

2.1 注册中心选型决策树

Nacos vs Eureka vs Consul

指标NacosEurekaConsul一致性协议AP/CP可切换APCP健康检查TCP/HTTP/MYSQL心跳检测多种检查方式设置管理内置支持需结合Config需结合Vault 选型建议

  1. public class RegistrySelection {
  2.     public static String choose(boolean needConfigCenter, boolean multiDC) {
  3.         if (needConfigCenter) return "Nacos";
  4.         return multiDC ? "Consul" : "Eureka";
  5.     }
  6. }
复制代码
2.2 熔断组件性能对比

Sentinel vs Hystrix基准测试

压测指标Sentinel(1.8.6)Hystrix(1.5.18)QPS上限15万+2万+相应延迟<5ms10-50ms内存占用50MB200MB+ 线程模子差异

  1. // Hystrix线程池隔离
  2. @HystrixCommand(threadPoolKey = "orderThread")
  3. public Order getOrder() {...}
  5. // Sentinel信号量隔离
  6. @SentinelResource(value = "orderResource",
  7.                  blockHandler = "flowBlockHandler")
  8. public Order getOrder() {...}
复制代码
3. 版本兼容性与环境搭建

3.1 版本映射关系（2023最新）

Spring BootSpring CloudSpring Cloud Alibaba2.7.x2021.0.x2021.0.5.02.6.x2021.0.x2021.0.4.0 依赖管理最佳实践

  1. <!-- 父pom定义 -->
  2. <dependencyManagement>
  3.     <dependencies>
  4.         <dependency>
  5.             <groupId>com.alibaba.cloud</groupId>
  6.             <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  7.             <version>2021.0.5.0</version>
  8.             <type>pom</type>
  9.             <scope>import</scope>
  10.         </dependency>
  11.     </dependencies>
  12. </dependencyManagement>
复制代码
3.2 当地开发环境搭建

最小化启动设置

  1. bootstrap.yml
  2. spring:
  3.   application:
  4.     name: demo-service
  5.   cloud:
  6.     nacos:
  7.       discovery:
  8.         server-addr: localhost:8848
  9.       config:
  10.         server-addr: localhost:8848
  11.         file-extension: yaml
  12.         group: DEFAULT_GROUP
复制代码
关键依赖清单

  1. <!-- 必须依赖 -->
  2. <dependency>
  3.     <groupId>com.alibaba.cloud</groupId>
  4.     <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  5. </dependency>
  6. <dependency>
  7.     <groupId>com.alibaba.cloud</groupId>
  8.     <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
  9. </dependency>
复制代码
二、服务注册与设置中心：Nacos

1. Nacos核心功能实战

1.1 动态服务注册与发现

多集群隔离设置

  1. ```yaml
  2. application-cluster.yml
  3. spring:
  4.   cloud:
  5.     nacos:
  6.       discovery:
  7.         cluster-name: ${NACOS_CLUSTER:SHANGHAI_A}  # 集群名称
  8.         namespace: ${NACOS_NAMESPACE:DEV}          # 命名空间隔离
  9.         group: ${NACOS_GROUP:ORDER_GROUP}          # 业务分组
复制代码
服务注册源码解析

  1. // NacosServiceRegistry自动注册流程
  2. public class NacosAutoServiceRegistration {
  3.     @EventListener(WebServerInitializedEvent.class)
  4.     public void register() {
  5.         // 核心注册方法
  6.         namingService.registerInstance(
  7.             applicationName,
  8.             instance.setClusterName(clusterName)
  9.         );
  10.     }
  11. }
复制代码
1.2 设置热更新机制

@RefreshScope底层原理

  1. public class RefreshScope extends GenericScope {
  2.     // 关键方法：配置变更时触发Bean重建
  3.     public void refreshAll() {
  4.         super.destroy();  // 销毁旧Bean
  5.         context.getBeanFactory().initializeBean(...); // 重新初始化
  6.     }
  7. }
复制代码
动态设置示例

  1. @RestController
  2. @RefreshScope
  3. public class ConfigController {
  4.     @Value("${order.timeout:5000}")
  5.     private Integer timeout;  // 配置变更后自动更新
  6.    
  7.     @GetMapping("/timeout")
  8.     public Integer getTimeout() {
  9.         return timeout;
  10.     }
  11. }
复制代码
2. 高可用生产级摆设

2.1 集群化摆设架构

MySQL长期化方案

  1. -- 初始化数据库脚本
  2. CREATE DATABASE nacos_config CHARACTER SET utf8mb4;
  3. USE nacos_config;
  4. SOURCE ${NACOS_HOME}/conf/nacos-mysql.sql
复制代码
集群启动参数

  1. 启动命令示例
  2. java -Dnacos.standalone=false \
  3.      -Dnacos.mysql.url=jdbc:mysql://db-cluster:3306/nacos_config \
  4.      -Dnacos.mysql.user=nacos \
  5.      -Dnacos.mysql.password=encrypted_password \
  6.      -jar nacos-server.jar
复制代码
2.2 灰度发布流程

  1. [/code] 是
  2. 否
  3. 创建灰度设置
  4. 关联特定IP/标签
  5. 验证通过?
  6. 全量发布
  7. 回滚版本
  8. [hr] [size=4][b]3. 口试高频问题[/b][/size]
  10. [size=3][b]3.1 CP/AP模式切换原理[/b][/size]
  12. [size=2][b]Raft协议实现CP[/b][/size]
  14. [code]// Nacos的Distro协议处理类
  15. public class DistroProtocol {
  16.     // AP模式下数据同步
  17.     public void sync(DistroKey key, byte[] data) {
  18.         // 异步广播给其他节点
  19.     }
  20. }
复制代码
模式切换设置

  1. application.properties
  2. nacos.naming.data.consistency=AP  # 可选AP/CP
复制代码
3.2 设置推送机制

长轮询流程

  1. // ClientLongPolling核心逻辑
  2. class ClientLongPolling implements Runnable {
  3.     public void run() {
  4.         // 默认30s长轮询超时
  5.         String[] dataIds = request.getParameterValues("dataIds");
  6.         List<String> changedGroups = checkUpdate(dataIds);
  7.         if(!changedGroups.isEmpty()) {
  8.             // 立即返回变更数据
  9.         } else {
  10.             // 加入阻塞队列等待通知
  11.         }
  12.     }
  13. }
复制代码
版本对比算法

  1. public class ConfigCache {
  2.     // 客户端缓存校验逻辑
  3.     public boolean checkListenerMd5(String group, String dataId, String md5) {
  4.         return Objects.equals(md5, getLocalMd5(group, dataId));
  5.     }
  6. }
复制代码
三、分布式流量治理：Sentinel

1. 流量控制与熔断降级

1.1 熔断规则三维控制体系

规则设置模板

  1. ```java
  2. // 熔断规则构建器
  3. DegradeRule rule = new DegradeRuleBuilder()
  4.     .withResource("paymentApi")
  5.     .withGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO) // 异常比例模式
  6.     .withCount(0.5)  // 阈值50%
  7.     .withTimeWindow(10) // 熔断时长(s)
  8.     .withMinRequestAmount(5) // 最小触发请求数
  9.     .withStatIntervalMs(10000) // 统计窗口(ms)
  10.     .build();
复制代码
熔断策略对比矩阵

熔断维度设置参数适用场景相应时间DEGRADE_GRADE_RT慢调用熔断非常比例DEGRADE_GRADE_EXCEPTION_RATIO服务不稳固时非常数DEGRADE_GRADE_EXCEPTION_COUNT非高频场景 1.2 热点参数限流实战

热点规则设置

  1. @SentinelResource(
  2.     value = "queryUser",
  3.     blockHandler = "paramFlowBlockHandler",
  4.     fallback = "userFallback"
  5. )
  6. public User queryUser(@RequestParam String userId) {...}
  8. // 热点参数规则
  9. ParamFlowRule rule = new ParamFlowRule("queryUser")
  10.     .setParamIdx(0) // 第一个参数
  11.     .setCount(100); // 单参数阈值
复制代码
体系自顺应掩护

  1. // 全局系统规则配置
  2. SystemRule systemRule = new SystemRule()
  3.     .setHighestSystemLoad(4.0) // max load
  4.     .setAvgRt(200)             // 平均RT(ms)
  5.     .setMaxThread(800)         // 最大线程数
  6.     .setQps(5000);             // 全局QPS
复制代码
2. 规则长期化与生产实践

2.1 Nacos动态规则推送

设置中心数据结构

  1. {
  2.   "resource": "paymentApi",
  3.   "controlBehavior": 0,
  4.   "count": 100,
  5.   "grade": 1,
  6.   "strategy": 0
  7. }
复制代码
主动推送原理

  1. [/code] Sentinel DashboardNacos微服务Sentinel发布规则设置设置变更通知动态加载新规则Sentinel DashboardNacos微服务Sentinel
  2. [size=3][b]2.2 集群限流摆设方案[/b][/size]
  4. [size=2][b]Token Server模式[/b][/size]
  6. [code]application-cluster.yaml
  7. spring:
  8.   cloud:
  9.     sentinel:
  10.       transport:
  11.         dashboard: sentinel-dashboard:8080
  12.       filter:
  13.         enabled: false
  14.       # 集群配置
  15.       cluster:
  16.         server:
  17.           host: 192.168.1.10
  18.           port: 18730
  19.         client:
  20.           server-ip: 192.168.1.10
  21.           request-timeout: 200
复制代码
集群流控算法

  1. // 集群请求处理逻辑
  2. public class ClusterFlowChecker {
  3.     public boolean allowCheck(FlowRule rule, int count) {
  4.         // 向Token Server申请令牌
  5.         return acquireClusterToken(rule, count);
  6.     }
  7. }
复制代码
3. 口试聚焦

3.1 线程隔离模子对比

Hystrix线程池隔离

  1. @HystrixCommand(
  2.     threadPoolKey = "orderThread",
  3.     threadPoolProperties = {
  4.         @HystrixProperty(name="coreSize", value="20")
  5.     }
  6. )
  7. public Order getOrder() {...}  // 每个命令独立线程池
复制代码
Sentinel信号量隔离

  1. @SentinelResource(
  2.     value = "orderResource",
  3.     blockHandler = "flowBlock",
  4.     fallback = "orderFallback"
  5. )  // 共享线程资源，通过信号量控制
  6. public Order getOrder() {...}
复制代码
3.2 分布式链路流控方案

链路维度限流

  1. // 入口资源定义
  2. try (Entry entry = SphU.entry("parentResource")) {
  3.     // 调用子服务
  4.     childService.call();  // 子资源自动统计
  5. }
复制代码
网关层流控

  1. 网关路由规则
  2. spring:
  3.   cloud:
  4.     gateway:
  5.       routes:
  6.         ▪ id: payment_route
  8.           uri: lb://payment-service
  9.           predicates:
  10.             ▪ Path=/payment/**
  12.           filters:
  13.             ▪ name: RequestRateLimiter
  15.               args:
  16.                 redis-rate-limiter.replenishRate: 100
  17.                 redis-rate-limiter.burstCapacity: 200
复制代码
四、分布式事务：Seata

1. 事务模式深度解析

1.1 AT模式核心机制

Undo Log工作原理

  1. ```sql
  2. -- 业务操作前镜像
  3. SELECT * FROM product WHERE id=1 FOR UPDATE;
  4. -- 执行业务SQL
  5. UPDATE product SET stock=stock-1 WHERE id=1;
  6. -- 生成后镜像
  7. SELECT * FROM product WHERE id=1;
复制代码
全局锁实现逻辑

  1. // GlobalLockInterceptor核心代码
  2. public Object invoke(MethodInvocation invocation) {
  3.     if (isGlobalLockRequired()) {
  4.         // 获取全局锁
  5.         GlobalLockHelper.lock(businessKey);
  6.     }
  7.     return invocation.proceed();
  8. }
复制代码
1.2 TCC模式开发规范

三阶段模板方法

  1. @LocalTCC
  2. public interface OrderTccAction {
  3.     @TwoPhaseBusinessAction(name = "prepareCreateOrder",
  4.                           commitMethod = "commit",
  5.                           rollbackMethod = "rollback")
  6.     boolean prepare(BusinessActionContext actionContext,
  7.                    @BusinessActionContextParameter(paramName = "orderId") String orderId);
  8.    
  9.     boolean commit(BusinessActionContext actionContext);
  10.     boolean rollback(BusinessActionContext actionContext);
  11. }
复制代码
TCC防悬挂方案

  1. // 空回滚检查
  2. if (actionContext.getActionContext("orderId") == null) {
  3.     throw new TccAvoidHangingException();
  4. }
复制代码
2. 生产环境优化方案

2.1 高可用摆设架构

DB存储模式设置

  1. registry.conf
  2. store {
  3.   mode = "db"
  4.   db {
  5.     datasource = "druid"
  6.     url = "jdbc:mysql://tc-cluster:3306/seata"
  7.     user = "seata"
  8.     password = "encrypted_pwd"
  9.   }
  10. }
复制代码
TC集群摆设方案

  1. docker-compose.yml
  2. seata-server:
  3.   image: seataio/seata-server:1.7.0
  4.   environment:
  5.     ◦ SEATA_IP=192.168.1.100
  7.     ◦ SEATA_PORT=8091
  9.     ◦ STORE_MODE=db
  11.   volumes:
  12.     ◦ ./registry.conf:/seata-server/resources/registry.conf
复制代码
2.2 事务分组策略

分组路由规则

  1. application.properties
  2. spring.cloud.alibaba.seata.tx-service-group=order-service-group
  3. seata.tx-service-group.default.grouplist=192.168.1.101:8091,192.168.1.102:8091
复制代码
集群负载均衡

  1. [/code] Begin
  2. Commit
  3. TM
  4. TC1
  5. TC2
  6. DB1
  7. DB2
  8. [hr] [size=4][b]3. 口试实战题[/b][/size]
  10. [size=3][b]3.1 AT模式防脏写方案[/b][/size]
  12. [size=2][b]全局锁校验流程[/b][/size]
  14. [code]// AbstractConnectionProxy检查逻辑
  15. public boolean checkGlobalLock(String tableName, String pk) {
  16.     return SELECT * FROM lock_table
  17.            WHERE table_name=#{tableName} AND pk=#{pk} FOR UPDATE;
  18. }
复制代码
非常处置惩罚场景

非常类型触发条件办理方案脏写全局锁获取失败回滚当前分支事务脏读未提交数据被读取默认隔离级别为Read Committed 3.2 TCC模式常见问题

空回滚处置惩罚模板

  1. @Transactional
  2. public boolean rollback(BusinessActionContext context) {
  3.     if (!isTryPhaseExecuted(context.getXid())) { // 检查try阶段是否执行
  4.         // 记录空回滚标记
  5.         insertNullRollbackRecord(context.getXid());
  6.         return true;
  7.     }
  8.     // 正常回滚逻辑
  9. }
复制代码
幂等性保障方案

  1. -- 控制表设计
  2. CREATE TABLE tcc_control (
  3.     xid VARCHAR(128) PRIMARY KEY,
  4.     action_name VARCHAR(64),
  5.     status TINYINT,
  6.     gmt_modified DATETIME
  7. );
复制代码
五、分布式消息通讯：RocketMQ

1. Spring Cloud Stream整合

1.1 消息发布/订阅模子

Binder设置模板

  1. ```yaml
  2. application.yml
  3. spring:
  4.   cloud:
  5.     stream:
  6.       bindings:
  7.         orderOutput: # 生产者通道
  8.           destination: ORDER_TOPIC
  9.           content-type: application/json
  10.         paymentInput: # 消费者通道  
  11.           destination: PAYMENT_TOPIC
  12.           group: payment-group
  13.           consumer:
  14.             concurrency: 3 # 并发线程数
  16.       rocketmq:
  17.         binder:
  18.           namesrv-addr: 192.168.1.100:9876
复制代码
事务消息实战

  1. // 事务消息发送模板
  2. @Transactional
  3. public void createOrderWithTransaction(Order order) {
  4.     // 1. 本地事务
  5.     orderMapper.insert(order);
  6.    
  7.     // 2. 发送事务消息
  8.     rocketMQTemplate.sendMessageInTransaction(
  9.         "order-tx-group",
  10.         MessageBuilder.withPayload(order)
  11.             .setHeader("order_id", order.getId())
  12.             .build(),
  13.         null
  14.     );
  15. }
  17. // 事务监听器
  18. @RocketMQTransactionListener(txProducerGroup="order-tx-group")
  19. public class OrderTransactionListenerImpl implements RocketMQLocalTransactionListener {
  20.     @Override
  21.     public RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) {
  22.         // 执行本地事务
  23.         return RocketMQLocalTransactionState.COMMIT;
  24.     }
  25. }
复制代码
2. 生产级可靠性保障

2.1 消息高可用机制

Broker集群摆设方案

  1. broker-a.properties
  2. brokerClusterName=DefaultCluster
  3. brokerName=broker-a
  4. brokerId=0
  5. namesrvAddr=192.168.1.100:9876
  6. defaultTopicQueueNums=8
  7. storePathRootDir=/rocketmq/store-a
  8. enableDLegerCommitLog=true
  9. dLegerGroup=DLedgerGroup00
  10. dLegerPeers=n0-192.168.1.101:40911;n1-192.168.1.102:40911
复制代码
消息存储架构

  1. [/code] Write
  2. Producer
  3. CommitLog
  4. ConsumeQueue
  5. Consumer
  6. IndexFile
  7. [size=3][b]2.2 死信队列处置惩罚[/b][/size]
  9. [size=2][b]重试策略设置[/b][/size]
  11. [code]// 消费者重试配置
  12. @Bean
  13. public ConsumerFactory<String, Object> consumerFactory() {
  14.     Map<String, Object> props = new HashMap<>();
  15.     props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 300000);
  16.     props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 10);
  17.     return new DefaultKafkaConsumerFactory<>(props);
  18. }
  20. // 死信队列监听
  21. @StreamListener("inputDlq")
  22. public void handleDlq(Message<?> message) {
  23.     // 人工处理逻辑
  24.     log.error("DLQ Message: {}", message.getPayload());
  25. }
复制代码
3. 口试常见问题

3.1 消息零丢失保障方案

全链路防护措施

环节措施实现方式生产者事务消息+当地表半消息机制+当地事务表Broker同步刷盘+主从复制设置flushDiskType=SYNC_FLUSH和brokerRole=SYNC_MASTER消费者手动ACK+重试队列关闭autoCommit，非常时返回RECONSUME_LATER 关键设置示例

  1. // 生产者可靠发送
  2. rocketMQTemplate.setVipChannelEnabled(false); // 避免VIP通道问题
  3. rocketMQTemplate.setRetryTimesWhenSendFailed(3);
  5. // 消费者可靠消费
  6. @RocketMQMessageListener(
  7.     consumerGroup = "order-group",
  8.     topic = "ORDER_TOPIC",
  9.     consumeMode = ConsumeMode.ORDERLY,  // 顺序消费
  10.     messageModel = MessageModel.CLUSTERING
  11. )
  12. public class OrderConsumer implements RocketMQListener<Order> {
  13.     @Override
  14.     public void onMessage(Order order) {
  15.         try {
  16.             process(order);
  17.         } catch (Exception e) {
  18.             throw new RocketMQConsumeException("消费失败，稍后重试");
  19.         }
  20.     }
  21. }
复制代码
3.2 消息堆积办理方案

紧急处置惩罚四步法

六、API网关：Spring Cloud Gateway与Alibaba整合

1. 网关核心功能扩展

1.1 Sentinel网关流控

流控规则设置

  1. ```yaml
  2. 网关流控规则（通过Nacos配置中心下发）
  3. spring:
  4.   cloud:
  5.     gateway:
  6.       routes:
  7.         ▪ id: order-service
  9.           uri: lb://order-service
  10.           predicates:
  11.             ▪ Path=/api/order/**
  13.           filters:
  14.             ▪ name: RequestRateLimiter
  16.               args:
  17.                 redis-rate-limiter.replenishRate: 100
  18.                 redis-rate-limiter.burstCapacity: 200
  19.             ▪ name: Sentinel
  21.               args:
  22.                 resource: gateway:order-service
  23.                 fallback: forward:/fallback
复制代码
自定义流控非常处置惩罚

  1. @Bean
  2. public SentinelGatewayBlockExceptionHandler sentinelBlockHandler() {
  3.     return (exchange, ex) -> {
  4.         Map<String,String> error = Map.of(
  5.             "code", "429",
  6.             "message", "请求过于频繁"
  7.         );
  8.         return Mono.just(error)
  9.             .flatMap(data -> {
  10.                 exchange.getResponse().setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
  11.                 return exchange.getResponse().writeWith(
  12.                     Mono.just(exchange.getResponse()
  13.                         .bufferFactory()
  14.                         .wrap(JSON.toJSONBytes(data)))
  15.                 );
  16.             });
  17.     };
  18. }
复制代码
1.2 Nacos动态路由

路由设置主动更新

  1. @RefreshScope
  2. @Configuration
  3. public class DynamicRouteConfig {
  4.    
  5.     @Autowired
  6.     private NacosConfigManager configManager;
  8.     @Bean
  9.     public RouteDefinitionRepository nacosRouteDefinitionRepository() {
  10.         return new NacosRouteDefinitionRepository(
  11.             configManager,
  12.             "gateway-routes",  // Nacos Data ID
  13.             "DEFAULT_GROUP"
  14.         ) {
  15.             @Override
  16.             public Flux<RouteDefinition> getRouteDefinitions() {
  17.                 // 监听Nacos配置变化
  18.                 return super.getRouteDefinitions()
  19.                     .doOnNext(route -> log.info("路由更新: {}", route));
  20.             }
  21.         };
  22.     }
  23. }
复制代码
服务上下线主动感知

  1. [/code] NacosGatewayService注册/下线实例推送服务变更变乱刷新路由缓存NacosGatewayService
  2. [hr] [size=4][b]2. 安全与性能优化[/b][/size]
  4. [size=3][b]2.1 JWT鉴权实现[/b][/size]
  6. [size=2][b]过滤器链设置[/b][/size]
  8. [code]public class JwtAuthFilter implements GlobalFilter {
  9.     @Override
  10.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  11.         String token = exchange.getRequest()
  12.             .getHeaders()
  13.             .getFirst("Authorization");
  14.         
  15.         if (!JwtUtils.validateToken(token)) {
  16.             exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
  17.             return exchange.getResponse().setComplete();
  18.         }
  19.         
  20.         return chain.filter(exchange);
  21.     }
  22. }
复制代码
OAuth2中继模式

  1. spring:
  2.   security:
  3.     oauth2:
  4.       client:
  5.         provider:
  6.           keycloak:
  7.             issuer-uri: http://auth-server/auth/realms/demo
  8.         registration:
  9.           gateway-client:
  10.             provider: keycloak
  11.             client-id: gateway
  12.             client-secret: secret
  13.             authorization-grant-type: client_credentials
复制代码
2.2 高性能缓存策略

相应缓存设置

  1. @Bean
  2. public RouteLocator cachedRoutes(RouteLocatorBuilder builder) {
  3.     return builder.routes()
  4.         .route("product-service", r -> r.path("/api/product/**")
  5.             .filters(f -> f.cache(
  6.                 CacheConfig.of()
  7.                     .setSize(1000)
  8.                     .setTimeToLive(Duration.ofMinutes(10))
  9.             ))
  10.             .uri("lb://product-service"))
  11.         .build();
  12. }
复制代码
请求归并示例

  1. @PostMapping("/batch")
  2. public Mono<List<Product>> batchQuery(@RequestBody List<String> ids) {
  3.     return Flux.fromIterable(ids)
  4.         .flatMap(id -> productService.getById(id))
  5.         .collectList();
  6. }
复制代码
3. 口试题解析

3.1 灰度发布实现方案

基于Header的路由策略

  1. spring:
  2.   cloud:
  3.     gateway:
  4.       routes:
  5.         ▪ id: canary-route
  7.           uri: lb://new-service
  8.           predicates:
  9.             ▪ Path=/api/**
  11.             ▪ Header=X-Canary, true
  13.         ▪ id: primary-route  
  15.           uri: lb://old-service
  16.           predicates:
  17.             ▪ Path=/api/**
复制代码
权重分流设置

  1. @Bean
  2. public RouteLocator weightRouteLocator(RouteLocatorBuilder builder) {
  3.     return builder.routes()
  4.         .route("weight-high", r -> r.weight("service-group", 80)
  5.             .uri("lb://new-service"))
  6.         .route("weight-low", r -> r.weight("service-group", 20)
  7.             .uri("lb://old-service"))
  8.         .build();
  9. }
复制代码
3.2 过滤器扩展实战

自定义过滤器示例

  1. public class LoggingFilter implements GatewayFilter {
  2.     @Override
  3.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  4.         long startTime = System.currentTimeMillis();
  5.         return chain.filter(exchange)
  6.             .then(Mono.fromRunnable(() -> {
  7.                 long duration = System.currentTimeMillis() - startTime;
  8.                 log.info("请求耗时: {}ms - {}", duration, exchange.getRequest().getURI());
  9.             }));
  10.     }
  11. }
  13. // 注册过滤器
  14. @Bean
  15. public RouteLocator customRoute(RouteLocatorBuilder builder) {
  16.     return builder.routes()
  17.         .route(r -> r.path("/custom/**")
  18.             .filters(f -> f.filter(new LoggingFilter()))
  19.             .uri("lb://custom-service"))
  20.         .build();
  21. }
复制代码
过滤器执行顺序
过滤器类型默认顺序典范用途Global Pre-1000认证/限流Route Filter0路由级修改Global Post1000日志/指标收集Error Handling最高优先级非常处置惩罚 七、进阶实战与性能调优

1. 微服务全链路监控

1.1 SkyWalking深度集成

Trace ID透传方案

  1. ```java
  2. // 手动埋点示例
  3. @RestController
  4. public class OrderController {
  5.     @GetMapping("/orders")
  6.     public List<Order> listOrders(@RequestHeader(value = "sw8", required = false) String traceId) {
  7.         // 跨服务传递Trace ID
  8.         return restTemplate.exchange("http://payment-service/payments",
  9.             HttpMethod.GET,
  10.             new HttpEntity<>(createHeadersWithTrace(traceId)),
  11.             List.class);
  12.     }
  14.     private HttpHeaders createHeadersWithTrace(String traceId) {
  15.         HttpHeaders headers = new HttpHeaders();
  16.         if (traceId != null) {
  17.             headers.add("sw8", traceId); // SkyWalking Header规范
  18.         }
  19.         return headers;
  20.     }
  21. }
复制代码
性能分析设置

  1. agent.config
  2. agent.service_name=${SW_SERVICE_NAME:order-service}
  3. collector.backend_service=${SW_GRPC:skywalking-oap:11800}
  4. sampler.rate=${SW_SAMPLER_RATE:5000} # 采样率
  5. logging.level=${SW_LOGGING_LEVEL:INFO}
复制代码
1.2 Prometheus指标埋点

自定义业务指标

  1. @RestController
  2. public class MetricsController {
  3.     private final Counter orderCounter = Counter.build()
  4.         .name("order_create_total")
  5.         .help("Total orders created")
  6.         .register();
  8.     @PostMapping("/orders")
  9.     public Order createOrder() {
  10.         orderCounter.inc(); // 指标计数
  11.         return orderService.create();
  12.     }
  13. }
复制代码
Grafana监控看板

  1. -- 订单成功率查询
  2. 100 - (sum(rate(http_server_requests_errors_total{application="$application"}[5m]))
  3.   / sum(rate(http_server_requests_total{application="$application"}[5m])) * 100)
复制代码
2. 云原生环境适配

2.1 Kubernetes摆设方案

Nacos集群StatefulSet设置

  1. nacos-statefulset.yaml
  2. apiVersion: apps/v1
  3. kind: StatefulSet
  4. metadata:
  5.   name: nacos
  6. spec:
  7.   serviceName: nacos-headless
  8.   replicas: 3
  9.   template:
  10.     spec:
  11.       containers:
  12.       ◦ name: nacos
  14.         image: nacos/nacos-server:2.2.3
  15.         env:
  16.         ▪ name: MODE
  18.           value: cluster
  19.         ▪ name: SPRING_DATASOURCE_PLATFORM
  21.           value: mysql
  22.         ▪ name: MYSQL_SERVICE_HOST
  24.           value: "mysql-service"
复制代码
服务网格Sidecar注入

  1. istio-sidecar-injection.yaml
  2. apiVersion: apps/v1
  3. kind: Deployment
  4. metadata:
  5.   name: order-service
  6.   annotations:
  7.     sidecar.istio.io/inject: "true" # 自动注入Envoy
  8. spec:
  9.   template:
  10.     metadata:
  11.       labels:
  12.         app: order-service
复制代码
3. 生产环境踩坑指南

3.1 Nacos客户端重试机制

重试策略设置

  1. application.properties
  2. spring.cloud.nacos.discovery.fail-fast=true
  3. spring.cloud.nacos.discovery.retry.max-attempts=5
  4. spring.cloud.nacos.discovery.retry.initial-interval=1000
  5. spring.cloud.nacos.discovery.retry.multiplier=1.5
复制代码
重试过程日志分析

  1. 2023-08-20 14:00:00 [nacos-retry] 第1次重试连接Nacos服务器...
  2. 2023-08-20 14:00:01 [nacos-retry] 第2次重试(间隔1500ms)...
  3. 2023-08-20 14:00:03 [nacos-retry] 连接成功！
复制代码
3.2 Sentinel规则长期化问题

常见故障场景

问题征象根本缘故起因办理方案规则频繁丢失Nacos长轮询超时调整config.long-poll-timeout=30000部门节点规则差异步网络分区启用TCP健康检查控制台修改不生效未开启push模式设置sentinel.dashboard.push=127.0.0.1:8080 调试命令

  1. 检查规则是否持久化到Nacos
  2. curl -X GET "http://nacos-server:8848/nacos/v1/cs/configs?dataId=sentinel-rule&group=DEFAULT_GROUP"
复制代码
八、求职口试专题突破

1. 计划类问题

1.1 亿级电商架构计划

高可用架构方案

  1. ```mermaid
  2. graph TD
  3.     A[客户端] --> B[SLB]
  4.     B --> C[API Gateway]
  5.     C --> D[服务网格]
  6.     D --> E[核心服务集群]
  7.     E --> F[分布式缓存]
  8.     F --> G[分库分表]
  9.     G --> H[异地多活]
  11.     style A fill:#f9f,stroke:#333
  12.     style H fill:#bbf,stroke:#333
复制代码
关键组件选型

场景技能栈优化要点秒杀体系Sentinel+Redis+Lua当地缓存+令牌桶限流订单中心Seata AT模式+分库分表热点数据分离商品详情RocketMQ+当地缓存多级缓存策略 1.2 Seata性能优化

跨库事务优化方案

  1. // 批量操作优化
  2. @GlobalTransactional
  3. public void batchProcess(List<Order> orders) {
  4.     // 1. 开启并行模式
  5.     orders.parallelStream().forEach(order -> {
  6.         // 2. 本地事务表批量插入
  7.         orderMapper.batchInsert(order);
  8.     });
  9.    
  10.     // 3. 异步提交全局事务
  11.     CompletableFuture.runAsync(() -> {
  12.         GlobalTransactionContext.reload(RootContext.getXID()).commit();
  13.     });
  14. }
复制代码
2. 源码级深挖

2.1 Nacos心跳机制

核心源码路径

  1. // ClientBeatCheckTask.run()
  2. public void run() {
  3.     // 心跳间隔动态调整（默认5s）
  4.     long nextTime = calculateNextTime();
  5.     // 心跳数据包构造
  6.     BeatInfo beatInfo = buildBeatInfo();
  7.     // 异步发送心跳
  8.     beatReactor.sendBeat(beatInfo);
  9. }
  11. // NacosNamingService.registerInstance()
  12. public void registerInstance(...) {
  13.     // 首次注册立即发送心跳
  14.     beatReactor.addBeatInfo(serviceName, beatInfo);
  15. }
复制代码
心跳非常处置惩罚

  1. @startuml
  2. participant Client
  3. participant Server
  5. Client -> Server: 发送心跳
  6. alt 正常响应
  7.     Server --> Client: OK
  8. else 超时未响应
  9.     Client -> Client: 指数退避重试
  10. end
  11. @enduml
复制代码
2.2 Sentinel滑动窗口

算法实现核心

  1. // ArrayMetric.leapWindow
  2. public void add(long currentTime, int count) {
  3.     // 1. 计算时间窗口下标
  4.     int idx = calculateTimeIdx(currentTime);
  5.     // 2. 更新窗口计数
  6.     WindowWrap<MetricBucket> old = array.get(idx);
  7.     if (old == null || !old.isTimeInWindow(currentTime)) {
  8.         // 创建新窗口
  9.         array.compareAndSet(idx, old, new WindowWrap<>(...));
  10.     }
  11.     old.value().add(count);
  12. }
  14. // StatisticNode.avgRt
  15. public double avgRt() {
  16.     // 滑动聚合计算
  17.     return rollingCounterInMinute.avgTime() * 60.0 / rollingCounterInMinute.totalCount();
  18. }
复制代码
3. 场景开放题

3.1 微服务雪崩办理方案

全链路防护体系

  1. 多级防护配置
  2. spring:
  3.   cloud:
  4.     sentinel:
  5.       flow:
  6.         qps-threshold: 1000 # 入口QPS限制
  7.       circuit:
  8.         rules:
  9.           ▪ resource: paymentApi
  11.             strategy: SlowRequestRatio
  12.             threshold: 0.5 # 慢调用比例
  13.       system:
  14.         highestSystemLoad: 4.0 # 系统负载保护
复制代码
应急处置惩罚流程

3.2 迁移挑战与方案

关键挑战对比

迁移难点Netflix方案Alibaba方案服务发现Eureka静态集群Nacos动态分区设置管理Config+Bus手动刷新Nacos主动推送事务支持无Seata完整方案 迁移实行步骤

[code][/code] 评估现有架构
组件替代方案计划
灰度迁移测试
监控对比验证
全量切换

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 IT评测·应用市场-qidao123.com技术社区 (https://dis.qidao123.com/) Powered by Discuz! X3.4