url: http://www.javadecompilers.com/

파일 선택 버튼을 클릭해서 파일탐색기에서 파일을 선택하거나 바로 드래그 앤 드롭으로 파일을 넣은후 해당 버튼을 누르면 .java 로 변환된 코드를 볼 수 있습니다.

CREATE DATABASE opentutorials;

🔖 데이터베이스 사용

USE opentutorials;

🔖 테이블 생성

CREATE TABLE topic(
    -> id INT(11) NOT NULL AUTO_INCREMENT,
    -> title VARCHAR(100) NOT NULL,
    -> description TEXT NULL,
    -> created DATETIME NOT NULL,
    -> author VARCHAR(30) NULL,
    -> profile VARCHAR(100) NULL,
    -> PRIMARY KEY(id));

🔖 테이블 구성요소 살펴보기

DESC topic;
+-------------+--------------+------+-----+---------+----------------+
| Field       | Type         | Null | Key | Default | Extra          |
+-------------+--------------+------+-----+---------+----------------+
| id          | int          | NO   | PRI | NULL    | auto_increment |
| title       | varchar(100) | NO   |     | NULL    |                |
| description | text         | YES  |     | NULL    |                |
| created     | datetime     | NO   |     | NULL    |                |
| author      | varchar(30)  | YES  |     | NULL    |                |
| profile     | varchar(100) | YES  |     | NULL    |                |
+-------------+--------------+------+-----+---------+----------------+

🔖 테이블에 데이터 추가

INSERT INTO topic (title,description,created,author,profile) VALUES ('MySQL','MySQL is ...',NOW(),'egoing','developer');

🔖 테이블 모든 데이터 읽기

SELECT * FROM topic;
+----+------------+-------------------+---------------------+--------+---------------------------+
| id | title      | description       | created             | author | profile                   |
+----+------------+-------------------+---------------------+--------+---------------------------+
|  1 | MySQL      | MySQL is ...      | 2024-04-09 06:22:04 | egoing | developer                 |
|  2 | ORACLE     | ORACLE is ...     | 2024-04-09 06:23:50 | egoing | developer                 |
|  3 | SQL Server | SQL Server is ... | 2024-04-09 06:24:44 | duru   | data administrator        |
|  4 | PostgreSQL | PostgreSQL is ... | 2024-04-09 06:25:27 | taeho  | data scientist, developer |
|  5 | MongoDB    | MongoDB is ...    | 2024-04-09 06:25:57 | egoing | developer                 |
+----+------------+-------------------+---------------------+--------+---------------------------+
5 rows in set (0.00 sec)

🔖 원하는 컬럼만 읽기

SELECT id,title,author FROM topic;
+----+------------+--------+
| id | title      | author |
+----+------------+--------+
|  1 | MySQL      | egoing |
|  2 | ORACLE     | egoing |
|  3 | SQL Server | duru   |
|  4 | PostgreSQL | taeho  |
|  5 | MongoDB    | egoing |
+----+------------+--------+

🔖 기본 조건절 사용해서 읽기

SELECT id,title,author FROM topic WHERE author='egoing';
+----+---------+--------+
| id | title   | author |
+----+---------+--------+
|  1 | MySQL   | egoing |
|  2 | ORACLE  | egoing |
|  5 | MongoDB | egoing |
+----+---------+--------+

🔖 정렬해서 읽기 (기본은 ASC=오름차순)

SELECT id,title,author FROM topic WHERE author='egoing' ORDER BY id DESC;
+----+---------+--------+
| id | title   | author |
+----+---------+--------+
|  5 | MongoDB | egoing |
|  2 | ORACLE  | egoing |
|  1 | MySQL   | egoing |
+----+---------+--------+

🔖 갯수 제한해서 읽기

 SELECT id,title,author FROM topic WHERE author='egoing'ORDER BY id DESC LIMIT 2;
+----+---------+--------+
| id | title   | author |
+----+---------+--------+
|  5 | MongoDB | egoing |
|  2 | ORACLE  | egoing |
+----+---------+--------+

🔖 데이터 수정하기(업데이트하기)

UPDATE topic SET description='Oracle is ...', title='Oracle' WHERE id=2

SELECT * FROM topic;
+----+------------+-------------------+---------------------+--------+---------------------------+
| id | title      | description       | created             | author | profile                   |
+----+------------+-------------------+---------------------+--------+---------------------------+
|  1 | MySQL      | MySQL is ...      | 2024-04-09 06:22:04 | egoing | developer                 |
|  2 | Oracle     | Oracle is ...     | 2024-04-09 06:23:50 | egoing | developer                 |
|  3 | SQL Server | SQL Server is ... | 2024-04-09 06:24:44 | duru   | data administrator        |
|  4 | PostgreSQL | PostgreSQL is ... | 2024-04-09 06:25:27 | taeho  | data scientist, developer |
|  5 | MongoDB    | MongoDB is ...    | 2024-04-09 06:25:57 | egoing | developer                 |
+----+------------+-------------------+---------------------+--------+---------------------------+

🔖 데이터 삭제하기

DELETE FROM topic WHERE id=5;

SELECT * FROM topic;
+----+------------+-------------------+---------------------+--------+---------------------------+
| id | title      | description       | created             | author | profile                   |
+----+------------+-------------------+---------------------+--------+---------------------------+
|  1 | MySQL      | MySQL is ...      | 2024-04-09 06:22:04 | egoing | developer                 |
|  2 | Oracle     | Oracle is ...     | 2024-04-09 06:23:50 | egoing | developer                 |
|  3 | SQL Server | SQL Server is ... | 2024-04-09 06:24:44 | duru   | data administrator        |
|  4 | PostgreSQL | PostgreSQL is ... | 2024-04-09 06:25:27 | taeho  | data scientist, developer |
+----+------------+-------------------+---------------------+--------+---------------------------+

