- 과정중 도출된 잘못된 도메인 이벤트들을 걸러내는 작업을 수행함
    - 중복/불필요, 처리 프로세스에 해당하는 이벤트 제거

-가입신청, 서비스관리센터, 설치 부분을 정의함

- 도메인 서열 분리 : 가입신청 -> 서비스관리센터 -> 설치 순으로 정의

- View Model 추가

# ManagementCenter.java (Entity)

    @PostUpdate
    public void onPostUpdate() {
            ipTVShopProject.external.Installation installation = new ipTVShopProject.external.Installation();

            installation.setOrderId(this.getOrderId());
            ManagementCenterApplication.applicationContext.getBean(ipTVShopProject.external.InstallationService.class)
                    .installationCancellation(installation);

	-------->
	
            ManagementCenterApplication.applicationContext.getBean(ipTVShopProject.external.InstallationService.class)
                    .installationCancellation2222222(installation);
    }	    

# ManagementCenter.java (Entity)

    @PostUpdate
    public void onPostUpdate(){
    /**
            ipTVShopProject.external.Installation installation = new ipTVShopProject.external.Installation();

            installation.setOrderId(this.getOrderId());
            ManagementCenterApplication.applicationContext.getBean(ipTVShopProject.external.InstallationService.class)
                    .installationCancellation(installation);

    **/
    } 

- Local
	cd Order
	mvn spring-boot:run

	cd ManagementCenter
	mvn spring-boot:run

	cd Installation
	mvn spring-boot:run

	cd orderstatus
	mvn spring-boot:run

- EKS : CI/CD 통해 빌드/배포 ("운영 > CI-CD 설정" 부분 참조)

	package ipTVShopProject;

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

	@Entity
	@Table(name="Installation_table")
	public class Installation {

		@Id
		@GeneratedValue(strategy=GenerationType.AUTO)
		private Long id;
		private Long engineerId;
		private String engineerName;
		private String installReservationDate;
		private String installCompleteDate;
		private Long orderId;
		private String status;

		public Long getId() {
			return id;
		}

		public void setId(Long id) {
			this.id = id;
		}
		public Long getEngineerId() {
			return engineerId;
		}

		public void setEngineerId(Long engineerId) {
			this.engineerId = engineerId;
		}
		public String getEngineerName() {
			return engineerName;
		}

		public void setEngineerName(String engineerName) {
			this.engineerName = engineerName;
		}
		public String getInstallReservationDate() {
			return installReservationDate;
		}

		public void setInstallReservationDate(String installReservationDate) {
			this.installReservationDate = installReservationDate;
		}
		public String getInstallCompleteDate() {
			return installCompleteDate;
		}

		public void setInstallCompleteDate(String installCompleteDate) {
			this.installCompleteDate = installCompleteDate;
		}
		public Long getOrderId() {
			return orderId;
		}

		public void setOrderId(Long orderId) {
			this.orderId = orderId;
		}
		public String getStatus() {
			return status;
		}

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

	}

	<dependency>
		<groupId>mysql</groupId>
		<artifactId>mysql-connector-java</artifactId>
		<scope>runtime</scope>
	</dependency>

	datasource:
		url: ${url}
		username: ${username}
		password: ${password}
		driver-class-name: com.mysql.cj.jdbc.Driver

    env:
      - name: url
	valueFrom:
	  configMapKeyRef:
	    name: iptv
	    key: urlstatus 
      - name: username
	valueFrom:
	  secretKeyRef:
	    name: iptv
	    key: username          
      - name: password
	valueFrom:
	  secretKeyRef:
	    name: iptv
	    key: password    

# (ManagementCenter) InstallationService.java

	package ipTVShopProject.external;


	@FeignClient(name="Installation", url="http://Installation:8080")
	public interface InstallationService {

		@RequestMapping(method= RequestMethod.PATCH, path="/installations")
		public void installationCancellation(@RequestBody Installation installation);

	}

# (Installation) InstallationController.java

	package ipTVShopProject;

	@RestController
	public class InstallationController {
	    @Autowired
	    InstallationRepository installationRepository;

	    @RequestMapping(method=RequestMethod.POST, path="/installations")
	    public void installationCancellation(@RequestBody Installation installation) {

		Installation installationCancel = installationRepository.findByOrderId(installation.getOrderId());
		installationCancel.setStatus("INSTALLATIONCANCELED");
		installationRepository.save(installationCancel);

	    }
	}

# (order) order.java

    @PostPersist
    public void onPostPersist(){

        if(this.getStatus().equals("JOINORDED")){
            JoinOrdered joinOrdered = new JoinOrdered();
            BeanUtils.copyProperties(this, joinOrdered);
            joinOrdered.publishAfterCommit();
        }
    }

# (ManagementCenter) PolicyHandler.java

@Service
public class PolicyHandler{
    @Autowired
    ManagementCenterRepository managementCenterRepository;

