切换导航条
此项目
正在载入...
登录
zhangFan
/
gateway
·
提交
转到一个项目
GitLab
转到仪表盘
项目
活动
文件
提交
管道
0
构建
0
图表
里程碑
问题
0
合并请求
0
成员
标记
维基
派生
网络
创建新的问题
下载为
邮件补丁
差异文件
浏览文件
作者
朱兆平
3 months ago
提交
3ac9f23fcec71347f5b8bb4dd4882a5af711489c
1 个父辈
eacff797
master
1. 优化路由判定
2. 安全配置
显示空白字符变更
内嵌
并排对比
正在显示
4 个修改的文件
包含
239 行增加
和
24 行删除
config/application.yml
pom.xml
src/main/java/com/example/gateway/filter/WrapperResponseGlobalFilter.java
src/main/resources/logback-dev.xml
config/application.yml
查看文件 @
3ac9f23
...
...
@@ -3,6 +3,7 @@ spring:
host
:
192.168.1.53
port
:
6379
timeout
:
60000
password
:
vmvnv1v2VV.
application
:
name
:
gateway-server-v12
profiles
:
...
...
@@ -73,6 +74,10 @@ management:
gateway
:
enabled
:
false
endpoint
:
gateway
:
enabled
:
false
env
:
enabled
:
false
health
:
enabled
:
true
# 启用健康检查端点
info
:
...
...
pom.xml
查看文件 @
3ac9f23
...
...
@@ -11,13 +11,13 @@
</parent>
<groupId>
com.example
</groupId>
<artifactId>
gateway
</artifactId>
<version>
1.0-
WIN
</version>
<version>
1.0-
linux
</version>
<name>
gateway
</name>
<description>
gateway project for Spring Boot
</description>
<properties>
<java.version>
1.8
</java.version>
<spring-cloud.version>
Greenwich.SR
2
</spring-cloud.version>
<spring-cloud.version>
Greenwich.SR
6
</spring-cloud.version>
</properties>
<dependencies>
...
...
src/main/java/com/example/gateway/filter/WrapperResponseGlobalFilter.java
查看文件 @
3ac9f23
...
...
@@ -58,7 +58,7 @@ public class WrapperResponseGlobalFilter implements GlobalFilter, Ordered {
if
(
request
.
getPath
().
toString
().
contains
(
LOGIN
)){
return
chain
.
filter
(
exchange
);
}
boolean
flag
=
U
rlFilter
(
request
);
boolean
flag
=
u
rlFilter
(
request
);
if
(!
flag
){
exchange
.
getResponse
().
setStatusCode
(
HttpStatus
.
UNAUTHORIZED
);
return
exchange
.
getResponse
().
setComplete
();
...
...
@@ -119,36 +119,50 @@ public class WrapperResponseGlobalFilter implements GlobalFilter, Ordered {
return
-
2
;
}
public
boolean
UrlFilter
(
ServerHttpRequest
request
)
{
//先鉴权匿名者可访问的接口
if
(
anonymousUrlFilter
(
request
)){
public
boolean
urlFilter
(
ServerHttpRequest
request
)
{
// 鉴权匿名者可访问的接口
if
(
anonymousUrlFilter
(
request
))
{
return
true
;
}
String
token
=
""
;
if
(!
request
.
getPath
().
toString
().
contains
(
LOGIN
))
{
HttpHeaders
rqHeader
=
request
.
getHeaders
();
if
(
rqHeader
.
containsKey
(
"Authorization"
)){
token
=
rqHeader
.
get
(
"Authorization"
).
toString
();
token
=
token
.
substring
(
1
,
token
.
length
()
-
1
);
log
.
info
(
"[TOKEN]-Request Authorization INFO is:[{}]"
,
token
);
}
}
String
redisKey
=
token
.
replace
(
"Bearer "
,
""
);
log
.
info
(
"[REDIS-KEY]-is:[{}]"
,
redisKey
);
// 获取请求路径
String
path
=
request
.
getPath
().
toString
();
// 如果不是登录请求,尝试获取并处理Authorization头
if
(!
path
.
contains
(
LOGIN
))
{
HttpHeaders
headers
=
request
.
getHeaders
();
String
token
=
headers
.
getFirst
(
"Authorization"
);
// 如果存在Authorization头,并且是Bearer类型
if
(
token
!=
null
&&
token
.
startsWith
(
"Bearer "
))
{
token
=
token
.
substring
(
7
);
// "Bearer ".length()
log
.
info
(
"[TOKEN]-Request Authorization INFO is:[{}]"
,
token
);
// 构建Redis键
String
redisKey
=
token
;
log
.
info
(
"[REDIS-KEY]-is:[{}]"
,
redisKey
);
// 尝试从Redis中获取用户信息
String
json
=
stringRedisTemplate
.
opsForValue
().
get
(
redisKey
);
if
(
json
!=
null
)
{
List
<
PERMISSION
>
permissionList
=
JsonToBean
.
jsonToUser
(
json
);
for
(
PERMISSION
permission
:
permissionList
)
{
log
.
trace
(
"访问url:[{}]<->权限[{}]"
,
request
.
getPath
().
toString
(),
permission
.
getUrl
());
if
(
pathMatcher
.
match
(
permission
.
getUrl
(),
request
.
getPath
().
toString
()))
{
log
.
info
(
"[FILTER]-[URL:{}]->鉴权成功"
,
request
.
getPath
().
toString
());
// 使用并行流优化循环
if
(
permissionList
.
parallelStream
().
anyMatch
(
permission
->
{
log
.
trace
(
"访问url:[{}]<->权限[{}]"
,
path
,
permission
.
getUrl
());
return
pathMatcher
.
match
(
permission
.
getUrl
(),
path
);
}))
{
log
.
info
(
"[FILTER]-[URL:{}]->鉴权成功"
,
path
);
return
true
;
}
}
else
{
log
.
warn
(
"[FILTER]-没有对应token的redis缓存,鉴权失败"
);
}
}
}
else
{
log
.
info
(
"[FILTER]-没有对应token的redis缓存,鉴权失败"
);
}
log
.
info
(
"[FILTER]-[URL:{}]->鉴权失败"
,
request
.
getPath
().
toString
());
// 如果未通过任何鉴权检查,记录失败并返回false
log
.
warn
(
"[FILTER]-[URL:{}]->鉴权失败"
,
path
);
return
false
;
}
...
...
@@ -159,6 +173,7 @@ public class WrapperResponseGlobalFilter implements GlobalFilter, Ordered {
*/
public
boolean
anonymousUrlFilter
(
ServerHttpRequest
request
){
//内部服务接口,不允许外部访问
System
.
out
.
println
(
"request.getPath().toString() = "
+
request
.
getPath
().
toString
());
if
(
pathMatcher
.
match
(
"/**/anonymous/**"
,
request
.
getPath
().
toString
()))
{
return
true
;
}
...
...
src/main/resources/logback-dev.xml
0 → 100644
查看文件 @
3ac9f23
<?xml version="1.0" encoding="UTF-8"?>
<!--参考文档链接:https://blog.csdn.net/qq_34912478/article/details/80877132-->
<!-- 日志级别从低到高分为TRACE < DEBUG < INFO < WARN < ERROR < FATAL,如果设置为WARN,则低于WARN的信息都不会输出 -->
<!-- scan:当此属性设置为true时,配置文件如果发生改变,将会被重新加载,默认值为true -->
<!-- scanPeriod:设置监测配置文件是否有修改的时间间隔,如果没有给出时间单位,默认单位是毫秒。当scan为true时,此属性生效。默认的时间间隔为1分钟。 -->
<!-- debug:当此属性设置为true时,将打印出logback内部日志信息,实时查看logback运行状态。默认值为false。 -->
<configuration
scan=
"true"
scanPeriod=
"10 seconds"
>
<!--<include resource="org/springframework/boot/logging/logback/base.xml" />-->
<contextName>
logback
</contextName>
<!-- name的值是变量的名称,value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义变量后,可以使“${}”来使用变量。 -->
<property
name=
"log.path"
value=
"./logs"
/>
<!-- 彩色日志 -->
<!-- 彩色日志依赖的渲染类 -->
<conversionRule
conversionWord=
"clr"
converterClass=
"org.springframework.boot.logging.logback.ColorConverter"
/>
<conversionRule
conversionWord=
"wex"
converterClass=
"org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter"
/>
<conversionRule
conversionWord=
"wEx"
converterClass=
"org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter"
/>
<!-- 彩色日志格式 -->
<property
name=
"CONSOLE_LOG_PATTERN"
value=
"${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"
/>
<!--输出到控制台-->
<appender
name=
"CONSOLE"
class=
"ch.qos.logback.core.ConsoleAppender"
>
<!--此日志appender是为开发使用,只配置最底级别,控制台输出的日志级别是大于或等于此级别的日志信息-->
<filter
class=
"ch.qos.logback.classic.filter.ThresholdFilter"
>
<level>
INFO
</level>
</filter>
<encoder>
<Pattern>
${CONSOLE_LOG_PATTERN}
</Pattern>
<!-- 设置字符集 -->
<charset>
UTF-8
</charset>
</encoder>
</appender>
<!--输出到文件-->
<!-- 时间滚动输出 level为 DEBUG 日志 -->
<appender
name=
"DEBUG_FILE"
class=
"ch.qos.logback.core.rolling.RollingFileAppender"
>
<!-- 正在记录的日志文件的路径及文件名 -->
<file>
${log.path}/log_debug.log
</file>
<!--日志文件输出格式-->
<encoder>
<pattern>
%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
<charset>
UTF-8
</charset>
<!-- 设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy
class=
"ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
>
<!-- 日志归档 -->
<fileNamePattern>
${log.path}/debug/log-debug-%d{yyyy-MM-dd}.%i.log
</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy
class=
"ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"
>
<maxFileSize>
100MB
</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>
15
</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录debug级别的 -->
<filter
class=
"ch.qos.logback.classic.filter.LevelFilter"
>
<level>
debug
</level>
<onMatch>
ACCEPT
</onMatch>
<onMismatch>
DENY
</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 INFO 日志 -->
<appender
name=
"INFO_FILE"
class=
"ch.qos.logback.core.rolling.RollingFileAppender"
>
<!-- 正在记录的日志文件的路径及文件名 -->
<file>
${log.path}/log_info.log
</file>
<!--日志文件输出格式-->
<encoder>
<pattern>
%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
<charset>
UTF-8
</charset>
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy
class=
"ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
>
<!-- 每天日志归档路径以及格式 -->
<fileNamePattern>
${log.path}/info/log-info-%d{yyyy-MM-dd}.%i.log
</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy
class=
"ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"
>
<maxFileSize>
100MB
</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>
15
</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录info级别的 -->
<filter
class=
"ch.qos.logback.classic.filter.LevelFilter"
>
<level>
info
</level>
<onMatch>
ACCEPT
</onMatch>
<onMismatch>
DENY
</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 WARN 日志 -->
<appender
name=
"WARN_FILE"
class=
"ch.qos.logback.core.rolling.RollingFileAppender"
>
<!-- 正在记录的日志文件的路径及文件名 -->
<file>
${log.path}/log_warn.log
</file>
<!--日志文件输出格式-->
<encoder>
<pattern>
%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
<charset>
UTF-8
</charset>
<!-- 此处设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy
class=
"ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
>
<fileNamePattern>
${log.path}/warn/log-warn-%d{yyyy-MM-dd}.%i.log
</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy
class=
"ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"
>
<maxFileSize>
100MB
</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>
15
</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录warn级别的 -->
<filter
class=
"ch.qos.logback.classic.filter.LevelFilter"
>
<level>
warn
</level>
<onMatch>
ACCEPT
</onMatch>
<onMismatch>
DENY
</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 ERROR 日志 -->
<appender
name=
"ERROR_FILE"
class=
"ch.qos.logback.core.rolling.RollingFileAppender"
>
<!-- 正在记录的日志文件的路径及文件名 -->
<file>
${log.path}/log_error.log
</file>
<!--日志文件输出格式-->
<encoder>
<pattern>
%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
<charset>
UTF-8
</charset>
<!-- 此处设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy
class=
"ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
>
<fileNamePattern>
${log.path}/error/log-error-%d{yyyy-MM-dd}.%i.log
</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy
class=
"ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"
>
<maxFileSize>
100MB
</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>
15
</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录ERROR级别的 -->
<filter
class=
"ch.qos.logback.classic.filter.LevelFilter"
>
<level>
ERROR
</level>
<onMatch>
ACCEPT
</onMatch>
<onMismatch>
DENY
</onMismatch>
</filter>
</appender>
<!--
<logger>用来设置某一个包或者具体的某一个类的日志打印级别、
以及指定<appender>。<logger>仅有一个name属性,
一个可选的level和一个可选的addtivity属性。
name:用来指定受此logger约束的某一个包或者具体的某一个类。
level:用来设置打印级别,大小写无关:TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF,
还有一个特俗值INHERITED或者同义词NULL,代表强制执行上级的级别。
如果未设置此属性,那么当前logger将会继承上级的级别。
addtivity:是否向上级logger传递打印信息。默认是true。
-->
<!--<logger name="org.springframework.web" level="info"/>-->
<!--<logger name="org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor" level="INFO"/>-->
<!--
使用mybatis的时候,sql语句是debug下才会打印,而这里我们只配置了info,所以想要查看sql语句的话,有以下两种操作:
第一种把<root level="info">改成<root level="DEBUG">这样就会打印sql,不过这样日志那边会出现很多其他消息
第二种就是单独给dao下目录配置debug模式,代码如下,这样配置sql语句会打印,其他还是正常info级别:
-->
<!--
root节点是必选节点,用来指定最基础的日志输出级别,只有一个level属性
level:用来设置打印级别,大小写无关:TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF,
不能设置为INHERITED或者同义词NULL。默认是DEBUG
可以包含零个或多个元素,标识这个appender将会添加到这个logger。
-->
<!--开发环境:打印控制台-->
<springProfile
name=
"dev"
>
<root
level=
"INFO"
>
<appender-ref
ref=
"CONSOLE"
/>
<appender-ref
ref=
"DEBUG_FILE"
/>
<appender-ref
ref=
"INFO_FILE"
/>
<appender-ref
ref=
"WARN_FILE"
/>
<appender-ref
ref=
"ERROR_FILE"
/>
</root>
</springProfile>
<!--生产环境:输出到文件-->
<springProfile
name=
"pro"
>
<root
level=
"info"
>
<appender-ref
ref=
"CONSOLE"
/>
<appender-ref
ref=
"DEBUG_FILE"
/>
<appender-ref
ref=
"INFO_FILE"
/>
<appender-ref
ref=
"ERROR_FILE"
/>
<appender-ref
ref=
"WARN_FILE"
/>
</root>
</springProfile>
</configuration>
\ No newline at end of file
...
...
请
注册
或
登录
后发表评论