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

Ne0inhk

— 17 min read
Spring Boot 微服务架构设计与实现

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

在这里插入图片描述
25.1 学习目标与重点提示

学习目标：掌握Spring Boot微服务架构设计与实现的核心概念与使用方法，包括微服务架构的定义与特点、Spring Boot与微服务的集成、Spring Boot与微服务的配置、Spring Boot与微服务的基本方法、Spring Boot的实际应用场景，学会在实际开发中处理微服务架构设计与实现问题。
重点：微服务架构的定义与特点、Spring Boot与微服务的集成、Spring Boot与微服务的配置、Spring Boot与微服务的基本方法、Spring Boot的实际应用场景。

25.2 微服务架构概述

微服务架构是Java开发中的重要组件。

25.2.1 微服务架构的定义

定义：微服务架构是一种软件架构风格，将应用程序拆分为一组独立的服务，每个服务运行在自己的进程中，通过网络进行通信。
作用：

  • 提高应用程序的可扩展性。
  • 提高应用程序的可维护性。
  • 提高应用程序的可靠性。

常见的微服务架构：

  • Spring Cloud：Spring Cloud是Spring Boot提供的微服务框架。
  • Netflix OSS：Netflix OSS是Netflix提供的微服务框架。
  • Docker：Docker是一种容器化技术，用于打包和部署应用程序。
  • Kubernetes：Kubernetes是一种容器编排工具，用于管理和调度应用程序。

✅ 结论：微服务架构是一种软件架构风格，作用是提高应用程序的可扩展性、可维护性、可靠性。

25.2.2 微服务架构的特点

定义：微服务架构的特点是指微服务架构的特性。
特点：

  • 独立部署：每个服务可以独立部署。
  • 独立开发：每个服务可以独立开发。
  • 独立运行：每个服务运行在自己的进程中。
  • 网络通信：每个服务通过网络进行通信。

✅ 结论：微服务架构的特点包括独立部署、独立开发、独立运行、网络通信。

25.3 Spring Boot与微服务的集成

Spring Boot与微服务的集成是Java开发中的重要内容。

25.3.1 集成Spring Cloud Eureka的步骤

定义：集成Spring Cloud Eureka的步骤是指使用Spring Boot与Spring Cloud Eureka集成的方法。
步骤：

  1. 创建Spring Boot项目。
  2. 添加所需的依赖。
  3. 配置Spring Cloud Eureka。
  4. 创建服务提供者。
  5. 创建服务消费者。
  6. 测试应用。

示例：
服务注册中心（Eureka Server）的pom.xml文件中的依赖：

<dependencies><!-- Eureka Server依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR12</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

服务注册中心（Eureka Server）的application.properties文件中的配置：

# 服务器端口 server.port=8761 # Eureka Server配置 eureka.client.register-with-eureka=false eureka.client.fetch-registry=false eureka.instance.hostname=localhost

服务注册中心（Eureka Server）的启动类：

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication@EnableEurekaServerpublicclassEurekaServerApplication{publicstaticvoidmain(String[] args){SpringApplication.run(EurekaServerApplication.class, args);}}

服务提供者（Product Service）的pom.xml文件中的依赖：

<dependencies><!-- Web依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Eureka Client依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR12</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

服务提供者（Product Service）的application.properties文件中的配置：

# 服务器端口 server.port=8081 # 应用名称 spring.application.name=product-service # Eureka Client配置 eureka.client.service-url.defaultZone=http://localhost:8761/eureka/ eureka.instance.prefer-ip-address=true

服务提供者（Product Service）的实体类：

