apache__rocketmq_CVE-2023-37582_4-9-6

Apache RocketMQ

Apache RocketMQ는 낮은 지연 시간, 높은 성능과 신뢰성, 조 단위 용량 및 유연한 확장성을 갖춘 분산 메시징 및 스트리밍 플랫폼입니다.

다양한 기능을 제공합니다:

• 발행/구독, 요청/응답 및 스트리밍을 포함한 메시징 패턴
• 금융 수준의 트랜잭션 메시지
• DLedger 기반의 내장형 내결함성 및 고가용성 구성 옵션
• 내장형 메시지 추적 기능, opentracing도 지원
• 다양한 빅데이터 및 스트리밍 생태계 통합
• 시간 또는 오프셋에 의한 메시지 역추적
• 동일한 큐 내에서 신뢰할 수 있는 FIFO 및 엄격한 순서 메시징
• 효율적인 pull 및 push 소비 모델
• 단일 큐에서 백만 개 수준의 메시지 누적 용량
• gRPC, MQTT, JMS 및 OpenMessaging과 같은 다양한 메시징 프로토콜
• 유연한 분산 확장 배포 아키텍처
• 초고속 배치 메시지 교환 시스템
• SQL 및 Tag와 같은 다양한 메시지 필터 메커니즘
• 격리된 테스트 및 클라우드 격리 클러스터를 위한 Docker 이미지
• 구성, 메트릭 및 모니터링을 위한 풍부한 기능의 관리 대시보드
• 인증 및 권한 부여
• 소스와 싱크를 모두 위한 무료 오픈 소스 커넥터
• 경량 실시간 컴퓨팅

빠른 시작

이 단락에서는 다양한 방법으로 RocketMQ를 설치하는 방법을 안내합니다. 로컬 개발 및 테스트를 위해 각 구성 요소에 대해 하나의 인스턴스만 생성됩니다.

RocketMQ 로컬에서 실행하기

RocketMQ는 모든 주요 운영 체제에서 실행되며 Java JDK 버전 8 이상만 설치되어 있으면 됩니다. 확인하려면 java -version을 실행하십시오:

$ java -version
java version "1.8.0_121"

Windows 사용자는 여기를 클릭하여 4.9.3 RocketMQ 바이너리 릴리스를 다운로드하고, 로컬 디스크(예: D:\rocketmq)에 압축을 풉니다. macOS 및 Linux 사용자는 다음 명령을 실행하십시오:

# Apache 미러에서 릴리스 다운로드
$ wget https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip

# 릴리스 압축 풀기
$ unzip rocketmq-all-4.9.3-bin-release.zip

터미널을 준비하고 압축이 풀린 bin 디렉토리로 이동합니다:

$ cd rocketmq-4.9.3/bin

1) NameServer 시작

NameServer는 0.0.0.0:9876에서 수신 대기합니다. 로컬 머신에서 해당 포트가 다른 프로세스에서 사용 중이 아닌지 확인한 후 다음을 수행하십시오.

macOS 및 Linux 사용자:

### Name Server 시작
$ nohup sh mqnamesrv &

### Name Server가 성공적으로 시작되었는지 확인
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

Windows 사용자는 먼저 환경 변수를 설정해야 합니다:

• 바탕 화면에서 컴퓨터 아이콘을 마우스 오른쪽 버튼으로 클릭합니다.
• 상황에 맞는 메뉴에서 속성을 선택합니다.
• 고급 시스템 설정 링크를 클릭합니다.
• 환경 변수를 클릭합니다.
• 환경 변수 ROCKETMQ_HOME="D:\rocketmq"를 추가합니다.

그런 다음 rocketmq 디렉토리로 변경하고 다음을 입력하여 실행합니다:

$ mqnamesrv.cmd
The Name Server boot success...

2) Broker 시작

macOS 및 Linux 사용자:

### Broker 시작
$ nohup sh bin/mqbroker -n localhost:9876 &

### Broker가 성공적으로 시작되었는지 확인, 예: Broker IP는 192.168.1.2, Broker 이름은 broker-a
$ tail -f ~/logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...

Windows 사용자:

$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...

Docker에서 RocketMQ 실행하기

Docker 컨테이너 내에서 자신의 머신에 RocketMQ를 실행할 수 있습니다. host 네트워크를 사용하여 컨테이너의 수신 포트를 노출합니다.

1) NameServer 시작

$ docker run -it --net=host apache/rocketmq ./mqnamesrv

2) Broker 시작

$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876

Kubernetes에서 RocketMQ 실행하기

RocketMQ Operator를 사용하여 Kubernetes 클러스터 내에서 RocketMQ 클러스터를 실행할 수도 있습니다. 작업 전에 머신에 kubectl 및 관련 kubeconfig 파일이 설치되어 있는지 확인하십시오.

1) CRD 설치

