[SpringBoot] mallangShop

📍 GitHub 바로가기

Project Intro

---

1 AllInOneController 역할분리

📌 서버에서의 처리과정 → 대부분 비슷함
처리과정을 크게 3개로 분리함 (Controller, Service, Repository)

1️⃣ Controller

• ① Client Request를 받음

• ② Request에 대한 처리를 Service에게 전담시킴

• ③ 처리 Response Client에게 반환

2️⃣ Service

• Client Request를 처리하는 실세

• 비즈니스 로직 → 현업에서 서비스코드가 계속 비대해짐

• DB 정보 → Repository에 Request 보냄

3️⃣ Repository

• DB 관리 (연결, 해제, 자원관리)

• DB CRUD 작업처리

---

2 AllInOneController 코드분리

1️⃣ 관심사분리

📍 Controller

📍 Service

📍 Repository

2️⃣ 코드분리

📍 Controller

// JSON 형태의 데이터반환
@RestController
@RequestMapping("/api")
public class ProductController {

    // 관심상품 등록
    @PostMapping("/products")
    public ProductResponseDto createProduct(@RequestBody ProductRequestDto productRequestDto) throws SQLException {

        ProductService productService = new ProductService();

        return productService.createProduct(productRequestDto);

    }

    // 관심상품 조회
    @GetMapping("/products")
    public List<ProductResponseDto> getProducts() throws SQLException {

        ProductService productService = new ProductService();

        return productService.getProducts();

    }

    // 관심상품 최저가 등록
    @PutMapping("/products/{id}")
    public Long updateProduct(@PathVariable Long id, @RequestBody ProductMypriceRequestDto productMypriceRequestDto) throws SQLException {

        ProductService productService = new ProductService();

        return productService.updateProduct(id, productMypriceRequestDto);

    }

}

📍 Service

@Component // Bean 등록
public class ProductService {

    // 관심상품 등록
    public ProductResponseDto createProduct(ProductRequestDto productRequestDto) throws SQLException {

        Product product = Product.of(productRequestDto);

        ProductRepository productRepository = new ProductRepository();

        return productRepository.createProduct(product);

    }

    // 관심상품 조회
    public List<ProductResponseDto> getProducts() throws SQLException {

        ProductRepository productRepository = new ProductRepository();

        return productRepository.getProducts();

    }

    // 관심상품 최저가 등록
    public Long updateProduct(Long id, ProductMypriceRequestDto productMypriceRequestDto) throws SQLException {

        ProductRepository productRepository = new ProductRepository();

        Product product = productRepository.getProduct(id);

        if (product == null) {
            throw new NullPointerException("해당 상품은 존재하지 않습니다");
        }

        return productRepository.updateProduct(product.getId(), productMypriceRequestDto);

    }

}

📍 Repository

@Component // Bean 등록
public class ProductRepository {

    // 관심상품 등록
    public ProductResponseDto createProduct(Product product) throws SQLException {

        // DB 연결
        Connection connection = DriverManager.getConnection("jdbc:h2:mem:db;MODE=MYSQL", "mallang", "");

        // DB Query 작성
        PreparedStatement preparedStatement = connection.prepareStatement("select max(id) as id from product");

        ResultSet resultSet = preparedStatement.executeQuery();

        if (resultSet.next()) {
            product.setId(resultSet.getLong("id") + 1);
        } else {
            throw new SQLException("Product 테이블의 마지막 id 값을 찾아오지 못했습니다");
        }

        preparedStatement = connection.prepareStatement("insert into product(id, title, image, link, lprice, myprice)values(?, ?, ?, ?, ?, ?)");
        preparedStatement.setLong(1, product.getId());
        preparedStatement.setString(2, product.getTitle());
        preparedStatement.setString(3, product.getImage());
        preparedStatement.setString(4, product.getLink());
        preparedStatement.setInt(5, product.getLprice());
        preparedStatement.setInt(6, product.getMyprice());

        // DB Query 실행
        preparedStatement.executeUpdate();

        // DB 연결해제
        preparedStatement.close();

        return ProductResponseDto.of(product);

    }

