- 도메인 서열 분리 
    - Core Domain:  order, delivery : 안될 핵심 서비스이며, 연견 Up-time SLA 수준을 99.999% 목표, 배포주기는 order 의 경우 1주일 1회 미만, delivery 의 경우 1개월 1회 미만
    - Supporting Domain: 경쟁력을 내기위한 서비스이며, SLA 수준은 연간 60% 이상 uptime 목표, 배포주기는 각 팀의 자율이나 표준 스프린트 주기가 1주일 이므로 1주일 1회 이상을 기준으로 함.
    - General Domain:   pay : 결제서비스로 3rd Party 외부 서비스를 사용하는 것이 경쟁력이 높음 (핑크색으로 이후 전환할 예정)

- 고객이  주문한다 (ok)
- 주문을 하면 결제 기능이 호출된다 (ok)
- 고객이 주문 취소할 수 있다 (ok)
- 주문이 취소되면 결재가 취소된다 (ok)
- 결재가 취소되면 배송이 취소된다 (ok)
- 고객이 주문상태를 확인한다 (ok)

  1 결제가 되지 않은 주문건은 아예 거래가 성립되지 않아야 한다  Sync 호출 (ok)
  2 주문은 365일 24시간 받을 수 있어야 한다  Async (event-driven), Eventual Consistency (ok)

- Chris Richardson, MSA Patterns 참고하여 Inbound adaptor와 Outbound adaptor를 구분함
- 호출관계에서 PubSub 과 Req/Resp 를 구분함
- 서브 도메인과 바운디드 컨텍스트의 분리:  각 팀의 KPI 별로 아래와 같이 관심 구현 스토리를 나눠가짐

cd gateway
mvn spring-boot:run

cd order
mvn spring-boot:run 

cd pay
mvn spring-boot:run  

cd delivery
mvn spring-boot:run  

cd cancel
mvn spring-boot:run  

cd mypage
mvn spring-boot:run  

## DDD 의 적용

- 각 서비스내에 도출된 핵심 Aggregate Root 객체를 Entity 로 선언하였다: (예시는 order 마이크로 서비스). 이때 가능한 현업에서 사용하는 언어 (유비쿼터스 랭귀지)를 그대로 사용하려고 노력하였고 영문으로 사용하여 별다른 오류 없이 구현하였다.

@Id
@GeneratedValue(strategy=GenerationType.AUTO)
private Long id;
private String productId;
private Integer qty;
private String status;

public Long getId() {
    return id;
}

public void setId(Long id) {
    this.id = id;
}
public String getProductId() {
    return productId;
}

public void setProductId(String productId) {
    this.productId = productId;
}
public Integer getQty() {
    return qty;
}

public void setQty(Integer qty) {
    this.qty = qty;
}
public String getStatus() {
    return status;
}

public void setStatus(String status) {
    this.status = status;
}

- Entity Pattern 과 Repository Pattern 을 적용하여 JPA 를 통하여 다양한 데이터소스 유형 (RDB or NoSQL) 에 대한 별도의 처리가 없도록 데이터 접근 어댑터를 자동 생성하기 위하여 Spring Data REST 의 RestRepository 를 적용하였다

- 적용 후 REST API 의 테스트

# order 서비스의 주문취소 처리
http DELETE http://localhost:8081/orders/1