### CRD 설치
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy

### CRD가 성공적으로 설치되었는지 확인
$ kubectl get crd | grep rocketmq.apache.org
brokers.rocketmq.apache.org                 2022-05-12T09:23:18Z
consoles.rocketmq.apache.org                2022-05-12T09:23:19Z
nameservices.rocketmq.apache.org            2022-05-12T09:23:18Z
topictransfers.rocketmq.apache.org          2022-05-12T09:23:19Z

### operator가 실행 중인지 확인
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj   1/1     Running   0          93s

2) 클러스터 인스턴스 생성

### RocketMQ 클러스터 리소스 생성
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml

### 클러스터 리소스가 실행 중인지 확인
$ kubectl get sts
NAME                 READY   AGE
broker-0-master      1/1     107m
broker-0-replica-1   1/1     107m
name-service         1/1     107m

Apache RocketMQ 커뮤니티

• RocketMQ Streams: Apache RocketMQ 기반의 경량 스트림 컴퓨팅 엔진입니다.
• RocketMQ Flink: 데이터 스트림 및 Table에서 소스 및 싱크 커넥터를 지원하는 Apache Flink용 Apache RocketMQ 커넥터입니다.
• RocketMQ 다중 언어 클라이언트
  • RocketMQ Client CPP
  • RocketMQ Client Go
  • RocketMQ Client Python
  • RocketMQ Client Nodejs
• RocketMQ Spring: 개발자가 Apache RocketMQ를 Spring Boot와 빠르게 통합할 수 있도록 도와주는 프로젝트입니다.
• RocketMQ Exporter: Prometheus용 Apache RocketMQ 익스포터입니다.
• RocketMQ Operator: Kubernetes에서 Apache RocketMQ 클러스터를 실행하는 방법을 제공합니다.
• RocketMQ Docker: Apache RocketMQ용 Docker 이미지의 Git 저장소입니다.
• RocketMQ Dashboard: Apache RocketMQ의 운영 및 유지보수 콘솔입니다.
• RocketMQ Connect: Apache RocketMQ와 다른 시스템 간에 데이터를 확장 가능하고 안정적으로 스트리밍하기 위한 도구입니다.
• RocketMQ MQTT: 새로운 MQTT 프로토콜 아키텍처 모델로, Apache RocketMQ가 IoT 기기 및 모바일 앱과 같은 단말기의 메시지를 더 잘 지원할 수 있게 합니다.
• RocketMQ Incubating Community Projects: Apache RocketMQ의 인큐베이터 커뮤니티 프로젝트로, logappender, rocketmq-ansible, rocketmq-beats-integration, rocketmq-cloudevents-binding 등을 포함합니다.

배우기 & 문의하기

• 메일링 리스트: https://rocketmq.apache.org/about/contact/
• 홈페이지: https://rocketmq.apache.org
• 문서: https://rocketmq.apache.org/docs/quick-start/
• 이슈: https://github.com/apache/rocketmq/issues
• Rips: https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal
• 질문: https://stackoverflow.com/questions/tagged/rocketmq
• Slack: https://rocketmq-invite-automation.herokuapp.com/

기여하기

단순한 정리 작업부터 대규모의 새로운 기능 또는 기타 물질적 보상에 이르기까지 새로운 기여는 언제나 환영합니다. 자세한 내용은 여기를 참조하십시오.

라이선스

Apache License, Version 2.0 Copyright (C) Apache Software Foundation

수출 통제 고지

이 배포본에는 암호화 소프트웨어가 포함되어 있습니다. 현재 거주하고 있는 국가에서는 암호화 소프트웨어의 수입, 소지, 사용 및/또는 타국으로의 재수출에 대한 제한이 있을 수 있습니다. 암호화 소프트웨어를 사용하기 전에 해당 국가의 법률, 규정 및 정책을 확인하여 암호화 소프트웨어의 수입, 소지, 사용 및 재수출이 허용되는지 확인하십시오. 자세한 내용은 http://www.wassenaar.org/를 참조하십시오.

미국 상무부 산업안보국(BIS)은 이 소프트웨어를 정보 보안 소프트웨어로 분류하였으며, 비대칭 알고리즘을 사용하거나 암호화 기능을 수행하는 수출 통제 번호(ECCN) 5D002.C.1에 해당합니다. 이 Apache Software Foundation 배포본의 형식과 방식은 객체 코드와 소스 코드 모두에 대해 License Exception ENC Technology Software Unrestricted (TSU) 예외(BIS 수출 관리 규정, Section 740.13 참조)에 따라 수출이 가능합니다.

다음은 포함된 암호화 소프트웨어에 대한 자세한 내용입니다:

이 소프트웨어는 Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/)를 사용하여 인증 및 서비스 간 네트워크를 통해 전송되는 데이터의 암호화 및 복호화를 지원합니다.