【OpenFeign】OpenFeign指定url方式调用

OpenFeign一般是结合注册中心一起使用的,也就是可以通过提供服务的名称而不是url来完成对目标服务的访问。但是出于本地调试的需要,或者考虑到一些简单的服务可能并不需要依赖注册中心,所以本篇我们就讲解一下OpenFeign直接通过目标服务的url进行调用的方式。

FeignClient注解配置URL

在@FeignClient注解的url属性中写一个固定的调用地址:

package com.morris.user.client;import com.morris.user.entity.Order;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;import java.util.List;/*** 指定url属性*/
@FeignClient(value = "order-service", url = "http://localhost:8020", path = "/order", contextId = "orderUrl")
public interface OrderUrlClient {@GetMapping("findOrderByUserId")List<Order> findOrderByUserId(@RequestParam("userId") Long userId);}

或者写一个可配置的地址,这样可以在配置文件里指定,可以根据不同的环境配置不同的URL,这种方式在创建feign客户端的时候就需要规划好:

@FeignClient(value = "order-service", url = "${customer.url}", path = "/order", contextId = "orderUrl")
public interface OrderUrlClient {@GetMapping("findOrderByUserId")List<Order> findOrderByUserId(@RequestParam("userId") Long userId);}

实现RequestInterceptor接口?

实现RequestInterceptor接口在发起HTTP请求之前将注册中心调用方式修改为url方式调用。

在@FeignClient注解中指定configuration属性,这里并没有指定url属性:

package com.morris.user.client;import com.morris.user.config.FeignUrlConfig;
import com.morris.user.entity.Order;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;import java.util.List;@FeignClient(value = "order-service", path = "/order", contextId = "orderUrl2", configuration = FeignUrlConfig.class)
public interface OrderUrlClient2 {@GetMapping("findOrderByUserId")List<Order> findOrderByUserId(@RequestParam("userId") Long userId);}

FeignUrlConfig类中注入了一个RequestInterceptor类来拦截OrderUrlClient2中的请求,这里只会拦截OrderUrlClient2类中的请求:

package com.morris.user.config;import feign.Logger;
import feign.Request;
import org.springframework.context.annotation.Bean;public class FeignUrlConfig {@Beanpublic Logger.Level feignLoggerLevel() {return Logger.Level.FULL;}@Beanpublic FeignUrlRequestInterceptor feignTraceRequestInterceptor() {return new FeignUrlRequestInterceptor();}
}

FeignUrlRequestInterceptor类中将请求的地址修改为具体的url,而不是之前的serviceId。

package com.morris.user.config;import feign.RequestInterceptor;
import feign.RequestTemplate;public class FeignUrlRequestInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate template) {System.out.println("old: " + template.url()); // /findOrderByUserId?userId=1template.target("http://localhost:8020/order");System.out.println("new: " + template.url()); // http://localhost:8020/order/findOrderByUserId?userId=1}
}

发起请求后抛出如下异常:

java.lang.RuntimeException: Load balancer does not contain an instance for the service localhostat com.morris.user.config.FeignErrorDecoder.decode(FeignErrorDecoder.java:24) ~[classes/:na]

可以发现Feign还是会去注册中心寻找服务,这是为什么呢?

通过阅读FeignClientFactoryBean源码发现:

