项目初始化

datax-common/datax-common-core/pom.xml

@@ -79,6 +79,10 @@
             <groupId>com.fasterxml.jackson.datatype</groupId>
             <artifactId>jackson-datatype-jsr310</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-oauth2</artifactId>
+        </dependency>
     </dependencies>
 
 </project>
\ No newline at end of file

datax-common/datax-common-core/src/main/java/cn/datax/common/utils/SecurityUtil.java

 package cn.datax.common.utils;
 
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.oauth2.provider.OAuth2Authentication;
+
 public class SecurityUtil {
+
+    /**
+     * 获取客户端
+     *
+     * @return clientId
+     */
+    private String getClientId() {
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+        if (authentication instanceof OAuth2Authentication) {
+            OAuth2Authentication auth2Authentication = (OAuth2Authentication) authentication;
+            return auth2Authentication.getOAuth2Request().getClientId();
+        }
+        return null;
+    }
+
+    /**
+     * 获取用户名称
+     *
+     * @return username
+     */
+    private String getUsername() {
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+        if (authentication instanceof OAuth2Authentication) {
+            OAuth2Authentication auth2Authentication = (OAuth2Authentication) authentication;
+            return auth2Authentication.getName();
+        }
+        return null;
+    }
 }