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

【AI大模型前沿】通义万相Wan2.2：阿里270亿参数巨兽开源，消费级显卡就能跑，免费平替Sora上线

【AI大模型前沿】通义万相Wan2.2：阿里270亿参数巨兽开源，消费级显卡就能跑，免费平替Sora上线

系列篇章💥 No.文章1【AI大模型前沿】深度剖析瑞智病理大模型 RuiPath：如何革新癌症病理诊断技术2【AI大模型前沿】清华大学 CLAMP-3：多模态技术引领音乐检索新潮流3【AI大模型前沿】浙大携手阿里推出HealthGPT：医学视觉语言大模型助力智能医疗新突破4【AI大模型前沿】阿里 QwQ-32B：320 亿参数推理大模型，性能比肩 DeepSeek-R1，免费开源5【AI大模型前沿】TRELLIS：微软、清华、中科大联合推出的高质量3D生成模型6【AI大模型前沿】Migician：清华、北大、华科联手打造的多图像定位大模型，一键解决安防监控与自动驾驶难题7【AI大模型前沿】DeepSeek-V3-0324：AI 模型的全面升级与技术突破8【AI大模型前沿】BioMedGPT-R1：清华联合水木分子打造的多模态生物医药大模型，开启智能研发新纪元9【AI大模型前沿】DiffRhythm：西北工业大学打造的10秒铸就完整歌曲的AI歌曲生成模型10【AI大模型前沿】R1-Omni：阿里开源全模态情感识别与强化学习的创新结合11【AI大模型前沿】Qwen2.5-Omni：

By Ne0inhk

【研发规范】Git 提交（commit）、CodeReview规范

本文将分为三个部分： 1. 为什么需要提交规范？ 2. 提交规范详解（核心内容） 3. 与 Code Review 流程的结合 1. 为什么需要提交规范？ 在 Code Review 前，如果提交的代码杂乱无章，审查者会非常痛苦： * 理解成本高：审查者需要花费大量时间猜测这个提交到底做了什么和为什么这么做。 * 范围不明确：一个提交里混杂了多个功能的修改，难以聚焦审查。 * 历史追溯困难：混乱的提交信息使得日后排查问题、生成变更日志（Changelog）变得几乎不可能。 良好的提交规范旨在解决这些问题，它的核心目标是：让每一次提交都是一个逻辑独立、意图明确、易于理解的故事单元。 2. 提交规范详解 一份优秀的提交（Commit）主要由两部分组成： 1. 提交信息 2. 提交内容（代码变更集） A. 提交信息规范 提交信息是写给未来维护者（包括你自己） 的说明文档。一个常见的规范格式是：

By Ne0inhk
【Linux工具】git

【Linux工具】git

文章目录 * Git 概述 * 主要功能 * 使用场景 * 资源链接 * 使用和下载git * 总结 Git 概述 Git是一个流行的分布式版本控制系统，主要用于跟踪计算机文件的变化，尤其是在软件开发中。它允许多个开发者协同工作，并管理项目的版本历史。 主要功能 1. 版本跟踪 记录文件的每次更改，用户可以随时回溯到先前的版本。 2. 分支管理 允许开发者创建独立的工作线，便于新特性的开发和实验。 3. 合并功能 轻松合并不同分支的更改，处理冲突并保持代码整洁。 4. 分布式操作 每个开发者都有完整的代码库副本，允许离线工作并提高效率。 使用场景 * 软件开发 最常见的用途，管理源代码的版本控制。 * 文档管理 跟踪文档修改历史，尤其是在团队协作中。 资源链接 * Git官方文档 * Atlassian的Git指南 使用和下载git 如果在你的Linux系统上没有下载git那么我们可以使用下面命令进行下载 sudo yum install -y git 这里我

By Ne0inhk
开源力量：GitCode+昇腾NPU 部署Mistral-7B-Instruct-v0.2模型的技术探索与经验总结

开源力量：GitCode+昇腾NPU 部署Mistral-7B-Instruct-v0.2模型的技术探索与经验总结

开源力量：GitCode+昇腾NPU 部署Mistral-7B-Instruct-v0.2模型的技术探索与经验总结 目录 开源力量：GitCode+昇腾NPU 部署Mistral-7B-Instruct-v0.2模型的技术探索与经验总结 摘要 一、技术背景 1.1 昇腾NPU 1.2 GitCode平台 1.3 vLLM Ascend 二、环境准备 2.1 创建GitCode Notebook 2.2 配置Hugging Face镜像 三、部署方案一：原生部署（transformers + torch_npu） 3.1 安装依赖 3.2 下载模型 3.3 推理代码 3.

By Ne0inhk