Mesh 微服务平台秒杀

apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  name: mesh-ingress
spec:
  rules:
  - host: example.com
    http:
      paths:
      - path: /
        pathType: Prefix
        backend:
          service:
            name: mesh-service
            port:
              number: 80

import io.github.resilience4j.ratelimiter.RateLimiter;
import io.github.resilience4j.ratelimiter.RateLimiterConfig;
import io.github.resilience4j.ratelimiter.RateLimiterRegistry;

RateLimiterConfig config = RateLimiterConfig.custom()
    .limitForPeriod(10)
    .limitRefreshPeriod(Duration.ofSeconds(1))
    .timeoutDuration(Duration.ofMillis(100))
    .build();

RateLimiterRegistry rateLimiterRegistry = RateLimiterRegistry.of(config);
RateLimiter rateLimiter = rateLimiterRegistry.rateLimiter("myRateLimiter");

CheckedFunction0<String> restrictedCall = RateLimiter.decorateCheckedSupplier(rateLimiter, () -> "Hello World");
Try<String> result = Try.of(restrictedCall)
    .recover(throwable -> "Hello from Recovery").get();

-- 示例：创建读写分离的数据库用户
CREATE USER 'readonlyuser'@'%' IDENTIFIED BY 'password';
GRANT SELECT ON mydatabase.* TO 'readonlyuser'@'%';