💡 먼저 Docker가 설치되어있다는 전제하에

1. MySQL 이미지 다운로드

• 명령어로 원하는 버전의 MySQL 이미지를 다운받거나
• docker desktop에서 직접 검색해서 다운받을수도 있다
  • 아래 캡처 사진에서 원하는 버전 선택하고 pull 누르면 이미지를 다운 받을 수 있다

    $ docker pull mysql:8.0.36

2. 다운받은 이미지 확인

아래 명령어로 다운받은 이미지를 확인 할 수 있다

$ docker images
REPOSITORY            TAG        IMAGE ID       CREATED         SIZE
mysql                 latest     3d6757ec48c5   13 days ago     638MB
redis                 7-alpine   0be8a78a8b83   2 months ago    46.5MB

• mysql, redis가 있는걸 볼 수 있다

3. MySQL Docker 컨테이너 생성

$ docker run --name mysql -e MYSQL_ROOT_PASSWORD=1234 -p 3306:3306 mysql:8.0.36

mysql : 원하는 컨테이너 이름 작성 MYSQL_ROOT_PASSWORD=1234 : root 계정 비밀번호 설정 3306:3306 : 외부포트:docker 내부포트 설정 8.0.36: 원하는 MySQL버전

4. 생성된 컨테이너 확인

$ docker ps
CONTAINER ID   IMAGE     COMMAND                   CREATED       STATUS          PORTS                               NAMES
147ac55c1fe5   mysql     "docker-entrypoint.s…"   3 hours ago   Up 19 minutes   0.0.0.0:3306->3306/tcp, 33060/tcp   mysql

• ps: 실행중인 컨테이너 목록 확인
• ps -a: 정지 되어 있는 컨테이너 까지 모든 컨테이너 목록 확인

5. 컨테이너 bash 쉘 접속하기

컨테이너를 실행시킨 후 bash쉘에 접속한다

컨테이너 시작

$ docker start mysql

• mysql : 컨테이너 이름

$ docker exec -it mysql bash
bash-4.4#

접속하면 위와같이 bash-4.4# 가 나올 것이다

• docker desktop에서는 오른쪽 메뉴의 'Open in terminal'을 눌러도 접속할 수 있다

6. MySQL 서버 접속

bash-4.4# mysql -u root -p
Enter password:

mysql -u root -p 를 치면 위와 같이 비밀번호를 치라고 나오고 위에 설정해준 비밀번호를 치면

Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 8
Server version: 8.3.0 MySQL Community Server - GPL

Copyright (c) 2000, 2024, Oracle and/or its affiliates.

Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql>

접속완료!

참고

• https://velog.io/@hanif/%EB%8F%84%EC%BB%A4-%EC%BB%A8%ED%85%8C%EC%9D%B4%EB%84%88-%EB%8B%A4%EB%A3%A8%EA%B8%B0
• https://www.inflearn.com/course/%EB%8F%99%EC%8B%9C%EC%84%B1%EC%9D%B4%EC%8A%88-%EC%9E%AC%EA%B3%A0%EC%8B%9C%EC%8A%A4%ED%85%9C/dashboard

우리 서비스가 네고기능도 있고 여러가지의 상태값, 예를들어 상품상태, 네고상태, 주문상태...에 따라서 처리해야할 것들이 많아서 결제만 깔끔하게 딱 이루어진 코드는 없지만 각 상태에 따라서 결제를 어떻게 처리 했는지 기록해보려고 한다. pg사 연동 코드를 찾는 이들에게 조금의 도움이 될까 싶어 끄적끄적 적어보았다

ERD

프로젝트의 전체적인 erd는 위와 같고 내가 집중해서 봐야하는 쪽은 아래 확대한 부분이다 상품 테이블: 등록된 상품에 대한 정보 주문 테이블: 결제 상세 페이지에 들어가게 되었을때 저장되는 주문 관련 정보 네고 테이블: 네고를 진행 했을시 저장되는 정보 결제 테이블: 결제 시도 후 포트원 결제 단건조회 결과를 저장 취소내역 테이블: 환불 시 저장되는 결제 관련 정보

1. 포트원 라이브러리 설정

build.gradle

repositories {
    mavenCentral()

    //iamport
    maven {
        url 'https://jitpack.io'
    }
}

dependencies{
    //iamport
    implementation 'com.github.iamport:iamport-rest-client-java:0.2.23'
}

2. config 파일 설정

imp_key, imp_secret_key는 properties 파일에 올리고 숨겨서 사용하였다. 그리고 IamportClient를 빈으로 등록하여 사용할수 있도록 설정하였다

IamportApiProperty.java

@Getter
@Configuration
@PropertySource("classpath:/secret.properties")
public class IamportApiProperty {
    @Value("${imp_key}")
    private String impKey;
    @Value("${imp_secret}")
    private String impSecret;
}

IamportConfig.java

@Configuration
@RequiredArgsConstructor
public class IamportConfig {
    private final IamportApiProperty iamportApiProperty;

    @Bean
    public IamportClient iamportClient() {
        return new IamportClient(iamportApiProperty.getImpKey(), iamportApiProperty.getImpSecret());
    }
}

3. 주문 상세 페이지

전체적인 결제 진행 과정과 상태값은 다음과 같다.

결제 진행 과정

주문 상세 페이지 -(결제 버튼 누름)→ 사전 검증 -(사전검증 성공시)→ 프론트 측에서 pg사 결제 진행 -(결제 완료 시 결제 결과 서버측으로 넘김)→ 사후 검증 -(사후검증 완료시)→ 결제 완료

