apache__rocketmq_CVE-2023-37582_4-9-6

Apache RocketMQ

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

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

• प्रकाशित/सदस्यता, अनुरोध/उत्तर और स्ट्रीमिंग सहित संदेश पैटर्न
• वित्तीय ग्रेड का लेन-देन संदेश
• DLedger पर आधारित अंतर्निहित दोष सहनशीलता और उच्च उपलब्धता कॉन्फ़िगरेशन विकल्प
• अंतर्निहित संदेश ट्रेसिंग क्षमता, 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.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 उपयोगकर्ताओं के लिए, आपको पहले पर्यावरण चर सेट करने होंगे:

• डेस्कटॉप से, Computer आइकन पर राइट क्लिक करें।
• संदर्भ मेनू से Properties चुनें।
• Advanced system settings लिंक पर क्लिक करें।
• Environment Variables पर क्लिक करें।
• पर्यावरण 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...

RocketMQ को Docker में चलाएँ

आप अपनी मशीन पर 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

RocketMQ को Kubernetes में चलाएँ

आप RocketMQ Operator का उपयोग करके Kubernetes क्लस्टर के भीतर RocketMQ क्लस्टर भी चला सकते हैं। अपने संचालन से पहले, सुनिश्चित करें कि आपकी मशीन पर kubectl और संबंधित kubeconfig फ़ाइल स्थापित है।

1) CRDs स्थापित करें

### CRDs स्थापित करें
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy

### जाँचें कि CRDs सफलतापूर्वक स्थापित हुए हैं या नहीं
$ 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