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

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.mzph.cn/pingmian/52558.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

FAISS 索引

FAISS(Facebook AI Similarity Search)是一个由 Facebook 开发的开源库,用于高效的相似性搜索和密集向量的聚类。它非常适合处理大规模的向量搜索任务,例如推荐系统、图像搜索、自然语言处理中的嵌入搜索等。 FAISS 文件概述 FAI…

vite 实现包的拆分

Vite 和 Rollup 是现代前端开发中两个非常流行的工具,它们各自有独特的用途和特点,但它们之间也存在一定的联系。 Vite Vite 是一个由 Vue 团队成员开发的前端构建工具,它的核心特点是在开发环境下提供极快的服务器启动和热模块替换&#x…

【视频讲解】SMOTEBoost、RBBoost和RUSBoost不平衡数据集的集成分类酵母数据集、治癌候选药物|数据分享...

全文链接:https://tecdat.cn/?p37502 分析师:Zilin Wu 在当今的大数据时代,科研和实际应用中常常面临着海量数据的处理挑战。在本项目中,我们拥有上万条数据,这既是宝贵的资源,也带来了诸多难题。一方面&a…

【递归回溯之floodfill算法专题练习】

1. 图像渲染 class Solution {int dx[4] {0, 0, -1, 1};int dy[4] {1, -1, 0, 0};int m, n;int oldcolor; public:vector<vector<int>> floodFill(vector<vector<int>>& image, int sr, int sc, int color) {oldcolor image[sr][sc]; // 保存原…

MySQL数据库MVCC机制底层原理详解

mvcc机制即多版本并发控制 当在事务中使用了写操作&#xff08;增删改&#xff09;语句时会给当前事务生成一个事务id&#xff0c;事务id是递增的 同时&#xff0c;对于被修改的行的数据会创建一个数据版本 &#xff0c;这个数据版本除了包含原有的字段还会包含一个事务id和一…

Linux驱动开发—创建总线,创建属性文件

文章目录 1.什么是BUS&#xff1f;1.1总线的主要概念1.2总线的操作1.3总线的实现 2.创建总线关键结构体解析2.1注册总线到系统2.2 struct bus_type *bus 解析 3.实验结果分析1. devices 目录2. drivers 目录3. drivers_autoprobe 文件4. drivers_probe 文件5. uevent 文件 4.在…

【Rust光年纪】深度解读:Rust语言中各类消息队列客户端库详细对比

选择最佳 Rust 消息队列客户端库&#xff1a;全面对比与分析 前言 随着现代应用程序的复杂性不断增加&#xff0c;消息队列成为构建可靠、高性能系统的重要组件。本文将介绍一些用于Rust语言的消息队列客户端库&#xff0c;包括AMQP、Apache Kafka、NSQ、Apache Pulsar和Rock…

开发新系统时,数据库字符集怎么选择对中文的支持最好?

在新开发的系统时,如果你希望确保中文按拼音顺序正确排序,同时支持更多的特殊字符与符号,下面是对 utf8mb4_zh_cn_ci、utf8mb4_unicode_ci 和 utf8mb4_unicode_520_ci 这几种字符集和校对规则的分析以及推荐方案: 校对规则分析 utf8mb4_zh_cn_ci: 特点:这是专为简体中文…

goalng http client的MaxIdleConnsPerHost,MaxIdleConns,MaxConnsPerHost参数设置总结

MaxIdleConnsPerHost&#xff1a;优先设置这个&#xff0c;决定了对于单个Host需要维持的连接池大小。该值的合理确定&#xff0c;应该根据性能测试的结果调整。MaxIdleConns&#xff1a;客户端连接单个Host&#xff0c;不少于MaxIdleConnsPerHost大小&#xff0c;不然影响MaxI…

数据压缩(2)——变长编码

【定长编码】 变长和定长是很基本的概念&#xff0c;不光是在数据压缩&#xff0c;在其他很多地方都可以见到&#xff0c;这里就不多说了。 前文说过&#xff0c;在数据压缩时&#xff0c;我们需要用某些字符A替换或修改某些字符B&#xff0c;字符A占用的存储空间更小一些。 …

【力扣】划分为k个相等的子集

&#x1f525;博客主页&#xff1a; 我要成为C领域大神&#x1f3a5;系列专栏&#xff1a;【C核心编程】 【计算机网络】 【Linux编程】 【操作系统】 ❤️感谢大家点赞&#x1f44d;收藏⭐评论✍️ 本博客致力于知识分享&#xff0c;与更多的人进行学习交流 给定一个整数数组 …

超越基础:Visual Basic在科学计算与数据分析的革新应用

标题&#xff1a;超越基础&#xff1a;Visual Basic在科学计算与数据分析的革新应用 Visual Basic&#xff08;VB&#xff09;&#xff0c;最初以其易于学习和使用而闻名&#xff0c;常被视为入门级编程语言。然而&#xff0c;VB的潜力远不止于简单的应用程序开发。在科学计算…

WHAT - 综合书单推荐

拥有一个成功的人生&#xff0c;书籍确实是一个重要的知识来源。可以将书籍分为几个主要类别&#xff0c;每个类别对应不同的知识领域和成长方向。以下是一些建议的分类及每类书籍推荐&#xff1a; 1. 个人发展与心理学 《如何赢得朋友与影响他人》 - 戴尔卡耐基《思考&#…

【qt】锁

线程安全问题. 多线程程序太复杂了. 加锁 把多个线程要访问的公共资源&#xff0c;通过锁保护起来.>把并发执行变成串行执行. Linux mutex 互斥量. C11引入std::mutex Qt 同样也提供了对应的锁&#xff0c;来针对系统提供的锁进行封装.QMutex 多个线程进行加锁的对象&…

example-apisix-1 清空日志之后启动异常处理

异常信息 2024/08/27 11:34:33 [emerg] 1#1: bind() to unix:/usr/local/apisix/conf/config_listen.sock failed (98: Address already in use) nginx: [emerg] bind() to unix:/usr/local/apisix/conf/config_listen.sock failed (98: Address already in use) 2024/08/27 1…

【生日视频制作】室内告白表白祝福布置霓虹灯AE模板修改文字软件生成器教程特效素材【AE模板】

室内告白表白祝福布置霓虹灯生日视频制作教程AE模板改字生成器 怎么如何做的【生日视频制作】室内告白表白祝福布置霓虹灯AE模板修改文字软件生成器教程特效素材【AE模板】 生日视频制作步骤&#xff1a; 安装AE软件下载AE模板把AE模板导入AE软件修改图片或文字渲染出视频

【Go - 每日一小问: 对未初始化的的 chan 进行读写,会怎么样?为什么?】

对未初始化的 chan 进行读写会有不同的行为&#xff1a; 1. 对未初始化的 chan 进行读取 读取操作&#xff1a; 对未初始化的 chan 进行读取操作会导致永久阻塞&#xff08;deadlock&#xff09;&#xff0c;因为没有任何 goroutine 可以向这个 chan 发送数据。读取操作会一直…

Signac R|如何合并多个 Seurat 对象 (1)

引言 在本文中演示了如何合并包含单细胞染色质数据的多个 Seurat 对象。为了进行演示&#xff0c;将使用 10x Genomics 提供的四个 scATAC-seq PBMC 数据集&#xff1a; 500-cell PBMC 1k-cell PBMC 5k-cell PBMC 10k-cell PBMC 实战 在整合多个单细胞染色质数据集的过程中&…

SAP与生产制造MPM系统集成案例

一、需求介绍 某公司为保证企业内部生产管理系统的多项基础数据的同步更新&#xff0c;确保各模块间信息的一致性和准确性&#xff0c;对后续的生产计划和物料管理打下基础&#xff0c;该公司将MPM系统和SAP系统经过SAP PO中间件集成平台进行了集成。MPM全称为Manufacturing…

超实用的8个无版权、免费、高清图片素材网站整理

不管是设计、文章配图&#xff0c;还是视频制作&#xff0c;图片都至关重要。但是图片版权一直都是困扰很多设计、自媒体以及企业的大问题。现在&#xff0c;因为图片侵权被告的案例已经是司空见惯了&#xff0c;有的公众号甚至因为图片版权问题遭受致命打击。 1. Pexels Pexe…