    // 관심상품 조회
    public List<ProductResponseDto> getProducts() throws SQLException {

        List<ProductResponseDto> productResponseDtoList = new ArrayList<>();

        // DB 연결
        Connection connection = DriverManager.getConnection("jdbc:h2:mem:db;MODE=MYSQL", "mallang", "");

        // DB Query 작성 및 실행
        Statement statement = connection.createStatement();

        ResultSet resultSet = statement.executeQuery("select * from product");

        // DB Query 결과 -> ProductResponseDtoList로 변환
        // DB Query 결과 -> productResponseDtoList 변환
        while (resultSet.next()) {
            Product product = new Product();

            product.setId(resultSet.getLong("id"));
            product.setTitle(resultSet.getString("title"));
            product.setImage(resultSet.getString("image"));
            product.setLink(resultSet.getString("link"));
            product.setLprice(resultSet.getInt("lprice"));
            product.setMyprice(resultSet.getInt("myprice"));

            productResponseDtoList.add(ProductResponseDto.of(product));
        }

        // DB 연결해제
        resultSet.close();

        connection.close();

        return productResponseDtoList;

    }

    // 관심상품 최저가 등록
    public Long updateProduct(Long id, ProductMypriceRequestDto productMypriceRequestDto) throws SQLException {

        // DB 연결
        Connection connection = DriverManager.getConnection("jdbc:h2:mem:db;MODE=MYSQL", "mallang", "");

        // DB Query 작성
        PreparedStatement preparedStatement = connection.prepareStatement("update product set myprice = ? where id = ?");

        preparedStatement.setInt(1, productMypriceRequestDto.getMyprice());
        preparedStatement.setLong(2, id);

        // DB Query 실행
        preparedStatement.executeUpdate();

        // DB 연결해제
        preparedStatement.close();

        connection.close();

        return null;

    }

    public Product getProduct(Long id) throws SQLException {

        Product product = new Product();

        // DB 연결
        Connection connection = DriverManager.getConnection("jdbc:h2:mem:db;MODE=MYSQL", "mallang", "");

        // DB Query 작성
        PreparedStatement preparedStatement = connection.prepareStatement("select * from product where id = ?");

        preparedStatement.setLong(1, id);

        // DB Query 실행
        ResultSet resultSet = preparedStatement.executeQuery();

        if (resultSet.next()) {
            product.setId(resultSet.getLong("id"));
            product.setTitle(resultSet.getString("title"));
            product.setImage(resultSet.getString("image"));
            product.setLink(resultSet.getString("link"));
            product.setLprice(resultSet.getInt("lprice"));
            product.setMyprice(resultSet.getInt("myprice"));
        }

        // DB 연결해제
        resultSet.close();

        preparedStatement.close();

        connection.close();

        return product;

    }

}

---

3 객체중복생성 해결

📌 객체중복생성 해결 : 한 클래스 내에서, 메서드마다 같은 객체가 중복해서 계속 생성되는 것 → private final 멤버변수로 선언해서 공유하여 사용하는 방법

📍 ProductController.java

ProductService productService = new ProductService(); → 삭제

📍 ProductService.java

ProductRepository productRepository = new ProductRepository(); → 삭제

---

4 DI(의존성주입)

1️⃣ 강한결합

• ① Controller1 → Service1 객체 생성하여 사용

public class Controller1 {
	
    private final Service1 service1;
    
    public Controller1() {
    	this.service1 = new Service1();
    }

}

• ② Service1 → Repository 객체 생성하여 사용

public class Service1 {
	
    private final Repository1 repository1;
    
    public Service() {
    	this.repository1 = new Repository1;
    }
    
}

• ③ Repository1 객체선언

public class Repository1 {•••}

2️⃣ 강한결합 문제점

• Controller 5개 → 각각 Service1 생성해서 사용중

• Repository1 생성자 변경 → 모든 Controller, Service 코드변경 필요 🚨

3️⃣ 강한결합 해결법

📌 강한결합해결법 : 각 객체에 대한 객체생성 1번만 → 생성된 하나의 객체를 모든곳에서 재사용 ⭐️

• ① Repository1 클래스 선언 및 객체생성 → repository1

public class Repository1{•••}

// 객체생성
Repository1 repository1 = new Repository1();

• ② Service1 클래스 선언 및 객체생성(repository1 재사용) → service1

class Service1 {
	
    private final Repository1 repository1;
    
    // repository1 객체 재사용
    public Service1(Repository1 repository1) {
    	this.repository1 = repository1;
    }
    
}

• ③ Controller1 선언(service1 재사용)

class Controller1 {
	
    private final Service1 service1;
    
    // service1 객체 재사용
    public Controller1(Service1 service1) {
    	this.service1 = service1;
    }
    
}

4️⃣ 강한결합 개선결과

• Repository1 생성자 변경 → 다른 코드에 영향을 주지 않음

• Service1 생성자 변경 → 다른 코드에 영향을 주지 않음

---

5 Spring IoC 컨테이너

