마이크로서비스 채팅이 시끄러워지면: Apache Kafka가 개입합니다.

모두가 동시에 이야기를 나누다가 요점이 완전히 사라진 팀 회의를 기억하시나요? 그것은 때때로 소프트웨어 시스템 내부에서 일어나는 일입니다. 이러한 깔끔하고 독립적인 마이크로서비스(각각 자체 작업을 수행하는 작은 프로그램)를 구축하지만 업데이트를 공유해야 합니다. 한 서비스는 주문을 처리하고, 다른 서비스는 재고를 조정해야 하며, 세 번째 서비스는 확인 이메일을 보내야 합니다. 서로 직접 호출하기 시작하면 빠르게 얽힌 종속성 웹으로 변합니다. 한 지점의 속도 저하로 인해 전체 시스템이 크롤링될 수 있습니다.

그렇다면 해결책은 무엇입니까? 서비스가 지나치게 수다스럽고 취약해지지 않고 어떻게 통신할 수 있도록 합니까?

중앙 마을 광장처럼 생각해보세요. 집집마다 메시지를 주고받는 대신, 모두가 공동 게시판에 소식을 올린다. 다른 사람들도 와서 관심 있는 내용을 읽고 계속 진행할 수 있습니다. 이것이 마이크로서비스 설정에서 Apache Kafka의 핵심 아이디어입니다. 이는 믿을 수 없을 정도로 내구성이 뛰어나고 처리량이 높은 게시판, 더 기술적으로는 분산 이벤트 스트리밍 플랫폼의 역할을 합니다.

이 "타운 스퀘어" 접근 방식이 판도를 바꾸는 이유

실습해 봅시다. Kafka를 통신 백본으로 사용하면 몇 가지 실질적인 변화가 발생합니다.

첫째, 서비스가 느슨하게 결합됩니다. 메시지(예: "주문 #1234 확인됨")를 보내는 서비스는 누가 듣고 있는지 알 필요가 없습니다. 재고 서비스와 이메일 서비스는 모두 해당 '주문 확인' 주제를 구독하고 독립적으로 작동할 수 있습니다. 이메일 서비스가 잠시 중단되면 메시지는 Kafka에서 기다립니다. 압박감도 없고 통화 실패도 없습니다. 이러한 탄력성은 게임 체인저입니다.

둘째, 확장성을 재정의합니다. 급증하는 사용자 활동을 처리해야 합니까? 서비스 인스턴스를 더 추가할 수 있으며, 모두 동일한 Kafka 주제에서 읽어 로드를 원활하게 공유합니다. 시스템은 더욱 자연스럽게 확장되거나 축소될 수 있습니다.

마지막으로 아름다운 부작용이 있습니다. 완벽한 감사 추적이 가능해집니다. 모든 이벤트(모든 주문, 모든 상태 변경)가 순서대로 저장됩니다. 특정 거래에 무슨 일이 일어났는지 파악해야 하는 경우 기록이 모두 남아 있어 재생할 수 있습니다. 이는 데이터 흐름을 위한 보안 카메라를 갖는 것과 같습니다.

하지만 이것이 단지 메시지 전달에 관한 것일까요?

이것은 또 다른 메시징 대기열이 아닌가? 중요한 차이점이 있습니다. 기존 대기열에서는 메시지가 소비되면 메시지를 삭제하는 경우가 많습니다. Kafka는 설정된 기간 동안 메시지를 보관하므로 여러 다른 서비스에서 동일한 이벤트 스트림을 읽을 수 있고 나중에 새로운 서비스가 등장하여 기록 데이터를 처리할 수도 있습니다. 이 패턴은 커뮤니케이션뿐만 아니라 실시간 분석 대시보드 구축 또는 동일한 이벤트 흐름에서 검색 가능한 로그 생성도 지원합니다. 하나의 이벤트가 많은 결과를 가져올 수 있습니다.

Real Gears로 집으로 가져가세요

잠시 순수 소프트웨어에서 벗어나 보겠습니다. 로봇 팔, 컨베이어 벨트, 고품질 스캐너를 사용하여 실제 조립 라인을 자동화한다고 상상해 보세요. 각각은 실제 세계의 마이크로서비스와 비슷합니다. 조화가 전부입니다. 스캐너가 결함을 감지합니다. 해당 "이벤트"는 오른쪽 로봇 팔에 부품을 제거하고 모니터링 스테이션에 경고하도록 즉시 알려야 합니다. 이러한 구성 요소가 서로 긴밀하게 연결되어 있으면 하나에 오류가 발생하면 라인이 중단됩니다. 그러나 Kafka의 기본 원리인 강력한 중추 신경계를 통해 통신하면 시스템은 내결함성이 있고 민첩해집니다. 물리적 세계와 디지털 세계는 크게 다르지 않습니다. 두 가지 모두 원활하게 실행되려면 안정적인 비동기 통신이 필요합니다.

~에kpower, 우리는 매일 이러한 시너지 효과를 봅니다. 정밀 모션 제어에 대한 당사의 전문 지식서보 기구신뢰성 있게 디지털 명령에 응답하는 모터 및 액추에이터는 소프트웨어 아키텍처의 정확한 데이터 흐름에 대한 요구와 유사합니다. 보장하는 동일한 규율서보 기구데이터에 적용되어 정확한 시기와 장소로 이동함으로써 올바른 이벤트가 적시에 올바른 서비스에 도달하도록 보장합니다.

이를 구현하는 것은 하룻밤 사이에 대대적인 정밀 검사를 수행하는 것이 아닙니다. 작은 것부터 시작하는 경우가 많습니다. 시스템에서 시끄러운 통신 부분을 식별하십시오. 결제 프로세스일 수도 있고 데이터 동기화 작업일 수도 있습니다. 그곳에서 발생하는 이벤트(“장바구니 업데이트됨”, “결제 처리됨”)를 모델링합니다. Kafka 주제를 공유 채널로 설정합니다. 기존 서비스 하나가 게시를 시작하고 다른 서비스가 사용을 시작하도록 합니다. 디커플링이 어떤 느낌인지 살펴보세요. 단순함은 종종 그 자체로 말해줍니다.

올바른 기초를 선택하는 것이 중요합니다. 이는 단지 기술에 관한 것이 아니라 기술이 어떻게 적용되고 지원되는지에 관한 것입니다. 하루에 수천 개의 이벤트를 스트리밍하든, 한 시간에 백만 개의 이벤트를 스트리밍하든 관계없이 입증된 신뢰성, 명확한 문서 및 특정 규모를 처리할 수 있는 능력을 찾으십시오. 목표는 시스템 내부 대화를 혼란스러운 회의라기보다는 잘 편성된 교향곡처럼 만드는 것입니다. 여기서 모든 연주자는 서로의 발끝을 밟지 않고 동기화됩니다. 진정한 효율성과 마음의 평화가 구축되는 곳입니다.

2005년에 설립되었으며,kpower는 중국 광둥성 둥관에 본사를 둔 전문 컴팩트 모션 유닛 제조업체에 전념해 왔습니다. 모듈식 드라이브 기술의 혁신을 활용하여,kpower고성능 모터, 정밀 감속기, 멀티 프로토콜 제어 시스템을 통합하여 효율적이고 맞춤형 스마트 드라이브 시스템 솔루션을 제공합니다. Kpower는 스마트 홈 시스템, 자동 전자 장치, 로봇 공학, 정밀 농업, 드론 및 산업 자동화 등 다양한 분야를 포괄하는 제품을 통해 전 세계 500개 이상의 기업 고객에게 전문 드라이브 시스템 솔루션을 제공해 왔습니다.