태그: 메시지큐
6편
-
RabbitMQ·Redis 큐 vs Kafka vs NATS: 메시징 시스템별 철학과 선택 기준
RabbitMQ·Redis 큐, Kafka, NATS가 메시지를 다루는 방식의 차이를 비교하고, ack 전에 컨슈머가 죽거나 offset 커밋 순서가 틀려 메시지가 중복·유실되는 상황을 at-least-once 전달과 멱등 처리로 막는 방법을 Python 예제로 설명합니다.
-
C++에서 Kafka 쓰기: librdkafka 프로듀서·컨슈머 그룹, 오프셋 관리, 리밸런싱과 메시지 유실
C++에서 Apache Kafka 연동. librdkafka로 프로듀서와 컨슈머 그룹 구현, 오프셋 관리, 연결 타임아웃·메시지 유실·리밸런싱 같은 흔한 문제 해결, 배치·압축 성능 최적화를 다룹니다.
-
C++ Kafka 고급 활용 | librdkafka·Exactly-Once Semantics (EOS)·트랜잭션·스트림 처리
librdkafka로 C++ 스트림 파이프라인을 만들 때 메시지를 중복·유실 없이 처리하는 방법을 다룹니다. 멱등 프로듀서, 트랜잭션 API와 read_committed 컨슈머, 리밸런스 뒤 중복 처리, Queue full·Not leader 같은 에러 대응을 예제로 설명합니다.
-
C++에서 RabbitMQ 쓰기: SimpleAmqpClient·rabbitmq-c, 토픽 라우팅, Dead Letter, 메시지 TTL
이메일 발송 같은 느린 작업 때문에 API 응답이 막힐 때 RabbitMQ로 비동기 처리하는 방법. SimpleAmqpClient와 rabbitmq-c 설치·연결, 프로듀서·컨슈머, 토픽 라우팅, 우선순위 큐, Dead Letter와 TTL을 다룹니다.
-
C++ RabbitMQ 고급 기능 | Topic·Priority Queue·Dead Letter·TTL
rabbitmq-c와 SimpleAmqpClient로 로그 레벨별 토픽 라우팅, VIP 메시지를 먼저 처리하는 우선순위 큐, 실패 메시지를 모으는 Dead Letter Exchange, 메시지·큐 TTL을 구현하고 PRECONDITION_FAILED 같은 선언 충돌 에러를 해결합니다.
-
C++에서 RabbitMQ·Kafka 연동하기: 메시지 큐 기반 비동기 처리 구현과 에러 대응
주문 처리처럼 결제·재고·메일을 동기로 묶어 느려진 서비스를 RabbitMQ와 Kafka 프로듀서·컨슈머로 나누는 C++ 코드를 보여줍니다. 두 브로커의 선택 기준, ACK 전 크래시로 인한 메시지 유실, 리밸런스 중 오프셋 커밋 실패 대응도 담았습니다.