Java微服务详解及完整代码示例_Java

一、微服务核心概念

独立性：每个服务独立开发、部署、扩展。
单一职责：每个服务专注于一个业务功能（如用户管理、订单处理）。
分布式通信：通过 api 或异步消息传递交互。
自治性：服务可选用不同技术栈、数据库。
弹性设计：容错、服务降级、负载均衡。

二、java 微服务技术栈

spring boot：快速构建独立运行的微服务。
spring cloud：提供微服务治理工具（服务发现、配置中心、网关等）。
服务发现：netflix eureka、consul。
api 网关：spring cloud gateway、zuul。
通信：feign（声明式 http 客户端）、resttemplate。
容错：resilience4j、hystrix。
配置管理：spring cloud config。
消息队列：rabbitmq、kafka。
容器化：docker、kubernetes。

三、微服务示例：电商系统

假设构建一个简单的电商系统，包含以下服务：

用户服务（user service）：管理用户信息。
订单服务（order service）：处理订单创建、查询。
支付服务（payment service）：处理支付流程。
api 网关（gateway）：路由请求。
服务注册中心（eureka server）：服务注册与发现。

四、代码示例

1. 服务注册中心（eureka server）

依赖：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-server</artifactid>
</dependency>

启动类：

@springbootapplication
@enableeurekaserver
public class eurekaserverapplication {
    public static void main(string[] args) {
        springapplication.run(eurekaserverapplication.class, args);
    }
}

配置文件（application.yml）：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-client</artifactid>
</dependency>

2. 用户服务（user service）

依赖：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-client</artifactid>
</dependency>

启动类：

@springbootapplication
@enableeurekaclient
public class userserviceapplication {
    public static void main(string[] args) {
        springapplication.run(userserviceapplication.class, args);
    }
}

rest 控制器：

@restcontroller
@requestmapping("/users")
public class usercontroller {
    @getmapping("/{id}")
    public user getuser(@pathvariable long id) {
        return new user(id, "alice", "alice@example.com");
    }
}

配置文件（application.yml）：

server:
  port: 8081
spring:
  application:
    name: user-service
eureka:
  client:
    service-url:
      defaultzone: http://localhost:8761/eureka/

3. 订单服务（order service）

通过 feign 调用用户服务：

@feignclient(name = "user-service")
public interface userserviceclient {
    @getmapping("/users/{id}")
    user getuser(@pathvariable long id);
}

@restcontroller
@requestmapping("/orders")
public class ordercontroller {
    @autowired
    private userserviceclient userserviceclient;

    @postmapping
    public order createorder(@requestbody orderrequest request) {
        user user = userserviceclient.getuser(request.getuserid());
        return new order(1l, user.getid(), "created");
    }
}

4. api 网关（spring cloud gateway）

路由配置：

spring:
  cloud:
    gateway:
      routes:
        - id: user-service
          uri: lb://user-service
          predicates:
            - path=/users/**
        - id: order-service
          uri: lb://order-service
          predicates:
            - path=/orders/**

五、关键功能实现

服务发现：所有服务注册到 eureka，通过服务名（如 user-service）通信。
负载均衡：ribbon 自动实现客户端负载均衡。

容错机制：

@circuitbreaker(name = "userservice", fallbackmethod = "fallbackgetuser")
@getmapping("/{id}")
public user getuser(@pathvariable long id) {
    return userserviceclient.getuser(id);
}

public user fallbackgetuser(long id, throwable t) {
    return new user(id, "fallback user", "fallback@example.com");
}