상태값

우리의 서비스는 네고가 만약 성공했다면 그 사람에게 해당 상품이 20분간 예약이 되고 그 시간동안에 다른사람은 해당 상품을 구매할수도, 네고할 수도 없다. 그리고 만약 그 사람이 해당 상품을 20분 내에 구매하지 않았더라도 네고에 성공했기 때문에 그 사람은 네고를 성공한 가격에 해당 상품을 구매할 수 있도록 해야했다. 그래서 위와 같이 많은 상태값을 이용하게 되었다.

사용자가 주문하기 버튼을 눌렀을때 주문 상세 페이지로 들어오게 되고 이때 주문 테이블에 주문 정보를 저장한다. (최대한 결제관련해서만 적어보려고 생략한 부분이 많습니다! 자세한 코드는 아래 깃허브 링크를 참고해주세요 :-) )

PaymentService.java

public PaymentDetailResponse getPaymentDetail(Long productId,
        PrincipalDetails principalDetails) {
        User user = userService.findById(principalDetails.getUserId());

        //상품상태에 따른 처리 과정 생략

        int price = product.getGoldenPrice();

        Order order = Order.of(product.getId(), user.getId(), null, price);

        //네고 확인하는 과정 생략

        Order savedOrder = orderRepository.save(order);

        return PaymentDetailResponse.of(savedOrder.getId(), user, product, price,
            product.getYanoljaPrice());
    }

4. 사전검증

사전검증시 백엔드에서는 포트원측에 주문 id , 결제 금액을 저장하는 작업을 진행한다. 해당 작업이 완료되면 프론트 측으로 결제 관련 정보들을 응답으로 넘겨 주게 되고 응답으로 넘어온 데이터를 이용하여 포트원 결제를 진행하도록 하였다.

이때, 포트원 측에 주문 id, 결제 금액을 저장하는 이유는 넘어온 데이터를 이용하여 포트원 결제를 진행할때 포트원 측에서 저장된 데이터와 결제를 진행하는 데이터가 같은지 검증하기 위하여 다음과 같은 처리를 한다고 한다!

PaymentController.java

@PostMapping("/{orderId}/prepare")
    public ResponseEntity<CommonResponse<PaymentReadyResponse>> preparePayment(
            @PathVariable(name = "orderId") final Long productId,
            @AuthenticationPrincipal PrincipalDetails principalDetails) {
        PaymentReadyResponse paymentReadyResponse = paymentService.preparePayment(productId, principalDetails);
        return ResponseEntity.ok(CommonResponse.ok("Payment ready successfully", paymentReadyResponse));
    }

PaymentService.java

public PaymentReadyResponse preparePayment(Long orderId, PrincipalDetails principalDetails) {

        User user = userService.findById(principalDetails.getUserId());

        Order order = orderRepository.findById(orderId).orElseThrow(
            () -> new CustomException(ErrorCode.ORDER_NOT_FOUND)
        );

        Product product = productService.getProduct(order.getProductId());
        if (product.isNotOnSale()) {
            throw new CustomException(ErrorCode.PRODUCT_NOT_ON_SALE);
        }

        //상품상태 = 예약중, 해당 경우에 본인이 네고를 진행하였고 결제 대기중인지 확인
        Optional<Nego> nego = negoRepository.findFirstByUser_IdAndProduct_IdOrderByCreatedAtDesc(
            user.getId(), product.getId());
        if (product.getProductStatus() == ProductStatus.RESERVED) {
            if (nego.isEmpty()) {
                throw new CustomException(ErrorCode.PRODUCT_NOT_ON_SALE);
            }
            if (nego.get().getStatus() != NegotiationStatus.PAYMENT_PENDING) {
                throw new CustomException(ErrorCode.PRODUCT_NOT_ON_SALE);
            }
        }

        //주문 상태 = 결제 대기중 으로 변경
        order.requestPayment();

        //포트원 측에 주문 id, 결제 금액을 저장 
        iamportRepository.prepare(order.getId(), BigDecimal.valueOf(order.getTotalPrice()));
        return PaymentReadyResponse.create(user, product, order);
    }

5. 사후 검증

포트원 측에 저장된 실제 결제값과 우리쪽 주문 데이터베이스에 저장된 결제되어야 하는 값을 비교하는 작업을 진행한다. 이때 우리의 결과값은 SUCCESS ,TIME_OVER, FAILED 세가지였다. SUCCESS = 정상적으로 결제 완료된 건 TIME_OVER = 네고 성공 후 시간 초과 FAILED = 결제가 되지 않은 경우, 더 이상 살 수 없는 상품일 경우

여기서 네고 성공한 사람이 주문 상세 페이지에 들어올때는 20분간 예약중인 시간 내에 들어왔지만 결제 완료시에 그 시간이 지났다면 해당 거래를 취소시키도록 서비스가 기획되었다.

이때 TIME_OVER인 경우와 FAILED에서 더 이상 살 수 없는 상품일 경우에는 이미 사용자의 카드 결제가 완료 되었지만 주문을 실패처리해야하기 때문에 결제된 것을 취소처리 하는 과정을 추가하였다.

PaymentController.java

@PostMapping("/result")
    public ResponseEntity<CommonResponse<PaymentResponse>> savePayment(
            @Valid @RequestBody PaymentRequest request,
            @AuthenticationPrincipal PrincipalDetails principalDetails
    ) {
        PaymentResponse paymentResponse = paymentService.savePayment(request, principalDetails);
        return ResponseEntity.ok(CommonResponse.ok("Payment result", paymentResponse));
    }

