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级别的基础上，记录请求和响应的header FULL 记录请求和响应的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.测试服务调用查看日志