真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

SpringBoot并發(fā)登錄人數(shù)控制的實(shí)現(xiàn)方法

通常系統(tǒng)都會(huì)限制同一個(gè)賬號的登錄人數(shù),多人登錄要么限制后者登錄,要么踢出前者,Spring Security 提供了這樣的功能,本文講解一下在沒有使用Security的時(shí)候如何手動(dòng)實(shí)現(xiàn)這個(gè)功能

成都創(chuàng)新互聯(lián)公司-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比鄒城網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式鄒城網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們,業(yè)務(wù)覆蓋鄒城地區(qū)。費(fèi)用合理售后完善,十年實(shí)體公司更值得信賴。

demo 技術(shù)選型

  • SpringBoot
  • JWT
  • Filter
  • redis + Redisson

JWT(token)存儲在Redis中,類似 JSessionId-Session的關(guān)系,用戶登錄后每次請求在Header中攜帶jwt
如果你是使用session的話,也完全可以借鑒本文的思路,只是代碼上需要加些改動(dòng)

兩種實(shí)現(xiàn)思路

比較時(shí)間戳

維護(hù)一個(gè) username: jwtToken 這樣的一個(gè) key-value 在Reids中, Filter邏輯如下

SpringBoot 并發(fā)登錄人數(shù)控制的實(shí)現(xiàn)方法

public class CompareKickOutFilter extends KickOutFilter {

  @Autowired
  private UserService userService;

  @Override
  public boolean isAccessAllowed(HttpServletRequest request, HttpServletResponse response) {
    String token = request.getHeader("Authorization");
    String username = JWTUtil.getUsername(token);
    String userKey = PREFIX + username;

    RBucket bucket = redissonClient.getBucket(userKey);
    String redisToken = bucket.get();

    if (token.equals(redisToken)) {
      return true;

    } else if (StringUtils.isBlank(redisToken)) {
      bucket.set(token);

    } else {
      Long redisTokenUnixTime = JWTUtil.getClaim(redisToken, "createTime").asLong();
      Long tokenUnixTime = JWTUtil.getClaim(token, "createTime").asLong();

      // token > redisToken 則覆蓋
      if (tokenUnixTime.compareTo(redisTokenUnixTime) > 0) {
        bucket.set(token);

      } else {
        // 注銷當(dāng)前token
        userService.logout(token);
        sendJsonResponse(response, 4001, "您的賬號已在其他設(shè)備登錄");
        return false;

      }

    }

    return true;

  }
}

隊(duì)列踢出

SpringBoot 并發(fā)登錄人數(shù)控制的實(shí)現(xiàn)方法

public class QueueKickOutFilter extends KickOutFilter {
  /**
   * 踢出之前登錄的/之后登錄的用戶 默認(rèn)踢出之前登錄的用戶
   */
  private boolean kickoutAfter = false;
  /**
   * 同一個(gè)帳號最大會(huì)話數(shù) 默認(rèn)1
   */
  private int maxSession = 1;

  public void setKickoutAfter(boolean kickoutAfter) {
    this.kickoutAfter = kickoutAfter;
  }

  public void setMaxSession(int maxSession) {
    this.maxSession = maxSession;
  }

  @Override
  public boolean isAccessAllowed(HttpServletRequest request, HttpServletResponse response) throws Exception {
    String token = request.getHeader("Authorization");
    UserBO currentSession = CurrentUser.get();
    Assert.notNull(currentSession, "currentSession cannot null");
    String username = currentSession.getUsername();
    String userKey = PREFIX + "deque_" + username;
    String lockKey = PREFIX_LOCK + username;

    RLock lock = redissonClient.getLock(lockKey);

    lock.lock(2, TimeUnit.SECONDS);

    try {
      RDeque deque = redissonClient.getDeque(userKey);

      // 如果隊(duì)列里沒有此token,且用戶沒有被踢出;放入隊(duì)列
      if (!deque.contains(token) && currentSession.isKickout() == false) {
        deque.push(token);
      }

      // 如果隊(duì)列里的sessionId數(shù)超出最大會(huì)話數(shù),開始踢人
      while (deque.size() > maxSession) {
        String kickoutSessionId;
        if (kickoutAfter) { // 如果踢出后者
          kickoutSessionId = deque.removeFirst();
        } else { // 否則踢出前者
          kickoutSessionId = deque.removeLast();
        }

        try {
          RBucket bucket = redissonClient.getBucket(kickoutSessionId);
          UserBO kickoutSession = bucket.get();

          if (kickoutSession != null) {
            // 設(shè)置會(huì)話的kickout屬性表示踢出了
            kickoutSession.setKickout(true);
            bucket.set(kickoutSession);
          }

        } catch (Exception e) {
        }

      }

      // 如果被踢出了,直接退出,重定向到踢出后的地址
      if (currentSession.isKickout()) {
        // 會(huì)話被踢出了
        try {
          // 注銷
          userService.logout(token);
          sendJsonResponse(response, 4001, "您的賬號已在其他設(shè)備登錄");

        } catch (Exception e) {
        }

        return false;

      }

    } finally {
      if (lock.isHeldByCurrentThread()) {
        lock.unlock();
        LOGGER.info(Thread.currentThread().getName() + " unlock");

      } else {
        LOGGER.info(Thread.currentThread().getName() + " already automatically release lock");
      }
    }

    return true;
  }

}

比較兩種方法

  • 第一種方法邏輯簡單粗暴, 只維護(hù)一個(gè)key-value 不需要使用鎖,非要說缺點(diǎn)的話沒有第二種方法靈活。
  • 第二種方法我很喜歡,代碼很優(yōu)雅靈活,但是邏輯相對麻煩一些,而且為了保證線程安全地操作隊(duì)列,要使用分布式鎖。目前我們項(xiàng)目中使用的是第一種方法

演示

下載地址: https://gitee.com/yintianwen7/taven-springboot-learning/tree/master/login-control

  1. 運(yùn)行項(xiàng)目,訪問localhost:8887 demo中沒有存儲用戶信息,隨意輸入用戶名密碼,用戶名相同則被踢出
  2. 訪問 localhost:8887/index.html 彈出用戶信息, 代表當(dāng)前用戶有效
  3. 另一個(gè)瀏覽器登錄相同用戶名,回到第一個(gè)瀏覽器刷新頁面,提示被踢出
  4. application.properties中選擇開啟哪種過濾器模式,默認(rèn)是比較時(shí)間戳踢出,開啟隊(duì)列踢出 queue-filter.enabled=true

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。


網(wǎng)頁標(biāo)題:SpringBoot并發(fā)登錄人數(shù)控制的實(shí)現(xiàn)方法
當(dāng)前鏈接:http://weahome.cn/article/igjdgg.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部