成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

SpringBoot 整合 OAuth2 實現資源保護

開發 前端
我們在認證服務上是把Users對象序列化存儲到了Redis,所以這里還需要這個類,其實如果用了網關,這些認證就不需要在資源端進行了,核心配置類主要完整,開啟資源服務認證,定義我們需要保護的接口,token的存儲對象及錯誤信息的統一處理。

上一篇整合介紹了OAuth2的認證服務,接下來利用認證服務提供的token來包含我們的資源。

環境:2.4.12 + OAuth2 + Redis

  • pom.xml
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-pool2</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.security.oauth.boot</groupId>
  <artifactId>spring-security-oauth2-autoconfigure</artifactId>
  <version>2.2.11.RELEASE</version>
</dependency>
  • application.yml
server:
  port: 8088
---
spring:
  application:
    name: oauth-resource
---
spring:
  redis:
    host: localhost
    port: 6379
    password: 
    database: 1
    lettuce:
      pool:
        maxActive: 8
        maxIdle: 100
        minIdle: 10
        maxWait: -1
  • Domain對象(我們在認證服務上是把Users對象序列化存儲到了Redis,所以這里還需要這個類,其實如果用了網關,這些認證就不需要在資源端進行了)
public class Users implements UserDetails, Serializable {


  private static final long serialVersionUID = 1L;


  private String id ;
  private String username ;
  private String password ;
}
  • 核心配置類
@Configuration
@EnableResourceServer
public class OAuthConfig extends ResourceServerConfigurerAdapter {  


  private static final Logger logger = LoggerFactory.getLogger(OAuthConfig.class) ;
  
  public static final String RESOURCE_ID = "gx_resource_id";  
  
  @Resource
  private RedisConnectionFactory redisConnectionFactory ;
  
  @Override  
  public void configure(ResourceServerSecurityConfigurer resources) throws Exception {  
    resources.resourceId(RESOURCE_ID) ;
    OAuth2AuthenticationEntryPoint oAuth2AuthenticationEntryPoint = new OAuth2AuthenticationEntryPoint();  
    oAuth2AuthenticationEntryPoint.setExceptionTranslator(webResponseExceptionTranslator());
    resources.authenticationEntryPoint(oAuth2AuthenticationEntryPoint) ;
    resources.tokenExtractor((request) -> {
      String tokenValue = extractToken(request) ;
      if (tokenValue != null) {
        PreAuthenticatedAuthenticationToken authentication = new PreAuthenticatedAuthenticationToken(tokenValue, "");
        return authentication;
      }
      return null;
    }) ;
  }  
 private String extractToken(HttpServletRequest request) {
    // first check the header... Authorization: Bearer xxx
    String token = extractHeaderToken(request);
    // sencod check the header... access_token: xxx
    if (token == null) {
      token = request.getHeader("access_token") ;
    }
    // bearer type allows a request parameter as well
    if (token == null) {
      logger.debug("Token not found in headers. Trying request parameters.") ;
      token = request.getParameter(OAuth2AccessToken.ACCESS_TOKEN) ;
      if (token == null) {
        logger.debug("Token not found in request parameters.  Not an OAuth2 request.") ;
      } else {
        request.setAttribute(OAuth2AuthenticationDetails.ACCESS_TOKEN_TYPE, OAuth2AccessToken.BEARER_TYPE);
      }
    }
    return token;
  }
  private String extractHeaderToken(HttpServletRequest request) {
    Enumeration<String> headers = request.getHeaders("Authorization");
    while (headers.hasMoreElements()) { // typically there is only one (most servers enforce that)
      String value = headers.nextElement();
      if ((value.toLowerCase().startsWith(OAuth2AccessToken.BEARER_TYPE.toLowerCase()))) {
        String authHeaderValue = value.substring(OAuth2AccessToken.BEARER_TYPE.length()).trim();
        // Add this here for the auth details later. Would be better to change the signature of this method.
        request.setAttribute(OAuth2AuthenticationDetails.ACCESS_TOKEN_TYPE,
        value.substring(0, OAuth2AccessToken.BEARER_TYPE.length()).trim());
        int commaIndex = authHeaderValue.indexOf(',');
        if (commaIndex > 0) {
          authHeaderValue = authHeaderValue.substring(0, commaIndex);
        }
        return authHeaderValue;
      }
    }
    return null;
  }
    
  @Override  
  public void configure(HttpSecurity http) throws Exception {  
    http.csrf().disable() ;
    http.requestMatcher(request -> {
      String path = request.getServletPath() ;
      if (path != null && path.startsWith("/demo")) {
        return true ;
      }
      return false ;
    }).authorizeRequests().anyRequest().authenticated() ;
  }
    