publicclassProduct{privateLong id;privateString productId;privateString productName;privatedouble price;privateint sales;publicProduct(){}publicProduct(Long id,String productId,String productName,double price,int sales){this.id = id;this.productId = productId;this.productName = productName;this.price = price;this.sales = sales;}// Getter和Setter方法publicLonggetId(){return id;}publicvoidsetId(Long id){this.id = id;}publicStringgetProductId(){return productId;}publicvoidsetProductId(String productId){this.productId = productId;}publicStringgetProductName(){return productName;}publicvoidsetProductName(String productName){this.productName = productName;}publicdoublegetPrice(){return price;}publicvoidsetPrice(double price){this.price = price;}publicintgetSales(){return sales;}publicvoidsetSales(int sales){this.sales = sales;}@OverridepublicStringtoString(){return"Product{"+"id="+ id +",+ productId +'\''+",+ productName +'\''+", price="+ price +", sales="+ sales +'}';}}

服务提供者（Product Service）的控制器类：

importorg.springframework.web.bind.annotation.*;importjava.util.ArrayList;importjava.util.List;importjava.util.stream.Collectors;@RestController@RequestMapping("/api/products")publicclassProductController{privateList<Product> products =newArrayList<>();publicProductController(){ products.add(newProduct(1L,"P001","手机",1000.0,100)); products.add(newProduct(2L,"P002","电脑",5000.0,50)); products.add(newProduct(3L,"P003","电视",3000.0,80)); products.add(newProduct(4L,"P004","手表",500.0,200)); products.add(newProduct(5L,"P005","耳机",300.0,150));}@GetMapping("/")publicList<Product>getAllProducts(){return products;}@GetMapping("/{id}")publicProductgetProductById(@PathVariableLong id){return products.stream().filter(product -> product.getId().equals(id)).findFirst().orElse(null);}@PostMapping("/")publicProductaddProduct(@RequestBodyProduct product){ product.setId((long)(products.size()+1)); products.add(product);return product;}@PutMapping("/{id}")publicProductupdateProduct(@PathVariableLong id,@RequestBodyProduct 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}")publicvoiddeleteProduct(@PathVariableLong id){ products.removeIf(product -> product.getId().equals(id));}}

服务提供者（Product Service）的启动类：

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication@EnableEurekaClientpublicclassProductServiceApplication{publicstaticvoidmain(String[] args){SpringApplication.run(ProductServiceApplication.class, args);}}

服务消费者（Order Service）的pom.xml文件中的依赖：

<dependencies><!-- Web依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Eureka Client依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- Ribbon依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR12</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

服务消费者（Order Service）的application.properties文件中的配置：

# 服务器端口 server.port=8082 # 应用名称 spring.application.name=order-service # Eureka Client配置 eureka.client.service-url.defaultZone=http://localhost:8761/eureka/ eureka.instance.prefer-ip-address=true

服务消费者（Order Service）的实体类：

publicclassProduct{privateLong id;privateString productId;privateString productName;privatedouble price;privateint sales;publicProduct(){}publicProduct(Long id,String productId,String productName,double price,int sales){this.id = id;this.productId = productId;this.productName = productName;this.price = price;this.sales = sales;}// Getter和Setter方法publicLonggetId(){return id;}publicvoidsetId(Long id){this.id = id;}publicStringgetProductId(){return productId;}publicvoidsetProductId(String productId){this.productId = productId;}publicStringgetProductName(){return productName;}publicvoidsetProductName(String productName){this.productName = productName;}publicdoublegetPrice(){return price;}publicvoidsetPrice(double price){this.price = price;}publicintgetSales(){return sales;}publicvoidsetSales(int sales){this.sales = sales;}@OverridepublicStringtoString(){return"Product{"+"id="+ id +",+ productId +'\''+",+ productName +'\''+", price="+ price +", sales="+ sales +'}';}}publicclassOrder{privateLong id;privateString orderId;privateList<Product> products;publicOrder(){}publicOrder(Long id,String orderId,List<Product> products){this.id = id;this.orderId = orderId;this.products = products;}// Getter和Setter方法publicLonggetId(){return id;}publicvoidsetId(Long id){this.id = id;}publicStringgetOrderId(){return orderId;}publicvoidsetOrderId(String orderId){this.orderId = orderId;}publicList<Product>getProducts(){return products;}publicvoidsetProducts(List<Product> products){this.products = products;}@OverridepublicStringtoString(){return"Order{"+"id="+ id +",+ orderId +'\''+", products="+ products +'}';}}

服务消费者（Order Service）的控制器类：

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.cloud.client.loadbalancer.LoadBalanced;importorg.springframework.context.annotation.Bean;importorg.springframework.http.ResponseEntity;importorg.springframework.web.bind.annotation.*;importorg.springframework.web.client.RestTemplate;importjava.util.ArrayList;importjava.util.List;importjava.util.stream.Collectors;@RestController@RequestMapping("/api/orders")publicclassOrderController{@AutowiredprivateRestTemplate restTemplate;privateList<Order> orders =newArrayList<>();publicOrderController(){ orders.add(newOrder(1L,"O001",newArrayList<>())); orders.add(newOrder(2L,"O002",newArrayList<>())); orders.add(newOrder(3L,"O003",newArrayList<>()));}@Bean@LoadBalancedpublicRestTemplaterestTemplate(){returnnewRestTemplate();}@GetMapping("/")publicList<Order>getAllOrders(){return orders;}@GetMapping("/{id}")publicOrdergetOrderById(@PathVariableLong id){return orders.stream().filter(order -> order.getId().equals(id)).findFirst().orElse(null);}@PostMapping("/")publicOrderaddOrder(@RequestBodyOrder order){ order.setId((long)(orders.size()+1)); orders.add(order);return order;}@PutMapping("/{id}")publicOrderupdateOrder(@PathVariableLong id,@RequestBodyOrder order){Order existingOrder =getOrderById(id);if(existingOrder !=null){ existingOrder.setOrderId(order.getOrderId()); existingOrder.setProducts(order.getProducts());}return existingOrder;}@DeleteMapping("/{id}")publicvoiddeleteOrder(@PathVariableLong id){ orders.removeIf(order -> order.getId().equals(id));}@GetMapping("/{id}/products")publicList<Product>getOrderProducts(@PathVariableLong id){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products;}returnnewArrayList<>();}@PostMapping("/{id}/products")publicOrderaddOrderProduct(@PathVariableLong id,@RequestBodyProduct product){Order order =getOrderById(id);if(order !=null){ order.getProducts().add(product);}return order;}@DeleteMapping("/{id}/products/{productId}")publicOrderdeleteOrderProduct(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){ order.getProducts().removeIf(product -> product.getId().equals(productId));}return order;}@GetMapping("/{id}/product/{productId}")publicProductgetProductById(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products.stream().filter(product -> product.getId().equals(productId)).findFirst().orElse(null);}returnnull;}}

