是对下面代码的优化
自动根据参数拼接http请求地址
Feign集成了ribbon配置项和Hystrix熔断的Fallback配置项，可以使用Feign来配置他。
为了方便测试，我们将一切的ribbon配置项和Hystrix项全部注释掉
feign:
hystrix:
enabled: true # 开启Feign的熔断功能
compression:
request:
enabled: true # 开启请求压缩
mime-types: text/html,application/xml,application/json # 设置压缩的数据类型
min-request-size: 2048 # 设置触发压缩的大小下限
response:
enabled: true # 开启响应压缩
将请求地址中路径去除一些前缀路径之后再作为代理的服务地址
http://127.0.0.1:10010/api/user/8 --> http://user-service/user/8
通过StripPrefix=n 来指定了路由要去掉的n个前缀,案例
package fei.zhou.gatewaydemo.filter;
import java.util.Arrays;
import java.util.List;
import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
@Component
public class MyParam11GatewayFilterFactory extends AbstractGatewayFilterFactory<MyParam11GatewayFilterFactory.Config> {
static final String PARAM_NAME = "param";
public MyParam11GatewayFilterFactory() {
super(Config.class);
}
@Override
public List<String> shortcutFieldOrder() {
return Arrays.asList(PARAM_NAME);
}
@Override
public GatewayFilter apply(Config config) {
return (exchange, chain) -> {
// http://localhost:10010/user/8?name=userId config.param ==> name
// 获取请求参数中param对应的参数名 的参数值
ServerHttpRequest request = exchange.getRequest();
if (request.getQueryParams().containsKey(config.param)) {
request.getQueryParams().get(config.param).forEach(
value -> System.out.println("------------局部过滤器-------参数名字:" + config.param + "--参数值:" + value));
}
return chain.filter(exchange);
};
}
public static class Config {
// 对应在配置过滤器的时候指定的参数名
private String param;
public String getParam() {
return param;
}
public void setParam(String param) {
this.param = param;
}
}
}
package fei.zhou.gatewaydemo.filter;
import org.apache.commons.lang.StringUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Component
public class MyGlobal11Filter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
System.out.println("--------------全局过滤器MyGlobal11Filter------------------");
String token = exchange.getRequest().getQueryParams().getFirst("token");
if (StringUtils.isBlank(token)) {
// 设置响应状态码为未授权
// UNAUTHORIZED(401, "Unauthorized"),
exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
return exchange.getResponse().setComplete();
}
return chain.filter(exchange);
}
@Override
public int getOrder() {
// 值越小越先执行
return 1;
}
}
hystrix:
command:
default:
execution:
isolation:
thread:
# 服务提供者的超时时间，2秒，如果请求服务提供者超过2秒，就服务降级和线程隔离
timeoutInMilliseconds: 6000
ribbon:
ConnectTimeout: 1000 # 连接超时时长
ReadTimeout: 2000 # 数据通信超时时长
MaxAutoRetries: 0 # 当前服务器的重试次数
MaxAutoRetriesNextServer: 0 # 重试多少次服务
OkToRetryOnAllOperations: false # 是否对所有的请求方式都重试
spring:
cloud:
gateway:
globalcors:
corsConfigurations:
'[/**]':
#allowedOrigins: * # 这种写法或者下面的都可以，*表示全部
allowedOrigins:
- "http://docs.spring.io"
allowedMethods:
- GET
spring:
cloud:
config:
# 要与仓库中的配置文件的application保持一致
name: userService
# 要与仓库中的配置文件的profile保持一致
profile: dev
# git仓库中的配置文件所属的分支
label: master
discovery:
# 使用配置中心
enabled: true
# 配置中心服务名
service-id: config-server
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
http://127.0.0.1:12000/actuator/bus-refresh
映射的配置
# 暴露触发消息总线的地址
include: bus-refresh
代码地址
https://gitee.com/DanShenGuiZu/spring_cloud_config.git