<T> T getTarget() {FeignContext context = applicationContext.getBean(FeignContext.class);Feign.Builder builder = feign(context);if (!StringUtils.hasText(url)) {if (!name.startsWith("http")) {url = "http://" + name;}else {url = name;}url += cleanPath();// url不存在return (T) loadBalance(builder, context,new HardCodedTarget<>(type, name, url));}if (StringUtils.hasText(url) && !url.startsWith("http")) {url = "http://" + url;}String url = this.url + cleanPath();Client client = getOptional(context, Client.class);if (client != null) {if (client instanceof LoadBalancerFeignClient) {// not load balancing because we have a url,// but ribbon is on the classpath, so unwrapclient = ((LoadBalancerFeignClient) client).getDelegate();}if (client instanceof FeignBlockingLoadBalancerClient) {// not load balancing because we have a url,// but Spring Cloud LoadBalancer is on the classpath, so unwrap// url不存在client = ((FeignBlockingLoadBalancerClient) client).getDelegate();}builder.client(client);}Targeter targeter = get(context, Targeter.class);return (T) targeter.target(this, builder, context,new HardCodedTarget<>(type, name, url));
}

当@FeignClient中的url属性不存在时,底层的Client使用的是FeignBlockingLoadBalancerClient,这个Client会根据serviceId去注册中心查询服务,并进行负载均衡,虽然FeignUrlRequestInterceptor修改了url地址,但是Client会根据修改后的serviceId,也就是FeignUrlRequestInterceptor只能修改serviceId,不能改变调用方式。

当@FeignClient中的url属性存在时,底层的Client使用的是FeignBlockingLoadBalancerClient.getDelegate(),也就是ApacheHttpClient,这个client就不会去注册中心查询服务了,直接发起接口的调用。

自定义FeignBlockingLoadBalancerClient

自定义一个FeignBlockingLoadBalancerClient来改写url:

@FeignClient注解中指定configuration属性:

package com.morris.user.client;import com.morris.user.config.OrderUrlClient3Config;
import com.morris.user.entity.Order;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;import java.util.List;@FeignClient(value = "order-service", path = "/order", contextId = "orderUrl3", configuration = OrderUrlClient3Config.class)
public interface OrderUrlClient3 {@GetMapping("findOrderByUserId")List<Order> findOrderByUserId(@RequestParam("userId") Long userId);}

OrderUrlClient3Config类中注入了一个OrderUrlClient3Client类来拦截OrderUrlClient3中的请求,这里只会拦截OrderUrlClient3类中的请求,如果要实现全局的拦截,可以在OrderUrlClient3Config类上加@Configuration注解:

package com.morris.user.config;import feign.Client;
import feign.Logger;
import org.springframework.context.annotation.Bean;public class OrderUrlClient3Config {@Beanpublic Logger.Level feignLoggerLevel() {return Logger.Level.FULL;}@Beanpublic OrderUrlClient3Client orderUrlClient3Client() {return new OrderUrlClient3Client(new Client.Default(null, null), null);}
}

OrderUrlClient3Client类继承了FeignBlockingLoadBalancerClient,重写了execute()方法:

package com.morris.user.config;import feign.Client;
import feign.Request;
import feign.Response;
import org.springframework.cloud.loadbalancer.blocking.client.BlockingLoadBalancerClient;
import org.springframework.cloud.openfeign.loadbalancer.FeignBlockingLoadBalancerClient;
import org.springframework.web.util.UriComponentsBuilder;import java.io.IOException;
import java.net.URI;public class OrderUrlClient3Client extends FeignBlockingLoadBalancerClient {private final Client delegate;public OrderUrlClient3Client(Client delegate, BlockingLoadBalancerClient loadBalancerClient) {super(delegate, loadBalancerClient);this.delegate = delegate;}@Overridepublic Response execute(Request request, Request.Options options) throws IOException {final URI originalUri = URI.create(request.url());// 修改urlURI newUri = UriComponentsBuilder.fromUri(originalUri).host("localhost").port(8020).build().toUri();Request newRequest = Request.create(request.httpMethod(), newUri.toString(),request.headers(), request.body(), request.charset(),request.requestTemplate());return delegate.execute(newRequest, options);}
}

BeanFactoryPostProcessor修改bean的url属性

这里可以使用Spring的扩展,给@FeignClient对应的Bean对象FeignClientFactoryBean加上url属性,这样在容器启动过程中就加上了url属性,feign创建的client为ApacheHttpClient,而不是FeignBlockingLoadBalancerClient

package com.morris.user.config;import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeansException;
import org.springframework.beans.PropertyValue;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.DefaultListableBeanFactory;
import org.springframework.stereotype.Component;import java.util.Objects;@Component
public class OrderUrl4BeanFactoryPostProcessor implements BeanFactoryPostProcessor {@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {if(!(beanFactory instanceof DefaultListableBeanFactory)) {return;}DefaultListableBeanFactory defaultListableBeanFactory = (DefaultListableBeanFactory) beanFactory;String[] bdNames = defaultListableBeanFactory.getBeanDefinitionNames();for (String bdName : bdNames) {BeanDefinition beanDefinition = defaultListableBeanFactory.getBeanDefinition(bdName);if (!Objects.equals("org.springframework.cloud.openfeign.FeignClientFactoryBean", beanDefinition.getBeanClassName())) {continue;}if(!bdName.equals("com.morris.user.client.OrderUrlClient4")) {// 这里只拦截OrderUrlClient4,放开就是全局continue;}PropertyValue urlPv = beanDefinition.getPropertyValues().getPropertyValue("url");if (Objects.nonNull(urlPv)) {Object value = urlPv.getValue();if (value instanceof String) {String url = (String) value;if (StringUtils.isNotBlank(url)) {// 已指定url跳过continue;}}}// 相当于给@FeignClinet注解加上url属性beanDefinition.getPropertyValues().addPropertyValue("url", "http://localhost:8020");}}
}

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

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

相关文章

vue2项目 预渲染 Unable to prerender all routes 错误排查与解决方案

前言 今天在做我的Vue2项目的SEO优化时&#xff0c;我采用了prerender-spa-plugin与vue-meta-info的一套官网前端SEO预渲染方案。 但是&#xff0c;在打包时&#xff0c;报错Unable to prerender all routes。尝试了很多种网上方案&#xff0c;都没有成功&#xff0c;最后从源…

基于vue3和audio封装的简易音频播放器

样式如图所示 <template><div class"audio-player"><div class"player_top" flex-ac flex-justify-between ><div class"fileName genericTitle" fs-28 l-height-32 height-64 pr-42 flex-ac><span class"t…

维护和升级LabVIEW程序

在维护和升级LabVIEW程序时&#xff0c;需要全面考虑代码的现状和未来的需求。以下是各个方面的详细注意事项&#xff0c;以确保程序能够在稳定性和性能方面得到提升。 1. 理解现有代码: 深入代码分析: 仔细阅读现有的代码&#xff0c;了解其逻辑结构、数据流、和控制流程。关注…

中国大模型平台市场份额最新排名Top5!场景化应用昭示新蓝海

8月21日&#xff0c;IDC&#xff08;国际数据公司&#xff09;首次发布了《中国大模型平台市场份额&#xff0c;2023&#xff1a;大模型元年 —— 初局》。数据显示&#xff0c;2023年中国大模型平台及相关应用市场规模达17.65亿元人民币。 在过去的2023年&#xff0c;行业对于…

Linux用户账户管理精髓:创建、删除、密码与会话管理全攻略

目录 一、创建与删除用户 二、设置与修改密码 三、用户切换与会话管理 在Linux系统中&#xff0c;用户账户管理是系统管理员日常工作中不可或缺的一部分。良好的用户账户管理不仅有助于维护系统的安全性&#xff0c;还能提高系统的可用性和可管理性。以下将详细介绍创建与删…

会话跟踪方案:Cookie Session Token

什么是会话技术&#xff1f; Cookie 以登录为例&#xff0c;用户在浏览器中将账号密码输入并勾选自动登录&#xff0c;浏览器发送请求&#xff0c;请求头中设置Cookie&#xff1a;userName:张三 ,password:1234aa &#xff0c;若登录成功&#xff0c;服务器将这个cookie保存…

「数组」数组双指针算法合集:二路合并|逆向合并|快慢去重|对撞指针 / LeetCode 88|26|11(C++)

目录 概述 1.二路合并 思路 复杂度 Code 2.逆向合并 思路 复杂度 Code 3.快慢去重 思路 复杂度 Code 4.对撞指针 思路 复杂度 Code 总结 概述 数组的线性枚举是我们学习编程时遇到的第一种枚举手段。但是它看起来有点愚蠢&#xff1a;只有一个索引i承担全部…

linux基础命令(超级详细)

Linux 系统提供了丰富的命令行工具&#xff0c;用于各种文件操作、系统管理和网络配置等任务。以下是一些常用的 Linux 基础命令&#xff1a; 一、 文件和目录操作 1. ls: 列出目录内容 ls 列出当前目录的文件和目录 ls -l 以长格式列出文件和目录&#xff0c;包…

学生党蓝牙耳机哪个牌子性价比高?推荐四款内行精选百元耳机!

作为没有什么经济来源的学生党&#xff0c;唯一来钱的途径就是家里给的生活费。所以在选择一款蓝牙耳机时就很纠结&#xff0c;那么首先你得清楚学生党的购物习性&#xff0c;因为大部分学生党在买东西时因为经济能力问题&#xff0c;主要追求的还是性价比&#xff0c;可以在实…

IP-RDS-222、IP-PRZ-59-AM12、EG-TRZ-42-L、EG-TRZ-42-H比例减压阀放大器

IP-DAR-250、IP-DAR-43C-L、IP-DAR-43C-H、IP-RDS-222、IP-PRZ-59-AM12、EG-TRZ-42-L、EG-TRZ-42-H比例减压阀 EE-PRB、EE-PRD比例压力阀 EE-P2G、ET-P2S、EB-P2A、EE-P2A、ET-P2A、EE-P2H、EG-F2A、EU-F2A比例流量阀 EF-F3G、EU-F3G比例压力补偿流量阀 EQ-S4M、EG-S4M、EQ…

DVWA靶场通关(CSRF)

CSRF 是跨站请求伪造&#xff0c;是指利用受害者尚未失效的身份认证信息&#xff08;cookie、会话等&#xff09;&#xff0c;诱骗其点击恶意链接或者访问包含攻击代码的页面&#xff0c;在受害人不知情的情况下以受害者的身份向&#xff08;身份认证信息所对应的&#xff09;服…

数据结构-单调栈

给定一个不含有重复值的数组arr&#xff0c;找到每一个i位置左边和右边离i位置最近且值比arr[i]小的位置。返回所有位置相应的信息。 import java.util.Stack;public class MonotonousStack {public static void main(String[] args) {int arr[] {1,2,3,9,8,7,5,6,4};int res[…

【Deep-ML系列】Pegasos Kernel SVM Implementation(手写支持向量机)

引言 支持向量机&#xff08;SVM&#xff09;是机器学习领域中一种非常强大的分类算法&#xff0c;广泛应用于各种分类任务。今天&#xff0c;我们将深入探讨SVM中的Pegasos算法及其与核函数的结合。通过代码示例和详细解释&#xff0c;我们将理解Pegasos算法如何逐步调整模型…

eNSP 华为ACL配置

华为ACL配置 需求&#xff1a; 公司保证财务部数据安全&#xff0c;禁止研发部门和互联网访问财务服务器&#xff0c;但总裁办不受影响 R1&#xff1a; <Huawei>sys [Huawei]sys Router1 [Router1]undo info-center enable [Router1]int g1/0/0 [Router1-GigabitEth…

开放式耳机为什么性价比高?四款开放式蓝牙耳机排行榜前十名推荐

如果说需要高性价比的蓝牙耳机推荐的话&#xff0c;我会比较推荐开放式耳机&#xff0c;因为这类的耳机产品价格普遍都不会太高&#xff0c;但配置却都很好。那除了性价比高&#xff0c;开放式耳机还有其他好的地方吗&#xff1f;那当然是有的&#xff0c;对于蓝牙耳机来说&…

线程池相关面试题

一、JDK自带的线程池有那些&#xff1f; 1.Executors.newCachedThreadPool() 创建一个可缓存线程的线程池&#xff0c;若线程池长度超出需要&#xff0c;可回收线程&#xff0c;若没有可回收&#xff0c;则新建线程 2.Executors.newFixedThreadPool() 创建定长线程池&#…

HTML+JS谁是卧底游戏

先说一句&#xff1a;一段时间没发文章&#xff0c;好多僵尸粉关注我&#xff0c;这CSDN&#x1f620; 主要功能 玩家设置&#xff1a;在游戏开始前&#xff0c;输入总人数、卧底人数和白板人数。系统会自动计算出剩下的平民人数&#xff0c;并随机分配身份。 身份查看&#…

DHCP协议-CSP认证

文章目录 DHCP协议 DHCP协议 stringstream的用法 应用实践 #include<bits/stdc.h>using namespace std;signed main() {string s"wo shi wwl, also wlw";stringstream ss;ss<<s;while(ss>>s){if(s[s.size()-1],) s[s.size()-1] ;cout<<s<…

授权cleanmymac访问全部磁盘 Mac授权访问权限 cleanmymac缺少权限

CleanMyMac是Mac系统下的一款专业的苹果电脑清理软件&#xff0c;同时也是一款优秀的电脑系统管理软件。它能有效清理系统垃圾&#xff0c;快速释放磁盘内存&#xff0c;缓解卡顿现象&#xff0c;保障系统顺畅地运行。 全磁盘访问权限&#xff0c;就好比机场内进行的安全检查。…

【AD9361 数字基带】多片基带内FPGA补偿 I/Q Rotation

I/Q 旋转 Rotation 在许多多通道射频系统中&#xff0c;如 AD-FMCOMMS5&#xff0c;甚至在 AD-FMCOMMS2、AD-FMCOMMS3 上&#xff0c;都需要测量或校正两个复数 &#xff08;I/Q&#xff09; RF 信号之间的相位差。 从纯粹的数学描述来看&#xff0c;单个正弦波没有相位&…