作者：洛水石
> 标签：微服务网关、Spring Cloud Gateway、鉴权、限流、日志

__________________________________________________

一、为什么需要微服务网关

1.1 单体应用 vs 微服务架构

在单体应用中，所有功能模块共享一个入口：

``__INLINE_

客户端 → Nginx → 单体应用(用户/订单/支付模块)

__`__INLINE_

微服务架构下，服务数量爆炸式增长：

__`__INLINE_

客户端 → 用户服务:8081

→ 订单服务:8082

→ 支付服务:8083

→ 库存服务:8084

→ 物流服务:8085

→ ...

__`__INLINE_

没有网关的问题：

- 客户端需要维护多个服务地址

- 每个服务都要实现鉴权、限流、日志

- 跨域问题需要在每个服务处理

- 服务升级时客户端需要同步修改

1.2 网关的核心价值

__`__INLINE_

┌─────────────────────────────────────────────┐

│               微服务网关                      │

│  ┌─────────┬─────────┬─────────┬─────────┐ │

│  │  路由    │  鉴权   │  限流   │  日志   │ │

│  │ Routing │  Auth   │  Rate   │  Log    │ │

│  │         │         │  Limit  │         │ │

│  └─────────┴─────────┴─────────┴─────────┘ │

└─────────────────────────────────────────────┘

│              │              │

用户服务    订单服务    支付服务    库存服务

__`__INLINE_

网关统一处理：

- 路由转发：/api/users → 用户服务

- 统一鉴权：JWT Token 校验

- 限流熔断：保护后端服务

- 日志追踪：请求全链路记录

__________________________________________________

二、Spring Cloud Gateway 快速入门

2.1 核心概念

概念	说明	示例
Route	路由规则	/api/users/** → lb://user-service
Predicate	断言条件	Path、Method、Header
Filter	过滤器	鉴权、限流、日志

2.2 基础配置

pom.xml 依赖：

__`__INLINE_xml

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-gateway</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-loadbalancer</artifactId>

</dependency>

</dependencies>

__`__INLINE_

application.yml 基础路由：

__`__INLINE_yaml

server:

port: 8080

spring:

application:

name: gateway-service

cloud:

gateway:

routes:

用户服务路由

- id: user-service

uri: lb://user-service

predicates:

