【SpringCloud】之远程消费(进阶使用)

 🎉🎉欢迎来到我的CSDN主页!🎉🎉

🏅我是君易--鑨,一个在CSDN分享笔记的博主。📚📚

🌟推荐给大家我的博客专栏《SpringCloud开发之远程消费》。🎯🎯

🎁如果感觉还不错的话请给我关注加三连吧!🎁🎁


前言

         在上一期的SpringCloud的分享中我们对其SpringCloud有了一个初步的了解,在上一期我们一起学习了什么是SpringCloud、详细的讲述了SpringCloud核心组件在业务中的一些用法以及作用,最后我们还涉及到了nacos在SpringCloud中的集成使用。本期的博客分享基于上期的博客进行一个远程消费的一个分享

一、 什么是远程消费

1. 概述

        在 Spring Cloud 中,远程消费通常指的是一个微服务通过网络调用另一个微服务的接口,以实现跨服务的功能调用。这种跨服务的通信方式常见于分布式系统中,其中不同的微服务协同工作以完成更大的业务目标。在微服务架构中,各个微服务通常拥有独立的代码库和部署单元

2.  实现方式

2.1 RestTemplate

   RestTemplate 是 Spring 提供的一个用于访问 REST 服务的模板类。通过 RestTemplate,你可以发起 HTTP 请求,从而实现对其他微服务提供的 RESTful API 的调用。在 Spring Cloud 中,可以通过使用 @LoadBalanced 注解来启用负载均衡,使得 RestTemplate 可以根据服务名称自动选择合适的实例。

 代码示例展示
@Bean
@LoadBalanced
public RestTemplate restTemplate() {return new RestTemplate();
}

2.2 Feign

        Spring Cloud Feign 是一个基于注解的声明式 HTTP 客户端,它简化了使用 RestTemplate 的代码。通过定义接口并添加 @FeignClient 注解,开发者可以直接调用其他微服务的接口,而 Feign 会在运行时自动创建实现类并处理 HTTP 请求

代码示例展示
@FeignClient(name = "another-service")
public interface AnotherServiceClient {@GetMapping("/api/someEndpoint")String getSomeData();
}

2.3 WebFlux WebClient

        对于响应式编程,Spring WebFlux 提供了 WebClient,它也可以用于进行远程服务调用。WebClient 提供了非阻塞的 API,适用于构建响应式系统

代码示例展示
WebClient webClient = WebClient.create("http://another-service");
String result = webClient.get().uri("/api/someEndpoint").retrieve().bodyToMono(String.class).block();

         总之,这些方法都允许微服务之间进行远程通信,使得不同微服务能够协同工作,共同完成复杂的业务逻辑。在使用这些远程消费的方法时,通常需要考虑到服务的可用性、负载均衡、容错机制(如断路器模式)等因素,以确保系统的稳定性和可靠性。

二、DTO封装

        VO(View Object):视图对象,用于展示层,它的作用是把某个指定页面(或组件)的所有数据 封装起来。
        DTO(Data Transfer Object):数据传输对象,这个概念来源于J2EE的设计模式,原来的目的是 为了EJB的分布式应用提供粗粒度的数据实体,以减少分布式调用的次数,从而提高分布式调用的性能和降低网络负载,但在这里,我泛指用于展示层与服务层之间的数据传输对象。
        DO(Domain Object):领域对象,就是从现实世界中抽象出来的有形或无形的业务实体。
        PO(Persistent Object):持久化对象,它跟持久层(通常是关系型数据库)的数据结构形成一 一对应的映射关系,如果持久层是关系型数据库,那么,数据表中的每个字段(或若干个)就对应PO的一个(或若干个)属性。

        消费者 远程调用 生产者 : 需要网络传输,使用DTO同一封装对象
         原理与 SpringBoot 启动类相同
        1.将 DTO 对象封装到公共 DTO 模块
        2.为需要的项目引入公共 DTO 模块

 注意点

         1.不需要继承父模块(重复引用问题)
        2.打包方式为jar
        3.不需要添加启动类的编译

三、Feign实现远程消费

        如果我们基于上一期的博客中的代码去实现我们的代码的话,我们的代码要写到爆,因此我们接下来就以Feign来详细说明其实现的过程

1. 导入其Fegin的pom依赖

        在我们的主项目中去导入我们的Fegin的pom依赖。

