Apache RocketMQ عبارة عن منصة موزعة للمراسلة والبث المباشر تتميز بزمن وصول منخفض وأداء وموثوقية عاليتين وقدرة تصل إلى تريليون مستوى وقابلية توسع مرنة.
ويقدم مجموعة متنوعة من الميزات:
ترشدك هذه الفقرة خلال خطوات تثبيت 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...
لمستخدمي ويندوز:
$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...
يمكنك تشغيل RocketMQ على جهازك الخاص داخل حاويات Docker، وسيتم استخدام الشبكة 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 داخل مجموعة Kubernetes باستخدام RocketMQ Operator. قبل العمليات، تأكد من تثبيت 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
نرحب دائمًا بالمساهمات الجديدة، سواء لعمليات التنظيف البسيطة أو الميزات الجديدة الكبيرة أو المكافآت المادية الأخرى، لمزيد من التفاصيل انظر هنا.
ترخيص Apache، الإصدار 2.0 حقوق الطبع والنشر (C) لمؤسسة Apache Software Foundation
يتضمن هذا التوزيع برامج التشفير. قد يكون لدى البلد الذي تقيم فيه حاليًا قيود على استيراد برامج التشفير و/أو حيازتها و/أو استخدامها و/أو إعادة تصديرها إلى بلد آخر. قبل استخدام أي برنامج تشفير، يرجى التحقق من القوانين واللوائح والسياسات المعمول بها في بلدك فيما يتعلق باستيراد برامج التشفير أو حيازتها أو استخدامها أو إعادة تصديرها، لمعرفة ما إذا كان ذلك مسموحًا به. راجع http://www.wassenaar.org/ لمزيد من المعلومات.
قامت وزارة التجارة التابعة للحكومة الأمريكية، مكتب الصناعة والأمن (BIS)، بتصنيف هذا البرنامج على أنه رقم مراقبة السلع التصديرية (ECCN) 5D002.C.1، والذي يتضمن برنامج أمان المعلومات الذي يستخدم أو يؤدي وظائف التشفير باستخدام خوارزميات غير متماثلة. إن شكل وطريقة توزيع Apache Software Foundation يجعلها مؤهلة للتصدير بموجب استثناء الترخيص ENC Technology Software Unrestricted (TSU) (راجع لوائح إدارة تصدير BIS، القسم 740.13) لكل من رمز الكائن والتعليمة البرمجية المصدر.
فيما يلي مزيد من التفاصيل حول برنامج التشفير المضمن:
يستخدم هذا البرنامج Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) لدعم المصادقة والتشفير وفك تشفير البيانات المرسلة عبر الشبكة بين الخدمات.