62、SpringBoot 使用RestTemplate 整合第三方 RESTful 服务

这节的要点:
就是弄两个项目 , 从 端口9090 这个项目,通过 restTemplate, 去访问 端口8080 的项目,并获取8080项目的数据。

★ RESTful服务包含两方面的含义

1. 自己的应用要暴露一些功能供别人来调用。此时我们是服务端。2. 我们的应用要去整合第三方的RESTful服务此时我们就是客户端。

★ RESTful客户端的两种方式

- 应用基于传统的Spring MVC框架,此时考虑使用RestTemplate来整合第三方RESTful服务。RestTemplate就属于传统Spring Web的API。- 应用基于传统的Web Flux框架,此时考虑使用WebClient来整合第三方RESTful服务。WebClient本身就是属于WebFlux API

★ RestTemplate整合第三方RESTful服务

(1)调用RestTemplateBuilder来构建RestTemplate千万不要自己去创建RestTemplate对象,相当于你没有利用spring容器的依赖注入。就是不要这样-->  this.restTemplate = new RestTemplate();(2)调用RestTemplate的如下方法:delete | getForXxx | postForXxx | put exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Map<String,?> uriVariables):delete | getForXxx | postForXxx | put 都是 exchange的快捷方式execute(String url, HttpMethod method, RequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Map<String,?> uriVariables):原始

千万不要自己去创建RestTemplate对象,相当于你没有利用spring容器的依赖注入。如图
就是注入这个RestTemplate 对象时,
要用restTemplateBuilder.build();,
不要去new RestTemplate();

在这里插入图片描述

代码演示

RESTful_XML 8080 项目代表 restful 服务的 服务端,生成json响应的,
MyRestTemPlate 9090 项目代表 restful 服务的 客户端,发起请求的

这个 RESTful_XML 就是第三方RESTful 服务,MyRestTemPlate 项目通过RestTemplate 来整合它

需求:两个项目 , 从 9090 这个项目,通过 restTemplate 去访问 8080 的项目,并获取数据。

查看所有图书的方法。
这个 rootUri 个人的ip是会变的,以后测试需要更改
在这里插入图片描述
效果:成功通过restTemplate,从项目9090 访问到项目8080的数据
在这里插入图片描述
其他的方法也一样
根据id查看图书
在这里插入图片描述

根据id修改图书:两种方法,有返回值和没有返回值

方式1: 用 put() 方法,restTemplate.put() 默认没有返回值

在这里插入图片描述

在这里插入图片描述

方式2:用 exchange() 方法,restTemplate.exchange() 有返回值

在这里插入图片描述

在这里插入图片描述

完整代码:

MyRestTemPlate

Book

在这里插入图片描述

package cn.ljh.app.domain;import lombok.Data;@Data
public class Book
{private Integer id;private String name;private double price;private String author;public Book(Integer id, String name, double price, String author){this.id = id;this.name = name;this.price = price;this.author = author;}
}

ClientController

