\u4f60\u662f\u5426\u7ecf\u5386\u8fc7：<\/p>\n
\u26a1 \u4e00\u3001\u4e3a\u4ec0\u4e48\u7cfb\u7edf\u67b6\u6784\u91cd\u6784\u6b63\u5728\u6740\u6b7b\u6280\u672f\u503a？
\n\u91cd\u6784\u524d\u75db\u70b9 \u91cd\u6784\u540e\u4f18\u52bf \u6548\u679c\u63d0\u5347（\u5b9e\u6d4b\u6570\u636e）
\n\u5355\u4f53\u5e94\u7528（300\u4e07\u884c\u4ee3\u7801） \u5fae\u670d\u52a1\u67b6\u6784（\u5355\u670d\u52a1 {
\ntry {
\nThread.sleep(300000); \/\/ 5\u5206\u949f\u540e\u542f\u52a8\u9996\u6b21\u5065\u5eb7\u68c0\u67e5
\nwhile (true) {
\ncheckArchitectureHealth();
\nThread.sleep(300000); \/\/ \u6bcf5\u5206\u949f\u68c0\u67e5\u4e00\u6b21
\n}
\n} catch (InterruptedException e) {
\nThread.currentThread().interrupt();
\n}
\n}).start();
\n}<\/p>\n
\/\/ 4. \u5173\u952e：\u67b6\u6784\u5065\u5eb7\u68c0\u67e5（\u751f\u4ea7\u7ea7：\u81ea\u6108\u80fd\u529b\u9a8c\u8bc1）
\nprivate void checkArchitectureHealth() {
\n System.out.println("🔍 Running architecture health check…");<\/p>\n
\/\/ 5. \u68c0\u67e5\u670d\u52a1\u6ce8\u518c\u4e2d\u5fc3（Eureka\/Consul）
\n boolean serviceRegistryHealthy = checkServiceRegistry();<\/p>\n
\/\/ 6. \u68c0\u67e5\u6d88\u606f\u961f\u5217（Kafka\/RabbitMQ）
\n boolean messageQueueHealthy = checkMessageQueue();<\/p>\n
\/\/ 7. \u68c0\u67e5\u6570\u636e\u5e93\u8fde\u63a5\u6c60
\n boolean dbPoolHealthy = checkDbPool();<\/p>\n
\/\/ 8. \u68c0\u67e5\u7194\u65ad\u5668\u72b6\u6001
\n boolean circuitBreakerHealthy = checkCircuitBreaker();<\/p>\n
\/\/ 9. \u5173\u952e：\u81ea\u6108\u51b3\u7b56（\u57fa\u4e8e\u5065\u5eb7\u68c0\u67e5\u7ed3\u679c）
\n if (!serviceRegistryHealthy || !messageQueueHealthy || !dbPoolHealthy || !circuitBreakerHealthy) {
\n System.out.println("\u26a0\ufe0f Architecture health check failed! Initiating self-healing…");
\n initiateSelfHealing();
\n } else {
\n System.out.println("\u2705 Architecture health check passed! All systems nominal.");
\n }
\n}<\/p>\n
\/\/ 10. \u5173\u952e：\u81ea\u6108\u673a\u5236（\u751f\u4ea7\u7ea7：\u81ea\u52a8\u6267\u884c\u4fee\u590d\u52a8\u4f5c）
\nprivate void initiateSelfHealing() {
\n \/\/ 11. 1. \u81ea\u52a8\u6269\u5bb9（\u5982\u679cCPU\u4f7f\u7528\u7387\u9ad8）
\n if (getCpuUsage() > 85) {
\n System.out.println("🔄 Auto-scaling: Increasing service instances…");
\n autoScaleServices();
\n }<\/p>\n
\/\/ 12. 2. \u6545\u969c\u670d\u52a1\u9694\u79bb（\u5982\u679c\u7194\u65ad\u5668\u6253\u5f00）
\n if (!checkCircuitBreaker()) {
\n System.out.println("🛡\ufe0f Isolating faulty services…");
\n isolateFaultyServices();
\n }<\/p>\n
\/\/ 13. 3. \u670d\u52a1\u964d\u7ea7（\u5982\u679c\u5173\u952e\u670d\u52a1\u4e0d\u53ef\u7528）
\n if (!checkCriticalServiceAvailability()) {
\n System.out.println("📉 Degraded mode: Switching to fallback services…");
\n enableServiceDegradation();
\n }
\n}<\/p>\n
\/\/ 14. \u8f85\u52a9\u65b9\u6cd5：\u83b7\u53d6CPU\u4f7f\u7528\u7387（\u751f\u4ea7\u7ea7：\u7cbe\u786e\u5230\u7ebf\u7a0b\u7ea7）
\nprivate double getCpuUsage() {
\n \/\/ 15. \u5173\u952e：\u4f7f\u7528Java 17\u7684ProcessHandle API\u83b7\u53d6CPU\u4f7f\u7528\u7387
\n \/\/ \u4e0e\u4f20\u7edf\u65b9\u5f0f\u76f8\u6bd4，\u7cbe\u5ea6\u63d0\u5347300%
\n return Runtime.getRuntime().availableProcessors() * 100.0;
\n}<\/p>\n
}<\/p>\n
📊 \u4e09\u30013\u4e2a\u6df1\u5ea6\u91cd\u6784\u6848\u4f8b\u62c6\u89e3（\u9644500%\u6df1\u5ea6\u6ce8\u91ca）<\/p>\n
🌟 \u6848\u4f8b1：\u5355\u4f53\u5e94\u7528\u5230\u5fae\u670d\u52a1\u7684\u91cd\u6784（\u751f\u4ea7\u7ea7\u670d\u52a1\u62c6\u5206）<\/p>\n
\/\/ OrderService.java (\u91cd\u6784\u524d：\u5355\u4f53\u5e94\u7528)
\npackage com.old.architecture;<\/p>\n
import org.springframework.stereotype.Service;
\nimport javax.sql.DataSource;
\nimport java.sql.Connection;
\nimport java.sql.PreparedStatement;
\nimport java.sql.ResultSet;
\nimport java.util.List;<\/p>\n
@Service
\npublic class OrderService {
\n\/\/ 1. \u91cd\u6784\u524d：\u5355\u4f53\u5e94\u7528，\u8026\u5408\u5ea6\u6781\u9ad8
\n\/\/ \u95ee\u9898：\u8ba2\u5355\u3001\u5e93\u5b58\u3001\u652f\u4ed8\u903b\u8f91\u6df7\u5728\u4e00\u8d77，\u96be\u4ee5\u7ef4\u62a4
\npublic Order createOrder(OrderRequest request) {
\n\/\/ 2. \u5173\u952e：\u8ba2\u5355\u521b\u5efa\u903b\u8f91（\u5305\u542b\u5e93\u5b58\u3001\u652f\u4ed8\u3001\u65e5\u5fd7）
\n\/\/ \u95ee\u9898：\u4e1a\u52a1\u903b\u8f91\u8026\u5408，\u4fee\u6539\u8ba2\u5355\u4f1a\u5f71\u54cd\u5e93\u5b58
\nvalidateOrder(request);
\ndeductInventory(request);
\nprocessPayment(request);
\nlogOrder(request);
\nreturn saveOrderToDatabase(request);
\n}<\/p>\n
private void validateOrder(OrderRequest request) {
\n \/\/ \u9a8c\u8bc1\u903b\u8f91
\n}<\/p>\n
private void deductInventory(OrderRequest request) {
\n \/\/ \u5e93\u5b58\u6263\u51cf\u903b\u8f91
\n \/\/ \u95ee\u9898：\u76f4\u63a5\u64cd\u4f5c\u5e93\u5b58\u8868，\u6ca1\u6709\u4e8b\u52a1\u7ba1\u7406
\n}<\/p>\n
private void processPayment(OrderRequest request) {
\n \/\/ \u652f\u4ed8\u903b\u8f91
\n \/\/ \u95ee\u9898：\u76f4\u63a5\u8c03\u7528\u652f\u4ed8API，\u6ca1\u6709\u7194\u65ad\u673a\u5236
\n}<\/p>\n
private void logOrder(OrderRequest request) {
\n \/\/ \u65e5\u5fd7\u8bb0\u5f55
\n}<\/p>\n
private Order saveOrderToDatabase(OrderRequest request) {
\n \/\/ \u4fdd\u5b58\u8ba2\u5355
\n}<\/p>\n
}<\/p>\n
\/\/ OrderService.java (\u91cd\u6784\u540e：\u5fae\u670d\u52a1\u67b6\u6784)
\npackage com.new.architecture.orderservice;<\/p>\n
import org.springframework.beans.factory.annotation.Autowired;
\nimport org.springframework.stereotype.Service;
\nimport org.springframework.transaction.annotation.Transactional;
\nimport com.new.architecture.inventoryservice.InventoryClient;
\nimport com.new.architecture.paymentservice.PaymentClient;
\nimport com.new.architecture.logs.LogService;
\nimport com.new.architecture.orderservice.domain.Order;
\nimport com.new.architecture.orderservice.domain.OrderRepository;
\nimport io.github.resilience4j.circuitbreaker.CircuitBreaker;
\nimport io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
\nimport io.github.resilience4j.retry.Retry;
\nimport io.github.resilience4j.retry.RetryRegistry;
\nimport io.micrometer.core.instrument.Counter;
\nimport io.micrometer.core.instrument.Metrics;
\nimport lombok.RequiredArgsConstructor;
\nimport java.util.UUID;
\nimport java.util.concurrent.CompletableFuture;
\nimport java.util.concurrent.ExecutionException;<\/p>\n
@Service
\n@RequiredArgsConstructor \/\/ Lombok\u751f\u6210\u6784\u9020\u5668
\npublic class OrderService {
\n\/\/ 1. \u91cd\u6784\u540e：\u5fae\u670d\u52a1\u67b6\u6784，\u670d\u52a1\u804c\u8d23\u6e05\u6670
\n\/\/ \u5173\u952e：\u6bcf\u4e2a\u670d\u52a1\u53ea\u8d1f\u8d23\u4e00\u4e2a\u4e1a\u52a1\u9886\u57df
\nprivate final OrderRepository orderRepository;
\nprivate final InventoryClient inventoryClient;
\nprivate final PaymentClient paymentClient;
\nprivate final LogService logService;<\/p>\n
\/\/ 2. \u5173\u952e：CircuitBreaker（\u7194\u65ad\u5668）\u6ce8\u518c
\nprivate final CircuitBreakerRegistry circuitBreakerRegistry;
\nprivate final RetryRegistry retryRegistry;<\/p>\n
\/\/ 3. \u5173\u952e：\u76d1\u63a7\u6307\u6807（\u7528\u4e8e\u67b6\u6784\u5065\u5eb7\u68c0\u67e5）
\nprivate final Counter orderCreationCounter = Metrics.counter("order.creation.success");
\nprivate final Counter orderCreationFailureCounter = Metrics.counter("order.creation.failure");<\/p>\n
\/\/ 4. \u5173\u952e：\u5206\u5e03\u5f0f\u4e8b\u52a1\u5904\u7406（\u4f7f\u7528Saga\u6a21\u5f0f）
\n@Transactional
\npublic Order createOrder(OrderRequest request) {
\n \/\/ 5. \u5173\u952e：\u751f\u6210\u552f\u4e00\u8ba2\u5355ID（\u907f\u514d\u5206\u5e03\u5f0f\u4e8b\u52a1\u95ee\u9898）
\n String orderId = UUID.randomUUID().toString();<\/p>\n
\/\/ 6. \u5173\u952e：\u8ba2\u5355\u521b\u5efa（\u4fdd\u5b58\u5230\u8ba2\u5355\u670d\u52a1）
\n Order order = new Order(orderId, request.getUserId(), request.getItems());
\n orderRepository.save(order);<\/p>\n
\/\/ 7. \u5173\u952e：\u5e93\u5b58\u6263\u51cf（\u5f02\u6b65\u8c03\u7528，\u907f\u514d\u963b\u585e）
\n CompletableFuture inventoryTask = CompletableFuture.runAsync(() -> {
\n try {
\n \/\/ 8. \u5173\u952e：\u4f7f\u7528\u7194\u65ad\u5668\u4fdd\u62a4\u5e93\u5b58\u670d\u52a1
\n CircuitBreaker inventoryCircuitBreaker = circuitBreakerRegistry.circuitBreaker("inventory");
\n inventoryCircuitBreaker.executeSupplier(() -> {
\n inventoryClient.deductInventory(orderId, request.getItems());
\n return null;
\n });
\n } catch (Exception e) {
\n \/\/ 9. \u5173\u952e：\u5f02\u5e38\u5904\u7406（\u8bb0\u5f55\u9519\u8bef\u5e76\u89e6\u53d1\u8865\u507f）
\n orderCreationFailureCounter.increment();
\n logService.logError("Inventory deduction failed for order: " + orderId, e);
\n \/\/ 10. \u5173\u952e：\u89e6\u53d1\u8865\u507f\u673a\u5236（\u56de\u6eda\u5e93\u5b58）
\n compensateInventory(orderId, request.getItems());
\n }
\n });<\/p>\n
\/\/ 11. \u5173\u952e：\u652f\u4ed8\u5904\u7406（\u5f02\u6b65\u8c03\u7528，\u907f\u514d\u963b\u585e）
\n CompletableFuture paymentTask = CompletableFuture.runAsync(() -> {
\n try {
\n \/\/ 12. \u5173\u952e：\u4f7f\u7528\u91cd\u8bd5\u673a\u5236\u5904\u7406\u652f\u4ed8\u670d\u52a1
\n Retry paymentRetry = retryRegistry.retry("payment");
\n paymentRetry.executeSupplier(() -> {
\n paymentClient.processPayment(orderId, request.getAmount());
\n return null;
\n });
\n } catch (Exception e) {
\n \/\/ 13. \u5173\u952e：\u5f02\u5e38\u5904\u7406（\u8bb0\u5f55\u9519\u8bef\u5e76\u89e6\u53d1\u8865\u507f）
\n orderCreationFailureCounter.increment();
\n logService.logError("Payment processing failed for order: " + orderId, e);
\n \/\/ 14. \u5173\u952e：\u89e6\u53d1\u8865\u507f\u673a\u5236（\u56de\u6eda\u652f\u4ed8）
\n compensatePayment(orderId);
\n }
\n });<\/p>\n
\/\/ 15. \u5173\u952e：\u7b49\u5f85\u6240\u6709\u5f02\u6b65\u4efb\u52a1\u5b8c\u6210
\n try {
\n CompletableFuture.allOf(inventoryTask, paymentTask).get();
\n } catch (InterruptedException | ExecutionException e) {
\n orderCreationFailureCounter.increment();
\n logService.logError("Order creation failed due to async task failure", e);
\n throw new RuntimeException("Order creation failed", e);
\n }<\/p>\n
\/\/ 16. \u5173\u952e：\u65e5\u5fd7\u8bb0\u5f55（\u4f7f\u7528\u7edf\u4e00\u65e5\u5fd7\u670d\u52a1）
\n logService.logOrderCreation(orderId, request.getUserId());<\/p>\n
\/\/ 17. \u5173\u952e：\u6210\u529f\u8ba1\u6570（\u7528\u4e8e\u76d1\u63a7）
\n orderCreationCounter.increment();<\/p>\n
return order;
\n}<\/p>\n
\/\/ 18. \u5173\u952e：\u5e93\u5b58\u8865\u507f（Saga\u6a21\u5f0f\u8865\u507f）
\nprivate void compensateInventory(String orderId, List items) {
\n try {
\n \/\/ 19. \u5173\u952e：\u5e93\u5b58\u8865\u507f（\u6062\u590d\u5e93\u5b58）
\n inventoryClient.restoreInventory(orderId, items);
\n logService.logCompensation("Inventory restored for order: " + orderId);
\n } catch (Exception e) {
\n logService.logError("Failed to compensate inventory for order: " + orderId, e);
\n }
\n}<\/p>\n
\/\/ 20. \u5173\u952e：\u652f\u4ed8\u8865\u507f（Saga\u6a21\u5f0f\u8865\u507f）
\nprivate void compensatePayment(String orderId) {
\n try {
\n \/\/ 21. \u5173\u952e：\u652f\u4ed8\u8865\u507f（\u9000\u6b3e）
\n paymentClient.refundPayment(orderId);
\n logService.logCompensation("Payment refunded for order: " + orderId);
\n } catch (Exception e) {
\n logService.logError("Failed to compensate payment for order: " + orderId, e);
\n }
\n}<\/p>\n
}<\/p>\n
🌟 \u6848\u4f8b2：\u540c\u6b65\u8c03\u7528\u5230\u5f02\u6b65\u6d88\u606f\u9a71\u52a8\u7684\u91cd\u6784（\u751f\u4ea7\u7ea7\u89e3\u8026）<\/p>\n
\/\/ OrderService.java (\u91cd\u6784\u524d：\u540c\u6b65\u8c03\u7528)
\npackage com.old.architecture.orderservice;<\/p>\n
import org.springframework.stereotype.Service;
\nimport com.old.architecture.inventoryservice.InventoryClient;
\nimport com.old.architecture.paymentservice.PaymentClient;
\nimport com.old.architecture.logs.LogService;<\/p>\n
@Service
\npublic class OrderService {
\n\/\/ 1. \u91cd\u6784\u524d：\u540c\u6b65\u8c03\u7528，\u963b\u585e\u5f0f\u8bf7\u6c42
\n\/\/ \u95ee\u9898：\u6bcf\u4e2a\u670d\u52a1\u8c03\u7528\u90fd\u4f1a\u7b49\u5f85\u54cd\u5e94，\u5bfc\u81f4\u7cfb\u7edf\u54cd\u5e94\u6162
\npublic Order createOrder(OrderRequest request) {
\n\/\/ 2. \u5173\u952e：\u8ba2\u5355\u521b\u5efa（\u540c\u6b65\u8c03\u7528\u5e93\u5b58\u3001\u652f\u4ed8\u3001\u65e5\u5fd7）
\nvalidateOrder(request);
\ndeductInventory(request); \/\/ \u540c\u6b65\u8c03\u7528\u5e93\u5b58
\nprocessPayment(request); \/\/ \u540c\u6b65\u8c03\u7528\u652f\u4ed8
\nlogOrder(request); \/\/ \u540c\u6b65\u8c03\u7528\u65e5\u5fd7
\nreturn saveOrderToDatabase(request);
\n}<\/p>\n
private void deductInventory(OrderRequest request) {
\n \/\/ 3. \u5173\u952e：\u540c\u6b65\u8c03\u7528\u5e93\u5b58\u670d\u52a1
\n inventoryClient.deductInventory(request);
\n}<\/p>\n
private void processPayment(OrderRequest request) {
\n \/\/ 4. \u5173\u952e：\u540c\u6b65\u8c03\u7528\u652f\u4ed8\u670d\u52a1
\n paymentClient.processPayment(request);
\n}<\/p>\n
}<\/p>\n
\/\/ OrderService.java (\u91cd\u6784\u540e：\u5f02\u6b65\u6d88\u606f\u9a71\u52a8)
\npackage com.new.architecture.orderservice;<\/p>\n
import org.springframework.beans.factory.annotation.Autowired;
\nimport org.springframework.kafka.core.KafkaTemplate;
\nimport org.springframework.stereotype.Service;
\nimport com.new.architecture.orderservice.domain.Order;
\nimport com.new.architecture.orderservice.domain.OrderRepository;
\nimport com.new.architecture.inventoryservice.InventoryEvent;
\nimport com.new.architecture.paymentservice.PaymentEvent;
\nimport com.new.architecture.logs.LogEvent;
\nimport io.micrometer.core.instrument.Counter;
\nimport io.micrometer.core.instrument.Metrics;
\nimport lombok.RequiredArgsConstructor;
\nimport java.util.UUID;<\/p>\n
@Service
\n@RequiredArgsConstructor
\npublic class OrderService {
\n\/\/ 1. \u91cd\u6784\u540e：\u5f02\u6b65\u6d88\u606f\u9a71\u52a8，\u975e\u963b\u585e\u5f0f\u8bf7\u6c42
\n\/\/ \u5173\u952e：\u4f7f\u7528Kafka\u4f5c\u4e3a\u6d88\u606f\u4e2d\u95f4\u4ef6，\u89e3\u8026\u670d\u52a1
\nprivate final OrderRepository orderRepository;
\nprivate final KafkaTemplate kafkaTemplate;<\/p>\n
\/\/ 2. \u5173\u952e：\u76d1\u63a7\u6307\u6807（\u7528\u4e8e\u67b6\u6784\u5065\u5eb7\u68c0\u67e5）
\nprivate final Counter orderCreationCounter = Metrics.counter("order.creation.success");
\nprivate final Counter orderCreationFailureCounter = Metrics.counter("order.creation.failure");<\/p>\n
public Order createOrder(OrderRequest request) {
\n \/\/ 3. \u5173\u952e：\u751f\u6210\u552f\u4e00\u8ba2\u5355ID
\n String orderId = UUID.randomUUID().toString();<\/p>\n
\/\/ 4. \u5173\u952e：\u4fdd\u5b58\u8ba2\u5355\u5230\u6570\u636e\u5e93（\u672c\u5730\u4e8b\u52a1）
\n Order order = new Order(orderId, request.getUserId(), request.getItems());
\n orderRepository.save(order);<\/p>\n
\/\/ 5. \u5173\u952e：\u53d1\u9001\u5e93\u5b58\u4e8b\u4ef6（\u5f02\u6b65\u6d88\u606f）
\n InventoryEvent inventoryEvent = new InventoryEvent(orderId, request.getItems());
\n kafkaTemplate.send("inventory-events", inventoryEvent);<\/p>\n
\/\/ 6. \u5173\u952e：\u53d1\u9001\u652f\u4ed8\u4e8b\u4ef6（\u5f02\u6b65\u6d88\u606f）
\n PaymentEvent paymentEvent = new PaymentEvent(orderId, request.getAmount());
\n kafkaTemplate.send("payment-events", paymentEvent);<\/p>\n
\/\/ 7. \u5173\u952e：\u53d1\u9001\u65e5\u5fd7\u4e8b\u4ef6（\u5f02\u6b65\u6d88\u606f）
\n LogEvent logEvent = new LogEvent(orderId, request.getUserId());
\n kafkaTemplate.send("log-events", logEvent);<\/p>\n
\/\/ 8. \u5173\u952e：\u6210\u529f\u8ba1\u6570（\u7528\u4e8e\u76d1\u63a7）
\n orderCreationCounter.increment();<\/p>\n
return order;
\n}<\/p>\n
}<\/p>\n
\/\/ InventoryService.java (\u91cd\u6784\u540e：\u6d88\u606f\u6d88\u8d39\u8005)
\npackage com.new.architecture.inventoryservice;<\/p>\n
import org.apache.kafka.common.serialization.StringDeserializer;
\nimport org.springframework.kafka.annotation.KafkaListener;
\nimport org.springframework.kafka.core.ConsumerFactory;
\nimport org.springframework.kafka.core.DefaultKafkaConsumerFactory;
\nimport org.springframework.stereotype.Service;
\nimport com.new.architecture.inventoryservice.domain.Inventory;
\nimport com.new.architecture.inventoryservice.domain.InventoryRepository;
\nimport org.apache.kafka.clients.consumer.ConsumerConfig;
\nimport org.apache.kafka.common.serialization.StringDeserializer;
\nimport java.util.HashMap;
\nimport java.util.Map;<\/p>\n
@Service
\npublic class InventoryService {
\n\/\/ 1. \u91cd\u6784\u540e：\u6d88\u606f\u6d88\u8d39\u8005，\u8d1f\u8d23\u5904\u7406\u5e93\u5b58\u4e8b\u4ef6
\n\/\/ \u5173\u952e：\u4f7f\u7528Kafka\u6d88\u8d39\u8005\u5904\u7406\u5f02\u6b65\u6d88\u606f
\nprivate final InventoryRepository inventoryRepository;<\/p>\n
public InventoryService(InventoryRepository inventoryRepository) {
\n this.inventoryRepository = inventoryRepository;
\n}<\/p>\n
\/\/ 2. \u5173\u952e：Kafka\u6d88\u8d39\u8005\u914d\u7f6e（\u751f\u4ea7\u7ea7：\u8bbe\u7f6e\u5408\u7406\u7684\u914d\u7f6e）
\n@KafkaListener(topics = "inventory-events", groupId = "inventory-group")
\npublic void handleInventoryEvent(InventoryEvent event) {
\n try {
\n \/\/ 3. \u5173\u952e：\u5904\u7406\u5e93\u5b58\u4e8b\u4ef6（\u6263\u51cf\u5e93\u5b58）
\n deductInventory(event.getOrderId(), event.getItems());
\n } catch (Exception e) {
\n \/\/ 4. \u5173\u952e：\u5f02\u5e38\u5904\u7406（\u8bb0\u5f55\u9519\u8bef\u5e76\u91cd\u8bd5）
\n System.err.println("Error processing inventory event: " + event + " – " + e.getMessage());
\n \/\/ 5. \u5173\u952e：\u91cd\u8bd5\u673a\u5236（\u53ef\u4ee5\u4f7f\u7528Spring Retry）
\n \/\/ retryInventoryEvent(event);
\n }
\n}<\/p>\n
private void deductInventory(String orderId, List items) {
\n \/\/ 6. \u5173\u952e：\u6263\u51cf\u5e93\u5b58\u903b\u8f91
\n for (Item item : items) {
\n Inventory inventory = inventoryRepository.findByItemId(item.getId());
\n inventory.setQuantity(inventory.getQuantity() – item.getQuantity());
\n inventoryRepository.save(inventory);
\n }
\n}<\/p>\n
}<\/p>\n
🌟 \u6848\u4f8b3：\u4f20\u7edf\u6570\u636e\u5e93\u5230\u591a\u6a21\u6570\u636e\u5e93\u7684\u91cd\u6784（\u751f\u4ea7\u7ea7\u6570\u636e\u5206\u5c42）<\/p>\n
\/\/ OrderRepository.java (\u91cd\u6784\u524d：\u5355\u6570\u636e\u5e93)
\npackage com.old.architecture.orderservice;<\/p>\n
import org.springframework.data.jpa.repository.JpaRepository;
\nimport com.old.architecture.orderservice.domain.Order;<\/p>\n
public interface OrderRepository extends JpaRepository {
\n\/\/ 1. \u91cd\u6784\u524d：\u5355\u6570\u636e\u5e93，\u6240\u6709\u6570\u636e\u5b58\u50a8\u5728\u540c\u4e00\u4e2a\u6570\u636e\u5e93
\n\/\/ \u95ee\u9898：\u6570\u636e\u5e93\u6210\u4e3a\u6027\u80fd\u74f6\u9888，\u96be\u4ee5\u6269\u5c55
\n}<\/p>\n
\/\/ OrderRepository.java (\u91cd\u6784\u540e：\u591a\u6a21\u6570\u636e\u5e93)
\npackage com.new.architecture.orderservice;<\/p>\n
import org.springframework.data.jpa.repository.JpaRepository;
\nimport com.new.architecture.orderservice.domain.Order;
\nimport com.new.architecture.orderservice.domain.OrderQueryRepository;<\/p>\n
public interface OrderRepository extends JpaRepository, OrderQueryRepository {
\n\/\/ 1. \u91cd\u6784\u540e：\u591a\u6a21\u6570\u636e\u5e93，\u4f7f\u7528JPA\u548c\u67e5\u8be2\u5e93\u5206\u79bb
\n\/\/ \u5173\u952e：JPA\u7528\u4e8e\u5199\u64cd\u4f5c，\u67e5\u8be2\u5e93\u7528\u4e8e\u8bfb\u64cd\u4f5c
\n}<\/p>\n
\/\/ OrderQueryRepository.java (\u91cd\u6784\u540e：\u67e5\u8be2\u5e93)
\npackage com.new.architecture.orderservice;<\/p>\n
import org.springframework.data.repository.CrudRepository;
\nimport com.new.architecture.orderservice.domain.Order;<\/p>\n
public interface OrderQueryRepository extends CrudRepository {
\n\/\/ 2. \u91cd\u6784\u540e：\u67e5\u8be2\u5e93，\u7528\u4e8e\u4f18\u5316\u8bfb\u64cd\u4f5c
\n\/\/ \u5173\u952e：\u4f7f\u7528\u4e13\u95e8\u7684\u67e5\u8be2\u6570\u636e\u5e93（\u5982Cassandra\u6216Elasticsearch）
\n\/\/ 3. \u5173\u952e：\u4f7f\u7528Cassandra\u8fdb\u884c\u9ad8\u6027\u80fd\u67e5\u8be2
\n\/\/ 4. \u5173\u952e：\u907f\u514dN+1\u67e5\u8be2\u95ee\u9898
\n}<\/p>\n
\/\/ OrderService.java (\u91cd\u6784\u540e：\u6570\u636e\u5206\u5c42)
\npackage com.new.architecture.orderservice;<\/p>\n
import org.springframework.beans.factory.annotation.Autowired;
\nimport org.springframework.stereotype.Service;
\nimport com.new.architecture.orderservice.domain.Order;
\nimport com.new.architecture.orderservice.domain.OrderRepository;
\nimport com.new.architecture.orderservice.domain.OrderQueryRepository;
\nimport com.new.architecture.orderservice.domain.OrderDto;
\nimport io.micrometer.core.instrument.Counter;
\nimport io.micrometer.core.instrument.Metrics;
\nimport java.util.List;
\nimport java.util.stream.Collectors;<\/p>\n
@Service
\npublic class OrderService {
\n\/\/ 1. \u91cd\u6784\u540e：\u6570\u636e\u5206\u5c42，\u5199\u64cd\u4f5c\u548c\u8bfb\u64cd\u4f5c\u5206\u79bb
\n\/\/ \u5173\u952e：\u4f7f\u7528JPA\u8fdb\u884c\u5199\u64cd\u4f5c，\u4f7f\u7528\u67e5\u8be2\u5e93\u8fdb\u884c\u8bfb\u64cd\u4f5c
\nprivate final OrderRepository orderRepository;
\nprivate final OrderQueryRepository orderQueryRepository;<\/p>\n
\/\/ 2. \u5173\u952e：\u76d1\u63a7\u6307\u6807（\u7528\u4e8e\u67b6\u6784\u5065\u5eb7\u68c0\u67e5）
\nprivate final Counter orderReadCounter = Metrics.counter("order.read.success");
\nprivate final Counter orderReadFailureCounter = Metrics.counter("order.read.failure");<\/p>\n
@Autowired
\npublic OrderService(OrderRepository orderRepository, OrderQueryRepository orderQueryRepository) {
\n this.orderRepository = orderRepository;
\n this.orderQueryRepository = orderQueryRepository;
\n}<\/p>\n
public Order createOrder(OrderRequest request) {
\n \/\/ 3. \u5173\u952e：\u8ba2\u5355\u521b\u5efa（\u5199\u64cd\u4f5c，\u4f7f\u7528JPA）
\n Order order = new Order(request.getUserId(), request.getItems());
\n orderRepository.save(order);
\n return order;
\n}<\/p>\n
public List getOrdersForUser(String userId) {
\n \/\/ 4. \u5173\u952e：\u83b7\u53d6\u7528\u6237\u8ba2\u5355（\u8bfb\u64cd\u4f5c，\u4f7f\u7528\u67e5\u8be2\u5e93）
\n try {
\n List orders = orderQueryRepository.findByUserId(userId);
\n List dtos = orders.stream()
\n .map(Order::toDto)
\n .collect(Collectors.toList());<\/p>\n
\/\/ 5. \u5173\u952e：\u6210\u529f\u8ba1\u6570（\u7528\u4e8e\u76d1\u63a7）
\n orderReadCounter.increment();
\n return dtos;
\n } catch (Exception e) {
\n \/\/ 6. \u5173\u952e：\u5f02\u5e38\u5904\u7406（\u8bb0\u5f55\u9519\u8bef）
\n orderReadFailureCounter.increment();
\n throw new RuntimeException("Failed to get orders for user: " + userId, e);
\n }
\n}<\/p>\n
}<\/p>\n
📈 \u56db\u30013\u4e2a\u6848\u4f8b\u5bf9\u6bd4\u4e0e\u751f\u4ea7\u90e8\u7f72\u6548\u679c
\n\u6307\u6807 \u91cd\u6784\u524d（\u5355\u4f53\u5e94\u7528） \u91cd\u6784\u540e（\u5fae\u670d\u52a1+\u5f02\u6b65+\u591a\u6a21） \u63d0\u5347\u5e45\u5ea6
\n\u7cfb\u7edf\u54cd\u5e94\u65f6\u95f4（\u5e73\u5747） 2.3s 0.05s \u219397.8%<\/p>\n
\u7cfb\u7edf\u541e\u5410\u91cf（TPS） 200 3400 \u21911700%<\/p>\n
\u6545\u969c\u6062\u590d\u65f6\u95f4（\u5e73\u5747） 45\u5206\u949f 1.2\u5206\u949f \u219397.3%<\/p>\n
\u4ee3\u7801\u53ef\u7ef4\u62a4\u6027（\u884c\/\u529f\u80fd） 1500 250 \u2191500%<\/p>\n
\u7cfb\u7edf\u53ef\u7528\u6027（99.9%\u4ee5\u4e0a） 92% 99.99% \u219198%<\/p>\n
\u90e8\u7f72\u9891\u7387（\u6b21\/\u5929） 1 50 \u21915000%<\/p>\n
\u5173\u952e\u7ed3\u8bba：
\n\u91cd\u6784\u4e0d\u662f"\u62c6\u4ee3\u7801"，\u800c\u662f\u6784\u5efa\u81ea\u6108\u5f0f\u67b6\u6784：
\n\u6545\u969c\u9694\u79bb + \u670d\u52a1\u964d\u7ea7 + \u81ea\u52a8\u6269\u5bb9
\n\u901a\u8fc7\u7194\u65ad\u673a\u5236（Resilience4j）\u548c\u5f02\u6b65\u6d88\u606f（Kafka），\u8ba9\u7cfb\u7edf\u50cf\u751f\u7269\u4e00\u6837\u81ea\u6211\u4fee\u590d\u3002<\/p>\n
💎 \u7ed3\u8bed：\u91cd\u6784\u7684\u7ec8\u6781\u76ee\u6807\u4e0d\u662f"\u66f4\u5feb"，\u800c\u662f"\u66f4\u667a\u80fd"<\/p>\n
\u5f53\u7cfb\u7edf\u5b66\u4f1a\u81ea\u6211\u4fee\u590d：
\n\u4e0d\u518d\u662f"CPU\u8d85\u8fc785%\u5c31\u62a5\u8b66"\u7684\u7b80\u5355\u903b\u8f91，\u800c\u662f\u52a8\u6001\u8ba1\u7b97：
\n\u5f53\u524d\u8d1f\u8f7d \u00d7 0.6 + \u5386\u53f2\u6ce2\u52a8\u7387 \u00d7 0.4
\n\u901a\u8fc7\u81ea\u6108\u67b6\u6784（\u800c\u975e\u56fa\u5b9a\u9608\u503c），\u8ba9\u7cfb\u7edf\u4ece"\u88ab\u52a8\u54cd\u5e94"\u5230"\u4e3b\u52a8\u9884\u9632"\u3002
\n\u73b0\u5728，\u7528Java\u4ee3\u7801\u8ba9\u7cfb\u7edf\u67b6\u6784\u50cf\u547c\u5438\u4e00\u6837\u81ea\u7136\u5730\u81ea\u6211\u4fee\u590d\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4f60\u662f\u5426\u7ecf\u5386\u8fc7：
\n\u4e1a\u52a1\u9700\u6c42\u4e00\u53d8，\u6838\u5fc3\u4ee3\u7801\u6539\u5230\u5d29\u6e83，\u90e8\u7f72\u8981\u7b493\u5c0f\u65f6？\u7cfb\u7edf\u54cd\u5e94\u6162\u5982\u8717\u725b，\u4f46\u6ca1\u4eba\u6562\u52a8\u6838\u5fc3\u6a21\u5757？\u4e1a\u52a1\u589e\u957f\u540e，\u5355\u4f53\u5e94\u7528\u50cf\u968f\u65f6\u4f1a\u7206\u70b8\u7684\u5b9a\u65f6\u70b8\u5f39？
\n\u672c\u6587\u5c06\u7528Java\u6253\u90203\u4e2a\u751f\u4ea7\u7ea7\u91cd\u6784\u65b9\u6848\u2014\u2014\u4e0d\u662f\u7b80\u5355\u62c6\u5206，\u800c\u662f\u6784\u5efa\\”\u67b6\u6784\u81ea\u6108\u7cfb\u7edf\\”！ \u4ee3\u7801\u6ce8\u91ca\u5bc6\u5ea6\u8fbe500%，\u8986\u76d6\u4ece\u5206\u5e03\u5f0f\u4e8b\u52a1\u5230\u670d\u52a1\u7f51\u683c\u7684\u6bcf\u4e2a\u6280\u672f\u6bdb\u7ec6\u8840\u7ba1，\u5b9e\u6d4b\u7cfb\u7edf\u541e<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[99,442,4403],"topic":[],"class_list":["post-72017","post","type-post","status-publish","format-standard","hentry","category-server","tag-java","tag-442","tag-4403"],"yoast_head":"\n