详解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组件内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Java的Jackson自定义序列化详解,对比序列化器,可以看到,使用@JsonValue注解已经将Leader类的序列化方式改变了,进而影响了Country类,再来执行test7()测试反序列化,结果与之前是一致的,需要的朋友可以参考下2023-11-11
java中synchronized Lock(本地同步)锁的8种情况
本文主要介绍了java中synchronized Lock(本地同步)锁的8种情况，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-09-09
这篇文章主要给大家介绍了关于Java中Calendar日期类用法详细介绍的相关资料,Calendar类是 Java 中用于处理日期和时间的抽象类,它提供了一种独立于特定日历系统的方式来处理日期和时间,需要的朋友可以参考下2023-12-12
本文主要介绍了springboot集成redisson的三种方式,包含自定义配置+手动注入,使用Yaml方式批量读取配置和spring boot自动配置类这三种,具有一定的参考价值,感兴趣的可以了解一下2024-03-03
java.lang.ThreadLocal该类提供了线程局部变量,用于在当前线程中共享数据,本文主要介绍了Java中ThreadLocal共享变量的使用,具有一定的参考价值,感兴趣的可以了解一下2024-01-01
这篇文章主要介绍了java 并发编程之共享变量的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-09-09
这篇文章主要介绍了Java DFA算法案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-08-08
若采用mybatis框架，数据库新建表，手动编写的话，需要编写大量的实体类、mapper文件、mapper.xml文件，都是一些重复且有规律的工作。我们可以引用插件，然后做配置，自动生成这些文件，本文就来详细的介绍一下2021-08-08
Spring Web MVC框架学习之配置Spring Web MVC
这一篇文章讲的是Spring Web MVC各部分的配置方法，包括Java代码配置和XML文件配置以及MVC命名空间的使用方法。2017-03-03
这篇文章主要介绍了Java线程组与未处理异常,结合实例形式分析了java线程组处理异常的相关技巧与操作注意事项,需要的朋友可以参考下2019-09-09
最新评论