服务消费者（Order Service）的启动类：

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication@EnableEurekaClientpublicclassOrderServiceApplication{publicstaticvoidmain(String[] args){SpringApplication.run(OrderServiceApplication.class, args);}}

测试类：

importorg.junit.jupiter.api.Test;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.test.context.SpringBootTest;importorg.springframework.boot.test.web.client.TestRestTemplate;importorg.springframework.boot.web.server.LocalServerPort;importorg.springframework.http.HttpEntity;importorg.springframework.http.HttpHeaders;importorg.springframework.http.HttpMethod;importorg.springframework.http.ResponseEntity;importjava.util.ArrayList;importjava.util.List;importstaticorg.assertj.core.api.Assertions.assertThat;@SpringBootTest(webEnvironment =SpringBootTest.WebEnvironment.RANDOM_PORT)classOrderServiceApplicationTests{@LocalServerPortprivateint port;@AutowiredprivateTestRestTemplate restTemplate;@TestvoidcontextLoads(){}@TestvoidtestGetAllOrders(){List<Order> orders = restTemplate.getForObject("http://localhost:"+ port +"/api/orders/",List.class);assertThat(orders).isNotNull();assertThat(orders.size()).isGreaterThanOrEqualTo(3);}@TestvoidtestAddOrder(){Order order =newOrder(null,"O004",newArrayList<>());Order savedOrder = restTemplate.postForObject("http://localhost:"+ port +"/api/orders/", order,Order.class);assertThat(savedOrder).isNotNull();assertThat(savedOrder.getOrderId()).isEqualTo("O004");}@TestvoidtestAddOrderProduct(){Product product =newProduct(1L,"P001","手机",1000.0,100);HttpEntity<Product> requestEntity =newHttpEntity<>(product);ResponseEntity<Order> response = restTemplate.exchange("http://localhost:"+ port +"/api/orders/1/products",HttpMethod.POST, requestEntity,Order.class);assertThat(response.getStatusCodeValue()).isEqualTo(200);assertThat(response.getBody()).isNotNull();assertThat(response.getBody().getProducts().size()).isGreaterThanOrEqualTo(1);}}