findPaymentByImpUid를 이용하여 결제 내역을 조회할 수 있다.

PaymentService.java

public PaymentResponse savePayment(PaymentRequest request, PrincipalDetails principalDetails) {

        Long userId = principalDetails.getUserId();

        Payment payment = iamportRepository.findPaymentByImpUid(request.getImpUid())
            .orElseThrow(() -> new CustomException(ErrorCode.PAYMENT_NOT_FOUND));

        Order order = orderRepository.findById(request.getOrderId())
            .orElseThrow(() -> new CustomException(ErrorCode.ORDER_NOT_FOUND));

        Product product = productService.getProduct(order.getProductId());

        Payment savedPayment = paymentRepository.save(payment);

        if (payment.isDifferentAmount(order.getTotalPrice())) {
            throw new CustomException(ErrorCode.INVALID_PAYMENT_AMOUNT_ERROR);
        }

이후 각 상황에 맞는 결과값을 내려준다.

        //결제가 되지 않은 경우
        if (savedPayment.isNotPaid()) {
            order.paymentFailed();
            return PaymentResponse.failed();
        }

        //상품상태 = 상품만료, 솔드아웃
        if (product.isNotOnSale()) {
            cancelPayment(request.getImpUid());
            return PaymentResponse.failed();
        }

        Optional<Nego> nego = negoRepository.findFirstByUser_IdAndProduct_IdOrderByCreatedAtDesc(
            userId, product.getId());

        //상품상태 = 예약중
        if (product.getProductStatus() == ProductStatus.RESERVED) {
            if (nego.isEmpty()) {
                cancelPayment(request.getImpUid());
                return PaymentResponse.failed();
            }
            if (nego.get().getStatus() != order.getNegoStatus()) {
                cancelPayment(request.getImpUid());
                return PaymentResponse.failed();
            }
            if (nego.get().getStatus() != NegotiationStatus.PAYMENT_PENDING) {
                cancelPayment(request.getImpUid());
                return PaymentResponse.failed();
            }
        }

        //상품상태 = 판매중
        //네고 내역 존재할 때
        if (nego.isPresent()) {
            //네고 상태: 결제 대기중 -> 타임아웃 => 결제 결과 타임오버
            if (nego.get().getStatus() != order.getNegoStatus()) {
                cancelPayment(request.getImpUid());
                return PaymentResponse.timeOver();
            }
            nego.get().transferPending();
        }

        order.waitTransfer();
        product.setProductStatus(ProductStatus.RESERVED);

        // 채팅방, 알림관련 생략

        return PaymentResponse.success(chatRoomId);
    }

여기까지가 내가 구현한 결제부분이었다. 사실 서비스를 이해하느라 더 오랜시간이 걸렸었고 이를 정리하고 수정하고 일어날 수 있는 모든 케이스를 찾아내야만 했기 때문에 완벽한 결제 구현을 못한것이 아쉬웠다. 하지만 이번 기회로 포트원을 사용해 볼 수 있어서 좋았고 좀 더 최적화 하는 과정을 거칠 예정이다!

💡 PG사란 ? : Payment Gateway 의 줄임말 구매자와 판매자 사이에서의 이뤄지는 결제를 안전하게 할 수 있도록 대행해주는 역할을 담당 대표적인 PG사로는 KG 이니시스, NHN, KCP, LGU+ 등이 있으며, 모바일 환경으로는 KG 모빌리언스, 다날, 카카오Pay 등이 있다 .

포트원(아임포트) 연동 준비

1. 포트원 회원가입 후 테스트 결제대행사 추가

포트원: https://admin.portone.io/ 위 주소로 들어가서 회원가입 후 '결제연동' 탭으로 이동후 원하는 결제대행사 테스트로 추가한다 나는 KG이니시스를 선택하였다

2. 결제 연동하기

사실 프론트의 결제 연동하는 코드는 위에 올렸던 메뉴바 가장 아래에 위치해있는 '콘솔가이드'에 자세히 나와있다 https://developers.portone.io/docs/ko/auth/guide/readme?v=v1

아래는 인증결제가 어떻게 이루어지는지 잘 설명되어있는 그림이다

나는 백엔드 쪽을 개발하는거라 프론트 코드는 위 사이트에 들어가서 참고하면 될것 같다. (우리 프론트 팀원도 해당 문서에 나와있는 코드를 거의 그대로 썻다고 한다!)

3. 포트원 관련 설정

프로젝트를 시작하기 전에 실제 pg창이 뜨는지 궁금해서 간단하게 적어본 html은 아래와 같았다.

index.html

<!DOCTYPE html>
<html lang="ko">
<head>
    <meta charset="utf-8">
</head>
<body> <!-- jQuery -->
<script type="text/javascript" src="https://code.jquery.com/jquery-1.12.4.min.js"></script> <!-- iamport.payment.js -->
<script type="text/javascript" src="https://cdn.iamport.kr/js/iamport.payment-1.2.0.js"></script>
<div><h2>IAMPORT 결제 데모</h2>
    <li>
        <button id="iamportPayment" type="button">결제테스트</button>
    </li>
