Spring Boot 微服务架构设计与实现

配置文件 application.properties 中，需关闭客户端注册行为，因为它是注册中心本身：

server.port=8761
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.instance.hostname=localhost

启动类加上 @EnableEurekaServer 注解即可：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

2. 创建服务提供者 (Product Service)

服务提供者需要注册到 Eureka。除了 Web 依赖，还需添加 spring-cloud-starter-netflix-eureka-client。

import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

@RestController
@RequestMapping("/api/products")
public class ProductController {
    private List<Product> products = new ArrayList<>();

    public ProductController() {
        products.add(new Product(1L, "P001", "手机", 1000.0, 100));
        products.add(new Product(2L, "P002", "电脑", 5000.0, 50));
        // ... 初始化更多数据
    }

    @GetMapping("/")
    public List<Product> getAllProducts() {
        return products;
    }

    @GetMapping("/{id}")
    public Product getProductById(@PathVariable Long id) {
        return products.stream()
                .filter(product -> product.getId().equals(id))
                .findFirst()
                .orElse(null);
    }

    @PostMapping("/")
    public Product addProduct(@RequestBody Product product) {
        product.setId((long) (products.size() + 1));
        products.add(product);
        return product;
    }

    @PutMapping("/{id}")
    public Product updateProduct(@PathVariable Long id, @RequestBody Product product) {
        Product existingProduct = getProductById(id);
        if (existingProduct != null) {
            existingProduct.setProductId(product.getProductId());
            existingProduct.setProductName(product.getProductName());
            existingProduct.setPrice(product.getPrice());
            existingProduct.setSales(product.getSales());
        }
        return existingProduct;
    }

    @DeleteMapping("/{id}")
    public void deleteProduct(@PathVariable Long id) {
        products.removeIf(product -> product.getId().equals(id));
    }
}

实体类 Product 记得补全 Getter/Setter 和构造函数。启动类需添加 @EnableEurekaClient，并在配置文件中指定注册中心地址：

server.port=8081
spring.application.name=product-service
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
eureka.instance.prefer-ip-address=true

3. 创建服务消费者 (Order Service)

消费者同样需要注册到 Eureka，并引入 Ribbon 依赖以实现负载均衡。我们使用 RestTemplate 配合 @LoadBalanced 注解来调用上游服务。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.ArrayList;
import java.util.List;

@RestController
@RequestMapping("/api/orders")
public class OrderController {
    @Autowired
    private RestTemplate restTemplate;

    private List<Order> orders = new ArrayList<>();

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @GetMapping("/{id}/product/{productId}")
    public Product getProductById(@PathVariable Long id, @PathVariable Long productId) {
        // 这里演示通过服务名调用，实际项目中通常直接调用产品服务的接口
        String url = "http://product-service/api/products/" + productId;
        return restTemplate.getForObject(url, Product.class);
    }

    // 其他 CRUD 方法省略...
}

消费者配置类似，端口设为 8082，应用名为 order-service。

配置中心集成

随着服务增多，分散的配置文件难以维护。Spring Cloud Config 允许我们将配置集中存储（如 Git），服务启动时自动拉取。

配置服务器 (Config Server)

引入 spring-cloud-config-server 依赖，启用 @EnableConfigServer。配置指向 Git 仓库地址：

server.port=8888
spring.cloud.config.server.git.uri=https://github.com/username/config-repo
spring.cloud.config.server.git.search-paths=config-repo

配置客户端

在客户端 bootstrap.properties 中指定配置中心地址：

spring.application.name=product-service
spring.cloud.config.uri=http://localhost:8888

这样，具体的业务配置（如数据库连接）可以放在 Git 仓库的 product-service-dev.properties 文件中，实现环境隔离。

负载均衡与基本方法

在微服务调用中，Ribbon 提供了客户端负载均衡能力。我们在消费者端定义 RestTemplate 时加上 @LoadBalanced 注解，请求中的服务名（如 product-service）会被自动解析并轮询到具体实例。

虽然 Feign 和 Hystrix 也是常用组件，但 Ribbon 作为底层基础，理解其原理对掌握服务间通信至关重要。

实际应用场景

Spring Boot 微服务架构适用于多种场景，例如：

• 产品服务化：将商品管理独立部署，便于扩容。
• 订单服务化：处理交易逻辑，与库存、支付解耦。
• 用户服务化：统一管理认证与权限。
• 支付服务化：对接第三方渠道，保障资金安全。

总结

本章我们深入探讨了 Spring Boot 微服务架构的设计与实现。从微服务的基本概念出发，掌握了 Eureka 注册中心的搭建、Config 配置中心的集成以及 Ribbon 负载均衡的使用。通过代码实战，理解了服务提供者与消费者的交互流程。在实际开发中，根据业务复杂度选择合适的组件组合，能有效提升系统的健壮性与可维护性。