【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.mzph.cn/news/601449.shtml

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

相关文章

pythonMatplotlib四：Matplotlib设置图的样式和颜色

pythonMatplotlib四：Matplotlib设置图的样式和颜色

1.设置线条样式&#xff1a; import matplotlib.pyplot as plt# 准备数据 x [1, 2, 3, 4, 5] y [2, 4, 6, 8, 10]# 创建折线图并设置线条样式 plt.plot(x, y, linestyle--, linewidth2)# 添加标题和标签 plt.title("折线图示例") plt.xlabel("X轴") plt…
阅读更多...
文件属性stat

文件属性stat

stat/fstat 获取文件属性#include <sys/stat.h> int stat(const char* path,struct stat* buf); //path : 路径 , buf : 属性&#xff1b;int fstat(int fd,struct stat* buf); //fd : 文件描述符 , buf : 属性&#xff1b;struct stat {dev_t st_dev; /* ID of…
阅读更多...
C++ 类的内存分布

C++ 类的内存分布

文章目录 1 . 前言2 . 无继承&#xff0c;无虚函数3 . 无继承&#xff0c;有虚函数4 . 单一继承&#xff0c;无虚函数5 . 单一继承&#xff0c;有虚函数&#xff0c;虚析构6 . 多重继承7 . 菱形继承8 . 虚拟继承9 . 总结 【极客技术传送门】 : https://blog.csdn.net/Engineer_…
阅读更多...
淘宝京东1688商品详情API接口，搜索商品列表接口

淘宝京东1688商品详情API接口，搜索商品列表接口

前言 在实际工作中&#xff0c;我们需要经常跟第三方平台打交道&#xff0c;可能会对接第三方平台API接口&#xff0c;或者提供API接口给第三方平台调用。 那么问题来了&#xff0c;如果设计一个优雅的API接口&#xff0c;能够满足&#xff1a;安全性、可重复调用、稳定性、好…
阅读更多...
vue-video-player播放hls视频流

vue-video-player播放hls视频流

需求 最近需要接入海康视频摄像头&#xff0c;然后把视频的画面接入到自己的网站系统中。以前对接过rtsp固定IP的显示视频&#xff0c;这次的不一样&#xff0c;没有了固定IP。海康的解决办法是&#xff0c;摄像头通过配置服务器到萤石云平台&#xff0c;然后购买企业版账号和…
阅读更多...
Window端口占用处理

Window端口占用处理

您好&#xff0c;我是码农飞哥&#xff08;wei158556&#xff09;&#xff0c;感谢您阅读本文&#xff0c;欢迎一键三连哦。 &#x1f4aa;&#x1f3fb; 1. Python基础专栏&#xff0c;基础知识一网打尽&#xff0c;9.9元买不了吃亏&#xff0c;买不了上当。 Python从入门到精…
阅读更多...
智能语音机器人NXCallbot

智能语音机器人NXCallbot

受出海公司业务全球化的影响&#xff0c;智能客服逐渐从便捷应用变为市场刚需。新基建七大领域中&#xff0c;人工智能及场景应用的基础建设是最核心的领域&#xff0c;而智能客服作为商业化实际应用的核心场景之一&#xff0c;能提升企业运营效率&#xff0c;为行业客户赋能。…
阅读更多...
目标检测-One Stage-RetinaNet

目标检测-One Stage-RetinaNet

文章目录 前言一、RetinaNet的网络结构和流程二、RetinaNet的创新点Balanced Cross EntropyFocal Loss 总结 前言 根据前文目标检测-One Stage-YOLOv2可以看出YOLOv2的速度和精度都有相当程度的提升&#xff0c;但是One Stage目标检测模型仍存在一个很大的问题&#xff1a; 前…
阅读更多...
ARM NEON 指令

ARM NEON 指令

NEON指令 按照操作数类型可以分为正常指令、宽指令、窄指令、饱和指令、长指令。 正常指令&#xff1a;生成大小相同且类型通常与操作数向量相同到结果向量。长指令&#xff1a;对双字向量操作数执行运算&#xff0c;生产四字向量到结果。所生成的元素一般是操作数元素宽度到…
阅读更多...
ReentrantLock底层原理学习一

ReentrantLock底层原理学习一

J.U.C 简介 Java.util.concurrent 是在并发编程中比较常用的工具类&#xff0c;里面包含很多用来在并发场景中使用的组件。比如线程池、阻塞队列、计时器、同步器、并发集合等等。并发包的作者是大名鼎鼎的 Doug Lea。我们在接下来的课程中&#xff0c;回去剖析一些经典的比较…
阅读更多...
vite4项目中，vant兼容750适配