✅ 结论：集成Spring Cloud Eureka的步骤包括创建Spring Boot项目、添加所需的依赖、配置Spring Cloud Eureka、创建服务提供者、创建服务消费者、测试应用。

25.4 Spring Boot与微服务的配置

Spring Boot与微服务的配置是Java开发中的重要内容。

25.4.1 配置Spring Cloud Config

定义：配置Spring Cloud Config是指使用Spring Boot与Spring Cloud Config集成的方法。
步骤：

  1. 创建Spring Boot项目。
  2. 添加所需的依赖。
  3. 配置Spring Cloud Config。
  4. 创建配置文件。
  5. 测试应用。

示例：
配置服务器（Config Server）的pom.xml文件中的依赖：

<dependencies><!-- Config Server依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-config-server</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR12</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

配置服务器（Config Server）的application.properties文件中的配置：

# 服务器端口 server.port=8888 # 配置服务器配置 spring.cloud.config.server.git.uri=https://github.com/username/config-repo spring.cloud.config.server.git.search-paths=config-repo spring.cloud.config.server.git.username=username spring.cloud.config.server.git.password=password

配置服务器（Config Server）的启动类：

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.config.server.EnableConfigServer;@SpringBootApplication@EnableConfigServerpublicclassConfigServerApplication{publicstaticvoidmain(String[] args){SpringApplication.run(ConfigServerApplication.class, args);}}

配置客户端（Product Service）的pom.xml文件中的依赖：

<dependencies><!-- Web依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Config Client依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-config</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR12</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

配置客户端（Product Service）的bootstrap.properties文件中的配置：

# 应用名称 spring.application.name=product-service # 配置服务器地址 spring.cloud.config.uri=http://localhost:8888

配置客户端（Product Service）的application.properties文件中的配置：

# 服务器端口 server.port=8081

配置文件（product-service-dev.properties）：

# 应用名称 spring.application.name=product-service # 服务器端口 server.port=8081 # 数据库连接信息 spring.datasource.url=jdbc:h2:mem:testdb spring.datasource.driver-class-name=org.h2.Driver spring.datasource.username=sa spring.datasource.password=password # JPA配置 spring.jpa.hibernate.ddl-auto=update spring.jpa.show-sql=true # H2数据库控制台 spring.h2.console.enabled=true spring.h2.console.path=/h2-console

✅ 结论：配置Spring Cloud Config是指使用Spring Boot与Spring Cloud Config集成的方法，步骤包括创建Spring Boot项目、添加所需的依赖、配置Spring Cloud Config、创建配置文件、测试应用。

25.5 Spring Boot与微服务的基本方法

Spring Boot与微服务的基本方法包括使用Ribbon、使用Feign、使用Hystrix。

25.5.1 使用Ribbon

定义：使用Ribbon是指Spring Boot与微服务集成的基本方法之一。
作用：

  • 实现服务间的通信。
  • 提高应用程序的性能。

