微服务架构在Java开发中的关键技术与实现方式

@Service
public class OrderService {
    // ... 省略其他方法
    
    @Autowired
    private InventoryService inventoryService;
    
    public void createOrder(Order order) {
        // ... 创建订单逻辑
        
        // 调用库存服务进行库存扣减
        inventoryService.reduceStock(order.getSkuId(), order.getQuantity());
    }
}

@Service
public class InventoryService {
    // ... 省略其他方法
    
    public void reduceStock(Long skuId, Integer quantity) {
        // ... 扣减库存逻辑
    }
}

// 定义库存服务的Feign接口
@FeignClient(name = "inventory-service")
public interface InventoryService {
    @RequestMapping(value = "/reduceStock", method = RequestMethod.POST)
    void reduceStock(@RequestParam("skuId") Long skuId, @RequestParam("quantity") Integer quantity);
}

// API网关路由配置
@Configuration
public class GatewayConfiguration {
    @Bean
    public RouteLocator gatewayRoutes(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("inventory-service", r -> r.path("/inventory/**").uri("lb://inventory-service"))
                .build();
    }
}

# 部分配置省略

eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8761/eureka/

@HystrixCommand(fallbackMethod = "fallbackMethod")
public void reduceStock(Long skuId, Integer quantity) {
    // ... 扣减库存逻辑
}

// 开启分布式事务
@GlobalTransactional
public void createOrder(Order order) {
    // ... 创建订单逻辑
    
    // 调用库存服务进行库存扣减
    inventoryService.reduceStock(order.getSkuId(), order.getQuantity());
    
    // ... 其他逻辑
}