feat: nacos网关微服务搭建/注册登录缓存用户角色权限信息

schisandra-cloud-storage-gateway/pom.xml

@@ -1,11 +1,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
-  <groupId>com.schisandra</groupId>
+  <groupId>com.schisandra.gateway</groupId>
   <artifactId>schisandra-cloud-storage-gateway</artifactId>
   <version>1.0-SNAPSHOT</version>
-  <packaging>pom</packaging>
+  <packaging>jar</packaging>
+
   <name>schisandra-cloud-storage-gateway</name>
 
   <properties>
@@ -25,16 +26,16 @@
     <dependency>
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>
-      <version>1.18.20</version>
-    </dependency>
-    <dependency>
-      <groupId>com.alibaba.cloud</groupId>
-      <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+      <version>1.18.24</version>
     </dependency>
     <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bootstrap</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.alibaba.cloud</groupId>
+      <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.alibaba.cloud</groupId>
       <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
@@ -69,6 +70,11 @@
       <artifactId>gson</artifactId>
       <version>2.8.9</version>
     </dependency>
+    <dependency>
+      <groupId>com.github.ben-manes.caffeine</groupId>
+      <artifactId>caffeine</artifactId>
+      <version>2.9.3</version>
+    </dependency>
   </dependencies>
 
   <dependencyManagement>

schisandra-cloud-storage-gateway/src/main/java/com/schisandra/gateway/auth/StpInterfaceImpl.java

