Apache RocketMQ는 짧은 대기 시간, 높은 성능 및 안정성, 1조 수준의 용량 및 유연한 확장성을 갖춘 분산 메시징 및 스트리밍 플랫폼입니다.
다양한 기능을 제공합니다:
이 단락에서는 다양한 방법으로 RocketMQ를 설치하는 단계를 안내합니다. 로컬 개발 및 테스트의 경우 각 구성 요소에 대해 하나의 인스턴스만 생성됩니다.
RocketMQ는 모든 주요 운영 체제에서 실행되며 Java JDK 버전 8 이상만 설치하면 됩니다. 확인하려면 java -version
실행하세요.
$ java -version
java version " 1.8.0_121 "
Windows 사용자의 경우 여기를 클릭하여 5.2.0 RocketMQ 바이너리 릴리스를 다운로드하고 D:rocketmq
와 같은 로컬 디스크에 압축을 푸세요. macOS 및 Linux 사용자의 경우 다음 명령을 실행합니다.
# Download release from the Apache mirror
$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip
# Unpack the release
$ unzip rocketmq-all-5.2.0-bin-release.zip
터미널을 준비하고 추출된 bin
디렉터리로 변경합니다.
$ cd rocketmq-all-5.2.0-bin-release/bin
1) 네임서버 시작
NameServer는 0.0.0.0:9876
에서 수신 대기하며 해당 포트가 로컬 시스템의 다른 사용자에 의해 사용되지 않는지 확인한 후 다음을 수행합니다.
macOS 및 Linux 사용자의 경우:
# ## start Name Server
$ nohup sh mqnamesrv &
# ## check whether Name Server is successfully started
$ 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) 브로커 시작
macOS 및 Linux 사용자의 경우:
# ## start Broker
$ nohup sh bin/mqbroker -n localhost:9876 &
# ## check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is 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를 실행할 수 있으며, host
네트워크는 컨테이너의 수신 대기 포트를 노출하는 데 사용됩니다.
1) 네임서버 시작
$ docker run -it --net=host apache/rocketmq ./mqnamesrv
2) 브로커 시작
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876
RocketMQ Operator를 사용하여 Kubernetes 클러스터 내에서 RocketMQ 클러스터를 실행할 수도 있습니다. 작업을 시작하기 전에 kubectl
및 관련 kubeconfig 파일이 머신에 설치되어 있는지 확인하세요.
1) CRD 설치
# ## install CRDs
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy
# ## check whether CRDs is successfully installed
$ 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
# ## check whether operator is running
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj 1/1 Running 0 93s
2) 클러스터 인스턴스 생성
# ## create RocketMQ cluster resource
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml
# ## check whether cluster resources is running
$ 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 라이센스, 버전 2.0 저작권 (C) Apache Software Foundation
이 배포판에는 암호화 소프트웨어가 포함되어 있습니다. 귀하가 현재 거주하고 있는 국가에서는 암호화 소프트웨어를 다른 국가로 수입, 소유, 사용 및/또는 재수출하는 데 제한이 있을 수 있습니다. 암호화 소프트웨어를 사용하기 전에 암호화 소프트웨어의 수입, 소유, 사용 및 재수출에 관한 해당 국가의 법률, 규정 및 정책을 확인하여 이것이 허용되는지 확인하십시오. 자세한 내용은 http://www.wassenaar.org/를 참조하세요.
미국 정부 상무부, 산업안보국(BIS)은 이 소프트웨어를 수출상품통제번호(ECCN) 5D002.C.1로 분류했습니다. 여기에는 비대칭 알고리즘을 사용하거나 암호화 기능을 수행하는 정보 보안 소프트웨어가 포함됩니다. 이 Apache Software Foundation 배포판의 형식과 방식으로 인해 개체 코드와 소스 코드 모두에 대해 라이선스 예외 ENC TSU(Technology Software Unrestricted) 예외(BIS 수출 관리 규정, 섹션 740.13 참조)에 따라 수출할 수 있습니다.
다음은 포함된 암호화 소프트웨어에 대한 자세한 내용을 제공합니다.
이 소프트웨어는 Apache Commons Crypto(https://commons.apache.org/proper/commons-crypto/)를 사용하여 서비스 간 네트워크를 통해 전송되는 데이터의 인증과 암호화 및 암호 해독을 지원합니다.