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

Flutter 三方库 flutter_adaptive_scaffold 的鸿蒙化适配指南 - 掌握一套代码适配全场景终端的自适应架构技术、助力鸿蒙应用构建从手机到平板及折叠屏的极致无缝交互体系

Flutter 三方库 flutter_adaptive_scaffold 的鸿蒙化适配指南 - 掌握一套代码适配全场景终端的自适应架构技术、助力鸿蒙应用构建从手机到平板及折叠屏的极致无缝交互体系

欢迎加入开源鸿蒙跨平台社区：https://openharmonycrossplatform.ZEEKLOG.net Flutter 三方库 flutter_adaptive_scaffold 的鸿蒙化适配指南 - 掌握一套代码适配全场景终端的自适应架构技术、助力鸿蒙应用构建从手机到平板及折叠屏的极致无缝交互体系 前言 在 OpenHarmony 鸿蒙应用追求“万物互联、全场景覆盖”的伟大进程中，屏幕尺寸的多样性（从 6 英寸手机到 12 英寸平板，再到 2D/3D 模式切换的折叠屏）是每一位 UI 开发者必须正面迎接的挑战。如何在不为每种设备重写 UI 的前提下，实现导航栏自动从“底部”平滑流转到“侧边”？如何在宽屏模式下自动开启“双栏（Master-Detail）”布局？flutter_adaptive_scaffold 作为一个由 Flutter

By Ne0inhk
在 macOS 上通过 Docker 本地安装 OpenClaw 完整教程

在 macOS 上通过 Docker 本地安装 OpenClaw 完整教程

在 macOS 上通过 Docker 本地安装 OpenClaw 完整教程 什么是 OpenClaw？—— 你的本地 AI 智能体执行框架 OpenClaw 不仅仅是一个聊天机器人，而是一个功能强大的 AI 智能体执行框架。你可以把它想象成一个能自主思考、调用工具、并替你完成复杂任务的数字员工。 🧠 核心概念 * 智能体：OpenClaw 的核心大脑。它能理解你的自然语言指令，拆解任务，并决定调用哪些工具来执行。 * 网关：所有外部访问的入口。它负责处理 WebSocket 连接、管理设备配对、路由消息，是你与智能体交互的桥梁。 * 技能：智能体可调用的具体工具，比如访问文件、操作浏览器、发送消息、查询数据库等。你可以根据需要扩展技能库。 * 记忆：OpenClaw 可以存储对话历史和重要信息，实现长期记忆和上下文理解，让交互更连贯。 * 通道：连接外部聊天平台的渠道，如

By Ne0inhk
HarmonyOS6半年磨一剑 - RcIcon组件实战案例集与应用开发指南

HarmonyOS6半年磨一剑 - RcIcon组件实战案例集与应用开发指南

文章目录 * 前言 * 项目简介 * 核心特性 * 开源计划 * rchoui官网 * 文档概述 * 第一章: 基础用法实战 * 1.1 三种符号引用方式 * 1.2 应用场景 - 工具栏快速导航 * 第二章: 尺寸系统实战 * 2.1 响应式尺寸配置 * 2.2 应用场景 - 统一设计系统尺寸规范 * 第三章: 颜色系统实战 * 3.1 多彩色系配置 * 3.2 应用场景 - 状态指示系统 * 第四章: 双风格系统实战 * 4.1 线型与实底风格对比 * 4.2 应用场景 - 底部导航栏 * 第五章: 圆角系统实战 * 5.

By Ne0inhk
Flutter 组件 short_uuids 适配鸿蒙 HarmonyOS 实战：唯一标识微缩技术，构建高性能短 ID 生成与分布式索引架构

Flutter 组件 short_uuids 适配鸿蒙 HarmonyOS 实战：唯一标识微缩技术，构建高性能短 ID 生成与分布式索引架构

欢迎加入开源鸿蒙跨平台社区：https://openharmonycrossplatform.ZEEKLOG.net Flutter 组件 short_uuids 适配鸿蒙 HarmonyOS 实战：唯一标识微缩技术，构建高性能短 ID 生成与分布式索引架构 前言 在鸿蒙（OpenHarmony）生态迈向万物互联、涉及海量离线资源标识、蓝牙广播载荷（BLE Payload）及二维码数据极限压缩的背景下，如何生成既能保留 UUID 强随机性、又能极大缩减字符长度的唯一标识符，已成为优化存储与通讯效率的“空间必修课”。在鸿蒙设备这类强调分布式软总线传输与每一字节功耗敏感的环境下，如果应用依然直接传输长度达 36 字符的标准 UUID，由于由于有效载荷溢出，极易由于由于传输协议限制导致数据截断或多次分包带来的延迟。 我们需要一种能够实现高进制转换、支持双向编解码且具备低碰撞概率的短 ID 生成方案。 short_uuids 为 Flutter 开发者引入了将标准 UUID 转化为短格式字符串的高性能算法。它利用

By Ne0inhk