</div>
<script>
    //문서가 준비되면 제일 먼저 실행
    $(document).ready(function () {
        $("#iamportPayment").click(function () {
            proceedPay(); //버튼 클릭하면 호출
        });
    })

    function proceedPay() {
        $.ajax({
            url: '/payment/proceed',
            type: 'POST',
            async: true,
            dataType: "Json",
            data:
                $('#orderForm').serialize(),
            success: function (data) {
                if (data.cnt > 0) {
                    requestPay(data)
                } else {
                    alert(data.msg)
                }
            },
            error: function (e) {
                alert("에러")
            }
        });

    }

    function requestPay(data) {
        IMP.init("가맹점 코드"); // 예: imp00000000
        //IMP.request_pay(param, callback) 결제창 호출

        IMP.request_pay({ // param
            pg: "html5_inicis.INIBillTst", //결제대행사 설정에 따라 다르며 공식문서 참고
            pay_method: "card", //결제방법 설정에 따라 다르며 공식문서 참고
            merchant_uid: data.no, //주문(db에서 불러옴) 고유번호
            name: data.products,
            amount: data.price,
            buyer_email: "",
            buyer_name: data.name,
            //buyer_tel: "010-4242-4242",
            buyer_addr: data.addr,
            //buyer_postcode: "01181"
        }, function (rsp) { // callback
            if (rsp.success) {
                // 결제 성공 시: 결제 승인 또는 가상계좌 발급에 성공한 경우
                // jQuery로 HTTP 요청
                jQuery.ajax({
                    url: "/payment/verify/" + rsp.imp_uid,
                    method: "POST",
                }).done(function (data) {
                    // 위의 rsp.paid_amount 와 data.response.amount를 비교한후 로직 실행 (iamport 서버검증)
                    if (rsp.paid_amount == data.response.amount) {
                        succeedPay(rsp.imp_uid, rsp.merchant_uid);
                    } else {
                        alert("결제 검증 실패");
                    }
                })
            } else {
                var msg = '결제에 실패하였습니다.';
                msg += '에러내용 : ' + rsp.error_msg;
                alert(msg);
            }
        });
    }
</script>
</body>
</html>

build.gradle에 포트원 관련 설정을 추가하였다.

repositories {
    mavenCentral()

    //iamport
    maven {
        url 'https://jitpack.io'
    }
}

dependencies {
    //iamport
    implementation 'com.github.iamport:iamport-rest-client-java:0.2.23'
}

추가로 아래 결제 검증을 할 때 필요한 설정 파일들을 만들어주었다. 이때 impKey, impSecretKey는 유출되면 안된다고 하여 properties 파일에 숨겨서 사용하였다.

IamportApiProperty.java

@Getter
@Configuration
@PropertySource("classpath:/secret.properties")
public class IamportApiProperty {
    @Value("${imp_key}")
    private String impKey;
    @Value("${imp_secret}")
    private String impSecret;
}

IamportConfig.java

@Configuration
@RequiredArgsConstructor
public class IamportConfig {
    private final IamportApiProperty iamportApiProperty;

    @Bean
    public IamportClient iamportClient() {
        return new IamportClient(iamportApiProperty.getImpKey(), iamportApiProperty.getImpSecret());
    }
}

4. 결제 검증

문서를 참고하면서 개발하다보면 결제정보를 검증하는 과정이 꼭 필요하다고 나와있었고 그 이유도 잘 나와있어서 우리도 결제정보를 검증하는 과정을 추가하게 되었다.

위 화면에서 보면 백엔드에서 검증은 총 2번 1. 사전검증, 2. 사후검증을 진행하도록 되어있다.

1. 사전검증 결제금액 사전등록 API를 요청하여 포트원 측에 주문아이디와 가격을 등록한다

   https://developers.portone.io/api/rest-v1/payment.validation?v=v1#post%20%2Fpayments%2Fprepare

   IamportRepository.java

   public void prepare(Long orderId, BigDecimal price) {
          try {
              iamportClient.postPrepare(new PrepareData(String.valueOf(orderId), price));
          } catch (Exception e) {
              throw new CustomException(ErrorCode.IAMPORT_ERROR);
          }
      }

2. 사후 검증

   1. 사전 검증 이후에 프론트 측에서 결제를 끝내고 나면 받게되는 포트원 결제고유번호(imp_uid), 가맹점 주문번호(merchant_uid)를 프론트엔드로부터 수신
      2. 결제 상세내역 조회를 위해 포트원 결제 단건 조회 API 요청
      3. 응답받은 내용을 바탕으로 실 결제 금액과 결제요청금액(가맹점 자체 데이터베이스)을 비교 사후 검증은 결제가 이루어지고 난 다음에 우리의 데이터베이스에 저장된것과 비교하여 결제가 잘 이루어 진게 맞는지 검증하는 과정이라 위 절차를 순서대로 진행하면 된다.

   나는 PaymentRequest의 결제고유번호(imp_uid), 가맹점 주문번호(merchant_uid)를 받고, 포트원 결제 단건 조회 API 요청하여 주문테이블에 저장되어있는 정보와 비교하여 정상적인 결제가 이루어졌다고 생각하면 결제테이블에 단건 조회 결과 = 결제 정보 를 저장하고 있다.(우리의 서비스가 복잡하여 실제로는 상태값들을 조회하는 과정이 많이 포함되어 있어서 실제 저장하고 있는 코드는 다른 글에서 다룰 예정이다!)

   IamportRepository.java

   public Optional<Payment> findPaymentByImpUid(String impUid) {
          try {
              IamportResponse<com.siot.IamportRestClient.response.Payment> response =
                      iamportClient.paymentByImpUid(impUid);
              return Optional.ofNullable(paymentMapper.mapFrom(response.getResponse()));
          } catch (Exception e) {
              throw new CustomException(ErrorCode.IAMPORT_ERROR);
          }
      }

이렇게 하면 간단한 결제 구현은 할 수 있다 😉

반효경 교수님의 운영체제 수업을 정리한 내용입니다

프로세스란

실행 중인 프로그램을 프로세스라고 이야기 한다

프로세스의 문맥

프로세스의 현재 상태를 나타내는것