    @StreamListener(KafkaProcessor.INPUT)
    public void wheneverJoinOrdered_OrderRequest(@Payload JoinOrdered joinOrdered){

        if(joinOrdered.isMe()){
            ManagementCenter oa = new ManagementCenter();

            oa.setOrderId(joinOrdered.getId());
            oa.setInstallationAddress(joinOrdered.getInstallationAddress());
            oa.setId(joinOrdered.getId());
            oa.setStatus("JOINORDED");
            oa.setEngineerName("Engineer" + joinOrdered.getId());
            oa.setEngineerId(joinOrdered.getId() + 100);

            managementCenterRepository.save(oa);
        }
    }
}

# application.yml 파일에 라우팅 경로 설정

spring:
  profiles: docker
  cloud:
    gateway:
      routes:
        - id: Order
          uri: http://Order:8080
          predicates:
            - Path=/orders/** 
        - id: ManagementCenter
          uri: http://ManagementCenter:8080
          predicates:
            - Path=/managementCenters/** 
        - id: Installation
          uri: http://Installation:8080
          predicates:
            - Path=/installations/** 
        - id: orderstatus
          uri: http://orderstatus:8080
          predicates:
            - Path=/orderStatuses/** 
      globalcors:
        corsConfigurations:
          '[/**]':
            allowedOrigins:
              - "*"
            allowedMethods:
              - "*"
            allowedHeaders:
              - "*"
            allowCredentials: true

server:
  port: 8080

# buildspec.yml 설정

  cat <<EOF | kubectl apply -f -
  apiVersion: v1
  kind: Service
  metadata:
    name: $_PROJECT_NAME
    labels:
      app: $_PROJECT_NAME
    spec:
    ports:
      - port: 8080
        targetPort: 8080
    selector:
      app: $_PROJECT_NAME
    type: LoadBalancer
  EOF

kubectl get deploy managementcenter -o yaml > managementcenter_deploy.yaml 
kubectl apply -f <(istioctl kube-inject -f managementcenter_deploy.yaml) 

kubectl get deploy installation -o yaml > installation_deploy.yaml 
kubectl apply -f <(istioctl kube-inject -f installation_deploy.yaml) 

cat <<EOF | kubectl apply -f -
apiVersion: networking.istio.io/v1alpha3
kind: DestinationRule
metadata:
  name: installation
spec:
  host: installation
  trafficPolicy:
    connectionPool:
      tcp:
        maxConnections: 1           # 목적지로 가는 HTTP, TCP connection 최대 값. (Default 1024)
      http:
        http1MaxPendingRequests: 1  # 연결을 기다리는 request 수를 1개로 제한 (Default 
        maxRequestsPerConnection: 1 # keep alive 기능 disable
        maxRetries: 3               # 기다리는 동안 최대 재시도 수(Default 1024)
    outlierDetection:
      consecutiveErrors: 5          # 5xx 에러가 5번 발생하면
      interval: 1s                  # 1초마다 스캔 하여
      baseEjectionTime: 30s         # 30 초 동안 circuit breaking 처리   
      maxEjectionPercent: 100       # 100% 로 차단
EOF

kubectl autoscale deploy order --min=1 --max=10 --cpu-percent=1

kubectl get deploy order -w

kubectl get hpa order -w

siege -c50 -t180S --content-type "application/json" 'http://a518c6481215d478b8b769aa034cdff4-46291629.us-east-2.elb.amazonaws.com:8080/orders POST {"productId": "2001", "productName": "internet", "installationAddress": "Seoul", "customerId": "1", "orderDate": "20200715", "status": "JOINORDED"}'

siege -c30 -t150S --content-type "application/json" 'http://a518c6481215d478b8b769aa034cdff4-46291629.us-east-2.elb.amazonaws.com:8080/orders POST {"productId": "2001", "productName": "internet", "installationAddress": "Seoul", "customerId": "1", "orderDate": "20200715", "status": "JOINORDED"}'

cat <<EOF | kubectl apply -f -
apiVersion: v1
kind: ConfigMap
metadata:
  name: iptv
data:
  urlstatus: "jdbc:mysql://iptv.cgzkudckye4b.us-east-2.rds.amazonaws.com:3306/orderstatus?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8"
EOF

cat <<EOF | kubectl apply -f -
apiVersion: v1
kind: Secret
metadata:
  name: iptv
type: Opaque
data:
  username: xxxxx <- 보안 상, 임의의 값으로 표시함 
  password: xxxxx <- 보안 상, 임의의 값으로 표시함
EOF

  - Kubernetes API 서버 컴포넌트 로그(api)
  - 감사(audit) 
  - 인증자(authenticator) 
  - 컨트롤러 관리자(controllerManager)
  - 스케줄러(scheduler)

출처 : https://docs.aws.amazon.com/ko_kr/eks/latest/userguide/logging-monitoring.html

기본적으로 클러스터 제어 플레인 로그는 CloudWatch Logs로 전송되지 않습니다. 
클러스터에 대해 로그를 전송하려면 각 로그 유형을 개별적으로 활성화해야 합니다. 
CloudWatch Logs 수집, 아카이브 스토리지 및 데이터 스캔 요금이 활성화된 제어 플레인 로그에 적용됩니다.

출처 : https://docs.aws.amazon.com/ko_kr/eks/latest/userguide/control-plane-logs.html

아래 내용 출처: https://bcho.tistory.com/1296?category=731548