![image](https://user-images.githubusercontent.com/68535067/97144196-5f40ed80-17a7-11eb-8ace-5792c7b783d9.png)

## 동기식 호출 과 Fallback 처리

분석단계에서의 조건 중 하나로 주문(order)->결제(pay) 간의 호출은 동기식 일관성을 유지하는 트랜잭션으로 처리하기로 하였다. 호출 프로토콜은 이미 앞서 Rest Repository 에 의해 노출되어있는 REST 서비스를 FeignClient 를 이용하여 호출하도록 한다. 

- 결제서비스를 호출하기 위하여 Stub과 (FeignClient) 를 이용하여 Service 대행 인터페이스 (Proxy) 를 구현 

@RequestMapping(method= RequestMethod.POST, path="/pays")
public void payment(@RequestBody Pay pay);


@RequestMapping(method= RequestMethod.POST, path="/pays")
public void paymentcancel(@RequestBody Pay pay);

- 주문을 받은 직후(@PostPersist) 결제를 요청하도록 처리

@PostPersist
public void onPostPersist(){
    Ordered ordered = new Ordered();
    BeanUtils.copyProperties(this, ordered);
    ordered.publishAfterCommit();

    //Following code causes dependency to external APIs
   // it is NOT A GOOD PRACTICE. instead, Event-Policy mapping is recommended.

    yes.external.Pay pay = new yes.external.Pay();
    pay.setOrderId(ordered.getId());
    Long lChargeAmount = Long.valueOf(12000);
    pay.setChargeAmount(lChargeAmount);
    pay.setStatus("Payed");

    // mappings goes here
    OrderApplication.applicationContext.getBean(yes.external.PayService.class)
        .payment(pay);


}
```

# 결제 (pay) 서비스를 잠시 내려놓음 (ctrl+c)

#주문처리
http localhost:8082/orders productId="Harry Portter" qty=1   #Fail

![image](https://user-images.githubusercontent.com/68535067/97143766-a4185480-17a6-11eb-9bb1-e2eff4e2cb04.png)

#결제서비스 재기동
cd pay
mvn spring-boot:run

#주문처리
http localhost:8082/orders productId="Harry Portter" qty=1   #Success

![image](https://user-images.githubusercontent.com/68535067/97144102-36205d00-17a7-11eb-9b4b-8956467228d7.png)

package yes;

import javax.persistence.*;
import org.springframework.beans.BeanUtils;
import java.util.List;

@Entity
@Table(name="Pay_table")
public class Pay {

    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private Long id;
    private Long orderId;
    private Long chargeAmount;
    private String status;

    @PostPersist
    public void onPostPersist() {
   	 if(this.getStatus().equals("Payed")){
	    PayConfirmed payConfirmed = new PayConfirmed();
	    BeanUtils.copyProperties(this, payConfirmed);
 	    payConfirmed.publishAfterCommit();
	 }else if(this.getStatus().equals("Pay Canceled")){
        PayCancelled payCancelled = new PayCancelled();
        BeanUtils.copyProperties(this, payCancelled);
        payCancelled.publishAfterCommit();
	 }

package yes;

import yes.config.kafka.KafkaProcessor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Service;

@Service
public class PolicyHandler{
    @StreamListener(KafkaProcessor.INPUT)
    public void onStringEventListener(@Payload String eventString){

    }

    @Autowired
    DeliveryRepository deliveryRepository;

    @StreamListener(KafkaProcessor.INPUT)
    public void wheneverPayConfirmed_Ship(@Payload PayConfirmed payConfirmed){

        if(payConfirmed.isMe()){
            System.out.println("##### listener Ship : " + payConfirmed.toJson());

            Delivery delivery = new Delivery();
            delivery.setOrderId(payConfirmed.getOrderId().toString());
            delivery.setStatus("Shipping");
            delivery.setDeliveryInfo("Delivery Info");

            deliveryRepository.save(delivery);

        }
    }

# 배송 서비스 (delivery) 를 잠시 내려놓음 (ctrl+c)

#주문처리
http localhost:8082/orders productId="Harry Portter3" qty=1   #Success

![image](https://user-images.githubusercontent.com/68535067/97149492-2ce7be00-17b0-11eb-9ade-c845abb1cb04.png)

#주문상태 확인
http localhost:8082/orders     # 주문상태 안바뀜 확인

![image](https://user-images.githubusercontent.com/68535067/97149492-2ce7be00-17b0-11eb-9ade-c845abb1cb04.png)

#delivery 서비스 기동
cd delivery
mvn spring-boot:run

#주문상태 확인
http localhost:8082/orders     # 모든 주문의 상태가 "배송됨"으로 확인

![image](https://user-images.githubusercontent.com/68535067/97149492-2ce7be00-17b0-11eb-9ade-c845abb1cb04.png)

# application.yml
feign:
  hystrix:
    enabled: true

hystrix:
  command:
    default:
      execution.isolation.thread.timeoutInMilliseconds: 60000

# (pay)pay.java (Entity)

    @PostPersist
    public void onPostPersist(){
        Paid paid = new Paid();
        BeanUtils.copyProperties(this, paid);
        paid.publishAfterCommit();

        try {
            Thread.sleep((long) (800 + Math.random() * 300));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

kubectl autoscale deploy payment --min=1 --max=10 --cpu-percent=15

siege -c100 -t120S -r10 --content-type "application/json" 'http://request:8080/requests POST {"memberId": "100", "qty":5}'

kubectl get deploy pay -w

siege -c100 -t120S -r10 --content-type "application/json" 'http://request:8080/requests POST {"memberId": "100", "qty":5}'

kubectl set image ...

# deployment.yaml 의 readiness probe 의 설정:


kubectl apply -f kubernetes/deployment.yaml