提交 4ab4b4c2 编写于 作者: H haoxr

refactor: 删除无用文件

上级 4542bea7
package com.youlai.gateway.filter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
/**
* 网关全局过滤器
*
* @author haoxr
* @date 2022/2/15
*/
@Component
@Slf4j
@RequiredArgsConstructor
public class GatewayGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
String authorization = request.getHeaders().getFirst("Authorization");
log.info("authorization:{}",authorization);
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 99;
}
}
package com.youlai.gateway.util;
import cn.hutool.json.JSONUtil;
import com.youlai.common.result.Result;
import com.youlai.common.result.ResultCode;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.server.reactive.ServerHttpResponse;
import reactor.core.publisher.Mono;
import java.nio.charset.StandardCharsets;
/**
* 异常响应工具类
*
* @Author haoxr
* @Date 2021/01/29 13:30
*/
public class WebFluxUtils {
public static Mono<Void> writeResponse(ServerHttpResponse response, ResultCode resultCode) {
switch (resultCode) {
case ACCESS_UNAUTHORIZED:
case INVALID_TOKEN:
response.setStatusCode(HttpStatus.UNAUTHORIZED);
break;
case TOKEN_ACCESS_FORBIDDEN:
response.setStatusCode(HttpStatus.FORBIDDEN);
break;
default:
response.setStatusCode(HttpStatus.BAD_REQUEST);
break;
}
response.getHeaders().set(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
response.getHeaders().set(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, "*");
response.getHeaders().set(HttpHeaders.CACHE_CONTROL, "no-cache");
String body = JSONUtil.toJsonStr(Result.failed(resultCode));
DataBuffer buffer = response.bufferFactory().wrap(body.getBytes(StandardCharsets.UTF_8));
return response.writeWith(Mono.just(buffer))
.doOnError(error -> DataBufferUtils.release(buffer));
}
}
MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAkVialdAhS5YHW+FdpQGf
b+7iiF3JCo9EtKvPB/WxnkJwP9xe27PP/b9NTPKuRrq8nrGtTEGJC1Yba88jXGLI
fTfIKRFZjyKrz9r4SlEfDEHhrPukURa27tohJdtbHrWCRX1mG0MIf46Hig4s90Cw
gKkppzzNnohqGFrZmJ8dVw1bdExw70TeosRxXs0ROgYjINKMDKwpmuxQhZSxWrSi
xljX4ZcV2Ct3WzZnSwST76P9/IHBFDgsvwNnA/M8xZB3+MovGMhsf1WqDiBN6QMM
m5YlLXOjWgzjKQsceMvb57rDSb2aYgnFjWabQetUPkiCJRlnJw3Cy+opCdIBpZO/
DQIDAQAB
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册