[실습] Point Microservice 만들기 - 2

JSCODE 박재성

2025-12-06

✅ Spring Boot 프로젝트 셋팅 & DB 연결

1. Spring Boot 프로젝트 셋팅
start.spring.io
https://start.spring.io/



• Artifact와 Name을 point-service라고 지어주자.
• Package name을 Java 컨벤션에 맞게 pointservice라고 지어주자.
• Java 21 버전을 선택하자. 아래 과정을 Java 21 버전을 기준으로 진행할 예정이다.
• Dependencies는 Spring Boot DevTools, Spring Web, MySQL Driver, Spring Data JPA를 선택하자.
 

2. application.yml 작성하기

이 프로젝트에서는 application.properties를 지우고 application.yml을 생성했다.

server:
  port: 8082

spring:
  datasource:
    url: jdbc:mysql://localhost:3308/point-db # DB 주소
    username: root # DB 계정
    password: password # DB 비밀번호
    driver-class-name: com.mysql.cj.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

 

3. Spring Boot 서버 실행시켜서 DB 연결 제대로 되는 지 확인하기
Spring Boot 실행시켰을 때 아래와 같은 에러 안 뜨고 서버가 실행되면, 정상적으로 DB가 잘 연결된 것이다.

✅ 포인트 적립 API 만들기

1. Point 엔티티 생성하기
domain/Point

@Entity
@Table(name = "points")
public class Point {

  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long pointId;

  private Long userId;

  private int amount;

  public Point() {
  }

  public Point(Long userId, int amount) {
    this.userId = userId;
    this.amount = amount;
  }

  public Long getPointId() {
    return pointId;
  }

  public Long getUserId() {
    return userId;
  }

  public int getAmount() {
    return amount;
  }
  
  // 포인트 적립 (나중에 Service 로직 짤 때 사용)
  public void addAmount(int amount) {
    this.amount += amount;
  }
  
  // 포인트 차감 (나중에 Service 로직 짤 때 사용)
  public void deductAmount(int amount) {
    this.amount -= amount;
  }
}

 

2. Reposiotry 만들기
domain/PointRepoistory

public interface PointRepository extends JpaRepository<Point, Long> {
	// 나중에 Service 로직 짤 때 사용
	Optional<Point> findByUserId(Long userId);
}

 

3. Controller 만들기
controller/PointController

@RestController
@RequestMapping("/points")
public class PointController {
  private final PointService pointService;

  public PointController(PointService pointService) {
    this.pointService = pointService;
  }
  
  @PostMapping("add")
  public ResponseEntity<Void> addPoints(
      @RequestBody AddPointRequestDto addPointRequestDto
  ) {
    pointService.addPoints(addPointRequestDto);
    return ResponseEntity.noContent().build();
  }
  
  @PostMapping("deduct") // deduct : 빼다
  public ResponseEntity<Void> deductPoints(
      @RequestBody DeductPointRequestDto deductPointRequestDto
  ) {
    pointService.deductPoints(deductPointRequestDto);
    return ResponseEntity.noContent().build();
  }
}

 

4. DTO 만들기
dto/AddPointRequestDto

public class AddPointRequestDto {
  private Long userId;
  private int amount;

  public Long getUserId() {
    return userId;
  }

  public int getAmount() {
    return amount;
  }
}

 
dto/DeductPointRequestDto

public class DeductPointRequestDto {
  private Long userId;
  private int amount;

  public Long getUserId() {
    return userId;
  }

  public int getAmount() {
    return amount;
  }
}

 
 

5. Service 만들기
service/PointService

@Service
public class PointService {
  private final PointRepository pointRepository;

  public PointService(PointRepository pointRepository) {
    this.pointRepository = pointRepository;
  }

  @Trasnsactional
  public void addPoints(AddPointRequestDto addPointRequestDto) {
    Point point = pointRepository.findByUserId(addPointRequestDto.getUserId())
        .orElseGet(() -> new Point(addPointRequestDto.getUserId(), 0));

    point.addAmount(addPointRequestDto.getAmount());

    pointRepository.save(point);
  }
  
  @Transactional
  public void deductPoints(DeductPointRequestDto deductPointRequestDto) {
    Point point = pointRepository.findByUserId(deductPointRequestDto.getUserId())
        .orElseThrow(() -> new IllegalArgumentException("사용자의 포인트 정보를 찾을 수 없습니다."));

    point.deductAmount(deductPointRequestDto.getAmount());

    pointRepository.save(point);
  }
}

 

6. 서버 다시 실행시키기



 

7. API 잘 작동하는 지 테스트해보기
[포인트 적립 API 테스트]





 
[포인트 차감 API 테스트]