Spring Boot 3 微服务架构实战 云原生电商平台全流程构建

// 使用Spring Cloud Gateway配置路由
@Configuration
public class GatewayConfig {
    @Bean
    public RouteLocator routes(RouteLocatorBuilder builder) {
        return builder.routes()
            .route("user-service", r -> r.path("/api/users/**")
                .uri("lb://user-service"))
            .route("product-service", r -> r.path("/api/products/**")
                .uri("lb://product-service"))
            .build();
    }
}

// 服务注册
@SpringBootApplication
@EnableEurekaClient
public class UserServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }
}

@RestController
@RequestMapping("/api/products")
public class ProductController {
    
    private final ProductService productService;
    
    public ProductController(ProductService productService) {
        this.productService = productService;
    }
    
    @GetMapping
    public Flux<Product> getAllProducts() {
        return productService.findAll();
    }
    
    @GetMapping("/{id}")
    public Mono<Product> getProductById(@PathVariable String id) {
        return productService.findById(id);
    }
    
    @PostMapping
    @ResponseStatus(HttpStatus.CREATED)
    public Mono<Product> createProduct(@RequestBody Product product) {
        return productService.save(product);
    }
}

@Configuration
@EnableWebSecurity
public class SecurityConfig {
    
    @Bean
    public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
        http
            .authorizeRequests()
                .antMatchers("/api/auth/**").permitAll()
                .anyRequest().authenticated()
                .and()
            .oauth2ResourceServer()
                .jwt();
        
        return http.build();
    }
    
    @Bean
    public JwtDecoder jwtDecoder() {
        return NimbusJwtDecoder.withJwkSetUri(jwkSetUri).build();
    }
}

@Service
public class OrderService {
    
    private final KafkaTemplate<String, OrderEvent> kafkaTemplate;
    
    @Autowired
    public OrderService(KafkaTemplate<String, OrderEvent> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }
    
    @Transactional
    public Order createOrder(Order order) {
        // 保存订单
        Order savedOrder = orderRepository.save(order);
        
        // 发送订单创建事件
        OrderEvent event = new OrderEvent(savedOrder.getId(), "ORDER_CREATED");
        kafkaTemplate.send("order-events", event);
        
        return savedOrder;
    }
}

@Service
public class InventoryService {
    
    @KafkaListener(topics = "order-events")
    public void processOrderEvent(OrderEvent event) {
        if ("ORDER_CREATED".equals(event.getType())) {
            // 处理库存扣减逻辑
            reduceInventory(event.getOrderId());
        }
    }
}

@GlobalTransactional
public Order createOrder(Order order) {
    // 1. 保存订单
    Order savedOrder = orderRepository.save(order);
    
    // 2. 扣减库存
    inventoryService.reduceInventory(order.getProductId(), order.getQuantity());
    
    // 3. 创建支付记录
    paymentService.createPaymentRecord(savedOrder.getId(), savedOrder.getTotalAmount());
    
    return savedOrder;
}

FROM eclipse-temurin:17-jre-alpine
VOLUME /tmp
COPY target/user-service-0.0.1-SNAPSHOT.jar app.jar
ENTRYPOINT ["java","-jar","/app.jar"]

apiVersion: apps/v1
kind: Deployment
metadata:
  name: user-service
spec:
  replicas: 3
  selector:
    matchLabels:
      app: user-service
  template:
    metadata:
      labels:
        app: user-service
    spec:
      containers:
      - name: user-service
        image: registry.example.com/user-service:latest
        ports:
        - containerPort: 8080
        env:
        - name: SPRING_PROFILES_ACTIVE
          value: "prod"
        - name: CONFIG_SERVER_URL
          value: "http://config-server:8888"

@RestController
@RequestMapping("/api/metrics")
public class MetricsController {
    
    private final Counter requestCounter;
    
    @Autowired
    public MetricsController(MeterRegistry registry) {
        this.requestCounter = registry.counter("api.requests", "endpoint", "/api/metrics");
    }
    
    @GetMapping
    public ResponseEntity<String> getMetrics() {
        requestCounter.increment();
        return ResponseEntity.ok("Metrics endpoint");
    }
}

name: CI/CD Pipeline

on:
  push:
    branches: [ main ]

jobs:
  build:
    runs-on: ubuntu-latest
    
    steps:
    - uses: actions/checkout@v3
    - name: Set up JDK 17
      uses: actions/setup-java@v3
      with:
        java-version: '17'
        distribution: 'temurin'
    
    - name: Build with Maven
      run: mvn clean package -DskipTests
    
    - name: Upload artifact
      uses: actions/upload-artifact@v3
      with:
        name: application
        path: target/*.jar

  deploy:
    needs: build
    runs-on: ubuntu-latest
    
    steps:
    - name: Download artifact
      uses: actions/download-artifact@v3
      with:
        name: application
    
    - name: Deploy to Kubernetes
      uses: steebchen/kubectl@v2.0.0
      with:
        config: ${{ secrets.KUBE_CONFIG_DATA }}
        command: |
          kubectl set image deployment/user-service user-service=registry.example.com/user-service:${{ github.sha }}