@@ -26,32 +26,32 @@ public class StpInterfaceImpl implements StpInterface {
     @Resource
     private RedisUtil redisUtil;
 
-    private String authPermissionPrefix = "auth.permission";
+    private final String AUTH_PERMISSION_PREFIX = "auth.permission";
 
-    private String authRolePrefix = "auth.role";
+    private final String AUTH_ROLE_PREFIX = "auth.role";
 
     @Override
-    public List<String> getPermissionList(Object loginId, String loginType) {
-        return getAuth(loginId.toString(), authPermissionPrefix);
+    public List<String> getPermissionList(Object userId, String loginType) {
+        return getAuth(userId.toString(), AUTH_PERMISSION_PREFIX);
     }
 
     @Override
-    public List<String> getRoleList(Object loginId, String loginType) {
-        return getAuth(loginId.toString(), authRolePrefix);
+    public List<String> getRoleList(Object userId, String loginType) {
+        return getAuth(userId.toString(), AUTH_ROLE_PREFIX);
     }
 
-    private List<String> getAuth(String loginId, String prefix) {
-        String authKey = redisUtil.buildKey(prefix, loginId.toString());
+    private List<String> getAuth(String userId, String prefix) {
+        String authKey = redisUtil.buildKey(prefix, userId);
         String authValue = redisUtil.get(authKey);
         if (StringUtils.isBlank(authValue)) {
             return Collections.emptyList();
         }
         List<String> authList = new LinkedList<>();
-        if (authRolePrefix.equals(prefix)) {
+        if (AUTH_ROLE_PREFIX.equals(prefix)) {
             List<AuthRole> roleList = new Gson().fromJson(authValue, new TypeToken<List<AuthRole>>() {
             }.getType());
             authList = roleList.stream().map(AuthRole::getRoleKey).collect(Collectors.toList());
-        } else if (authPermissionPrefix.equals(prefix)) {
+        } else if (AUTH_PERMISSION_PREFIX.equals(prefix)) {
             List<AuthPermission> permissionList = new Gson().fromJson(authValue, new TypeToken<List<AuthPermission>>() {
             }.getType());
             authList = permissionList.stream().map(AuthPermission::getPermissionKey).collect(Collectors.toList());

schisandra-cloud-storage-gateway/src/main/java/com/schisandra/gateway/filter/LoginFilter.java

@@ -31,16 +31,16 @@ public class LoginFilter implements GlobalFilter {
         ServerHttpRequest.Builder mutate = request.mutate();
         String url = request.getURI().getPath();
         log.info("LoginFilter.filter.url:{}", url);
-        if (url.equals("/user/doLogin") || url.equals("/user/getUserInfo")) {
-           return chain.filter(exchange);
+        if (url.equals("/auth/render/") || url.equals("/auth/callback/") || url.equals("/auth/user/register") || url.equals("/auth/user/login") || url.equals("/system/getConfigByKey")) {
+            return chain.filter(exchange);
         }
         SaTokenInfo tokenInfo = StpUtil.getTokenInfo();
-        String loginId = (String) tokenInfo.getLoginId();
-        if (StringUtils.isEmpty(loginId)) {
+        String userId = (String) tokenInfo.getLoginId();
+        if (StringUtils.isEmpty(userId)) {
             throw new Exception("未获取到用户信息");
         }
 
-        mutate.header("loginId", loginId);
+        mutate.header("userId", userId);
 
         return chain.filter(exchange.mutate().request(mutate.build()).build());
     }

schisandra-cloud-storage-gateway/src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 6000
+  port: 5050
 spring:
   cloud:
     gateway:
@@ -59,5 +59,6 @@ sa-token:
   # token 风格（默认可取值：uuid、simple-uuid、random-32、random-64、random-128、tik）
   token-style: random-32
   # 是否输出操作日志
-  is-log: true
-  token-prefix: schisandra
+  is-log: false
+  token-prefix: schisandra
+  is-print: false

schisandra-cloud-storage-gateway/src/main/resources/banner.txt

@@ -0,0 +1,18 @@
+
+
+                        ,---,
+                      ,--.' |      ,--,                                             ,---,
+                      |  |  :    ,--.'|                                 ,---,     ,---.'|  __  ,-.
+  .--.--.             :  :  :    |  |,      .--.--.                 ,-+-. /  |    |   | :,' ,'/ /|
+ /  /    '     ,---.  :  |  |,--.`--'_     /  /    '    ,--.--.    ,--.'|'   |    |   | |'  | |' | ,--.--.
+|  :  /`./    /     \ |  :  '   |,' ,'|   |  :  /`./   /       \  |   |  ,"' |  ,--.__| ||  |   ,'/       \
+|  :  ;_     /    / ' |  |   /' :'  | |   |  :  ;_    .--.  .-. | |   | /  | | /   ,'   |'  :  / .--.  .-. |
+ \  \    `. .    ' /  '  :  | | ||  | :    \  \    `.  \__\/: . . |   | |  | |.   '  /  ||  | '   \__\/: . .
+  `----.   \'   ; :__ |  |  ' | :'  : |__   `----.   \ ," .--.; | |   | |  |/ '   ; |:  |;  : |   ," .--.; |
+ /  /`--'  /'   | '.'||  :  :_:,'|  | '.'| /  /`--'  //  /  ,.  | |   | |--'  |   | '/  '|  , ;  /  /  ,.  |
+'--'.     / |   :    :|  | ,'    ;  :    ;'--'.     /;  :   .'   \|   |/      |   :    :| ---'  ;  :   .'   \
+  `--'---'   \   \  / `--''      |  ,   /   `--'---' |  ,     .-./'---'        \   \  /         |  ,     .-./
+              `----'              ---`-'              `--`---'                  `----'           `--`---'
+
+Spring Boot: ${spring-boot.formatted-version}
+五味子云存储

schisandra-cloud-storage-gateway/src/main/resources/bootstrap.yml

@@ -6,12 +6,13 @@ spring:
   cloud:
     nacos:
       config:
-        server-addr: 116.196.80.239:8848
+        server-addr: 1.95.0.111:8848
         prefix: ${spring.application.name}
         group: DEFAULT_GROUP
         namespace:
         file-extension: yaml
+        timeout: 60000
       discovery:
         enabled: true
-        server-addr: 116.196.80.239:8848
+        server-addr: 1.95.0.111:8848
 

schisandra-cloud-storage-gateway/src/main/resources/log4j2-spring.xml

@@ -0,0 +1,87 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--Configuration后面的status，这个用于设置log4j2自身内部的信息输出，可以不设置，当设置成trace时，你会看到log4j2内部各种详细输出-->
+<!--monitorInterval：Log4j能够自动检测修改配置 文件和重新配置本身，设置间隔秒数-->
+<configuration status="INFO" monitorInterval="5">
+    <!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
+    <!--变量配置-->
+    <Properties>
+        <!-- 格式化输出：%date表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度 %msg：日志消息，%n是换行符-->
+        <!-- %logger{36} 表示 Logger 名字最长36个字符 -->
+        <property name="LOG_PATTERN" value="%clr{%d{yyyy-MM-dd HH:mm:ss.SSS}}{faint} %clr{%5p} %clr{${sys:PID}}{magenta} %clr{---}{faint} %clr{[%thread]}{faint} %clr{%-40.40c{1.}}{cyan} %clr{:}{faint} %m%n%xwEx" />
+        <!-- 定义日志存储的路径 -->
+        <property name="FILE_PATH" value="../log" />
+        <property name="FILE_NAME" value="schisandra-cloud-storage-gateway.log" />
+    </Properties>
+
+    <!--https://logging.apache.org/log4j/2.x/manual/appenders.html-->
+    <appenders>
+
+        <console name="Console" target="SYSTEM_OUT">
+            <!--输出日志的格式-->
+            <PatternLayout pattern="${LOG_PATTERN}"/>
+            <!--控制台只输出level及其以上级别的信息（onMatch），其他的直接拒绝（onMismatch）-->
+            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
+        </console>
+
+        <!--文件会打印出所有信息，这个log每次运行程序会自动清空，由append属性决定，适合临时测试用-->
+        <File name="fileLog" fileName="${FILE_PATH}/temp.log" append="false">
+            <PatternLayout pattern="${LOG_PATTERN}"/>
+        </File>
+
+        <!-- 这个会打印出所有的info及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档-->
+        <RollingFile name="RollingFileInfo" fileName="${FILE_PATH}/info.log" filePattern="${FILE_PATH}/${FILE_NAME}-INFO-%d{yyyy-MM-dd}_%i.log.gz">
+            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch）-->
+            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
+            <PatternLayout pattern="${LOG_PATTERN}"/>
+            <Policies>
+                <!--interval属性用来指定多久滚动一次，默认是1 hour-->
+                <TimeBasedTriggeringPolicy interval="1"/>
+                <SizeBasedTriggeringPolicy size="10MB"/>
+            </Policies>
+            <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件开始覆盖-->
+            <DefaultRolloverStrategy max="15"/>
+        </RollingFile>
+
+        <!-- 这个会打印出所有的warn及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档-->
+        <RollingFile name="RollingFileWarn" fileName="${FILE_PATH}/warn.log" filePattern="${FILE_PATH}/${FILE_NAME}-WARN-%d{yyyy-MM-dd}_%i.log.gz">
+            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch）-->
+            <ThresholdFilter level="warn" onMatch="ACCEPT" onMismatch="DENY"/>
+            <PatternLayout pattern="${LOG_PATTERN}"/>
+            <Policies>
+                <!--interval属性用来指定多久滚动一次，默认是1 hour-->
+                <TimeBasedTriggeringPolicy interval="1"/>
+                <SizeBasedTriggeringPolicy size="10MB"/>
+            </Policies>
+            <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件开始覆盖-->
+            <DefaultRolloverStrategy max="15"/>
+        </RollingFile>
+
+        <!-- 这个会打印出所有的error及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档-->
+        <RollingFile name="RollingFileError" fileName="${FILE_PATH}/error.log" filePattern="${FILE_PATH}/${FILE_NAME}-ERROR-%d{yyyy-MM-dd}_%i.log.gz">
+            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch）-->
+            <ThresholdFilter level="error" onMatch="ACCEPT" onMismatch="DENY"/>
+            <PatternLayout pattern="${LOG_PATTERN}"/>
+            <Policies>
+                <!--interval属性用来指定多久滚动一次，默认是1 hour-->
+                <TimeBasedTriggeringPolicy interval="1"/>
+                <SizeBasedTriggeringPolicy size="10MB"/>
+            </Policies>
+            <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件开始覆盖-->
+            <DefaultRolloverStrategy max="15"/>
+        </RollingFile>
+
+    </appenders>
+
+    <!--Logger节点用来单独指定日志的形式，比如要为指定包下的class指定不同的日志级别等。-->
+    <!--然后定义loggers，只有定义了logger并引入的appender，appender才会生效-->
+    <loggers>
+        <root level="info">
+            <appender-ref ref="Console"/>
+            <appender-ref ref="RollingFileInfo"/>
+            <appender-ref ref="RollingFileWarn"/>
+            <appender-ref ref="RollingFileError"/>
+            <appender-ref ref="fileLog"/>
+        </root>
+    </loggers>
+
+</configuration>