<!--  引入openfeign的依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

2. 标记使用远程消费

        我们在需要远程消费的服务的启动类上打上注解进行标记说明该服务启用远程消费。

注解:@EnableFeignClients

         该注解是开启Feign功能,我们的消费者需要启用,因此在我们的消费者的启动类上打上其注解。

 

3. 生产者编写接口

        我们需要模拟远程消费,对应的生产者是不是应该编写一个Controller去提供一些接口让我们的消费者进行调用。

        在编写的过程中只要参数是复杂对象,即使指定了是GET方法,feign依然会以POST方法进行发送请求,同时生产者必 须支持POST请求并给参数添加@RequestBody注解

3.1 参数的接收方式

3.1.1 路径参数
//    路径接收参数的请求@RequestMapping("/{account}")public String getByPath(@PathVariable("account") String account){log.info("account:{}",account);//打印输出查看return "🍗";}

3.1.2 接收多个参数
//    接收多个参数的请求//    @RequestParam接受参数@RequestMapping("/param")public String getByPath(@RequestParam("account") String password,@RequestParam("password") String account){log.info("account:{},password:{}",account,password);//打印输出查看return "🍗";}

3.1.3 使用对象接收

        首先我们要在生产者进行创建一个实体类

User.java
package com.yx.provider.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** com.yx.provider.pojo** @author 君易--鑨* @site www.yangxin.com* @company 木易* @create 2024/1/6* 实体类,用于存储用户信息*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {private Long id;//idprivate String account;//账号private String password;//密码String password;//密码}

        编写对应的请求方法

    //    接收对象参数的请求//    @RequestBody接受参数@RequestMapping("/pojo")public String getByPath(@RequestBody User user){log.info("user:{}",user);//打印输出查看return "🍗";}
3.1.4 使用Map接收
   @RequestMapping("/more")public String getByMore(@RequestBody Map<String, Object> map) {log.info("more:{}" + map);return "🍗";}

4. 编写一个接口类

         如果我们的消费者还是使用上期博客中的那种方式去调用的话不方便,也不好。因此我们可以在消费者编写一个接口类用于调用。 

 FeginService.java
package com.yx.consumer.service;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;/*** com.yx.consumer.service** @author 君易--鑨* @site www.yangxin.com* @company 木易* @create 2024/1/6* 接口类,用于调用生产者的请求方法,连接生产者的Controller*/
@FeignClient("provider")//连接的注解
public interface FeginService {//    路径接收参数的请求@RequestMapping("/{account}")String getByPath(@PathVariable("account") String account);//    接收多个参数的请求//    @RequestParam接受参数@RequestMapping("/param")String getByPath(@RequestParam("account") String password,@RequestParam("password") String account);}

        编写对应的接口类的时候要注意一下几点 

5. 编写消费者的Controller

        重新编写请求方法进行调用生产者的方法

ConsumerController.java
package com.yx.consumer;import com.yx.consumer.service.FeginUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class ConsumerController {//    调用生产者  ,注入接口@Autowiredprivate FeginUserService feginUserService;//restTemplate相当于HttpClient,用于发送请求@RequestMapping("/test01 ")public String test01() {//    跳转到生产者去return feginUserService.getByPath("木易兮");}}

6. 测试

6.1 测试路径传参

        当我们启动项目之后,在其网页进行对其发送请求

6.2 测试传递多个参数

6.3 测试对象传递参数

        消费者中的接口类定义其方法

         对其的控制层编写请求

        运行测试  

        我们这里测试没有问题,但是我们要考虑一个问题,如果我们生产者的实体类比较多呢,难道都赋值到消费者去吗。 我们可以在主项目下新建一个maven项目作为公共模块,我们创建好之后对其pom文件进行修改。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"><modelVersion>4.0.0</modelVersion><artifactId>common</artifactId><packaging>jar</packaging><name>common Maven Webapp</name><url>http://maven.apache.org</url><parent><groupId>com.yx</groupId><artifactId>cloud</artifactId><version>1.0-SNAPSHOT</version></parent><dependencies></dependencies>
</project>

        还要将其实体类赋值过来

         将实体类的名称改成UserDto,该类中的属性不一定和User的属性一致,生产者和消费者中引入UserDto需要在pom文件中引入公共模块

 <dependency><groupId>com.yx</groupId><artifactId>common</artifactId><version>1.0-SNAPSHOT</version></dependency>

 

 

        引入之后我就用UserDto进行传参以及接收 

        消费者的接口类进行修改 以及请求类也需修改

        最后我们启动项目进行访问请求测试  

6.4  测试使用Map接收

        消费者对应的代码 

        最后我们重新启动项目运行测试即可 


 🎉🎉本期的博客分享到此结束🎉🎉

📚📚各位老铁慢慢消化📚📚

🎯🎯下期博客博主会带来新货🎯🎯

🎁三连加关注,阅读不迷路 !🎁

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/327820.html

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

相关文章

H266/VVC多样化视频编码工具概述

全景视频编码 全景视频&#xff1a; 具有360度全包围视角的球面视频。 全景视频编码&#xff1a; 包括H266在内的视频编码算法都是以平面视频为对象的&#xff0c;为了采用传统的视频编码编码算法&#xff0c;全景视频需要转换为平面视频&#xff0c;其中经纬图等角映射&#…

dubbo的基础知识

dubbo是什么 Dubbo是一个分布式服务框架&#xff0c;是一种高性能的远程通讯框架。它提供了基于Java的RPC&#xff08;远程过程调用&#xff09;通信机制&#xff0c;使得应用之间可以方便地进行远程调用&#xff0c;实现分布式服务的调用和管理。Dubbo提供了服务注册、发现、负…

【大数据进阶第三阶段之Hive学习笔记】Hive常用命令和属性配置

目录 1、Hive安装 2、HiveJDBC访问 2.1、启动hiveserver2服务 2.2、连接hiveserver2服务 2.3、注意 3、Hive常用交互命令 3.1、“-e”不进入hive的交互窗口执行sql语句 3.2、“-f”执行脚本中sql语句 4、Hive其他命令操作 4.1、退出hive窗口 4.2、在hive cli命令窗口…

基于OpenCV的透视变换

基础概念 透视变换(Perspective Transformation)是仿射变换的一种非线性扩展,是将图片投影到一个新的视平面(Viewing Plane)&#xff0c;也称作投影映射(Projective Mapping)。 原理&#xff1a;将二维的图片投影到一个三维视平面上&#xff0c;然后再转换到二维坐标下&#…

LeetCode 2807.在链表中插入最大公约数

【LetMeFly】2807.在链表中插入最大公约数 力扣题目链接&#xff1a;https://leetcode.cn/problems/insert-greatest-common-divisors-in-linked-list/ 给你一个链表的头 head &#xff0c;每个结点包含一个整数值。 在相邻结点之间&#xff0c;请你插入一个新的结点&#x…

使用 C# Winfrom编写倒计时功能

在日常生活中&#xff0c;我们经常需要倒计时来提醒自己重要的时间节点&#xff0c;比如倒计时到达一个特定的日期和时间。介绍一个使用 C# 编写的倒计时应用程序的实现。 步骤一&#xff1a;应用程序的功能 它具有以下几个主要特点&#xff1a; 用户输入目标日期和时间&…

CSS3 边框border、outline、box-shadow

1 border 语法&#xff1a;border: width style color 2 outline 语法&#xff1a;outline: width style color 2.1 outline-offet MDN解释&#xff1a;用于设置outline与一个元素边缘或边框之间的间隙 即&#xff1a;设置outline相对border外边缘的偏移&#xff0c;可以为…

excel统计分析——两因素有重复方差分析

参考资料&#xff1a;生物统计学 无重复观测值的两因素方差分析只能研究两个因素的主效应&#xff0c;不能考察因素间的交互作用&#xff0c;只有在确定因素间不存在交互作用时才能进行无重复观测值的试验和分析。为了准确估计因素的主效应、交互作用和随机误差&#xff0c;每个…

DQL命令查询数据 (二)

本课目标 掌握 ORDER BY 子句 使用 LIMIT 子句实现分页查询 掌握MySQL的分组查询 掌握MySQL的子查询 SELECT 语法 ORDER BY 排序 ORDER BY 子句&#xff1a;按照一定顺序显示查询结果 排序可以是升序&#xff08;ASC&#xff09;或者是降序&#xff08;DESC&#xff09;&…

使用C#发送邮箱验证码

使用C#发送邮箱验证码 在很多应用程序中&#xff0c;我们需要使用邮箱来进行用户身份验证。其中一种常见的方式是通过发送验证码到用户的邮箱&#xff0c;然后要求用户输入该验证码进行验证。本文将介绍如何使用 C# 发送邮箱验证码。 声明 验证码登录没有用任何的工具&#…

【大数据】Zookeeper 数据写入与分布式锁

Zookeeper 数据写入与分布式锁 1.数据是怎么写入的2.基于 Zookeeper 实现分布式锁 1.数据是怎么写入的 无论是 Zookeeper 自带的客户端 zkCli.sh&#xff0c;还是使用 Python&#xff08;或者其它语言&#xff09;实现的客户端&#xff0c;本质上都是连接至集群&#xff0c;然…

记事本在手机桌面上怎么找?手机里的记事本怎么找?

在日常生活、工作和学习中&#xff0c;我们时常需要随手记录一些重要的事项、灵感闪现的瞬间或者是待办的任务。比如&#xff0c;在超市购物前&#xff0c;列出购物清单&#xff1b;在开会时&#xff0c;记下重要的讨论点&#xff1b;在学习时&#xff0c;捕捉那一刹那的灵感。…

C语言-第十八周做题总结-数组3

id:454 A.字符串逆序 题目描述 输入一个字符串&#xff0c;对该字符串进行逆序&#xff0c;输出逆序后的字符串。 输入 输入在一行中给出一个不超过80个字符长度的、以回车结束的非空字符串。 输出 在一行中输出逆序后的字符串。 输入样例 输出样例 题解 先用一个while…

【大数据进阶第三阶段之Hive学习笔记】Hive基础入门

目录 1、什么是Hive 2、Hive的优缺点 2.1、 优点 2.2、 缺点 2.2.1、Hive的HQL表达能力有限 2.2.2、Hive的效率比较低 3、Hive架构原理 3.1、用户接口&#xff1a;Client 3.2、元数据&#xff1a;Metastore 3.3、Hadoop 3.4、驱动器&#xff1a;Driver Hive运行机制…

2.3_6 用信号量实现进程互斥、同步、前驱关系

2.3_6 用信号量实现进程互斥、同步、前驱关系 #mermaid-svg-fj0wp6tJGfadcT8h {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-fj0wp6tJGfadcT8h .error-icon{fill:#552222;}#mermaid-svg-fj0wp6tJGfadcT8h .error-t…

在Ubuntu22.04上离线部署Tailchat(一)

一&#xff1a;Tailchat介绍 Tailchat 是一款插件化易拓展的开源 IM 应用。可拓展架构赋予 Tailchat 无限可能性。前端微内核架构 后端微服务架构 使得 Tailchat 能够驾驭任何定制化/私有化的场景&#xff0c;是面向企业与私域用户打造&#xff0c;高度自由的群组管理与定制化…

第11章 GUI Page462~476 步骤二十三,二十四,二十五 Undo/Redo ③实现“Undo/Redo”菜单项

工程六 添加“编辑”菜单和子菜单 菜单ID分别为 idMenuEditUndo 和 idMenuEditRedo 热键&#xff08;快捷键&#xff09;分别为CtrlZ 和 CtrlShiftZ 变量名分别为 MenuItemEditUndo 和 MenuItemEditRedo 分别添加事件 ActionLink类增加成员函数 运行效果&#xff1a;“添加…

C语言注意点(2)

1.使用pow函数的相关问题 局部变量n0 while(num/pow(10,n)) n; 为什么不可行 printf("%d",num/pow(10,4)%10) 为什么要提前用temp先引出来 答&#xff1a;pow函数的返回值为double类型&#xff0c;1.终止条件不会满足 2.num/pow(10,4)结果为浮点型&#xff0c;浮…

运维工程师的出路

运维工程师的出路到底在哪里&#xff1f; 你是不是也常常听到身边的运维人员抱怨&#xff0c;他们的出路到底在哪里呢&#xff1f;别着急&#xff0c;让我告诉你&#xff0c;运维人员就像是IT界的“万金油”&#xff0c;他们像“修理工”一样维修服务器&#xff0c;像“消防员…

基于日照时数计算逐日太阳辐射

基于日照时数计算逐日太阳辐射