  @Bean
  public TokenStore tokenStore() {
    TokenStore tokenStore = null ;
    tokenStore = new RedisTokenStore(redisConnectionFactory) ;
    return tokenStore ;
  }
    
  @Bean  
  public WebResponseExceptionTranslator<?> webResponseExceptionTranslator() {  
    return new DefaultWebResponseExceptionTranslator() {
      @SuppressWarnings({ "unchecked", "rawtypes" })
      @Override
      public ResponseEntity translate(Exception e) throws Exception {
        ResponseEntity<OAuth2Exception> responseEntity = super.translate(e) ;
        ResponseEntity<Map<String, Object>> customEntity = exceptionProcess(responseEntity);
        return customEntity ;
      }  
    };  
  }  
    
  private static ResponseEntity<Map<String, Object>> exceptionProcess(
    ResponseEntity<OAuth2Exception> responseEntity) {
    Map<String, Object> body = new HashMap<>() ;
    body.put("code", -1) ;
    OAuth2Exception excep = responseEntity.getBody() ;
    String errorMessage = excep.getMessage();
    if (errorMessage != null) {
      errorMessage = "認證失敗,非法用戶" ;
      body.put("message", errorMessage) ;
    } else {
      String error = excep.getOAuth2ErrorCode();
      if (error != null) {
        body.put("message", error) ;
      } else {
        body.put("message", "認證服務異常,未知錯誤") ;
      }
    }
    body.put("data", null) ;
    ResponseEntity<Map<String, Object>> customEntity = new ResponseEntity<>(body, 
    responseEntity.getHeaders(), responseEntity.getStatusCode()) ;
    return customEntity;
  }  
}

核心配置類主要完整,開啟資源服務認證,定義我們需要保護的接口,token的存儲對象及錯誤信息的統一處理。

  • 測試接口
@RestController
@RequestMapping("/demo")
public class DemoController {
  
  @GetMapping("/res")
  public Object res() {
    return "success" ;
  }
  
}

測試:

先直接訪問token或者傳一個錯誤的tokenj

圖片圖片

接下先獲取一個正確的token

圖片圖片

圖片圖片

責任編輯:武曉燕 來源: Spring全家桶實戰案例源碼
相關推薦

2023-08-29 08:00:38

2025-04-29 09:07:21

2022-04-11 07:34:46

OAuth2UAA節點

2013-05-02 14:13:44

Android開發OAuth2服務認證

2025-06-26 04:11:00

SpringSecurityOAuth2

2017-08-04 18:10:09

2025-05-06 00:58:00

ServerlessOAuth2Token

2021-08-02 12:50:45

sessiontokenJava

2021-11-15 13:58:00

服務器配置授權

2021-08-29 23:33:44

OAuth2服務器Keycloak

2025-01-13 08:04:24

2024-03-01 11:33:31

2024-12-06 07:00:00

2022-11-07 08:36:11

2025-04-25 08:35:00

OAuth2權限驗證開發

2025-04-01 05:00:00

OAuth2服務器身份驗證

2022-11-16 14:02:44

2014-09-24 11:47:41

微信企業號開發

2014-04-21 14:56:45

NodeJSOAuth2服務器

2020-11-12 09:55:02

OAuth2
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 欧美亚洲视频 | 黄色片在线免费看 | 黄色三级免费 | 精品产国自在拍 | 91国在线高清视频 | 中文字幕视频在线观看免费 | 午夜电影网 | 久久亚洲二区 | 国产精品色婷婷久久58 | 国产免费黄网 | 国产99久久精品 | 欧美在线 | 国产精品亚洲第一区在线暖暖韩国 | 欧美一级免费看 | 在线观看av网站 | 亚洲视频一区 | 国产精品中文在线 | 久久综合久久久 | 草久久 | 久在线| 国产精品夜夜春夜夜爽久久电影 | 狠狠干美女 | 91资源在线观看 | 日韩欧美国产一区二区 | 久久婷婷色 | 97成人在线| a级黄色片在线观看 | 色综合久 | 色姑娘综合网 | 人人做人人澡人人爽欧美 | 日韩三| 亚洲国产成人精品女人久久久 | 国产一二三区在线 | 99免费精品视频 | 亚洲天堂精品久久 | 毛片在线看看 | 久久国产精品久久久久久 | 国产成年人小视频 | 免费国产一区 | 免费一二区 | 91麻豆精品国产91久久久久久久久 |