快捷導(dǎo)航

SpringBoot運(yùn)用Redis統(tǒng)計(jì)用戶(hù)在線數(shù)量的兩種方法實(shí)現(xiàn)

更新時(shí)間：2025年06月25日 09:36:19 作者：weixin_43833540

本文主要介紹了SpringBoot運(yùn)用Redis統(tǒng)計(jì)用戶(hù)在線數(shù)量的兩種方法實(shí)現(xiàn),包括通過(guò)RedisSet精確記錄用戶(hù)狀態(tài),或用RedisBitmap按位存儲(chǔ)優(yōu)化內(nèi)存,Set適合小規(guī)模場(chǎng)景,Bitmap適用于大規(guī)模連續(xù)ID,可根據(jù)需求選擇實(shí)現(xiàn)方式

項(xiàng)目依賴(lài)與配置

1. 引入依賴(lài)

首先，在pom.xml文件中添加Spring Data Redis依賴(lài)：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2. 配置Redis連接

在application.properties中進(jìn)行Redis連接的配置：

spring.redis.host=localhost
spring.redis.port=6379

方案1：借助Redis Set實(shí)現(xiàn)精確統(tǒng)計(jì)

1. 創(chuàng)建Redis操作Service

編寫(xiě)一個(gè)Redis操作Service，用于處理用戶(hù)在線狀態(tài)：

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.Set;

@Service
public class OnlineUserService {

    private static final String ONLINE_USERS_KEY = "online_users";

    private final RedisTemplate<String, String> redisTemplate;

    public OnlineUserService(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    // 用戶(hù)登錄
    public void login(String userId) {
        redisTemplate.opsForSet().add(ONLINE_USERS_KEY, userId);
    }

    // 用戶(hù)退出
    public void logout(String userId) {
        redisTemplate.opsForSet().remove(ONLINE_USERS_KEY, userId);
    }

    // 獲取在線用戶(hù)數(shù)
    public Long getOnlineCount() {
        return redisTemplate.opsForSet().size(ONLINE_USERS_KEY);
    }

    // 獲取所有在線用戶(hù)ID
    public Set<String> getOnlineUsers() {
        return redisTemplate.opsForSet().members(ONLINE_USERS_KEY);
    }
}

2. 控制器示例

創(chuàng)建一個(gè)控制器，用于測(cè)試上述功能：

import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/online")
public class OnlineUserController {

    private final OnlineUserService onlineUserService;

    public OnlineUserController(OnlineUserService onlineUserService) {
        this.onlineUserService = onlineUserService;
    }

    @PostMapping("/login/{userId}")
    public String login(@PathVariable String userId) {
        onlineUserService.login(userId);
        return userId + " 已登錄";
    }

    @PostMapping("/logout/{userId}")
    public String logout(@PathVariable String userId) {
        onlineUserService.logout(userId);
        return userId + " 已退出";
    }

    @GetMapping("/count")
    public Long getCount() {
        return onlineUserService.getOnlineCount();
    }

    @GetMapping("/users")
    public Set<String> getUsers() {
        return onlineUserService.getOnlineUsers();
    }
}

方案2：使用Redis Bitmap實(shí)現(xiàn)按位存儲(chǔ)

1. Bitmap操作Service

創(chuàng)建一個(gè)專(zhuān)門(mén)用于Bitmap操作的Service：

import org.springframework.data.redis.connection.RedisStringCommands;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class OnlineUserBitmapService {

    private static final String ONLINE_USERS_BITMAP_KEY = "online_users_bitmap";

    private final RedisTemplate<String, Object> redisTemplate;

    public OnlineUserBitmapService(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    // 用戶(hù)登錄（userId需為L(zhǎng)ong類(lèi)型）
    public void login(Long userId) {
        redisTemplate.execute((RedisCallback<Boolean>) connection ->
                connection.setBit(ONLINE_USERS_BITMAP_KEY.getBytes(), userId, true));
    }

    // 用戶(hù)退出
    public void logout(Long userId) {
        redisTemplate.execute((RedisCallback<Boolean>) connection ->
                connection.setBit(ONLINE_USERS_BITMAP_KEY.getBytes(), userId, false));
    }

    // 檢查用戶(hù)是否在線
    public Boolean isOnline(Long userId) {
        return redisTemplate.execute((RedisCallback<Boolean>) connection ->
                connection.getBit(ONLINE_USERS_BITMAP_KEY.getBytes(), userId));
    }

    // 獲取在線用戶(hù)數(shù)
    public Long getOnlineCount() {
        return redisTemplate.execute((RedisCallback<Long>) connection ->
                connection.bitCount(ONLINE_USERS_BITMAP_KEY.getBytes()));
    }

    // 統(tǒng)計(jì)指定范圍內(nèi)的在線用戶(hù)數(shù)
    public Long getOnlineCount(long start, long end) {
        return redisTemplate.execute((RedisCallback<Long>) connection ->
                connection.bitCount(ONLINE_USERS_BITMAP_KEY.getBytes(), start, end));
    }
}

2. 控制器示例

創(chuàng)建對(duì)應(yīng)的控制器：

import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/online/bitmap")
public class OnlineUserBitmapController {

    private final OnlineUserBitmapService onlineUserBitmapService;

    public OnlineUserBitmapController(OnlineUserBitmapService onlineUserBitmapService) {
        this.onlineUserBitmapService = onlineUserBitmapService;
    }

    @PostMapping("/login/{userId}")
    public String login(@PathVariable Long userId) {
        onlineUserBitmapService.login(userId);
        return userId + " 已登錄";
    }

    @PostMapping("/logout/{userId}")
    public String logout(@PathVariable Long userId) {
        onlineUserBitmapService.logout(userId);
        return userId + " 已退出";
    }

    @GetMapping("/count")
    public Long getCount() {
        return onlineUserBitmapService.getOnlineCount();
    }

    @GetMapping("/{userId}")
    public Boolean isOnline(@PathVariable Long userId) {
        return onlineUserBitmapService.isOnline(userId);
    }
}

使用建議

1. Set方案的適用場(chǎng)景

當(dāng)需要精確統(tǒng)計(jì)在線用戶(hù)數(shù)量，并且能夠獲取在線用戶(hù)列表時(shí)，可以使用Set方案。
適合用戶(hù)規(guī)模在百萬(wàn)級(jí)別以下的情況，因?yàn)镾et會(huì)存儲(chǔ)每個(gè)用戶(hù)的ID。

2. Bitmap方案的適用場(chǎng)景

若用戶(hù)ID是連續(xù)的整數(shù)（或者可以映射為連續(xù)整數(shù)），Bitmap方案會(huì)更節(jié)省內(nèi)存。
對(duì)于大規(guī)模用戶(hù)（比如億級(jí)）的在線統(tǒng)計(jì)，Bitmap方案具有明顯優(yōu)勢(shì)。
示例中使用Long類(lèi)型的userId，在實(shí)際應(yīng)用中，你可能需要一個(gè)ID映射器，將業(yè)務(wù)ID轉(zhuǎn)換為連續(xù)的整數(shù)。

到此這篇關(guān)于SpringBoot運(yùn)用Redis統(tǒng)計(jì)用戶(hù)在線數(shù)量的兩種方法實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Spring Boot Redis統(tǒng)計(jì)用戶(hù)在線內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: