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

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

时间:2024-08-28 11:25:01浏览次数:13  
标签:java OpenFeign Spring Nacos public org import com example

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: 8081

spring:
  application:
    name: product-service
  cloud:
    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", "[email protected]");
    }
}
  • 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: 8082

spring:
  application:
    name: user-service
  cloud:
    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 {

    @Autowired
    private ProductClient productClient;

    @Autowired
    private UserClient userClient;

    @PostMapping
    public 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: 8083

spring:
  application:
    name: order-service
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
  loadbalancer:
    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 的协同工作,我们能够轻松构建一个稳定、可靠且可扩展的微服务架构。希望本文的示例能够为你在实际项目中应用这些技术提供参考。

标签:java,OpenFeign,Spring,Nacos,public,org,import,com,example
From: https://blog.csdn.net/heromps/article/details/141569484

相关文章

  • 基于java的SpringBoot框架卫生健康系统
    博主介绍:java高级开发,从事互联网行业六年,熟悉各种主流语言,精通java、python、爬虫、web开发,已经做了六年的程序开发,开发过上千套大学生实战程序,可以定制、也可成品项目,博客中有上百套程序可供参考,欢迎共同交流学习。......
  • 使用idea快速创建springbootWeb项目(springboot+springWeb+mybatis-Plus)
    idea快速创建springbootWeb项目详细步骤如下1)创建项目2)选择springboot版本3)添加web依赖4)添加Thymeleaf5)添加lombok依赖然后点击create进入下一步双击pom.xml文件6)添加mybatis-plus依赖        这里使用的springboot版本比较新,mybatis-plus-boot-star......
  • springboot+vue+mybatis计算机毕业设计云养鸡互动平台+PPT+论文+讲解+售后
    快速发展的社会中,人们的生活水平都在提高,生活节奏也在逐渐加快。为了节省时间和提高工作效率,越来越多的人选择利用互联网进行线上打理各种事务,然后线上管理系统也就相继涌现。与此同时,人们开始接受方便的生活方式。他们不仅希望页面简单大方,还希望操作方便,可以快速锁定他们需......
  • springboot+vue+mybatis计算机毕业设计电影影评的垂直搜索引擎+PPT+论文+讲解+售后
    近年来,科技飞速发展,在经济全球化的背景之下,大数据将进一步提高社会综合发展的效率和速度,大数据技术也会涉及到各个领域,而爬虫实现网站数据可视化在网站数据可视化背景下有着无法忽视的作用。管理信息系统的开发是一个不断优化的过程,随着网络大数据时代的到来,管理信息系统与大......
  • Spring Boot 框架中配置文件 application.properties 当中的所有配置大全
    SpringBoot框架中配置文件application.properties当中的所有配置大全#SPRINGCONFIG(ConfigFileApplicationListener)spring.config.name=#配置文件名(默认为'application')spring.config.location=#配置文件的位置#多环境配置文件激活属性spring.profiles.active......
  • Java毕设项目II基于Spring Boot的医药管理系统的设计与实现
    目录一、前言二、技术介绍三、系统实现四、论文参考五、核心代码六、源码获取全栈码农以及毕业设计实战开发,CSDN平台Java领域新星创作者,专注于大学生项目实战开发、讲解和毕业答疑辅导。获取源码联系方式请查看文末一、前言"在当今医疗信息化快速发展的背景下,设计......
  • springboot+vue家教平台项目添加登录功能
    一.概述要为家教平台添加登录功能,建议先从后端开始,因为这样可以确保前端有一个明确的API进行交互,从而在开发前端时更容易进行调试和验证。后端开发:创建登录接口:在后端创建一个RESTfulAPI,用于处理用户登录请求。验证用户提交的登录号码和密码是否与数据库中的记录匹配......
  • Spring源码第十七讲 @Aspect 到 Advisor
    先做一些准备工作publicclassA017{publicstaticvoidmain(String[]args){GenericApplicationContextcontext=newGenericApplicationContext();context.registerBean("aspect1",Aspect1.class);context.registerBean("con......
  • 基于Java Springboot高校教师工作量管理系统
    一、作品包含源码+数据库+设计文档万字+PPT+全套环境和工具资源+部署教程二、项目技术前端技术:Html、Css、Js、Vue、Element-ui数据库:MySQL后端技术:Java、SpringBoot、MyBatis三、运行环境开发工具:IDEA/eclipse数据库:MySQL5.7数据库管理工具:Navicat10以上版本环境......
  • 基于Java Springboot闲置物品共享平台
    一、作品包含源码+数据库+设计文档万字+PPT+全套环境和工具资源+部署教程二、项目技术前端技术:Html、Css、Js、Vue、Element-ui数据库:MySQL后端技术:Java、SpringBoot、MyBatis三、运行环境开发工具:IDEA/eclipse数据库:MySQL5.7数据库管理工具:Navicat10以上版本环境......