• CPU 수행 상태를 나타내는 하드웨어 문맥
  • 각종 레지스터
  • Program Counter
• 프로세스의 주소 공간
  • code, data, stack
• 프로세스 관련 커널 자료 구조
  • Kernel 스택
  • PCB

프로세스의 상태

크게 세가지로 나눈다

1. Running(실행): CPU를 가지고 수행중인 상태
2. Ready(준비): CPU를 기다리는 상태(1개 밖에 없으니까)
3. Blocked(대기): CPU를 줘도 당장 수행할 수 없는 상태, 자신이 요청한 이벤트(예:입출력)이 즉시 만족되지 않아 이를 기다리는 상태

-> PCB를 통하여 해당 상태를 알 수 있다

PCB(Process Control Block) 프로세스 제어 블록

운영체제가 각 프로세스를 관리하기 위해 프로세스당 유지하는 정보 운영체제 커널의 주소공간에서 프로세스 마다 PCB를 가지고 있다

• 구성요소 네가지

1. OS가 관리상 사용하는 정보
2. CPU 수행 관련 하드웨어 값
3. 메모리 관련
4. 파일 관련

왜 커널의 메모리 공간에 저장되어 있는가? CPU에서 뺏기기 전에 어디까지 실행 되었는지와 같은 정보를 저장하고 가지고 있어야 하기 때문에

문맥 교환

CPU를 한 프로세스에서 다른 프로세스로 넘겨주는 과정

• CPU를 내어주는 프로세스의 상태를 그 프로세스의 PCB에 저장
• CPU를 얻는 프로세스의 상태를 그 프로세스의 PCB에서 읽어옴

프로세스를 스케줄링하기 위한 큐

Job Queue 현재 시스템 내에 있는 모든 프로세스의 집합 Ready Queue 현재 메모리 내에 있으면서 CPU를 잡아서 실행되기를 기다리는 프로세스의 집합 Device Queue I/O device의 처리를 기다리는 프로세스의 집합

->프로세스들은 각 큐들을 오가며 수행된다. (PCB를 그 포인터를 사용해 연결 해놓는다)

스케줄러

1. Long-term scheduler(장기 스케줄러 or job scheduler) 시작 프로세스 중(new상태) 어떤 것들을 ready queue로 보낼지 결정(메모리를 줘야 Ready로 올라감) 프로세스에 메모리 및 각종자원을 주는 문제 Degree of Multiprogramming(메모리에 올라갈 프로그램의 갯수)을 제어 시분할 system에는 보통 장기 스케줄러가 없음(무조건 Ready)

2. Short-term scheduler(단기 스케줄러 or CPU scheduler) 어떤 프로세스를 다음번에 running시킬지 결정 프로세스에 CPU를 주는 문제 충분히 빨라야 함(millisecond 단위)

3. Medium-Term Scheduler(중기 스케줄러 or Swapper) → 이 스케쥴러의 도입으로 Process의 Suspended상태 개념이 추가됨 여유 공간 마련을 위해 프로세스를 통째로 메모리에서 디스크로 쫓아냄 프로세스에게서 메모리를 뺐는 문제 Degree of Multiprogramming을 제어

중기 스케줄러가 도입 된 후의 프로세스의 상태

1. Running(실행): CPU를 가지고 수행중인 상태
2. Ready(준비): CPU를 기다리는 상태(1개 밖에 없으니까)
3. Blocked(대기): CPU를 줘도 당장 수행할 수 없는 상태, 자신이 요청한 이벤트(예:입출력)이 즉시 만족되지 않아 이를 기다리는 상태
4. Suspended: 외부적인 이유로 프로세스의 수행이 정지된 상태, 프로세스는 통째로 디스크에 swap out된다

-> Blocked와 Suspended의 차이: Blocked는 프로세스의 수행이 정지되어 있지는 않다

Thread 스레드

: 프로세스 중에서 CPU 수행 단위 Thread의 구성 Program Counter Register Set Stack Space

Thread가 동료 Thread와 공유하는 부분(=Task) Code Section Data Section OS Section

스레드의 장점

1. 빠른 응답성: 멀티 스레드 웹
2. 자원 공유: code, data, resource 를 공유 가능
3. 경제적 : 프로세스 하나를 만드는것에 비해서 스레드 하나를 만드는 것이 더 경제적

프로세스의 관리

프로세스 생성

부모 프로세스가 자식 프로세스를 생성 -> 그럼 어떻게 내용을 다르게 구성하나요? : fork로 새 프로세스를 복사한 후에 exec로 기존 프로세스를 새로운 프로세스로 전환한다

프로세스의 트리(계층 구조) 형성

프로세스는 자원을 필요로 함

• 운영체제로부터 받는다.
• 부모와 공유한다

자원의 공유

• 부모와 자식이 모든 자원을 공유하는 모델
• 일부를 공유하는 모델
• 전혀 공유하지 않는 모델

수행(Execution)

• 부모와 자식은 공존하며 수행되는 모델
• 자식이 종료(terminate)될 때까지 부모가 기다리는(wait=blocked) 모델

fork() 시스템 콜

실행 중인 프로세스로부터 새로운 프로세스를 복사하는 함수. 이를 사용하면 실행중인 프로세스와 똑같은 프로세스가 하나 더 만들어 진다.

• 부모 프로세스: 복사되는 프로세스
• 자식 프로세스: 복사된 프로세스 -부모프로세스와 자식프로세스를 어떻게 구별할까? → 부모프로세스는 자식프로세스의 ID(PID)가 양수로 나오고 자식프로세스는 0이 나옴

동작 과정

• PID가 바뀐다.
• 서로 차지하는 메모리 위치가 다르므로 메모리 관련 정보가 바뀐다.

