当前位置：首页 > article >正文

微服务组件

article 2024/11/13 14:28:22

微服务架构中的组件通常包括以下几个关键部分：

服务注册和发现 - 服务实例在启动时向服务注册中心注册，之后可以被其他服务发现。
API 网关 - 作为微服务系统的单一入口点，提供请求路由、负载均衡、安全等功能。
配置管理 - 中央化管理服务的配置，并支持动态更新。
断路器 - 提供一种机制，在服务故障时保持系统的稳定性。
分布式跟踪和监控 - 记录并跟踪服务调用过程，以便监控和故障排查。
消息队列 - 服务间的异步通信机制。
容器化和编排 - 使用容器来部署服务，并通过编排工具管理服务的生命周期。

下面我们将结合源码和代码示例，深入解析这些组件。

1. 服务注册和发现（Spring Cloud Netflix Eureka）

Eureka Server

@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

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

上面的代码启动了一个Eureka服务注册中心。任何使用 @EnableEurekaClient 注解的应用都可以注册到这个注册中心。

Eureka Client

@EnableEurekaClient
@SpringBootApplication
public class ProductServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProductServiceApplication.class, args);
    }
}

在上面的代码中，ProductServiceApplication 作为Eureka Client启动，并自动把自己注册到Eureka Server。

2. API 网关（Spring Cloud Gateway）

@EnableDiscoveryClient
@SpringBootApplication
public class ApiGatewayApplication {

    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("product_route", r -> r.path("/product/**")
                        .uri("lb://PRODUCT-SERVICE"))
                .build();
    }

    public static void main(String[] args) {
        SpringApplication.run(ApiGatewayApplication.class, args);
    }
}

上面的代码启动了一个API网关，并定义了一个路由规则，所有访问 /product/** 的请求都被路由到 PRODUCT-SERVICE。

3. 配置管理（Spring Cloud Config）

Config Server

@EnableConfigServer
@SpringBootApplication
public class ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

这段代码启动了一个配置服务器，服务可以从中获取配置信息。

Config Client

@RestController
@RefreshScope
public class MessageRestController {

    @Value("${message:Default Hello}")
    private String message;

    @GetMapping("/message")
    public String getMessage() {
        return this.message;
    }
}

在上述代码中，MessageRestController 使用 @RefreshScope 注解，允许在不停止服务的情况下刷新配置。

4. 断路器（Spring Cloud Circuit Breaker）

@RestController
public class DemoController {

    @GetMapping("/demo")
    @CircuitBreaker(name = "demoService", fallbackMethod = "fallback")
    public String demoService() {
        // 模拟服务故障
        throw new RuntimeException("Service Failure!");
    }

    public String fallback(Throwable t) {
        return "Fallback message";
    }
}

上面的代码演示了一个简单的断路器用法，当 demoService 方法失败时，会自动调用 fallback 方法。

5. 分布式跟踪（Spring Cloud Sleuth）

@Configuration
public class SleuthConfig {

    @Bean
    public Sampler defaultSampler() {
        return Sampler.ALWAYS_SAMPLE;
    }
}

Spring Cloud Sleuth 配置，确保所有的请求都被跟踪。

6. 消息队列（RabbitMQ）

@RestController
public class OrderController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostMapping("/order")
    public String placeOrder(@RequestBody Order order) {
        rabbitTemplate.convertAndSend("order-exchange", "orders", order);
        return "Order placed";
    }
}

上面的示例代码展示了如何发送消息到RabbitMQ的交换机 order-exchange。

7. 容器化和编排（Docker + Kubernetes）

Dockerfile 示例：

FROM openjdk:8-jdk-alpine
VOLUME /tmp
ADD target/product-service.jar app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"]

这段Dockerfile代码用于构建包含 product-service 服务的Docker镜像。

Kubernetes Deployment 示例：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: product-service
spec:
  replicas: 2
  selector:
    matchLabels:
      app: product-service
  template:
    metadata:
      labels:
        app: product-service
    spec:
      containers:
      - name: product-service
        image: product-service:latest
        ports:
        - containerPort: 8080