Spring Cloud（4）：Feign的使用

基于上一篇文章：https://www.cnblogs.com/xuyiqing/p/10867739.html

使用Ribbon实现了订单服务调用商品服务的Demo

下面介绍如何使用Feign实现这个Demo

Feign：伪RPC客户端，底层基于HTTP

在订单服务的POM中加入依赖

        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

并在启动类中加入注解，这里已经加入的Ribbon可以保留

package org.dreamtech.orderservice;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;@SpringBootApplication
@EnableFeignClients
public class OrderServiceApplication {public static void main(String[] args) {SpringApplication.run(OrderServiceApplication.class, args);}@Bean@LoadBalancedpublic RestTemplate restTemplate() {return new RestTemplate();}
}

Feign接口

package org.dreamtech.orderservice.service;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;@FeignClient(name = "product-service")
public interface ProductClient {@RequestMapping("/api/product/find")String findById(@RequestParam(value = "id")int id);
}

使用

package org.dreamtech.orderservice.service.impl;import com.fasterxml.jackson.databind.JsonNode;
import org.dreamtech.orderservice.domain.ProductOrder;
import org.dreamtech.orderservice.service.ProductClient;
import org.dreamtech.orderservice.service.ProductOrderService;
import org.dreamtech.orderservice.utils.JsonUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;import java.util.Date;
import java.util.Map;
import java.util.UUID;@Service
public class ProductOrderServiceImpl implements ProductOrderService {private final ProductClient productClient;@Autowiredpublic ProductOrderServiceImpl(ProductClient productClient) {this.productClient = productClient;}@Overridepublic ProductOrder save(int userId, int productId) {String response = productClient.findById(productId);JsonNode jsonNode = JsonUtils.str2JsonNode(response);ProductOrder productOrder = new ProductOrder();productOrder.setCreateTime(new Date());productOrder.setUserId(userId);productOrder.setTradeNo(UUID.randomUUID().toString());productOrder.setProductName(jsonNode.get("name").toString());productOrder.setPrice(Integer.parseInt(jsonNode.get("price").toString()));return productOrder;}
}

工具类

package org.dreamtech.orderservice.utils;import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;import java.io.IOException;public class JsonUtils {private static final ObjectMapper objectMapper = new ObjectMapper();public static JsonNode str2JsonNode(String str) {try {return objectMapper.readTree(str);} catch (IOException e) {return null;}}
}

重启Eureka Server和多个product-service：

访问http://localhost:8781/api/order/save?user_id=1&product_id=1，成功

使用注意：

1.Feign的路由和服务的路由必须一致（如这里的/api/product/find）

2.注意服务名的一致

3.参数必须加入@RequestParam确保参数名和服务的一致

4.如果服务的参数加入了@RequestBody，Feign客户端也要加入@RequestBody并修改为POST方式

5.这里获取到JSON直接解析，实际情况可以抽取公共实体类为JAR包引入返回实体类

FeignClient原理：

查看Clien类可以发现，Feign的实现是通过HTTP形式：

        HttpURLConnection convertAndSend(Request request, Options options) throws IOException {HttpURLConnection connection = (HttpURLConnection)(new URL(request.url())).openConnection();if (connection instanceof HttpsURLConnection) {HttpsURLConnection sslCon = (HttpsURLConnection)connection;if (this.sslContextFactory != null) {sslCon.setSSLSocketFactory(this.sslContextFactory);}if (this.hostnameVerifier != null) {sslCon.setHostnameVerifier(this.hostnameVerifier);}}

Client的实现类中：

发现Feign调用了Ribbon做负载均衡

    public Response execute(Request request, Options options) throws IOException {try {URI asUri = URI.create(request.url());String clientName = asUri.getHost();URI uriWithoutHost = cleanUrl(request.url(), clientName);RibbonRequest ribbonRequest = new RibbonRequest(this.delegate, request, uriWithoutHost);IClientConfig requestConfig = this.getClientConfig(options, clientName);return ((RibbonResponse)this.lbClient(clientName).executeWithLoadBalancer(ribbonRequest, requestConfig)).toResponse();} catch (ClientException var8) {IOException io = this.findIOException(var8);if (io != null) {throw io;} else {throw new RuntimeException(var8);}}}

处理超时问题：实际情况服务和调用者之间的通信可能较慢，这时候Feign会报错

如下配置Feign超时实际为10秒

feign:client:config:default:connectTimeout: 10000readTimeout: 10000

Feign默认超时为1秒

Feign和Ribbon的对比：

1.Feign里面包含Ribbon，Feign的负载均衡由Ribbon实现

2.Feign更方便，可以和Hystrix结合

转载于:https://www.cnblogs.com/xuyiqing/p/10869026.html

Spring Cloud（4）：Feign的使用相关推荐

Spring Cloud (Eureka,Feign,Hystrix整合）
Spring Cloud(Eureka,Feign,Hystrix整合) Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智能路由,微代 ...
Spring Cloud（四）：Spring Cloud Alibaba Feign Dubbo
扩展点 RequestInterceptor#apply 扩展点 feign.Client#execute spring cloud dubbo 调用 RPC RPC 全称是 Remote Proce ...
Spring Cloud中Feign如何统一设置验证token
前面我们大致的聊了下如何保证各个微服务之前调用的认证问题 Spring Cloud中如何保证各个微服务之间调用的安全性 Spring Cloud中如何保证各个微服务之间调用的安全性(下篇) 原理是通过 ...
解决Spring Cloud中Feign/Ribbon第一次请求失败的方法
前言在Spring Cloud中,Feign和Ribbon在整合了Hystrix后,可能会出现首次调用失败的问题,要如何解决该问题呢? 造成该问题的原因 Hystrix默认的超时时间是1秒,如果超过 ...
Java笔记(3) - 使用Spring Cloud Zookeeper + Feign实现服务发现
配置映射主机名和IP 为每台虚拟主机的/etc/hosts文件加上如下内容,服务发现需要用到默认主机名作为访问地址,这样可以不用为每个服务实例配置IP 192.168.253.30 megumi-30 ...
spring cloud + nacos + feign调用
//by yan 20211119 需求: 简单建个项目,用来测试调用注册在nacos的服务接口. 步骤: idea -> new project-> Spring Initializr ...
Spring Cloud 之 Feign 使用HTTP请求远程服务
Feign是从Netflix中分离出来的轻量级项目,能够在类接口上添加注释,成为一个REST API 客户端,Feign默认集成了Ribbon. Feign中对 Hystrix 有依赖关系.Feign ...
spring cloud利用feign和sentinel进行内部或外部远程调用
一.FeignClient注解 FeignClient注解被@Target(ElementType.TYPE)修饰,表示FeignClient注解的作用目标在接口上 /* Copyright 2013 ...
spring cloud整合feign和nacos报错：No Feign Client for loadBalancing defined. Did you forget to include
Did you forget to include spring-cloud-starter-loadbalancer 问题描述项目环境解决方案 1.引入eureka依赖--无效 2.降低spri ...
Spring Cloud Open Feign系列【11】Feign 编码解码器Encoder和Decoder源码分析
文章目录概述接口及相关实现类 Encoder 接口 Decoder接口执行流程源码分析 1. 项目结构改造 2. 编码器流程 3. 解码器流程 4. 异常解码处理流程 5. 404异常特殊处理 ...

Spring Cloud（4）：Feign的使用

Spring Cloud（4）：Feign的使用相关推荐

最新文章

热门文章