【OpenFeign】OpenFeign指定url方式调用

2024-08-23 13:20

本文主要是介绍【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");}}
}

这篇关于【OpenFeign】OpenFeign指定url方式调用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1099499

相关文章

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件: 2.调用utility bar api的方式有两种: 方法一,通过lwc调用: import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca

内核启动时减少log的方式

内核引导选项 内核引导选项大体上可以分为两类:一类与设备无关、另一类与设备有关。与设备有关的引导选项多如牛毛,需要你自己阅读内核中的相应驱动程序源码以获取其能够接受的引导选项。比如,如果你想知道可以向 AHA1542 SCSI 驱动程序传递哪些引导选项,那么就查看 drivers/scsi/aha1542.c 文件,一般在前面 100 行注释里就可以找到所接受的引导选项说明。大多数选项是通过"_

用命令行的方式启动.netcore webapi

用命令行的方式启动.netcore web项目 进入指定的项目文件夹,比如我发布后的代码放在下面文件夹中 在此地址栏中输入“cmd”,打开命令提示符,进入到发布代码目录 命令行启动.netcore项目的命令为:  dotnet 项目启动文件.dll --urls="http://*:对外端口" --ip="本机ip" --port=项目内部端口 例: dotnet Imagine.M

深入理解RxJava:响应式编程的现代方式

在当今的软件开发世界中,异步编程和事件驱动的架构变得越来越重要。RxJava,作为响应式编程(Reactive Programming)的一个流行库,为Java和Android开发者提供了一种强大的方式来处理异步任务和事件流。本文将深入探讨RxJava的核心概念、优势以及如何在实际项目中应用它。 文章目录 💯 什么是RxJava?💯 响应式编程的优势💯 RxJava的核心概念

【即时通讯】轮询方式实现

技术栈 LayUI、jQuery实现前端效果。django4.2、django-ninja实现后端接口。 代码仓 - 后端 代码仓 - 前端 实现功能 首次访问页面并发送消息时需要设置昵称发送内容为空时要提示用户不能发送空消息前端定时获取消息,然后展示在页面上。 效果展示 首次发送需要设置昵称 发送消息与消息展示 提示用户不能发送空消息 后端接口 发送消息 DB = []@ro

脏页的标记方式详解

脏页的标记方式 一、引言 在数据库系统中,脏页是指那些被修改过但还未写入磁盘的数据页。为了有效地管理这些脏页并确保数据的一致性,数据库需要对脏页进行标记。了解脏页的标记方式对于理解数据库的内部工作机制和优化性能至关重要。 二、脏页产生的过程 当数据库中的数据被修改时,这些修改首先会在内存中的缓冲池(Buffer Pool)中进行。例如,执行一条 UPDATE 语句修改了某一行数据,对应的缓

遮罩,在指定元素上进行遮罩

废话不多说,直接上代码: ps:依赖 jquer.js 1.首先,定义一个 Overlay.js  代码如下: /*遮罩 Overlay js 对象*/function Overlay(options){//{targetId:'',viewHtml:'',viewWidth:'',viewHeight:''}try{this.state=false;//遮罩状态 true 激活,f

【LabVIEW学习篇 - 21】:DLL与API的调用

文章目录 DLL与API调用DLLAPIDLL的调用 DLL与API调用 LabVIEW虽然已经足够强大,但不同的语言在不同领域都有着自己的优势,为了强强联合,LabVIEW提供了强大的外部程序接口能力,包括DLL、CIN(C语言接口)、ActiveX、.NET、MATLAB等等。通过DLL可以使用户很方便地调用C、C++、C#、VB等编程语言写的程序以及windows自带的大

Anaconda 中遇到CondaHTTPError: HTTP 404 NOT FOUND for url的问题及解决办法

最近在跑一个开源项目遇到了以下问题,查了很多资料都大(抄)同(来)小(抄)异(去)的,解决不了根本问题,费了很大的劲终于得以解决,记录如下: 1、问题及过程: (myenv) D:\Workspace\python\XXXXX>conda install python=3.6.13 Solving environment: done.....Proceed ([y]/n)? yDownloa

Jenkins构建Maven聚合工程,指定构建子模块

一、设置单独编译构建子模块 配置: 1、Root POM指向父pom.xml 2、Goals and options指定构建模块的参数: mvn -pl project1/project1-son -am clean package 单独构建project1-son项目以及它所依赖的其它项目。 说明: mvn clean package -pl 父级模块名/子模块名 -am参数