RocketMQ 네이티브 API 사용법
일반 메시지
생산자
단방향 전송
메시지를 한 방향으로만 전송하며, 전송 성공 여부를 확인할 수 없습니다.
// 생산자 그룹 지정하여 생산자 생성
DefaultMQProducer producer = new DefaultMQProducer("oneway-producer-group");
// 네임서버 주소 설정
producer.setNamesrvAddr("127.0.0.1:9876");
// 생산자 시작
producer.start();
// 토픽 지정 ...
8월 3일 19:36에 게시됨
Canal과 RocketMQ를 활용한 MySQL 데이터 증분 동기화 구현
개요
Canal은 MySQL의 바이너리 로그(binlog)를 기반으로 증분 데이터를 실시간으로 파싱하고, 이를 외부 시스템에 전달하는 오픈소스 미들웨어입니다. 주요 원리는 MySQL 슬레이브처럼 동작하여 마스터 DB로부터 binlog 스트림을 수신한 후, 해당 이벤트를 해석해 외부 소비자에게 제공하는 것입니다.
주요 사용 사례로는 다음과 같은 시나리오가 있습니다:
데이터베 ...
7월 15일 05:18에 게시됨
RocketMQ 하이어빌리티 클러스터 설치 및 설정 매뉴얼
시스템 전제 조건 및 환경 초기화
로켓 MQ(RocketMQ) 클러스터를 배포하기 위해서는 서버 간 네트워크 안정성과 일관된 시간 동기화가 필수적입니다. 먼저 방화벽과 SELinux 는 테스트 환경에서는 비활성화하고, 프로덕션 환경에서는 최소 권한 원칙에 따라 규칙을 적용해야 합니다.
시간 동기화 설정
서버 간 시간 오차는 메시지 순차 처리와 브로커 상태 확인에 치명적 ...
7월 10일 20:14에 게시됨
RocketMQ 이중 마스터 클러스터 구성 방법
실제 운영 환경에서 고가용성과 성능을 고려할 때, RocketMQ의 이중 마스터(Master-Master) 아키텍처는 충분한 안정성을 제공합니다. 아래에서는 두 대의 리눅스 서버를 활용해 이중 마스터 클러스터를 구축하는 절차를 설명합니다.
서버 정보
서버 A: 121.43.181.101
서버 B: 47.114.41.151
1. 설치 파일 다운로드 및 압축 해제 (A, B 동시 수행)
공식 미러 사이 ...
6월 25일 16:13에 게시됨
RocketMQ "No topic route info in name server for the topic" 오류 해결 가이드
배경
비즈니스 팀이 사용하는 RocketMQ 클러스터는 미들웨어 그룹에서 구축했으며, 클라이언트는 마이크로서비스 그룹이 원시 RocketMQ 클라이언트를 기반으로 캡슐화한 xcloud-rocketmq입니다.
비즈니스 팀은 프로젝트 출시 이후 온라인 프로그램에서 지속적으로 다음과 같은 오류가 발생한다고 피드백했습니다:
No topic route info in name server for the topic: RMQ_S ...
6월 18일 19:39에 게시됨
RocketMQ 단일 머신 테스트 환경 구성하기
1. RocketMQ 네트워크 생성
Docker를 사용하여 RocketMQ 전용 네트워크를 생성합니다.
[root@mq011 ~]# docker network create rocketmq-custom
a2f5b7c8d9e01f23g4h5i6j7k8l9m0n1o2p3q4r5s6t7u8v9w0x1y2z3a4b5c6d7e8f9g0h1
[root@mq011 ~]# docker inspect rocketmq-custom
[
{
"Name": "rocketmq-custom",
"Id": &quo ...
5월 29일 05:51에 게시됨
RocketMQ Producer 초기화와 내부 동작 메커니즘 분석
RocketMQ 메시지 플랫폼에서 Producer는 메시지 생성 및 전송을 담당하는 핵심 구성 요소다. 이번 글에서는 Producer의 생성부터 실제 운영에 필요한 내부 메커니즘까지 단계별로 살펴본다.
Producer 기본 구조
Producer를 사용하려면 먼저 DefaultMQProducer 인스턴스를 생성하고 필수 설정을 완료한 후 start() 메서드를 호출해야 한다. 가장 간단한 사용 예시는 다음 ...
5월 27일 01:49에 게시됨