BackEnd/Server

특정 요건에서는 이벤트의 순서가 반드시 보장되어야 하는 경우가 있다.  철수는 100원을 가진 상태에서 100원을 더 입금하고 200원을 결제했다. 하지만 어떤 이유로 먼저 발행된(t=5)인 100원 입금 이벤트보다 나중에 발행된(t=10) 200원 인출 이벤트가 먼저 도착했다. 철수는 잔액 부족으로 결제를 실패할 것이다 !! 자칫 이렇게 순서가 어긋나게 도착하는 경우는 안 일어날 것이라고 생각할 수 있다. 하지만 절대 어긋나지 않을 것이라는 보장은 없다. 순서를 보장하지 않는 경우, 결국 부정확한 결과를 초래할 수 있다. 오늘은 이런 비순차 이벤트, 지각 이벤트에 대해 말해보고자 한다. 여러 파티션에서 이벤트를 소비할 경우, 이벤트 처리 순서를 어떻게 정할 것인지?순서가 어긋난 이벤트, 지각 이벤트는..

모놀리식 기반의 레거시 시스템을 이벤트 기반 아키텍처로 전환하는 것은 여러 기업이 성장하면서 새로운 비즈니스 요건을 충족해야 하거나 규모를 늘릴 때 많이 거쳐가는 단계이다. 오늘은 이 과정에서 이벤트 기반 마이크로서비스 아키텍처로 마이그레이션할 때 필요한 "데이터 해방"에 대해 얘기해보려고 한다. 0. 데이터 해방이란?데이터해방(data liberation)은 교차 도메인 데이터 세트(cross-domain data set)를 식별하여 각 이벤트 스트림에 발행하는 이벤트 기반 아키텍처의 마이그레이션 전략이다. 나는 '해방'의 의미를 '놓아주다'로 해석했는데, 기존(레거시) 비즈니스 도메인에 묶여있는 데이터들을 다른 서비스가 소비(이벤트 등)할 수 있도록 데이터를 소싱하는 과정이라고 해석했다. 데이터를 해..

문제프로젝트 전체를 Spring Cloud를 이용하여 기본 뼈대를 MSA구조로 구축했다. 하지만 여기서 문제가 생겼다. public class App extends BaseTimeEntity { //... @ManyToOne(fetch = FetchType.LAZY) @JoinColumn(name = "user_id", nullable = false) private User user;} 기존에 설계했던 App Entity 는 User Entity와 연관관계 매핑으로 해결하려고 설계했다. 하지만, 지금 프로젝트 구성상 app-service와 user-service를 나누어 두었다. 그래서 app-service에선 user를 참조할 수 없는 것이다. 이에 관련해서 몇 가지 글들을..

https://nginxstore.com/blog/nginx/nginx-%EC%84%B1%EB%8A%A5-%ED%99%95%EC%9E%A5%EC%9D%84-%EC%9C%84%ED%95%9C-%EC%84%A4%EA%B3%84-%EB%B0%A9%EB%B2%95/ NGINX는 Master Process아래 여러 worker와 helper가 있다. # ps -ef --forest | grep nginx root 32475 1 0 13:36 ? 00:00:00 nginx: master process /usr/sbin/nginx -c /etc/nginx/nginx.conf nginx 32476 32475 0 13:36 ? 00:00:00 _ nginx: worker process nginx 32477 32475 0..

ngnix SSL 인증 키가 있다면 다음과 같이 설정하자!! 80포트(HTTP)로 들어올 시 443(HTTPS)로 Redirect하게 설정했다. 추가로, .html 을 rewrite까지 설정했다. /etc/nginx/nginx.conf # For more information on configuration, see: # * Official English Documentation: http://nginx.org/en/docs/ # * Official Russian Documentation: http://nginx.org/ru/docs/ user ec2-user; worker_processes auto; error_log /var/log/nginx/error.log notice; pid /run/nginx...

시세 정보 시세 정보는 거래소로부터 실시간으로 정보를 받는다. 아무래도 시세 정보를 다루려면 실시간으로 다루어야 하기 때문에, 낮은 지연시간, 빠른 장애 복구 를 우선시 해야한다. 토스의 시세정보 처리 과정을 살펴보겠다. 거래소로부터 받아오는 시세 정보를 UDP 멀티캐스트 그룹에 접속해서 읽어온다. 빠른 통신을 위해서 UDP를 사용하는 것 같다. 이 때, 헤더에 수신 시각을 포함하여 처리부에서 총 처리 시간을 측정한다. 처리부가 Redis에 저장하고, REST API를 제공한다. 처리부가 비지니스 로직이 가장 많기 때문에 장애 발생 확률이 가장 높다. 따라서, 처리부를 여러개로 늘리는 방법을 선택했다. 평소에는 한 처리부(처리부 A)를 가동하다가, 장애가 발생하면 빠르게 처리부 B로 전환할 수 있다. Z..