探索微服务架构中的动态服务发现与调用:使用 Nacos 与 Spring Cloud OpenFeign 打造高效订单管理系统

news/2024/9/18 15:04:56/ 标签: 架构, 微服务, 服务发现

1. 背景

在现代微服务架构中,服务之间的通信与协作是非常重要的。Spring Cloud Alibaba 提供了一套完整的微服务解决方案,其中包括 Nacos 用于服务注册与发现,OpenFeign 用于声明式服务调用,Spring Cloud LoadBalancer 用于负载均衡。本文将通过一个简单的电商系统示例,演示如何使用这些组件来实现服务之间的交互。

2. 应用场景

在本示例中,我们将实现一个电商系统,包含以下三个服务:

  • 订单服务(Order Service):处理用户的订单请求。
  • 商品服务(Product Service):提供商品信息查询。
  • 用户服务(User Service):管理用户信息和验证。

每个服务将注册到 Nacos 服务注册中心,并通过 OpenFeign 实现服务之间的调用。此外,我们将使用 Spring Cloud LoadBalancer 来实现负载均衡。

3. 环境准备

在开始之前,确保以下环境和依赖已安装:

  • JDK 8 或更高版本
  • Maven
  • Nacos(可在本地运行 Nacos 服务)
  • Spring Boot 2.5+ 和 Spring Cloud 2021+ 版本

4. Nacos 配置

所有服务都将注册到 Nacos,因此需要在每个服务的 application.yml 中配置 Nacos。

spring:cloud:nacos:discovery:server-addr: localhost:8848  # Nacos 服务地址

5. 商品服务(Product Service)实现

商品服务提供商品信息查询接口。

5.1 项目结构
product-service├── src│   ├── main│   │   ├── java│   │   │   └── com.example.product│   │   │       ├── ProductServiceApplication.java│   │   │       ├── controller│   │   │       │   └── ProductController.java│   │   │       └── model│   │   │           └── Product.java│   │   └── resources│   │       └── application.yml└── pom.xml
5.2 代码实现
  • ProductServiceApplication.java
package com.example.product;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient  // 启用服务发现
public class ProductServiceApplication {public static void main(String[] args) {SpringApplication.run(ProductServiceApplication.class, args);}
}
  • ProductController.java