- Path=/api/users/**

filters:

- StripPrefix=1

订单服务路由

- id: order-service

uri: lb://order-service

predicates:

- Path=/api/orders/**

filters:

- StripPrefix=1

支付服务路由

- id: pay-service

uri: lb://pay-service

predicates:

- Path=/api/pay/**

filters:

- StripPrefix=1

__`__INLINE_

路由说明：

- __lb://__INLINE_：使用 LoadBalancer 负载均衡

- __StripPrefix=1__INLINE_：去掉第一个前缀 /api

- 例如：__/api/users/info → /users/info__INLINE_

__________________________________________________

三、统一鉴权实战

3.1 JWT 鉴权方案

__`__INLINE_

┌─────────┐         ┌─────────┐         ┌─────────┐

│  客户端  │ ──────→ │  网关    │ ──────→ │  业务服务 │

└─────────┘         └─────────┘         └─────────┘

│                  │

│ 1.登录获取Token   │

│←─────────────────│

│                  │

│ 2.请求携带Token   │

│─────────────────→│ 3.校验Token

│                  │

│ 4.返回数据        │ 5.转发请求

│←─────────────────│←───────────────│

__`__INLINE_

3.2 全局鉴权过滤器

__`__INLINE_java

@Component

@Slf4j

public class AuthGlobalFilter implements GlobalFilter, Ordered {

@Autowired

private JwtTokenProvider tokenProvider;

// 白名单路径（不需要鉴权）

private static final List<String__QUOTE_1__

3.3 Token 刷新机制

__`__INLINE_java

@Component

public class TokenRefreshFilter implements GlobalFilter, Ordered {

@Autowired

private JwtTokenProvider tokenProvider;

@Override

public Mono<Void__QUOTE_2__

3.4 权限控制（RBAC）

__`__INLINE_java

@Component

public class RbacAuthFilter implements GlobalFilter, Ordered {

// URL-角色映射配置

private static final Map<String, List<String>__QUOTE_3__

__________________________________________________

四、网关限流实战

4.1 限流算法选择

算法	特点	适用场景
固定窗口	简单，但存在突刺	简单限流
滑动窗口	平滑，精度高	精确限流
令牌桶	允许突发，平滑	API网关
漏桶	强制平滑输出	流量整形

网关推荐：令牌桶算法

4.2 Redis + Lua 分布式限流

__`__INLINE_java

@Component

public class RateLimitFilter implements GlobalFilter, Ordered {

@Autowired

private StringRedisTemplate redisTemplate;

// 限流配置：路径 -__QUOTE_4__

4.3 热点参数限流（Sentinel 集成）

__`__INLINE_java

@Configuration

public class SentinelGatewayConfig {

@PostConstruct

public void init() {

// 注册网关规则

GatewayRuleManager.loadRules(Arrays.asList(

// 用户API限流：100 QPS

new GatewayFlowRule("user-service")

.setCount(100)

.setIntervalSec(1),

// 订单API限流：50 QPS，热点参数限流

new GatewayFlowRule("order-service")

.setCount(50)

.setIntervalSec(1)

.setParamItem(new GatewayParamFlowItem()

.setParseStrategy(SentinelGatewayConstants.PARAM_PARSE_STRATEGY_URL_PARAM)

.setFieldName("userId")

),

// 支付API严格限流：10 QPS

new GatewayFlowRule("pay-service")

.setCount(10)

.setIntervalSec(1)

.setGrade(RuleConstant.FLOW_GRADE_QPS)

));

}

}

__`__INLINE_

__________________________________________________

五、全链路日志追踪

5.1 TraceID 传递

__`__INLINE_java

@Component

@Slf4j

public class TraceFilter implements GlobalFilter, Ordered {

public static final String TRACE_ID_HEADER = "X-Trace-Id";

public static final String SPAN_ID_HEADER = "X-Span-Id";

@Override

public Mono<Void__QUOTE_5__

5.2 异步日志收集

__`__INLINE_java

@Component

@Slf4j

public class AccessLogFilter implements GlobalFilter, Ordered {

@Autowired

private AccessLogProducer logProducer;

@Override

public Mono<Void__QUOTE_6__

5.3 ELK 日志查询

__`__INLINE_json

// Kibana 查询DSL

{

"query": {

"bool": {

"must": [

{ "match": { "traceId": "abc123def456" } },

{ "range": { "timestamp": { "gte": "now-1h" } } }

]

}

},

"sort": [{ "timestamp": "asc" }],

"aggs": {

"latency_percentiles": {

"percentiles": { "field": "duration", "percents": [50, 95, 99] }

}

}

}

__`__INLINE_

__________________________________________________

六、完整配置示例

6.1 application.yml

__`__INLINE_yaml

spring:

cloud:

gateway:

默认过滤器（所有路由生效）

default-filters:

- name: Retry

args:

retries: 3

statuses: BAD_GATEWAY,SERVICE_UNAVAILABLE

- name: CircuitBreaker

args:

name: default

fallbackUri: forward:/fallback

全局跨域配置

globalcors:

cors-configurations:

'[/**]':

allowedOrigins: "*"

allowedMethods: GET,POST,PUT,DELETE,OPTIONS

allowedHeaders: "*"

allowCredentials: false

maxAge: 3600

路由配置

routes:

- id: user-service

uri: lb://user-service

predicates:

- Path=/api/users/**

- Method=GET,POST,PUT,DELETE

filters:

- StripPrefix=1

- name: RequestRateLimiter

args:

redis-rate-limiter.replenishRate: 100

redis-rate-limiter.burstCapacity: 150

key-resolver: "#{@ipKeyResolver}"

- name: Hystrix

args:

name: user-service

fallbackUri: forward:/fallback/user

- id: order-service

uri: lb://order-service

predicates:

- Path=/api/orders/**

filters:

- StripPrefix=1

- name: RequestRateLimiter

args:

redis-rate-limiter.replenishRate: 50

redis-rate-limiter.burstCapacity: 80

熔断器配置

hystrix:

command:

default:

execution:

isolation:

thread:

timeoutInMilliseconds: 5000

circuitBreaker:

requestVolumeThreshold: 10

sleepWindowInMilliseconds: 10000

errorThresholdPercentage: 50

__`__INLINE_

6.2 网关启动类

__`__INLINE_java

@SpringBootApplication

@EnableDiscoveryClient

public class GatewayApplication {

public static void main(String[] args) {

SpringApplication.run(GatewayApplication.class, args);

}

@Bean

public KeyResolver ipKeyResolver() {

return exchange -__QUOTE_7__

__________________________________________________

七、性能优化建议

7.1 网关性能指标

指标	目标值	优化方案
吞吐量

7.2 生产环境配置

__`__INLINE_yaml

JVM 参数

-Xms2g -Xmx2g

-XX:+UseG1GC

-XX:MaxGCPauseMillis=100

-Dreactor.netty.ioWorkerCount=16

Netty 配置

spring:

cloud:

gateway:

httpclient:

connect-timeout: 2000

response-timeout: 5s

pool:

type: elastic

max-connections: 1000

max-idle-time: 10s

__``

__________________________________________________

总结

微服务网关三大核心能力：

能力	关键实现	注意事项
**统一鉴权**	JWT + 全局过滤器	Token刷新、RBAC权限控制
**限流保护**	令牌桶 + Redis	分布式限流、热点参数限流
**日志追踪**	TraceID + ELK	异步收集、全链路追踪

作者：洛水石 | 架构进阶 | 微服务网关实战

作者：洛水石 | 架构进阶 | Java高并发实战