Name		Name	Last commit message	Last commit date
parent directory ..
gradle/wrapper		gradle/wrapper
src		src
.gitignore		.gitignore
HELP.md		HELP.md
README.md		README.md
build.gradle		build.gradle
gradlew		gradlew
gradlew.bat		gradlew.bat
settings.gradle		settings.gradle

README.md

배치서버

역할

일정 시간마다 채팅 차단된 사용자의 전체 메시지 가림 처리

기술스택

Java 17
Springboot 3.0.2
Spring Batch
Spring Scheduler
Spring Data JPA
Redis
Mongo DB
Mysql8

아키텍처

제공 기능

기능	설명
매시지 가림 처리	채팅 차단된 사용자의 전체 메시지 가림 처리

구현

@RequiredArgsConstructor
  private class MyTasklet implements Tasklet {

    private final ChatRepository chatRepository;
    private final UserRepository userRepository;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
      List<User> blockedUsers = userRepository.findAllByIsDone(false);
      blockedUsers.forEach(blockedUser -> {
        List<Message> messages = chatRepository.findAllByTopicIdAndSender(
          blockedUser.getTopicId(), blockedUser.getName());
        messages.forEach(message -> {
          message.hide();
          chatRepository.save(message);
        });
        blockedUser.done();
        userRepository.save(blockedUser);
      });

      return RepeatStatus.FINISHED;
    }
  }

  @Scheduled(cron = "0 */5 * * * *")
  public void runJob() {
    HashMap<String, JobParameter<?>> confMap = new HashMap<>();
    confMap.put("time", new JobParameter(System.currentTimeMillis(), long.class));
    JobParameters jobParameters = new JobParameters(confMap);

    try {
      jobLauncher.run(job, jobParameters);
    } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException |
             JobParametersInvalidException | JobRestartException e) {
      log.error(e.getMessage());
    }
  }