package com.example.product.controller;import com.example.product.model.Product;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/api/products")
public class ProductController {@GetMapping("/{id}")public Product getProductById(@PathVariable Long id) {// 模拟从数据库获取商品信息return new Product(id, "Sample Product", "This is a sample product", 99.99);}
}
  • Product.java
package com.example.product.model;public class Product {private Long id;private String name;private String description;private Double price;public Product(Long id, String name, String description, Double price) {this.id = id;this.name = name;this.description = description;this.price = price;}// Getter 和 Setter 方法// ...
}
  • application.yml
server:port: 8081spring:application:name: product-servicecloud:nacos:discovery:server-addr: localhost:8848

6. 用户服务(User Service)实现

用户服务提供用户信息管理和验证接口。

6.1 项目结构
user-service├── src│   ├── main│   │   ├── java│   │   │   └── com.example.user│   │   │       ├── UserServiceApplication.java│   │   │       ├── controller│   │   │       │   └── UserController.java│   │   │       └── model│   │   │           └── User.java│   │   └── resources│   │       └── application.yml└── pom.xml
6.2 代码实现
  • UserServiceApplication.java
package com.example.user;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient  // 启用服务发现
public class UserServiceApplication {public static void main(String[] args) {SpringApplication.run(UserServiceApplication.class, args);}
}
  • UserController.java
package com.example.user.controller;import com.example.user.model.User;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/api/users")
public class UserController {@GetMapping("/{id}")public User getUserById(@PathVariable Long id) {// 模拟从数据库获取用户信息return new User(id, "John Doe", "john.doe@example.com");}
}
  • User.java
package com.example.user.model;public class User {private Long id;private String username;private String email;public User(Long id, String username, String email) {this.id = id;this.username = username;this.email = email;}// Getter 和 Setter 方法// ...
}
  • application.yml
server:port: 8082spring:application:name: user-servicecloud:nacos:discovery:server-addr: localhost:8848

7. 订单服务(Order Service)实现

订单服务将调用商品服务和用户服务来创建订单。

7.1 项目结构
order-service├── src│   ├── main│   │   ├── java│   │   │   └── com.example.order│   │   │       ├── OrderServiceApplication.java│   │   │       ├── controller│   │   │       │   └── OrderController.java│   │   │       ├── feign│   │   │       │   ├── ProductClient.java│   │   │       │   └── UserClient.java│   │   │       └── model│   │   │           ├── Order.java│   │   │           ├── OrderRequest.java│   │   │           ├── Product.java│   │   │           └── User.java│   │   └── resources│   │       └── application.yml└── pom.xml
7.2 代码实现
  • OrderServiceApplication.java
package com.example.order;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication
@EnableDiscoveryClient  // 启用服务发现
@EnableFeignClients  // 启用 OpenFeign 客户端
public class OrderServiceApplication {public static void main(String[] args) {SpringApplication.run(OrderServiceApplication.class, args);}
}
  • OrderController.java
package com.example.order.controller;import com.example.order.feign.ProductClient;
import com.example.order.feign.UserClient;
import com.example.order.model.Order;
import com.example.order.model.OrderRequest;
import com.example.order.model.Product;
import com.example.order.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/api/orders")
public class OrderController {@Autowiredprivate ProductClient productClient;@Autowiredprivate UserClient userClient;@PostMappingpublic Order createOrder(@RequestBody OrderRequest orderRequest) {// 通过 OpenFeign 调用商品服务Product product = productClient.getProductById(orderRequest.getProductId());// 通过 OpenFeign 调用用户服务User user = userClient.getUserById(orderRequest.getUserId());// 创建订单逻辑return new Order(user.getId(), product.getId(), 1, product.getPrice());}
}
  • ProductClient.java
package com.example.order.feign;import com.example.order.model.Product;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;@FeignClient(name = "product-service")
public interface ProductClient {@GetMapping("/api/products/{id}")Product getProductById(@PathVariable("id") Long id);
}
  • UserClient.java
package com.example.order.feign;import com.example.order.model.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;@FeignClient(name = "user-service")
public interface UserClient {@GetMapping("/api/users/{id}")User getUserById(@PathVariable("id") Long id);
}
  • Order.java
package com.example.order.model;public class Order {private Long userId;private Long productId;private Integer quantity;private Double totalPrice;public Order(Long userId, Long productId, Integer quantity, Double totalPrice) {this.userId = userId;this.productId = productId;this.quantity = quantity;this.totalPrice = totalPrice;}// Getter 和 Setter 方法// ...
}
  • OrderRequest.java
package com.example.order.model;public class OrderRequest {private Long userId;private Long productId;public OrderRequest(Long userId, Long productId) {this.userId = userId;this.productId = productId;}// Getter 和 Setter 方法// ...
}
  • application.yml
server:port: 8083spring:application:name: order-servicecloud:nacos:discovery:server-addr: localhost:8848loadbalancer:ribbon:enabled: false  # 使用 Spring Cloud LoadBalancer 代替 Ribbon

8. 服务注册与发现

启动所有三个服务,确保它们正确注册到 Nacos。在 Nacos 控制台中,你应该能够看到 order-serviceproduct-serviceuser-service 的实例。

9. 测试

