Spring Cloud Gateway调用Feign异步问题记录
更新时间：2023年04月26日 10:36:15 作者：@Kong
这篇文章主要介绍了Spring Cloud Gateway调用Feign异步问题记录，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
版本设定 spring cloud 2020.0.2版本
HttpMessageConverters
原因
由于Spring Cloud Gateway 是基于Spring 5、Spring Boot 2.X和Reactor开发的响应式组件，运用了大量的异步实现。
在项目启动过程中，并不会创建HttpMessageConverters实例，具体可查看源码HttpMessageConvertersAutoConfiguration
解决方法
启动时创建相应的Bean,注入到Spring容器
@Configuration
public class FeignConfig {
@Bean
public Decoder decoder(){
return new ResponseEntityDecoder(new SpringDecoder(feignHttpMessageConverter()));
}
private ObjectFactory<HttpMessageConverters> feignHttpMessageConverter(){
HttpMessageConverters httpMessageConverters=new HttpMessageConverters
(new MappingJackson2HttpMessageConverter());
return ()->httpMessageConverters;
}
}
Filter异步调用问题
场景
以鉴权为例，外部访问经由Gateway路由转发，需要验证当前请求中是否存在token，可以通过自定义过滤器实现GlobalFitler实现。
@PropertySource(value = "classpath:loginfilter.properties")
@Component
public class AuthLoginGlobalFilter implements GlobalFilter, Ordered {
@Value("#{'/per-user/login,/goods/**'.split(',')}")
private List<String> ignoreUrls;
@Autowired
private IUserFeign userFeign;
ExecutorService executorService = Executors.newFixedThreadPool(1);
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
if(ignoreUrls !=null && ignoreUrls.contains(request.getURI().getPath())) {
return chain.filter(exchange);
}
String access_token = request.getHeaders().getFirst("access_token");
if(StringUtils.isBlank(access_token)) {
return onError(exchange,"尚未登录");
}
R<String> r = userFeign.validToken(access_token);
if(r.getCode() == 200) {
ServerHttpRequest serverHttpRequest = request.mutate().header("uid",r.getData()).build();
return chain.filter(exchange.mutate().request(serverHttpRequest).build());
}
return onError(exchange,r.getMsg());
}
@Override
public int getOrder() {
return 0;
}
private Mono<Void> onError(ServerWebExchange exchange,String msg) {
ServerHttpResponse response = exchange.getResponse();
response.setStatusCode(HttpStatus.UNAUTHORIZED);
response.getHeaders().add("Content-Type","application/json;charset=UTF-8");
R r = new R.Builder().buildCustomize(HttpStatus.UNAUTHORIZED.value(),msg);
ObjectMapper objectMapper = new ObjectMapper();
String rs = "";
try {
rs = objectMapper.writeValueAsString(r);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
DataBuffer dataBuffer =response.bufferFactory().wrap(rs.getBytes());
return response.writeWith(Flux.just(dataBuffer));
}
}
R r = userFeign.validToken(access_token);属于同步调用，会报以下错误：
错误原因
在BlockingSingleSubscriber中会进行判断：
final T blockingGet() {
if (Schedulers.isInNonBlockingThread()) {
throw new IllegalStateException("block()/blockFirst()/blockLast() are blocking, which is not supported in thread " + Thread.currentThread().getName());
}
if (getCount() != 0) {
try {
await();
}
catch (InterruptedException ex) {
dispose();
throw Exceptions.propagate(ex);
}
}
Throwable e = error;
if (e != null) {
RuntimeException re = Exceptions.propagate(e);
//this is ok, as re is always a new non-singleton instance
re.addSuppressed(new Exception("#block terminated with an error"));
throw re;
}
return value;
}
解决方案
解决方案，同步转异步，如果需要获取返回结果，可以通过Future方式获取
@PropertySource(value = "classpath:loginfilter.properties")
@Component
public class AuthLoginGlobalFilter implements GlobalFilter, Ordered {
@Value("#{'/per-user/login,/goods/**'.split(',')}")
private List<String> ignoreUrls;
@Autowired
private IUserFeign userFeign;
ExecutorService executorService = Executors.newFixedThreadPool(1);
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
if(ignoreUrls !=null && ignoreUrls.contains(request.getURI().getPath())) {
return chain.filter(exchange);
}
String access_token = request.getHeaders().getFirst("access_token");
if(StringUtils.isBlank(access_token)) {
return onError(exchange,"尚未登录");
}
// WebFlux异步调用，同步会报错
Future future = executorService.submit((Callable<R>) () -> userFeign.validToken(access_token));
R<String> r = null;
try {
r = (R<String>) future.get();
if(r.getCode() == 200) {
ServerHttpRequest serverHttpRequest = request.mutate().header("uid",r.getData()).build();
return chain.filter(exchange.mutate().request(serverHttpRequest).build());
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
return onError(exchange,r.getMsg());
}
@Override
public int getOrder() {
return 0;
}
private Mono<Void> onError(ServerWebExchange exchange,String msg) {
ServerHttpResponse response = exchange.getResponse();
response.setStatusCode(HttpStatus.UNAUTHORIZED);
response.getHeaders().add("Content-Type","application/json;charset=UTF-8");
R r = new R.Builder().buildCustomize(HttpStatus.UNAUTHORIZED.value(),msg);
ObjectMapper objectMapper = new ObjectMapper();
String rs = "";
try {
rs = objectMapper.writeValueAsString(r);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
DataBuffer dataBuffer =response.bufferFactory().wrap(rs.getBytes());
return response.writeWith(Flux.just(dataBuffer));
}
}
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
Spring Batch是Spring的一个子项目,使用Java语言并基于Spring框架为基础开发,使得已经使用 Spring 框架的开发者或者企业更容易访问和利用企业服务，本文给大家介绍SpringBatch适配器的相关知识，感兴趣的朋友一起看看吧2021-11-11
这篇文章主要为大家详细介绍了SpringBoot如何整合Hmily实现TCC分布式事务,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下2024-11-11
这篇文章主要介绍了Springcloud-nacos实现配置和注册中心的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-07-07
我们知道Spring一次可以加载多个Bean定义的Xml配置文件,我们可以设想下如果让我们来做我们会怎么做？我估计会根据配置文件的顺序依次读取并加载，那再来看看Spring是如何做的？2021-06-06
Apache commons fileupload文件上传实例讲解
这篇文章主要为大家详细介绍了Apache commons fileupload文件上传实例,具有一定的参考价值，感兴趣的小伙伴们可以参考一下2016-10-10
Spring中的@PropertySource注解源码详细解析
这篇文章主要介绍了Spring中的@PropertySource注解源码详细解析,@PropertySource注解,标注在配置类@Configuration上面,下面主要分析一下@PropertySource注解的处理过程,也就是怎么把配置信息从.properies文件放到environment中的,需要的朋友可以参考下2024-01-01
Windows中在IDEA上安装和使用JetBrains Mono字体的教程
这篇文章主要介绍了Windows IDEA上安装和使用JetBrains Mono字体的教程，本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-03-03
后端接口在接收数据的时候，都需要进行检查。检查全部通过后，才能够执行业务逻辑。本文总结了四个Java检查日期字符串是否合法的方法，感兴趣的可以了解一下2022-10-10
这篇文章主要介绍了Android中Socket通信的实现方法,很有实用价值,需要的朋友可以参考下2014-08-08
这篇文章主要介绍了java编程中自动拆箱与自动装箱详解，具有一定参考价值，需要的朋友可以了解下。2017-11-11
最新评论