vite4项目中，vant兼容750适配

一般非vite项目&#xff0c;使用postcss-px-to-viewport。在设计稿为750时候&#xff0c;可使用以下配置兼容vant。 在vite4项目中&#xff0c;以上配置不行。需要调整下&#xff0c;使用postcss-px-to-viewport-8-plugin&#xff0c;并修改viewportWidth&#xff0c;具体如下…
阅读更多...
数据库有哪些新方向？

数据库有哪些新方向？

数据库的未来发展&#xff1a;从架构到类型&#xff0c;再到负载和AI的融合 随着技术的不断进步&#xff0c;数据库的发展方向也日益多样化。从数据库架构的角度来看&#xff0c;向云原生架构的演进是一个重要的趋势。这一方向已经催生了许多优秀的数据库产品&#xff0c;如Ga…
阅读更多...
CSS新增文本样式（完整）

CSS新增文本样式（完整）

文本样式 概念&#xff1a;在CSS3中&#xff0c;增加了丰富的文本修饰效果&#xff0c;使得页面更加美观舒服。 常用的文本样式属性 属性说明text-shadow文本阴影text-stroke文本描边text-align-last文本对齐white-space处理空白字符text-overflow文本溢出word-wrap | word-…
阅读更多...
【Linux 内核源码分析】关于Linux内核源码目录结构

【Linux 内核源码分析】关于Linux内核源码目录结构

Linux内核源码采用树形结构。功能相关的文件放到不同的子目录下面&#xff0c;使程序更具有可读行。 使用Source Insight打开源码&#xff0c;如下图所示&#xff0c;可以看到源码是树形结构。 目录含义描述arch存放与体系结构相关的代码&#xff0c;包括不同硬件平台的特定代…
阅读更多...
python基础教程六(字典方法)

python基础教程六(字典方法)

字典方法 与其他内置类型一样&#xff0c;字典也有方法。字典的方法很有用&#xff0c;但其使用频率可能不高。 1. clear 方法clear删除所有的字典项&#xff0c;这中操作时就地执行的&#xff08;就像list.sort一样&#xff09;&#xff0c;因此什么都不返回。 >>&g…
阅读更多...
Qt/QML编程学习之心得：QSocketNotifier（二十一）

Qt/QML编程学习之心得：QSocketNotifier（二十一）

QSocketNotifier在Qt中怎么使用？ QSocketNotifier使Qt的事件循环与其他基于文件描述符的事件循环集成成为可能。在Qt的主事件循环（QCoreApplication:：exec（））中检测到文件描述符操作。 使用低级（通常是特定于平台的）API打开设备后，可以创建一个套接字通知程序来监视文…
阅读更多...
第七部分 使用变量 （上）

第七部分 使用变量 （上）

目录 一、变量的基础 二、变量中的变量 在 Makefile 中的定义的变量&#xff0c;就像是 C/C语言中的宏一样&#xff0c;他代表了一个文本字串&#xff0c; 在 Makefile 中执行的时候其会自动原模原样地展开在所使用的地方。其与 C/C所不同的 是&#xff0c;你可以在 Makefile…
阅读更多...
DDoS攻击的多种方式

DDoS攻击的多种方式

DDOS攻击指分布式拒绝服务攻击&#xff0c;即处于不同位置的多个攻击者同时向一个或数个目标发动攻击&#xff0c;或者一个攻击者控制了位于不同位置的多台机器并利用这些机器对受害者同时实施攻击。由于攻击的发出点是分布在不同地方的&#xff0c;这类攻击称为分布式拒绝服务…
阅读更多...
leetcode:2451. 差值数组不同的字符串(python3解法）

leetcode:2451. 差值数组不同的字符串(python3解法）

难度&#xff1a;简单 给你一个字符串数组 words &#xff0c;每一个字符串长度都相同&#xff0c;令所有字符串的长度都为 n 。 每个字符串 words[i] 可以被转化为一个长度为 n - 1 的 差值整数数组 difference[i] &#xff0c;其中对于 0 < j < n - 2 有 difference[i]…
阅读更多...
C# 路径搜索算法 A* 算法 和 Dijkstra 算法

C# 路径搜索算法 A* 算法 和 Dijkstra 算法

A*算法和Dijkstra算法是两种常用的路径搜索算法&#xff0c;用于在图形结构中寻找最短路径。它们都属于单源最短路径算法&#xff0c;可以用于解决各种寻路问题。 A算法是一种启发式搜索算法&#xff0c;同时考虑了实际移动代价和估计距离代价&#xff0c;通过估计代价来指导搜…
阅读更多...
最新文章

Copyright @ 2022~2023