详解SpringCloud-OpenFeign组件的使用
更新时间：2020年12月10日 09:06:12 作者：山丘i
这篇文章主要介绍了SpringCloud-OpenFeign组件的使用,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
思考: 使用RestTemplate+ribbon已经可以完成服务间的调用，为什么还要使用feign？
String restTemplateForObject = restTemplate.getForObject("http://服务名/url?参数" + name, String.class);
存在问题:
1.每次调用服务都需要写这些代码,存在大量的代码冗余
2.服务地址如果修改,维护成本增高
3.使用时不够灵活
说明
https://cloud.spring.io/spring-cloud-openfeign/reference/html/
Feign是一个声明式的伪Http客户端，它使得写Http客户端变得更简单。使用Feign，只需要创建一个接口并注解。它具有可插拔的注解特性(可以使用springmvc的注解)，可使用Feign 注解和JAX-RS注解。Feign支持可插拔的编码器和解码器。Feign默认集成了Ribbon，默认实现了负载均衡的效果并且springcloud为feign添加了springmvc注解的支持。
1.openFeign 服务调用
还是在上一个项目的基础之上，在users项目中
1.服务调用方法引入依赖OpenFeign依赖
<!--Open Feign依赖--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>
2.入口类加入注解开启OpenFeign支持
@SpringBootApplication
@EnableFeignClients //开启openfeign支持
public class Users9999Application {
public static void main(String[] args) {
SpringApplication.run(Users9999Application.class, args);
}
}
3.创建一个客户端调用接口
// 此时的product项目中的方法
@RestController
@Slf4j
public class ProductController {
@Value("${server.port}")
private int port;
@GetMapping("/product/findAll")
public Map<String, Object> findAll(){
log.info("商品服务调用成功，当前的服务端口：[{}]",port);
HashMap<String, Object> map = new HashMap<>();
map.put("msg","服务调用成功，服务提供的端口为："+port);
map.put("status",true);
return map;
}
}
//--------------------------------------------------------------------
package com.md.clients;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
/**
* @author md
* @Desc 调用商品服务的组件
* @date 2020/12/9 15:30
*/
// 指定当前的接口是openfeign组件，value是调用的服务名
@FeignClient("products")
public interface ProductClient {
@GetMapping("/product/findAll")
String findAll();
}
4.使用feignClient客户端对象调用服务
@RestController
@Slf4j
public class UserController {
//注入客户端对象
@Autowired
private ProductClient productClient;
@GetMapping("/user/findAllFeignClient")
public String findAllFeignClient(){
log.info("通过使用OpenFeign组件调用商品服务...");
String msg = productClient.findAll();
return msg;
}
}
5.访问并测试服务http://localhost:9999/user/findAllFeignClient
2.调用服务并传参
服务和服务之间通信,不仅仅是调用,往往在调用过程中还伴随着参数传递,接下来重点来看看OpenFeign在调用服务时如何传递参数
3.GET方式调用服务传递参数
- 在商品服务中加入需要传递参数的服务方法来进行测试
- 在用户服务中进行调用商品服务中需要传递参数的服务方法进行测试
1.商品服务中添加如下方法
@GetMapping("/product/findOne")
public Map<String,Object> findOne(String productId){
log.info("商品服务查询商品信息调用成功,当前服务端口:[{}]",port);
log.info("当前接收商品信息的id:[{}]",productId);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品服务查询商品信息调用成功,当前服务端口: "+port);
map.put("status",true);
map.put("productId",productId);
return map;
}
2.用户服务中在product客户端中声明方法
//
@FeignClient("products")
public interface ProductClient {
@GetMapping("/product/findOne")
Map<String, Object> findOne(@RequestParam("productId") String productId);
}
注意：使用openfeign的get方式传递参数，参数变量必须通过@RequestParam注解进行修饰
3.用户服务中调用并传递参数
//
//注入客户端对象
@RestController
@Slf4j
public class UserController {
@Autowired
private ProductClient productClient;
@GetMapping("/user/findOne")
public Map<String, Object> findOne(String productId){
log.info("用来测试Openfiegn的GET方式参数传递");
Map<String, Object> msg = productClient.findOne(productId);
log.info("调用返回信息:[{}]",msg);
return msg;
}
}
4.测试访问
4.post方式调用服务传递参数
- 在商品服务中加入需要传递参数的服务方法来进行测试
- 在用户服务中进行调用商品服务中需要传递参数的服务方法进行测试
1.商品服务加入post方式请求并接受name
@PostMapping("/product/save")
public Map<String,Object> save(String name){
log.info("商品服务保存商品调用成功,当前服务端口:[{}]",port);
log.info("当前接收商品名称:[{}]",name);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品查询服务完成当前服务端口: "+port);
map.put("status",true);
map.put("name",name);
return map;
}
2.用户服务中在product客户端中声明方法
//value属性用来指定:调用服务名称
@FeignClient("products")
public interface ProductClient {
@PostMapping("/product/save")
String save(@RequestParam("name") String name);
}
3.用户服务中调用并传递参数
@Autowired
private ProductClient productClient;
@PostMapping("/user/save")
public Map<String, Object> save(String productName){
log.info("接收到的商品信息名称:[{}]",productName);
Map<String, Object> map = productClient.save(productName);
log.info("调用成功返回结果: "+map);
return map;
}
4.测试访问
5.传递对象类型参数
- 商品服务定义对象
- 商品服务定义对象接收方法
- 用户服务调用商品服务定义对象参数方法进行参数传递
//1.商品服务定义对象
@Data
public class Product {
private Integer id;
private String name;
private Date bir;
}
//2.商品服务定义接收对象的方法
@PostMapping("/product/saveProduct")
public Map<String,Object> saveProduct(@RequestBody Product product){
log.info("商品服务保存商品信息调用成功,当前服务端口:[{}]",port);
log.info("当前接收商品名称:[{}]",product);
Map<String, Object> map = new HashMap<String,Object>();
map.put("msg","商品服务查询商品信息调用成功,当前服务端口: "+port);
map.put("status",true);
map.put("product",product);
return map;
}
//3.将商品对象复制到用户服务中
// 先阶段先这样用着
//4.用户服务中在product客户端中声明方法
@FeignClient("products")
public interface ProductClient {
@PostMapping("/product/saveProduct")
String saveProduct(@RequestBody Product product);
}
//注意:服务提供方和调用方一定要加入@RequestBody注解
注意:服务提供方和调用方一定要加入@RequestBody注解
// 5.在用户服务中调用保存商品信息服务
//注入客户端对象
@Autowired
private ProductClient productClient;
@PostMapping("/user/saveProduct")
public Map<String, Object> saveProduct(Product product){
log.info("接收到的商品信息:[{}]",product);
Map<String, Object> map = productClient.saveProduct(product);
log.info("调用成功返回结果: "+map);
return map;
}
测试
5.OpenFeign超时设置
1.超时说明默认情况下,openFiegn在进行服务调用时,要求服务提供方处理业务逻辑时间必须在1S内返回,如果超过1S没有返回则OpenFeign会直接报错,不会等待服务执行,但是往往在处理复杂业务逻辑是可能会超过1S,因此需要修改OpenFeign的默认服务调用超时时间。
2.模拟超时服务提供方加入线程等待阻塞
3.进行客户端调用
4.修改OpenFeign默认超时时间
# 这里的PRODUCTS使用的是大写的方法 feign.client.config.PRODUCTS.connectTimeout=5000 #配置指定服务连接超时 feign.client.config.PRODUCTS.readTimeout=5000 #配置指定服务等待超时 #feign.client.config.default.connectTimeout=5000 #配置所有服务连接超时 #feign.client.config.default.readTimeout=5000 #配置所有服务等待超时
6.OpenFeign调用详细日志展示
0.说明
- 往往在服务调用时我们需要详细展示feign的日志,默认feign在调用是并不是最详细日志输出,因此在调试程序时应该开启feign的详细日志展示。feign对日志的处理非常灵活可为每个feign客户端指定日志记录策略，每个客户端都会创建一个logger默认情况下logger的名称是feign的全限定名需要注意的是，feign日志的打印只会DEBUG级别做出响应。
- 我们可以为feign客户端配置各自的logger.level对象，告诉feign记录那些日志logger.lever有以下的几种值
NONE 不记录任何日志BASIC 仅仅记录请求方法，url，响应状态代码及执行时间HEADERS 记录Basic级别的基础上，记录请求和响应的headerFULL 记录请求和响应的header，body和元数据
1.开启日志展示
# 这里的PRODUCTS使用的是大写的方法 feign.client.config.PRODUCTS.loggerLevel=full #开启指定服务日志展示 #feign.client.config.default.loggerLevel=full #全局开启服务日志展示 logging.level.com.baizhi.feignclients=debug #指定feign调用客户端对象所在包,必须是debug级别
2.测试服务调用查看日志
到此这篇关于SpringCloud-OpenFeign组件的使用的文章就介绍到这了,更多相关SpringCloud-OpenFeign组件内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文主要介绍了idea安装汉化插件的图文教程，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-07-07
这篇文章主要介绍了Java锁升级的实现过程，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-08-08
在Java应用程序中,为了确保安全性和保护用户数据,一种常见的做法是使用Token进行身份验证和授权,Token是由服务器生成的具有一定时效的令牌,用于识别和验证用户身份,当Token失效后,用户将无法再进行相关操作,从而提高系统的安全性2023-10-10
这篇文章主要为大家详细介绍了Spring思维导图，帮助你轻松学习Spring的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-03-03
Spring框架是由于软件开发的复杂性而创建的。然而，Spring的用途不仅仅限于服务器端的开发。从简单性、可测试性和松耦合性角度而言，绝大部分Java应用都可以从Spring中受益。今天来分析它的设计与实现资源加载器，从Spring.xml解析和注册Bean对象2021-06-06
这篇文章主要介绍了spring boot 中设置默认网页的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-04-04
renameTo()方法是File类的一部分,renameTo()函数用于将文件的抽象路径名重命名为给定的路径名,下面这篇文章主要给大家介绍了关于Java file类中renameTo方法操作的相关资料,需要的朋友可以参考下2022-11-11
序列化是将对象转换成二进制字节流的过程；反序列化是从二进制字节流中恢复对象的过程。文中降通过示例详解二者的使用与区别，需要的可以参考一下2022-08-08
这篇文章介绍了java调用未知类的指定方法简单实例，有需要的朋友可以参考一下2013-09-09
java中Pulsar InterruptedException 异常
这篇文章主要为大家介绍了java中Pulsar InterruptedException 异常分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-02-02
最新评论