📌 Spring Bean : Spring IoC 컨테이너가 관리하는 자바객체 → Spring에 의해 생성되고 관리되는 자바객체

📍 Java 프로그램
	- 각 객체 → 프로그램의 흐름을 결정
    - 각 객체를 개발자가 직접 생성 및 조작 (객체생성 → 메서드호출)
    - "모든작업을 개발자가 제어하는 구조"

📍 IoC 제어의 역전
	- 객체생성 → 관리위임주체에 맡김
    - 개발자가 직접 객체생성 ❌

• Spring에서는 new 생성자를 이용해 생성한 객체가 아니라,
  Spring에 의해 관리당하는 자바객체를 사용함

1️⃣ Spring Bean 등록방법

📍 @Component

• 클래스 위에 Annotation 선언

• 스프링 서버가 뜰 때 → 스프링 IoC에 Bean 저장

// 1. ProductService 객체생성
ProductService productService = new ProductService();

// 2. Spring IoC 컨테이너에 Bean(productService) 저장
// productService -> Spring IoC 컨테이너

• @ComponentScan(basePackages = "") packages 위치 및 하위 packages들에 적용됨

2️⃣ Spring Bean 사용방법

📍 @Bean

• ① 직접 객체생성 → Bean 등록요청
  

• ② 스프링서버 뜰 때 → 스프링 IoC에 Bean 저장

• ③ private final 멤버변수 선언 위에 → @Autowired 선언

• ④ Bean을 사용할 함수 위에 @Autowired 선언

• ⑤ Lombok → @RequriedArgsConstructor ; @Autowired + 생성자 생략가능 ⭐️

---

6 최종 Refactoring 코드

1️⃣ Product.java

<@Entity
@Getter @Setter
@NoArgsConstructor
public class Product {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    // Id 자동생성 및 증가
    private Long id;

    @Column(nullable = false)
    private String title;

    @Column(nullable = false)
    private String image;

    @Column(nullable = false)
    private String link;

    @Column(nullable = false)
    private int lprice;

    @Column(nullable = false)
    private int myprice;

    // 생성자
    @Builder
    private Product(String title, String image, String link, int lprice) {
        this.title = title;
        this.image = image;
        this.link = link;
        this.lprice = lprice;
        this.myprice = 0;
    }

    // 정적팩토리메서드
    public static Product of(ProductRequestDto productRequestDto) {
        return Product.builder()
                .title(productRequestDto.getTitle())
                .image(productRequestDto.getImage())
                .link(productRequestDto.getLink())
                .lprice(productRequestDto.getLprice())
                .build();
    }

    // 관심상품 최저가 등록 (update)
    public void update(ProductMypriceRequestDto productMypriceRequestDto) {
        this.myprice = productMypriceRequestDto.getMyprice();
    }

}

2️⃣ ProductController.java

// JSON 형태의 데이터반환
@RestController
@RequiredArgsConstructor
@RequestMapping("/api")
public class ProductController {

    // 객체중복생성 해결 -> 멤버변수 선언
    private final ProductService productService;

    // 관심상품 등록
    @PostMapping("/products")
    public ProductResponseDto createProduct(@RequestBody ProductRequestDto productRequestDto) {

        return productService.createProduct(productRequestDto);

    }

    // 관심상품 조회
    @GetMapping("/products")
    public List<ProductResponseDto> getProducts() {

        return productService.getProducts();

    }

    // 관심상품 최저가 등록
    @PutMapping("/products/{id}")
    public Long updateProduct(@PathVariable Long id, @RequestBody ProductMypriceRequestDto productMypriceRequestDto) {

        return productService.updateProduct(id, productMypriceRequestDto);

    }

}

3️⃣ ProductService.java

@Service
@RequiredArgsConstructor
public class ProductService {

    // 객체중복생성 해결 -> 멤버변수 선언
    private final ProductRepository productRepository;

    // 관심상품 등록
    @Transactional
    public ProductResponseDto createProduct(ProductRequestDto productRequestDto) {

        Product product = productRepository.saveAndFlush(Product.of(productRequestDto));

        return ProductResponseDto.of(product);

    }

    // 관심상품 조회
    @Transactional(readOnly = true)
    public List<ProductResponseDto> getProducts() {

        List<ProductResponseDto> productResponseDtoList = new ArrayList<>();

        List<Product> productList = productRepository.findAll();

        for (Product product : productList) {
            productResponseDtoList.add(ProductResponseDto.of(product));
        }

        return productResponseDtoList;

    }

