Java微服务开发实战：Spring Cloud分布式架构与弹性模式指南
java-microservices by pluginagentmarketplace/custom-plugin-java
安装命令
npx skills add https://github.com/pluginagentmarketplace/custom-plugin-java --skill java-microservices🇨🇳中文介绍
Java 微服务技能
使用 Spring Cloud 和分布式系统模式构建生产级微服务。
概述
本技能涵盖使用 Spring Cloud 的微服务架构，包括服务发现、API 网关、断路器、事件驱动通信和分布式追踪。
何时使用此技能
在您需要时使用：
- 设计微服务架构
- 实现服务间通信
- 配置弹性模式
- 设置事件驱动消息传递
- 添加分布式追踪
涵盖主题
Spring Cloud 组件
- 配置服务器（集中式配置）
- 服务发现（Eureka, Consul）
- API 网关（Spring Cloud Gateway）
- 负载均衡（Spring Cloud LoadBalancer）
弹性模式
- 断路器（Resilience4j）
- 带退避的重试
- 舱壁隔离
- 速率限制
事件驱动架构
- Apache Kafka 集成
- Spring Cloud Stream
- Saga 模式
- 事件溯源基础
可观测性
- 分布式追踪（Micrometer）
- 指标（Prometheus）
- 日志关联
快速参考
// Saga with Choreography
@Component
public class OrderSagaListener {
@KafkaListener(topics = "order.created")
public void handleOrderCreated(OrderCreatedEvent event) {
inventoryService.reserve(event.getItems());
}
@KafkaListener(topics = "payment.failed")
public void handlePaymentFailed(PaymentFailedEvent event) {
// Compensating transaction
inventoryService.release(event.getOrderId());
orderService.cancel(event.getOrderId());
}
}
// Circuit Breaker Configuration
@Configuration
public class ResilienceConfig {
@Bean
public Customizer<Resilience4JCircuitBreakerFactory> cbCustomizer() {
return factory -> factory.configureDefault(id ->
new Resilience4JConfigBuilder(id)
.circuitBreakerConfig(CircuitBreakerConfig.custom()
.failureRateThreshold(50)
.waitDurationInOpenState(Duration.ofSeconds(30))
.slidingWindowSize(10)
.build())
.build());
}
}
// API Gateway Routes
@Configuration
public class GatewayConfig {
@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
return builder.routes()
.route("orders", r -> r
.path("/api/orders/**")
.filters(f -> f
.stripPrefix(1)
.circuitBreaker(c -> c.setName("order-cb"))
.retry(retry -> retry.setRetries(3)))
.uri("lb://order-service"))
.build();
}
}
广告位招租
在这里展示您的产品或服务
触达数万 AI 开发者，精准高效