示例：
服务消费者（Order Service）的控制器类：

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.cloud.client.loadbalancer.LoadBalanced;importorg.springframework.context.annotation.Bean;importorg.springframework.http.ResponseEntity;importorg.springframework.web.bind.annotation.*;importorg.springframework.web.client.RestTemplate;importjava.util.ArrayList;importjava.util.List;importjava.util.stream.Collectors;@RestController@RequestMapping("/api/orders")publicclassOrderController{@AutowiredprivateRestTemplate restTemplate;privateList<Order> orders =newArrayList<>();publicOrderController(){ orders.add(newOrder(1L,"O001",newArrayList<>())); orders.add(newOrder(2L,"O002",newArrayList<>())); orders.add(newOrder(3L,"O003",newArrayList<>()));}@Bean@LoadBalancedpublicRestTemplaterestTemplate(){returnnewRestTemplate();}@GetMapping("/")publicList<Order>getAllOrders(){return orders;}@GetMapping("/{id}")publicOrdergetOrderById(@PathVariableLong id){return orders.stream().filter(order -> order.getId().equals(id)).findFirst().orElse(null);}@PostMapping("/")publicOrderaddOrder(@RequestBodyOrder order){ order.setId((long)(orders.size()+1)); orders.add(order);return order;}@PutMapping("/{id}")publicOrderupdateOrder(@PathVariableLong id,@RequestBodyOrder order){Order existingOrder =getOrderById(id);if(existingOrder !=null){ existingOrder.setOrderId(order.getOrderId()); existingOrder.setProducts(order.getProducts());}return existingOrder;}@DeleteMapping("/{id}")publicvoiddeleteOrder(@PathVariableLong id){ orders.removeIf(order -> order.getId().equals(id));}@GetMapping("/{id}/products")publicList<Product>getOrderProducts(@PathVariableLong id){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products;}returnnewArrayList<>();}@PostMapping("/{id}/products")publicOrderaddOrderProduct(@PathVariableLong id,@RequestBodyProduct product){Order order =getOrderById(id);if(order !=null){ order.getProducts().add(product);}return order;}@DeleteMapping("/{id}/products/{productId}")publicOrderdeleteOrderProduct(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){ order.getProducts().removeIf(product -> product.getId().equals(productId));}return order;}@GetMapping("/{id}/product/{productId}")publicProductgetProductById(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products.stream().filter(product -> product.getId().equals(productId)).findFirst().orElse(null);}returnnull;}}

✅ 结论：使用Ribbon是指Spring Boot与微服务集成的基本方法之一，作用是实现服务间的通信、提高应用程序的性能。

25.6 Spring Boot的实际应用场景

在实际开发中，Spring Boot微服务架构设计与实现的应用场景非常广泛，如：

  • 实现产品服务的微服务化。
  • 实现用户服务的微服务化。
  • 实现订单服务的微服务化。
  • 实现支付服务的微服务化。