  1. 使用 Postman 或 curl 发送 HTTP POST 请求到 order-service/api/orders 接口,传入 OrderRequest 数据。
  2. order-service 将通过 ProductClientUserClient 调用相应的商品服务和用户服务,获取商品和用户信息,并创建订单。

10. 总结

本文通过一个完整的电商系统示例,展示了如何使用 Spring Cloud Alibaba Nacos 进行服务注册与发现,使用 OpenFeign 进行声明式服务调用,以及使用 Spring Cloud LoadBalancer 实现负载均衡。通过 Nacos、OpenFeign 和 LoadBalancer 的协同工作,我们能够轻松构建一个稳定、可靠且可扩展的微服务架构。希望本文的示例能够为你在实际项目中应用这些技术提供参考。


http://www.ppmy.cn/news/1517164.html

相关文章

基于asp.net的茶叶销售系统网站附源码

这个一个基于asp.net的webform框架的茶叶销售系统源码,包含前后台,具体详情如下 1.主要功能 主要功能包含用户注册、茶叶浏览、我的购物车、购物订单、商品评论、个 人中心、后台登录、用户管理、商品管理、订单管理、评论管理、发布商品 等等模块。2.…

从国产 3A 大作《黑神话·悟空》的横空出世,深入分析国产游戏在图形渲染、物理引擎、AI等方面的技术亮点,以及这些技术如何推动了游戏体验的提升

深入分析国产游戏在图形渲染、物理引擎、AI等方面的技术亮点,以及这些技术如何推动了游戏体验的提升。 一、图形渲染技术在游戏行业的进步显著推动了视觉效果的提升,增强了玩家的沉浸感。以下是图形渲染领域的一些重要技术及其对游戏体验的影响&#xff…

DORIS - 执行 git submodule update --init --recursive 的目的是什么?

前言 以前,我们学习源码的时候只需要执行克隆命令即可,如下: git clone https://github.com/rocky/doris.git 当我学习DORIS的时候,发现执行完上面的命令后,还需要执行如下命令: git submodule update --init --recur…

[论文笔记]Improving Retrieval Augmented Language Model with Self-Reasoning

引言 今天带来一篇百度提出的关于提升RAG准确率的论文笔记,Improving Retrieval Augmented Language Model with Self-Reasoning。 为了简单,下文中以翻译的口吻记录,比如替换"作者"为"我们"。 检索增强语言模型(Retrie…

linux常见基础命令

Linux基础命令 (下面这些命令都是最常见的命令.更复杂的会在之后的C语言学习陆续深入) 1、 pwd 功能: print work directory的缩写,显示当前目录的绝对路径 2、 cd 功能: change directory的缩写,切换目录 绝对路径:以…

【KDD2024】大数据基础工程技术集群异常检测论文入选

近日,由阿里云计算平台大数据基础工程技术团队主导,与浙江大学合作的论文《Cluster-Wide Task Slowdown Detection in Cloud System》被数据挖掘领域顶会ACM SIGKDD2024接收,该论文从集群整体作业执行情况分布入手,旨在解决集群整…

服务器被渗透的表现及检测方法

本文将详细介绍服务器遭受渗透攻击后的常见症状,并提供一些实用的检测方法。我们还将通过具体的案例和代码示例来帮助读者更好地理解和检测服务器的安全状况。 1. 引言 服务器渗透是指攻击者未经授权访问服务器资源的过程。一旦服务器被成功渗透,可能会…

pgsql导入导出数据

1、pg_dump 进行数据库导出 导出数据库表结构和数据 pg_dump -U postgres -h localhost -d mydatabase -f /path/to/backup.sql-U 用户名-h 主机地址-d 要导出的数据库-f 导出的sql文件 2、pg_dumpall 备份所有数据库 pg_dumpall -U postgres -h localhost -f /path/to/all…

java框架基础--反射

前言 本文将详细讲述反射的基本概念以及反射底层代码的部分实现 反射 就是程序在运行状态时,对于任何一个类,都在仅知道类名的状况下,动态获取该类中的所有属性和方法(包括私有),可以动态地通过该类的对象调用类的属性和方法的机制称为反射机制 是将java中的类映射成一个个对象…

MAVEN 3.9.1安装

WIN系统MAVEN 3.9.1安装 1. 下载 下载官网地址:Index of /dist/maven/maven-3 (apache.org) 百度网盘: 通过网盘分享的文件:apache-maven-3.9.1-bin.zip 链接: https://pan.baidu.com/s/1VKmxrU5Hg6mbEUc43wjQUw 提取码: aua6 –来自百度网…

Linux 常用命令 - lsblk 【查看磁盘(块设备)使用情况】

简介 lsblk 源自于 “list block devices” 的缩写。这个命令用于列出系统中的所有块设备(block devices),比如硬盘、光驱等。它展示块设备的层次结构、大小和挂载点等信息,非常有助于系统管理员理解系统存储结构。 使用方式 l…

Spring:浅谈对SpringBean的认识

一、SpringBean的生命周期 1、实例化bean对象:通过反射的方式进行对象的创建,此时的创建只是在堆空间中申请空间,属性都是默认值。 2、设置对象属性:给对象中的属性进行值的设置工作。 3、检查Aware相关接口并设置相关依赖&#x…

C的温故而知新:位操作(C Primer Plus第十五章)

第十五章:位操作 这一章的篇幅不是很长,但既然能单独作为一章来讲的话,应该蛮重要的,但是我貌似没有总结出多少需要注意、加强记忆的东西,可见在JAVA的日常开发过程中基本不太遇见有关位操作的内容,所以我…

Apache Doris 使用 CBO 和 RBO 结合的优化策略

Apache Doris 在查询优化方面通过结合 RBO 和 CBO,实现了对简单和复杂查询的高效优化。RBO 负责处理常量折叠、子查询改写和谓词下推等基础优化操作,而 CBO 则在 Join Reorder 等复杂场景中发挥作用。这种结合策略使得 Apache Doris 能够在面对各种查询场景时,既能保证优化过…

4170条中医综合真题中医真题ACCESS\EXCEL数据库

今天这份数据库与《4820道西#医综合真#题西#医真题ACCESS数据库》结构相同,包含4千多道真题。这个数据库包含3个表,一个是分类表(SECTION_BEAN),一个是题库主表(QUESTION_INFO_BEAN)&#xff0c…

Queues

概述 RabbitMQ 是一个消息中间件: 它接收、存储并转发消息数据。本教程将带你通过一系列步骤来设置和使用 RabbitMQ。 环境准备 1. 安装 RabbitMQ - [下载](https://www.rabbitmq.com/download.html)并安装RabbitMQ服务器。 - 启动RabbitMQ服务器。 - 通过浏览器访问 htt…

全方位解析红鲸音视频会议SDK助力系统功能集成

在数字化转型的浪潮中,企业对于高效沟通与协作的需求日益迫切。随着远程办公、在线教育、在线医疗等场景的兴起,音视频会议功能已成为众多企业平台不可或缺的一部分。然而,对于许多企业而言,如何将这一功能无缝集成到现有系统或平…

只用一个 HTML 元素可以写出多少形状?——不规则图形篇

上一篇章的末尾(伪元素篇),我们送上了气泡框和笑脸两个好玩的案例。这两个案例其实就是使用伪元素实现的不规则图形的两个预热案例。 相信经过这两个案例的预热,聪明的您已经发现,通过适当且合理的拆分,就…

【Android 设备上的所有相关 WiFi 命令和使用方法】

请注意,这些命令的可用性可能会因设备型号和 Android 版本的不同而有所变化。 1. adb shell cmd wifi 命令 1.1 查看 WiFi 状态 命令:adb shell cmd wifi status功能: 查看 WiFi 的当前状态,如是否开启、连接的网络等。示例:adb shell cmd wifi status1.2 执行 WiFi 扫描 命…

王立铭脑科学50讲:34、两性,脑功能有没有性别差异

王立铭脑科学50讲:34、两性,脑功能有没有性别差异 自己的学习笔记。 1、从脑科学角度出发,1在认知能力上,两性在认知能力上,差别是微乎其微的。 有这个一个思想实验,假设刚开始两性有差异,经…