package cn.ljh.app.controller;import cn.ljh.app.domain.Book;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;import java.util.Collection;
import java.util.List;
import java.util.Map;@RestController
@RequestMapping("/mybooks")
public class ClientController
{private final RestTemplate restTemplate;public ClientController(RestTemplateBuilder restTemplateBuilder){/** 此处的 RestTemplateBuilder 是来自于Spring 容器的注入,* 因此它所构建的 RestTemplate 已经接收了spring 容器的默认设置* 如果直接创建 RestTemplate , 那就相当于完全没有利用Spring容器的依赖注入,* 因此完全不能接受spring容器的默认配置,这样后面所介绍的配置 RestTemplate 完全不可能实现配置了*/this.restTemplate = restTemplateBuilder.rootUri("http://192.168.0.108:8080/") //为整个RestTemplate 指定基路径.build();}//查看所有图书@GetMapping("/viewBooks")public ResponseEntity<List<Book>> viewBooks(){List<Book> list = restTemplate.getForObject("/books/viewBooks", List.class);ResponseEntity<List<Book>> entity = new ResponseEntity<>(list, null, HttpStatus.OK);return entity;}//查看所有图书@GetMapping("/viewBooks2")public ResponseEntity<Collection> viewBooks2(){//参数3:代表为 URL 填充路径参数值 ,就是路径后面的参数Collection data = restTemplate.getForObject("/books/viewBooks2", Collection.class);ResponseEntity<Collection> entity = new ResponseEntity<>(data, null, HttpStatus.OK);return entity;}//根据id查看图书@GetMapping("/{id}")public ResponseEntity<Book> getBookById(@PathVariable Integer id){Book book = restTemplate.getForObject("/books/{id}", Book.class, id);ResponseEntity<Book> entity = new ResponseEntity<>(book, null, HttpStatus.OK);return entity;}//根据id删除图书@DeleteMapping("/{id}")public ResponseEntity<Map<String, String>> deleteBookById(@PathVariable Integer id){//restTemplate 的 delete 默认是没有返回值的restTemplate.delete("/books/{id}", id);ResponseEntity<Map<String, String>> tip = new ResponseEntity<>(Map.of("tip", "id为:" + id + " 的图书删除成功"), null, HttpStatus.OK);return tip;}//根据id修改图书, restTemplate 的 put修改 默认是没有返回值的@PutMapping("/{id}")public ResponseEntity<Map<String, String>> updateById(@PathVariable Integer id){restTemplate.put("/books/{id}",Map.of("name", "修改的图书", "price", 120, "author", "图书的作者"),id);ResponseEntity<Map<String, String>> entity =new ResponseEntity<>(Map.of("tip", "图书修改成功"), null, HttpStatus.OK);return entity;}//因为 restTemplate 默认的 put修改、delete 是没有返回值的,如果要返回值,可以用 exchange 方法//参数2:代表要修改的数据封装在这个 map 里面@PutMapping("/exchange/{id}")public ResponseEntity<Map> updateById(@PathVariable Integer id, @RequestBody Map map){//把要修改的book对象传进这个 HttpEntity 对象里面HttpEntity<Map> entity = new HttpEntity<>(map);//参数1:访问服务端的路径  参数2:要执行的请求类型  参数3:请求的数据,就是要修改的对象的新数据//参数4:指定服务器响应的数据类型  参数5 :用于为 URL 的路径参数填充值ResponseEntity<Map> exchange = restTemplate.exchange("/books/{id}", HttpMethod.PUT, entity, Map.class, id);return exchange;}}

application.properties

在这里插入图片描述

pom.xml

pom文件没什么要改的

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.4.5</version></parent><groupId>cn.ljh</groupId><artifactId>my_resttemplate</artifactId><version>1.0.0</version><name>my_resttemplate</name><properties><java.version>11</java.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

RESTful_XML

Book

在这里插入图片描述

package cn.ljh.app.domain;import lombok.Data;@Data
public class Book
{private Integer id;private String name;private double price;private String author;public Book(Integer id, String name, double price, String author){this.id = id;this.name = name;this.price = price;this.author = author;}
}

controller

package cn.ljh.app.controller;import cn.ljh.app.domain.Book;
import cn.ljh.app.service.BookService;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;import java.util.Collection;
import java.util.List;/**     GET  /books/{id} - (获取数据) 获取指定id的图书*     GET  /books?参数  -(获取数据) 获取符合查询参数的图书*     GET  /books        -(获取数据) 获取所有图书*     POST /books        -(添加数据) 添加图书*     PUT  /books/{id}    -(更新数据) 更新指定ID的图书*     DELETE /books/{id}    -(删除数据) 删除指定ID的图书*     DELETE /books?参数    -(删除数据) 删除符合指定参数的图书**  Restful处理方法的返回值通常都应该使用HttpEntity或ResponseEntity。**/@RequestMapping("/books")
@RestController
public class BookController
{//有参构造器进行依赖注入private BookService bookService;public BookController(BookService bookService){this.bookService = bookService;}//根据id查看图书@GetMapping("/{id}")public ResponseEntity<Book> viewBookById(@PathVariable Integer id){Book book = bookService.getBookById(id);//参数1:响应数据体  参数2:需要添加的响应头,没有就给个null   参数3:响应码 , OK 代表 200return new ResponseEntity<>(book, null, HttpStatus.OK);}//查看所有图书----------------------方法1------------@GetMapping("viewBooks")public ResponseEntity<List<Book>> viewBooks(){List<Book> allBooks = bookService.getAllBooks();return new ResponseEntity<>(allBooks, null, HttpStatus.OK);}//查看所有图书------------------------方法2----------@GetMapping("/viewBooks2")public ResponseEntity<Collection<Book>> viewBooks2(){Collection<Book> allBooks2 = bookService.getAllBooks2();ResponseEntity<Collection<Book>> books = new ResponseEntity<>(allBooks2, null, HttpStatus.OK);return books;}//添加图书@PostMapping("")public ResponseEntity<Book> addBook(@RequestBody Book book){Book b = bookService.addOrUpdateBook(book);//HttpStatus.CREATED 代表返回的状态码为 201return new ResponseEntity<>(b, null, HttpStatus.CREATED);}//根据id更新图书信息@PutMapping("/{id}")public ResponseEntity<Book> updateBookById(@PathVariable Integer id, @RequestBody Book book){book.setId(id);Book b = bookService.addOrUpdateBook(book);return new ResponseEntity<>(b, null, HttpStatus.OK);}//根据id删除图书@DeleteMapping("/{id}")public ResponseEntity<Book> deleteBookById(@PathVariable Integer id){Book book = bookService.deleteBookById(id);return new ResponseEntity<>(book, null, HttpStatus.OK);}}

BookService

package cn.ljh.app.service;import cn.ljh.app.domain.Book;import java.util.Collection;
import java.util.List;public interface BookService
{//根据id查看图书Book getBookById(Integer id);//查看所有图书List<Book> getAllBooks();Collection<Book> getAllBooks2();//添加/修改图书Book addOrUpdateBook(Book book);//根据id删除图书Book deleteBookById(Integer id);}

BookServiceImpl

package cn.ljh.app.service.impl;import cn.ljh.app.domain.Book;
import cn.ljh.app.service.BookService;
import org.springframework.stereotype.Service;import java.util.*;
import java.util.concurrent.ConcurrentHashMap;@Service
public class BookServiceImpl implements BookService
{//创建一个线程安全的map集合存数据,假设为数据库static Map<Integer, Book> bookDB = new ConcurrentHashMap<>();static int nextId = 1;//初始化数据库的数据static{bookDB.put(nextId, new Book(nextId++, "火影忍者", 120, "岸本"));bookDB.put(nextId, new Book(nextId++, "七龙珠", 121, "鸟山明"));}//根据id查看图书@Overridepublic Book getBookById(Integer id){if (id != null){Book book = bookDB.get(id);if (book!=null){return book;}}throw new RuntimeException("根据id查看图书失败!");}//查看所有图书@Overridepublic List<Book> getAllBooks(){//获取map中的所有数据Collection<Book> mapBooks = bookDB.values();//强转List<Book> books = new ArrayList<>(mapBooks);return books;}@Overridepublic Collection<Book> getAllBooks2(){//获取map中的所有数据Collection<Book> mapBooks = bookDB.values();return mapBooks;}//添加/修改图书@Overridepublic Book addOrUpdateBook(Book book){if (book.getId() != null){//修改//map的key是唯一的,所以map里面有这个key的话,直接把原来的value覆盖掉bookDB.put(book.getId(),book);return book;}else {//新增//为新增的图书设置idbook.setId(nextId);//book添加完之后,这个id才会自增bookDB.put(nextId++,book);return book;}}//根据id删除图书@Overridepublic Book deleteBookById(Integer id){Book book = bookDB.remove(id);return book;}
}

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.4.5</version></parent><groupId>cn.ljh</groupId><artifactId>RESTful_XML</artifactId><version>1.0.0</version><name>RESTful_XML</name><properties><java.version>11</java.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- 添加 Jackson format XML , 用于对象与XML之间的转换 --><dependency><groupId>com.fasterxml.jackson.dataformat</groupId><artifactId>jackson-dataformat-xml</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

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

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

相关文章

Linux基本认识

一、Linux基本概念 Linux 内核最初只是由芬兰人林纳斯托瓦兹&#xff08;Linus Torvalds&#xff09;在赫尔辛基大学上学时出于个人爱好而编写的。 Linux 是一套免费使用和自由传播的类 Unix 操作系统&#xff0c;是一个基于 POSIX 和 UNIX 的多用户、多任务、支持多线程和多…

摄像头:输出图像YUV格式理论知识

本篇文章主要记录一下camera2输出摄像头的编码格式&#xff0c;及数据之间转换。本文章参考链接&#xff1a; https://blog.csdn.net/qq_39312146/article/details/129252235。 http://www.360doc.com/content/21/0522/14/17136639_978452591.shtml 只为了记录使用。 一、Came…

管理方法论:5. 团队发展的阶段模型——调整管理策略

概念 布鲁斯塔克曼(Bruce Tuckman)提出团队发展阶段模型。 团队发展的五个阶段是&#xff1a;组建期&#xff08;Forming&#xff09;、激荡期&#xff08;Storming&#xff09;、规范期&#xff08;Norming&#xff09;、执行期&#xff08;Performing&#xff09;和休整期&…

使用凌鲨进行聚合搜索

作为研发人员&#xff0c;我们经常需要在多个来源之间查找信息&#xff0c;以便进行研发工作。除了常用的搜索引擎如百度和必应之外&#xff0c;我们还需要查阅各种代码文档和依赖包等资源。这些资源通常分散在各个网站和文档库中&#xff0c;需要花费一定的时间和精力才能找到…

C++之生成详细汇编代码(二百一十六)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 人生格言&#xff1a; 人生…

前端JavaScript修饰器:简化代码,增强功能

​ &#x1f3ac; 岸边的风&#xff1a;个人主页 &#x1f525; 个人专栏 :《 VUE 》 《 javaScript 》 ⛺️ 生活的理想&#xff0c;就是为了理想的生活 ! ​ 目录 引言 1. 修饰器简介 2. 修饰器语法 3. 类修饰器 应用场景 示例代码 4. 方法修饰器 应用场景 示例代码 5. 属性…

webpack实战:最新QQ音乐sign参数加密分析

文章目录 1. 写在前面2. 接口抓包分析3. 扣webpack代码4. 补浏览器环境5. 验证加密结果 1. 写在前面 现在&#xff01;很多的网站使用Webpack加载和处理JS文件。所以对于使用了Webpack加载的JS代码&#xff0c;一旦它们被打包并在浏览器中执行&#xff0c;通常是难以直接阅读和…

CSS预编译:提升样式开发效率与可维护性的关键工具

&#x1f482; 个人网站:【工具大全】【游戏大全】【神级源码资源网】&#x1f91f; 前端学习课程&#xff1a;&#x1f449;【28个案例趣学前端】【400个JS面试题】&#x1f485; 寻找学习交流、摸鱼划水的小伙伴&#xff0c;请点击【摸鱼学习交流群】 引言 CSS预编译是一项前…

AMEYA360详解芯力特SIT1145AQ收发器芯片CAN FD Passive功能详解

01CAN FD Passive功能说明 芯力特在SIT1145AQ/FD版本中加入了CAN FD Passive功能&#xff0c;CAN FD Passive功能简单来说就是SIT1145AQ/FD在休眠或待机模式下屏蔽总线上的CAN FD报文。 为什么需要CAN FD Passive功能呢? SIT1145AQ的特定帧唤醒只支持CAN报文&#xff0c;当SIT…

跨域问题解决方案(三种)

Same Origin Policy同源策略&#xff08;SOP&#xff09; 具有相同的Origin&#xff0c;也即是拥有相同的协议、主机地址以及端口。一旦这三项数据中有一项不同&#xff0c;那么该资源就将被认为是从不同的Origin得来的&#xff0c;进而不被允许访问。 Cross-origin resource…

合宙Air724UG LuatOS-Air LVGL API控件-开关 (Switch)

开关 (Switch) 示例代码 function event_handler(obj, event)if event lvgl.EVENT_VALUE_CHANGED thenprint("State", lvgl.switch_get_state(obj))end endsw1 lvgl.switch_create(lvgl.scr_act(), nil) lvgl.obj_align(sw1, nil, lvgl.ALIGN_CENTER, 0, -50) lvg…

【数据结构初阶】三、 线性表里的链表(无头+单向+非循环链表)

相关代码gitee自取&#xff1a; C语言学习日记: 加油努力 (gitee.com) 接上期&#xff1a; 【数据结构初阶】二、 线性表里的顺序表_高高的胖子的博客-CSDN博客 引言 通过上期对顺序表的介绍和使用 我们可以知道顺序表有以下优点和缺点&#xff1a; 顺序表优点 尾插 和 尾…