OpenFeign指定url方式調(diào)用的方式詳解
更新時間：2024年11月08日 10:38:37 作者：morris131
OpenFeign一般是結(jié)合注冊中心一起使用的,也就是可以通過提供服務的名稱而不是url來完成對目標服務的訪問,本篇我們就講解一下OpenFeign直接通過目標服務的url進行調(diào)用的方式,需要的朋友可以參考下
引言
OpenFeign一般是結(jié)合注冊中心一起使用的，也就是可以通過提供服務的名稱而不是url來完成對目標服務的訪問。但是出于本地調(diào)試的需要，或者考慮到一些簡單的服務可能并不需要依賴注冊中心，所以本篇我們就講解一下OpenFeign直接通過目標服務的url進行調(diào)用的方式。
FeignClient注解配置URL
在@FeignClient注解的url屬性中寫一個固定的調(diào)用地址：
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);
}
或者寫一個可配置的地址，這樣可以在配置文件里指定，可以根據(jù)不同的環(huán)境配置不同的URL，這種方式在創(chuàng)建feign客戶端的時候就需要規(guī)劃好：
@FeignClient(value = "order-service", url = "${customer.url}", path = "/order", contextId = "orderUrl")
public interface OrderUrlClient {
@GetMapping("findOrderByUserId")
List<Order> findOrderByUserId(@RequestParam("userId") Long userId);
}
實現(xiàn)RequestInterceptor接口？
實現(xiàn)RequestInterceptor接口在發(fā)起HTTP請求之前將注冊中心調(diào)用方式修改為url方式調(diào)用。
在@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 {
@Bean
public Logger.Level feignLoggerLevel() {
return Logger.Level.FULL;
}
@Bean
public FeignUrlRequestInterceptor feignTraceRequestInterceptor() {
return new FeignUrlRequestInterceptor();
}
}
FeignUrlRequestInterceptor類中將請求的地址修改為具體的url，而不是之前的serviceId。
package com.morris.user.config;
import feign.RequestInterceptor;
import feign.RequestTemplate;
public class FeignUrlRequestInterceptor implements RequestInterceptor {
@Override
public void apply(RequestTemplate template) {
System.out.println("old: " + template.url()); // /findOrderByUserId?userId=1
template.target("http://localhost:8020/order");
System.out.println("new: " + template.url()); // http://localhost:8020/order/findOrderByUserId?userId=1
}
}
發(fā)起請求后拋出如下異常：
java.lang.RuntimeException: Load balancer does not contain an instance for the service localhost at com.morris.user.config.FeignErrorDecoder.decode(FeignErrorDecoder.java:24) ~[classes/:na]
可以發(fā)現(xiàn)Feign還是會去注冊中心尋找服務，這是為什么呢？
通過閱讀FeignClientFactoryBean源碼發(fā)現(xiàn)：
<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 unwrap
client = ((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會根據(jù)serviceId去注冊中心查詢服務，并進行負載均衡，雖然FeignUrlRequestInterceptor修改了url地址，但是Client會根據(jù)修改后的serviceId，也就是FeignUrlRequestInterceptor只能修改serviceId，不能改變調(diào)用方式。
當@FeignClient中的url屬性存在時，底層的Client使用的是FeignBlockingLoadBalancerClient.getDelegate()，也就是ApacheHttpClient，這個client就不會去注冊中心查詢服務了，直接發(fā)起接口的調(diào)用。
自定義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類中的請求，如果要實現(xiàn)全局的攔截，可以在OrderUrlClient3Config類上加@Configuration注解：
package com.morris.user.config;
import feign.Client;
import feign.Logger;
import org.springframework.context.annotation.Bean;
public class OrderUrlClient3Config {
@Bean
public Logger.Level feignLoggerLevel() {
return Logger.Level.FULL;
}
@Bean
public 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;
}
@Override
public Response execute(Request request, Request.Options options) throws IOException {
final URI originalUri = URI.create(request.url());
// 修改url
URI 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創(chuàng)建的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 {
@Override
public 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指定url方式調(diào)用的方式詳解的文章就介紹到這了,更多相關OpenFeign指定url調(diào)用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
Java SpringBoot Validation用法案例詳解
這篇文章主要介紹了Java SpringBoot Validation用法案例詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下2021-09-09
實例詳解Spring Boot實戰(zhàn)之Redis緩存登錄驗證碼
本章簡單介紹redis的配置及使用方法，本文示例代碼在前面代碼的基礎上進行修改添加，實現(xiàn)了使用redis進行緩存驗證碼，以及校驗驗證碼的過程。感興趣的的朋友一起看看吧2017-08-08
Transactional注解導致Spring Bean定時任務失效的解決方法
這篇文章主要介紹了Transactional注解導致Spring Bean定時任務失效的解決方法,文中通過代碼示例介紹的非常詳細,對大家解決問題有一定的幫助,需要的朋友可以參考下2024-10-10
本文詳細介紹了最長遞增子序列問題的定義及兩種優(yōu)化解法：貪心+二分查找和動態(tài)規(guī)劃+狀態(tài)壓縮,貪心+二分查找時間復雜度為O(nlogn),通過維護一個有序的“尾巴”數(shù)組來高效地找到最長遞增子序列,動態(tài)規(guī)劃+狀態(tài)壓縮則通過狀態(tài)壓縮將空間復雜度優(yōu)化至O(n)2025-02-02
這篇文章主要為大家介紹了JVM虛擬機性能監(jiān)控與故障處理工具介紹，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-07-07
這篇文章主要介紹了Java Map集合的使用及Collection工具類使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習吧2022-11-11
Java FineReport報表工具導出EXCEL的四種方式
這篇文章主要介紹了Java FineReport報表工具導出EXCEL的四種方式的相關資料,需要的朋友可以參考下2016-03-03
這篇文章主要介紹了Java?批量生成條碼的示例代碼,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-08-08
本文詳細介紹了SpringBoot和Netty的整合方法,包括添加依賴、創(chuàng)建Netty服務端代碼解析類、創(chuàng)建字符解析器等步驟,以及開發(fā)過程中遇到的問題及解決方法,感興趣的可以了解一下2024-10-10
這篇文章主要介紹了Java中的MapStruct用法詳解,MapStuct的使用非常簡單，把對應的jar包引入即可，本文通過示例代碼給大家介紹的非常詳細，需要的朋友可以參考下2022-04-04