exec() 시스템 콜

기존 프로세스를 새로운 프로세스로 전환하는 함수. 이미 만들어진 프로세스의 구조를 재활용 하는 것이다.

동작 과정

• 코드 영역에 있는 기존 내용이 지워지고 새로운 코드로 바뀐다.
• 데이터 영역이 새로운 변수로 채워지고 스택 영역이 리셋된다

프로세스 종료

프로세스가 마지막 명령을 수행한 후 운영체제에게 이를 알려줌(exit)

• 자식이 부모에게 output data를 보냄(via wait)
• 프로세스의 각종 자원들이 운영체제에게 반납됨

부모 프로세스가 자식의 수행을 종료시킴(abort)

• 자식이 할당 자원의 한계치를 넘어섬
• 자식에게 할당된 태스크가 더 이상 필요하지 않음
• 부모가 종료(exit)하는 경우
  • 운영체제는 부모 프로세스가 종료되는 경우 자식이 더 이상 수행되도록 두지 않는다.
  • 단계적인 종료 -> 프로세스의 계층 구조가 있을 때 가장 말단에 있는 프로세스부터 먼저 종료시킨다

http://www.kocw.net/home/cview.do?cid=6b984f376cfb8f70 이석복 교수님의 컴퓨터네트워크 수업을 정리한 내용입니다

계층화 된 네트워크 계층 중, 가장 상위계층인 어플리케이션 계층에 대해서 먼저 다룬다.

서버-클라이언트

서버

• IP주소 고정
• 항상 열려있다

클라이언트

• 서버와 상호작용
• 동적인 IP주소를 가지고 있다

전송 프로토콜 서비스

TCP

(전송 제어 프로토콜) 연결 지향 프로토콜

UDP

(사용자 데이터그램 프로토콜) 연결 없는 프로토콜

소켓 Socket

• 프로세스는 소켓을 이용하여 메세지를 송수신 한다
• 소켓은 일종의 통신 엔드포인트로서, 특정 IP 주소와 포트 번호를 바인딩하여 네트워크 상에서 식별된다

HTTP

HTTP: hypertext transfer protocol

• 하이퍼텍스트를 전송하는 프로토콜 ( 프로토콜이란? 컴퓨터 네트워크나 통신에서 사용되는 규칙과 규약의 모음 )
• 웹은 HTTP의 별칭
• HTTP는 TCP를 사용한다
• 클라이언트에 대한 정보를 저장해 놓지 않는다 -> Stateless하다
• 80번 port 사용

HTTP 연결 두가지 방식

1. non-persistent HTTP(지속적이지 않은 HTTP) 매번 TCP연결을 새로 맺는다 응답시간이 persistent방식 보다 오래 걸린다
2. persistent HTTP(지속적인 HTTP) TCP Connection을 재사용 한다 -> 하나의 TCP Connection으로 여러개의 HTTP 송수신을 수행한다

쿠키 Cookies

• HTTP의 stateless를 보완하기 위해 웹 서버가 클라이언트에게 정보를 저장하고 추적하는데 사용
• 사용자 식별 가능

웹 캐시 Web Caches(Proxy server)

• origin server에 HTTP 요청을 하는 대신 proxy 서버에 HTTP 요청
• 사용자에 의해 빈번하게 요청되는 데이터를 사용자와 가까운 웹개시 서버에 보관하여 빠른 서비스를 제공한다
• 장점
  • 응답 시간을 줄일 수 있다
  • 웹 트래픽을 줄일 수 있다

Conditional GET

• 조건이 맞을때만 GET을 하겠다
• Proxy server에서 생기는 일관성 문제를 해결하기 위해 사용 (일관성 문제: Cache에 저장된 데이터가 최신이 아닐 수 있음)

DNS(Domain Name System)

• 전화번호부 라고 생각
• hostname 를 IP 주소로 해석. (www.naver.com -> 125.209.222.141)
• IP, Port 번호를 일일이 다 기억하기 힘드니, 도메인 이름으로 접속할 수 있도록 한 시스템
• 분산화, 계층화 시켜놨다

DNS 구조

• 최상위 DNS 서버: 루트 네임 서버
• 아래 DNS 서버: TLD(Top Level Domain) 네임 서버
• 그 아래 실제 IP주소를 가지고 있는 DNS서버: Authoritative name 서버

-> 특정 DNS 서버의 하위 DNS 서버는 해당하는 상위 DNS서버가 모두 관리

DNS 동작 과정

1. Iterative query 1) 사용자가 특정 호스트 이름의 IP 주소를 요청하는 쿼리를 날리면, Local DNS 서버가 먼저 받는다. 2) Local DNS 서버는 루트 네임 서버에게 쿼리를 날리고, 루트 네임 서버는 .edu에 해당하는 TLD를 알려준다. 3) Local DNS 서버는 edu에 해당하는 TLD에게 쿼리를 날리고, TLD는 umass.edu에 해당하는 DNS 서버를 알려준다. 4) Local DNS 서버는 umass.edu에 해당하는 DNS 서버에게 쿼리를 날리고, 해당 DNS 서버는 gaia.cs.umass.edu에 해당하는 IP 주소를 알려준다. 즉, umass.edu를 책임지는 DNS 서버가 authoritative name 서버인 것이다. 5) 마지막으로 Local DNS 서버가 사용자에게 IP 주소를 전달한다.

=> 최종 IP 주소를 받을 때까지 요청 &응답을 계속해서 local name server가 반복

