apache__rocketmq_CVE-2023-33246_5-1-0

Apache RocketMQ

[![Build Status][maven-build-image]][maven-build-url] [![CodeCov][codecov-image]][codecov-url] [![Maven Central][maven-central-image]][maven-central-url] [![Release][release-image]][release-url] [![License][license-image]][license-url] [![Average Time to Resolve An Issue][percentage-of-issues-still-open-image]][pencentage-of-issues-still-open-url] [![Percentage of Issues Still Open][average-time-to-resolve-an-issue-image]][average-time-to-resolve-an-issue-url] [![Twitter Follow][twitter-follow-image]][twitter-follow-url]

Apache RocketMQ एक वितरित मैसेजिंग और स्ट्रीमिंग प्लेटफॉर्म है जिसमें कम विलंबता, उच्च प्रदर्शन और विश्वसनीयता, खरब-स्तरीय क्षमता और लचीली स्केलेबिलिटी है।

यह विभिन्न प्रकार की सुविधाएँ प्रदान करता है:

• प्रकाशन/सदस्यता, अनुरोध/उत्तर और स्ट्रीमिंग सहित मैसेजिंग पैटर्न
• वित्तीय ग्रेड के लेन-देन संदेश
• DLedger Controller पर आधारित अंतर्निहित दोष सहनशीलता और उच्च उपलब्धता कॉन्फ़िगरेशन विकल्प
• अंतर्निहित संदेश ट्रेसिंग क्षमता, साथ ही opentracing का समर्थन
• बहुमुखी बिग-डेटा और स्ट्रीमिंग इकोसिस्टम एकीकरण
• समय या ऑफ़सेट द्वारा संदेश पूर्वव्यापीकरण
• एक ही कतार में विश्वसनीय FIFO और सख्त क्रमबद्ध मैसेजिंग
• कुशल पुल और पश उपभोग मॉडल
• एक ही कतार में मिलियन-स्तरीय संदेश संचय क्षमता
• 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.4 RocketMQ बाइनरी रिलीज़ डाउनलोड करने के लिए यहाँ क्लिक करें, इसे अपनी स्थानीय डिस्क पर अनपैक करें, जैसे D:\rocketmq। macOS और Linux उपयोगकर्ताओं के लिए, निम्नलिखित कमांड निष्पादित करें:

# Download release from the Apache mirror
$ wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip

# Unpack the release
$ unzip rocketmq-all-4.9.4-bin-release.zip

एक टर्मिनल तैयार करें और निकाले गए bin निर्देशिका में बदलें:

$ cd rocketmq-4.9.4/bin

1) NameServer प्रारंभ करें

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) Broker प्रारंभ करें

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 चलाएँ

आप अपनी मशीन पर 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) CRDs स्थापित करें

### 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