示例：

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;importorg.springframework.web.bind.annotation.*;importorg.springframework.web.client.RestTemplate;importjava.util.ArrayList;importjava.util.List;importjava.util.stream.Collectors;@SpringBootApplication@EnableEurekaClientpublicclassProductServiceApplication{publicstaticvoidmain(String[] args){SpringApplication.run(ProductServiceApplication.class, args);}}@RestController@RequestMapping("/api/products")classProductController{privateList<Product> products =newArrayList<>();publicProductController(){ products.add(newProduct(1L,"P001","手机",1000.0,100)); products.add(newProduct(2L,"P002","电脑",5000.0,50)); products.add(newProduct(3L,"P003","电视",3000.0,80)); products.add(newProduct(4L,"P004","手表",500.0,200)); products.add(newProduct(5L,"P005","耳机",300.0,150));}@GetMapping("/")publicList<Product>getAllProducts(){return products;}@GetMapping("/{id}")publicProductgetProductById(@PathVariableLong id){return products.stream().filter(product -> product.getId().equals(id)).findFirst().orElse(null);}@PostMapping("/")publicProductaddProduct(@RequestBodyProduct product){ product.setId((long)(products.size()+1)); products.add(product);return product;}@PutMapping("/{id}")publicProductupdateProduct(@PathVariableLong id,@RequestBodyProduct 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}")publicvoiddeleteProduct(@PathVariableLong id){ products.removeIf(product -> product.getId().equals(id));}}@SpringBootApplication@EnableEurekaClientpublicclassOrderServiceApplication{publicstaticvoidmain(String[] args){SpringApplication.run(OrderServiceApplication.class, args);}}@RestController@RequestMapping("/api/orders")classOrderController{@AutowiredprivateRestTemplate restTemplate;privateList<Order> orders =newArrayList<>();publicOrderController(){ orders.add(newOrder(1L,"O001",newArrayList<>())); orders.add(newOrder(2L,"O002",newArrayList<>())); orders.add(newOrder(3L,"O003",newArrayList<>()));}@Bean@LoadBalancedpublicRestTemplaterestTemplate(){returnnewRestTemplate();}@GetMapping("/")publicList<Order>getAllOrders(){return orders;}@GetMapping("/{id}")publicOrdergetOrderById(@PathVariableLong id){return orders.stream().filter(order -> order.getId().equals(id)).findFirst().orElse(null);}@PostMapping("/")publicOrderaddOrder(@RequestBodyOrder order){ order.setId((long)(orders.size()+1)); orders.add(order);return order;}@PutMapping("/{id}")publicOrderupdateOrder(@PathVariableLong id,@RequestBodyOrder order){Order existingOrder =getOrderById(id);if(existingOrder !=null){ existingOrder.setOrderId(order.getOrderId()); existingOrder.setProducts(order.getProducts());}return existingOrder;}@DeleteMapping("/{id}")publicvoiddeleteOrder(@PathVariableLong id){ orders.removeIf(order -> order.getId().equals(id));}@GetMapping("/{id}/products")publicList<Product>getOrderProducts(@PathVariableLong id){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products;}returnnewArrayList<>();}@PostMapping("/{id}/products")publicOrderaddOrderProduct(@PathVariableLong id,@RequestBodyProduct product){Order order =getOrderById(id);if(order !=null){ order.getProducts().add(product);}return order;}@DeleteMapping("/{id}/products/{productId}")publicOrderdeleteOrderProduct(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){ order.getProducts().removeIf(product -> product.getId().equals(productId));}return order;}@GetMapping("/{id}/product/{productId}")publicProductgetProductById(@PathVariableLong id,@PathVariableLong productId){Order order =getOrderById(id);if(order !=null){List<Product> products = order.getProducts();return products.stream().filter(product -> product.getId().equals(productId)).findFirst().orElse(null);}returnnull;}}// 测试类@SpringBootTest(webEnvironment =SpringBootTest.WebEnvironment.RANDOM_PORT)classOrderServiceApplicationTests{@LocalServerPortprivateint port;@AutowiredprivateTestRestTemplate restTemplate;@TestvoidcontextLoads(){}@TestvoidtestGetAllOrders(){List<Order> orders = restTemplate.getForObject("http://localhost:"+ port +"/api/orders/",List.class);assertThat(orders).isNotNull();assertThat(orders.size()).isGreaterThanOrEqualTo(3);}@TestvoidtestAddOrder(){Order order =newOrder(null,"O004",newArrayList<>());Order savedOrder = restTemplate.postForObject("http://localhost:"+ port +"/api/orders/", order,Order.class);assertThat(savedOrder).isNotNull();assertThat(savedOrder.getOrderId()).isEqualTo("O004");}@TestvoidtestAddOrderProduct(){Product product =newProduct(1L,"P001","手机",1000.0,100);HttpEntity<Product> requestEntity =newHttpEntity<>(product);ResponseEntity<Order> response = restTemplate.exchange("http://localhost:"+ port +"/api/orders/1/products",HttpMethod.POST, requestEntity,Order.class);assertThat(response.getStatusCodeValue()).isEqualTo(200);assertThat(response.getBody()).isNotNull();assertThat(response.getBody().getProducts().size()).isGreaterThanOrEqualTo(1);}}

输出结果：

  • 访问http://localhost:8082/api/orders/：返回所有订单信息。
  • 访问http://localhost:8082/api/orders/1/products：返回订单1的产品信息。

✅ 结论：在实际开发中，Spring Boot微服务架构设计与实现的应用场景非常广泛，需要根据实际问题选择合适的微服务架构和工具。

总结

本章我们学习了Spring Boot微服务架构设计与实现，包括微服务架构的定义与特点、Spring Boot与微服务的集成、Spring Boot与微服务的配置、Spring Boot与微服务的基本方法、Spring Boot的实际应用场景，学会了在实际开发中处理微服务架构设计与实现问题。其中，微服务架构的定义与特点、Spring Boot与微服务的集成、Spring Boot与微服务的配置、Spring Boot与微服务的基本方法、Spring Boot的实际应用场景是本章的重点内容。从下一章开始，我们将学习Spring Boot的其他组件、微服务等内容。

Read more

从 Copilot 到工程化 Agent 执行框架：基于OpenCode + OpenSpec 的企业级 AI Coding 落地实践

从 Copilot 到工程化 Agent 执行框架：基于OpenCode + OpenSpec 的企业级 AI Coding 落地实践

引言：AI Coding 进入规范驱动自动化时代         当前，许多开发者在使用 AI 编程助手时正普遍面临—个痛点：在处理大型项目时， AI 似乎会“遗忘”上下文，导致代码回归、引入新 Bug 或生成不符合项目规范的混乱代码。正如研发同学反复出现的挫败感：  “代码库越大， AI 弄得越乱”。         这种被称为“Vibe Coding”的模式，是 AI 辅助工程必要的、但也是原始的第—步。它更像—种不可预测的艺术，而非可重复、可扩展的科学。要真正释放 AI 的生产力，我们必须迎来—次范式的进化：从凭感觉的“Vibe Coding” ，转向由规范驱动的（Spec-Driven Development）专业化 AI 工程新范式。         本文将深入探讨如何将强大的

By Ne0inhk
一文看懂：AI编程工具深度对比：Cursor、Copilot、Trae与Claude Code

一文看懂：AI编程工具深度对比：Cursor、Copilot、Trae与Claude Code

AI编程工具深度对比：Cursor、Copilot、Trae与Claude Code 引言 在人工智能技术蓬勃发展的今天，AI编程工具已成为开发者提高效率的重要助手。从早期的代码补全插件到如今能够理解整个代码库的智能助手，AI编程工具正在不断进化。本文将对当前主流的AI编程工具——Cursor、GitHub Copilot、Trae和Claude Code进行全面对比，帮助开发者选择最适合自己的工具。 主流AI编程工具概述 Cursor Cursor是一款基于VSCode的AI驱动代码编辑器，它最大的特点是能够理解整个代码库的上下文，提供智能的代码补全和重构建议。Cursor默认使用Claude-3.5-Sonnet模型，即使是OpenAI投资的公司，也选择了Claude模型作为默认选项，这足以说明其在代码生成领域的优势。 GitHub Copilot GitHub Copilot是由GitHub与OpenAI合作开发的AI编码助手，集成在VSCode、Visual Studio等主流编辑器中。它基于OpenAI的模型，能够根据注释和上下文自动生成代码，是AI编程工具

By Ne0inhk
JetBrains 内的 GitHub Copilot Agent Mode + MCP：从配置到实战

JetBrains 内的 GitHub Copilot Agent Mode + MCP：从配置到实战

1. 背景说明：Agent Mode 与 MCP 的意义 Agent Mode 是 GitHub Copilot 的新形态，它能理解自然语言指令，自动拆分任务，遍历项目文件，执行命令并修改代码，像一个“自主项目助手”一样工作。 Model Context Protocol (MCP) 是一套用于 Copilot 调用外部工具的协议标准，让 Agent Mode 能访问终端、读写文件、检查代码等能力。 JetBrains 自 2025 年 5 月起已提供 Agent Mode + MCP 公测支持。最新版的插件已经是正式的非Preview版本。 2. JetBrains 中如何启用 Agent Mode (1)

By Ne0inhk

读李宁老师的《AIGC 自动化编程 -- 基于 ChatGPT和 GitHub Copilot》

对“李宁”这个名字，最有印象的，除了体操王子，就是一位计算机图书领域的作者了。前几年就买过一本他写的 python（《Python从菜鸟到高手》）的书，感觉深入浅出，理解深刻，行文易懂。所以对作者怀有敬意和好感。 这几天翻阅他的这本 2023/10月出版的《AIGC 自动化编程 -- 基于 ChatGPT和 GitHub Copilot》这本书，虽然时光荏苒，技术进步飞速，书中有些内容已经过时，但是看到其中核心思想 -- 解决复杂问题，通用的做法就是先分解后合并，还是颇有裨益，于我心戚戚耶。遗憾没有早几年接触到这本书。 从2024 年初的 ChatGPT 大火，然后 2025年初DeepSeek 的横空出世（对普罗大众而言)，到 2025 年底，Google Genimi 3的发布，LLM

By Ne0inhk