2. Recursive query 1) 사용자가 특정 호스트 이름의 IP 주소를 요청하는 쿼리를 날리면, Local DNS 서버가 먼저 받는다. 2) Local DNS 서버는 루트 네임 서버에게 쿼리를 날리고, 루트 네임 서버는 .edu에 해당하는 TLD 서버에게 쿼리를 날린다. 3) edu에 해당하는 TLD 서버는 umass.edu에 해당하는 DNS 서버에게 쿼리를 날린다. 4) umass.edu에 해당하는 DNS 서버는 gaia.cs.umass.edu에 해당하는 IP 주소를 TLD 서버에게 알려준다. 즉, umass.edu를 책임지는 DNS 서버가 authoritative name 서버인 것이다. 5) TLD 서버는 루트 네임 서버에게 IP 주소를 알려준다. 6) 루트 네임 서버는 Local DNS 서버에게 IP 주소를 알려준다. 7) 마지막으로 Local DNS 서버가 사용자에게 IP 주소를 전달한다.

=> recursive하게 실제 domain name을 가지고 있는 server까지 query가 이동하여 IP 주소를 얻는 방법

TTL-> 캐시 문제 때문에 시간 정해놓고 레코드 없에기

반효경 교수님의 운영체제 수업을 정리한 내용입니다

운영체제란?

컴퓨터 하드웨어 바로 위에 설치되어 사용자 및 다른 모든 소프트웨어와 하드웨어를 연결하는 소프트웨어 계층

• 좁은 의미 운영체제의 핵심 부분으로 메모리에 상주하는 부분
• 넓은 의미 커널 뿐 아니라 각종 주변 시스템 유틸리티를 포함

운영체제의 목적

컴퓨터 시스템의 자원을 효율적으로 관리

운영체제의 분류

1. 동시 작업 가능 여부
2. 사용자의 수
   • 단일 사용자: MS-DOS, MS Windows
   • 다중 사용자: UNIX
3. 처리 방식
   • 일괄 처리(batch processing)
   • 시분할(time sharing)
   • 실시간(realtime OS)

용어 멀티태스킹: 컴퓨터 시스템이 동시에 여러 작업을 수행할 수 있는 능력. 여러 프로그램이 동시에 실행되는 것처럼 보이도록 하는 기술

멀티프로그래밍: 컴퓨터 시스템이 동시에 여러 프로그램을 메모리에 올려놓고 실행하는 기술

멀티 프로세스: 컴퓨터 시스템이 동시에 여러 개의 독립적인 프로세스를 실행하는 기술. 각 프로세스는 운영 체제로부터 독립적인 메모리 공간과 자원을 할당받아 실행된다

시분할: CPU의 시간을 분할하여 나누어 쓴다는 의미를 강조

-> 위 4개의 용어들은 비슷한 의미로 혼용됨

컴퓨터 시스템 구조

• CPU: 컴퓨터 시스템에서 중앙 처리 장치로서, 프로그램의 명령어를 해석하고 실행하는 역할을 수행
• Memory: 컴퓨터에서 프로그램과 데이터를 저장하는 공간. 주기억장치는 CPU가 직접 접근하여 데이터를 읽고 쓸 수 있는 고속의 저장장치로, RAM(Random Access Memory)과 ROM(Read-Only Memory)으로 나뉜다
• Disk: 컴퓨터에서 대용량의 데이터를 영구적으로 저장하는 보조기억장치
• I/O 입출력장치: 컴퓨터 시스템과 외부 환경 간의 데이터 흐름을 관리하는 장치

시스템콜: 사용자 프로그램이 커널 함수를 호출하는것

인터럽트

• 컴퓨터 시스템에서 발생하는 이벤트나 신호로 인해 CPU의 정상적인 실행 흐름이 중단되고, 운영체제 또는 하드웨어의 특정 처리루틴이 실행
• 넓은 의미: 하드웨어가 발생시킨 인터럽트

Trap: 소프트웨어 인터럽트

• Exception: 프로그램이 오류를 범한 경우
• 시스템 콜: 프로그램이 커널 함수를 호출하는 경우

Device Controller : 컴퓨터 시스템에서 하드웨어 장치(입출력 장치 등)를 제어하고 관리하는 부분. 해당 장치의 동작과 상호작용을 담당하여, 컴퓨터 시스템과 장치 간의 데이터 흐름을 조절

-> 두 경우 모두 I/O완료는 인터럽트로 알려줌

DMA(Direct Memomy Access) 직접 메모리 접근 :컴퓨터 시스템에서 메모리 전송을 위해 사용되는 기술로써 CPU의 개입 없이 주변장치와 메모리 간의 데이터 전송을 수행 -> 기본적으로, CPU는 데이터를 입출력 장치와 주변장치 간에 전달하기 위해 관여해야 하는데 이러한 CPU 대신 DMA 컨트롤러(DMA Controller)가 데이터 전송을 관리하고, CPU는 다른 작업을 수행할 수 있다.

저장장치 계층 구조 : 속도가 빠르고 값 비싼 저장장치를 CPU가까이 두고, 값 싸고 용량 큰 저장장치를 반대쪽에 배치

프로그램의 가상 메모리 공간 구성: code, data, stack

• code: cpu에서 수행할 기계어들이 위치
• data: 전역 변수, 프로그램이 시작될 때 부터 종료될 때 까지 남아있는 데이터들
• stack: 함수 호출, 리턴과 관련된 데이터들

사용자 프로그램이 사용하는 함수

1. 사용자 정의 함수: 자신의 프로그램에서 정의한 함수
2. 라이브러리 함수: 자신의 프로그램에서 정의하지 않고 가져다 쓴 함수
3. 커널 함수: 운영체제 프로그램의 함수

-> 커널 함수의 호출 = 시스템 콜