[실습] 하루 동안 서비스에 방문한 사용자 수(DAU) 카운팅하기 - 2

JSCODE 박재성

2026-01-12

✅ 구현 방법

• 하루동안 서비스에 방문한 사용자 수를 카운팅하려면, 하루에 어떤 사용자가 방문했는 지 데이터로 저장해두어야 한다. 이 때, 한 명의 사용자가 여러 번 방문하더라도 한 번으로 카운팅해야 하기 때문에 중복없이 저장해야 한다. 또한 순서와는 상관없이 데이터를 저장해도 된다. 이에 가장 적절한 Redis의 자료구조는 Set이다.

• 하루 단위로 방문한 사용자 수를 기록해야 하므로, 하루 단위로 구분할 수 있게 key에는 날짜값을 포함시킨다.

• 방문한 사용자를 기록하기 위해 value에는 사용자 id를 저장한다.

• 하루동안 서비스에 방문한 사용자 수를 카운팅할 때는 Set에 저장된 데이터 개수를 세알리면 된다.

✅ 실습

1. 코드 작성하기
DailyActiveUserService

@Service
@RequiredArgsConstructor
public class DailyActiveUserService {

  private final DailyActiveUserRepository dailyActiveUserRepository;
  private final RedisTemplate<String, String> redisTemplate;
  
  ...

  public void recordActiveUserWithRedis(Long userId) {
    LocalDate today = LocalDate.now();
    String key = "dau:" + today.toString(); // dau:YYYY-MM-DD
    // Redis에 userId를 Set 자료구조로 저장
    // Redis 명령어의 'SADD [key] [value]'와 동일하다.
    redisTemplate.opsForSet().add(key, userId.toString());
  }

  public long getDauWithRedis(LocalDate date) {
    String key = "dau:" + date.toString();
    // Redis에 저장된 Set을 활용하여 DAU를 계산
    // Redis 명령어의 'SCARD [key]'와 동일하다.
    return redisTemplate.opsForSet().size(key);
  }
}

 
DailyActiveUserController

@RestController
@RequestMapping("/dau")
@RequiredArgsConstructor
public class DailyActiveUserController {

  private final DailyActiveUserService dailyActiveUserService;

  ...

  // 활동 유저 기록 API
  @PostMapping("/record/redis")
  public void recordActiveUserWithRedis(
      @RequestBody RecordActiveUserRequestDto recordActiveUserRequestDto
  ) {
    dailyActiveUserService.recordActiveUserWithRedis(recordActiveUserRequestDto.getUserId());
  }

  // DAU 조회 API
  @GetMapping("/count/redis")
  public long getDauWithRedis(
      @RequestParam
      @DateTimeFormat(iso = DateTimeFormat.ISO.DATE)
      LocalDate date
  ) {
    return dailyActiveUserService.getDauWithRedis(date);
  }
}

 

2. Spring Boot 서버 실행시키기



 

3. Postman으로 잘 작동하는 지 확인하기
1. 활동 유저 기록 API



→ 데이터를 2개 넣어주자.
 
2. DAU 조회 API



 

4. 부하 테스트 스크립트 살펴보기
scripts/script_4-2.js

import http from 'k6/http';
import {check} from 'k6';

export const options = {
  vus: 1000,
  duration: '10s',
};

export default function () {
  // 1. 유저 활동 기록
  const userId = Math.floor(Math.random() * 100000) + 1; // 1 ~ 100000 사이의 랜덤 userId
  const payload = JSON.stringify({
    userId: userId,
  });

  const params = {
    headers: {
      'Content-Type': 'application/json',
    },
  };

  const recordRes = http.post('http://localhost:8080/dau/record/redis', payload, params);

  check(recordRes, {
    'record status is 200': (r) => r.status === 200,
  });

  // 2. DAU 조회
  // 오늘 날짜를 YYYY-MM-DD 형식으로 가져온다.
  const today = new Date().toISOString().split('T')[0];
  const countRes = http.get(`http://localhost:8080/dau/count/redis?date=${today}`);

  check(countRes, {
    'count status is 200': (r) => r.status === 200,
  });
}

이전 부하 테스트 스크립트와 비교했을 때 API 주소만 바뀌었다.
 

4. 부하 테스트 진행하기

$ k6 run scripts/script_4-2.js



부하테스트를 해보니 평균 TPS가 33699으로 성능이 눈에 띄게 향상된 걸 확인할 수 있다.
 

6. Set에 저장된 데이터가 차지하는 메모리량 체크하기

$ keys * # 데이터가 저장된 key 확인하기

$ SCARD dau:2026-01-08 # 해당 Set에 저장된 데이터 개수 확인하기

# MEMORY USAGE [key]
$ MEMORY USAGE dau:2026-01-08 # 특정 key가 차지하고 있는 메모리 확인



부하 테스트를 통해 저장된 데이터의 총 개수는 81548개이고, 해당 key 하나가 차지하는 메모리는 3567613 Byte인 걸 알 수 있다. 다음 강의 때 이 값들을 비교할 예정이기 때문에 이 값을 어딘가에 잘 적어두자.