如何解决请求消峰?主要实现代码及注解

请求消峰主要是通过流量控制策略来分散高并发访问期间的压力，常见的方法有以下几种：

1. **限流**：限制一段时间内对服务的访问频率，比如滑动窗口限流、令牌桶算法等。例如，Spring Cloud 提供了 `RateLimiter` 和 `Guava RateLimiter` 等工具。

// 使用Spring Cloud限流注解
@Autowired
public void initRateLimiter(FlowableRateLimiter rateLimiter) {
    RateLimiterConfig config = new RateLimiterConfig();
    // 设置令牌生成速率
    config.setTokenAmountPerSecond(50); // 每秒生成50个令牌
    // 创建RateLimiter实例
    this.rateLimiter = rateLimiter.limit(config);
}

@GetMapping("/api")
@RateLimiter(name = "myApi", limitForPeriod = "1s") // 限流配置
public ResponseEntity<String> handleRequest() {
    if (rateLimiter.tryAcquire()) { // 尝试获取令牌，如果成功，则继续处理请求
        // 处理业务逻辑...
        return ResponseEntity.ok("处理完成");
    } else {
        // 令牌不足，返回错误信息并拒绝请求
        return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).body("请求过多");
    }
}

2. **降级/熔断**：当主服务不可用时，切换到备用服务或简单地返回预定义结果，防止雪崩效应。Hystrix 或 Resilience4j 是常用的降级框架。

// Hystrix示例
HystrixCommand<String> command = new HystrixCommand<>(
    new Callable<String>() {
        @Override
        public String call() throws Exception {
            // 主服务请求
            return service.handleRequest();
        }
    },
    // 设置熔断策略
    new HystrixThreadPoolProperties.Setter()
        .withCoreSize(1)
        .withQueueSizeRejectionThreshold(-1),
    new HystrixCommandProperties.Setter()
        .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE)
);