    // 관심상품 최저가 등록
    @Transactional
    public Long updateProduct(Long id, ProductMypriceRequestDto productMypriceRequestDto) {

        Product product = productRepository.findById(id).orElseThrow(
                () -> new NullPointerException("해당 상품은 존재하지 않습니다;")
        );

        product.update(productMypriceRequestDto);

        return product.getId();

    }

}

4️⃣ ProductRepository.java

public interface ProductRepository extends JpaRepository<Product, Long> {
}

---

7 관심상품 최저가업데이트 스케줄러 설계

1️⃣ Product.java

@Entity
@Getter @Setter
@NoArgsConstructor
public class Product extends Timestamped {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    // Id 자동생성 및 증가
    private Long id;

    @Column(nullable = false)
    private String title;

    @Column(nullable = false)
    private String image;

    @Column(nullable = false)
    private String link;

    @Column(nullable = false)
    private int lprice;

    @Column(nullable = false)
    private int myprice;

    // 생성자
    @Builder
    private Product(String title, String image, String link, int lprice) {
        this.title = title;
        this.image = image;
        this.link = link;
        this.lprice = lprice;
        this.myprice = 0;
    }

    // 정적팩토리메서드
    public static Product of(ProductRequestDto productRequestDto) {
        return Product.builder()
                .title(productRequestDto.getTitle())
                .image(productRequestDto.getImage())
                .link(productRequestDto.getLink())
                .lprice(productRequestDto.getLprice())
                .build();
    }

    // 관심상품 최저가 등록 (update)
    public void update(ProductMypriceRequestDto productMypriceRequestDto) {
        this.myprice = productMypriceRequestDto.getMyprice();
    }

    // 관심상품 최저가 업데이트
    public void updateLprice(ItemDto itemDto) {
        this.lprice = itemDto.getLprice();
    }

}

2️⃣ Timestamped.java

@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
@Getter
public class Timestamped {

    @CreatedDate
    @Column(updatable = false)
    private LocalDateTime createdAt;

    @LastModifiedDate
    @Column
    private LocalDateTime modifiedAt;

}

• Application.java → @EnableJpaAuditing 추가필수

3️⃣ Scheduler.java

@Slf4j
@Component
@RequiredArgsConstructor
public class Scheduler {

    private final NaverApiService naverApiService;
    private final ProductService productService;
    private final ProductRepository productRepository;

    // 초, 분, 시, 일, 월, 주 순서
    @Scheduled(cron = "0 0 1 * * *")
    public void updateLprice() throws InterruptedException {

        log.info("최저가 업데이트 실행");

        List<Product> productList = productRepository.findAll();

        for (Product product : productList) {
            // 1초에 한 상품씩 조회
            TimeUnit.SECONDS.sleep(1);

            String title = product.getTitle();

            List<ItemDto> itemDtoList = naverApiService.searchItems(title);

            ItemDto itemDto = itemDtoList.get(0);

            // 1번째 관심상품 최저가를 업데이트
            Long id = product.getId();

            productService.updateBySearch(id, itemDto);
        }

    }

}

• Application.java → @EnableScheduling 추가필수

4️⃣ ProductService.java

@Service
@RequiredArgsConstructor
public class ProductService {

    // 객체중복생성 해결 -> 멤버변수 선언
    private final ProductRepository productRepository;

    // 관심상품 등록
    @Transactional
    public ProductResponseDto createProduct(ProductRequestDto productRequestDto) {

        Product product = productRepository.saveAndFlush(Product.of(productRequestDto));

        return ProductResponseDto.of(product);

    }

    // 관심상품 조회
    @Transactional(readOnly = true)
    public List<ProductResponseDto> getProducts() {

        List<ProductResponseDto> productResponseDtoList = new ArrayList<>();

        List<Product> productList = productRepository.findAll();

        for (Product product : productList) {
            productResponseDtoList.add(ProductResponseDto.of(product));
        }

        return productResponseDtoList;

    }

    // 관심상품 최저가 등록
    @Transactional
    public Long updateProduct(Long id, ProductMypriceRequestDto productMypriceRequestDto) {

        Product product = productRepository.findById(id).orElseThrow(
                () -> new NullPointerException("해당 상품은 존재하지 않습니다")
        );

        product.update(productMypriceRequestDto);

        return product.getId();

    }

    // 관심상품 최저가 업데이트
    public void updateBySearch(Long id, ItemDto itemDto) {

        Product product = productRepository.findById(id).orElseThrow(
                () -> new NullPointerException("해당 상품은 존재하지 않습니다")
        );

        // Product Entity method 실행
        product.updateLprice(itemDto);

    }

}