rocketmq

Apache RocketMQ

Apache RocketMQ adalah platform perpesanan dan streaming terdistribusi dengan latensi rendah, kinerja dan keandalan tinggi, kapasitas tingkat triliunan, dan skalabilitas fleksibel.

Ini menawarkan berbagai fitur:

• Pola pesan termasuk publikasi/berlangganan, permintaan/balas, dan streaming
• Pesan transaksional tingkat finansial
• Toleransi kesalahan bawaan dan opsi konfigurasi ketersediaan tinggi berdasarkan Pengontrol DLedger
• Kemampuan penelusuran pesan bawaan, juga mendukung penelusuran terbuka
• Integrasi ekosistem data besar dan streaming yang serbaguna
• Pesan retroaktif berdasarkan waktu atau offset
• FIFO yang andal dan pesan yang tertata ketat dalam antrean yang sama
• Model konsumsi tarik dan dorong yang efisien
• Kapasitas akumulasi pesan jutaan tingkat dalam satu antrian
• Berbagai protokol perpesanan seperti gRPC, MQTT, JMS, dan OpenMessaging
• Arsitektur penerapan perluasan skala terdistribusi yang fleksibel
• Sistem pertukaran pesan batch secepat kilat
• Berbagai mekanisme filter pesan seperti SQL dan Tag
• Gambar Docker untuk pengujian terisolasi dan cluster terisolasi cloud
• Dasbor administratif kaya fitur untuk konfigurasi, metrik, dan pemantauan
• Otentikasi dan otorisasi
• Konektor sumber terbuka gratis, untuk sumber dan sink
• Komputasi real-time yang ringan

---

Mulai Cepat

Paragraf ini memandu Anda melalui langkah-langkah menginstal RocketMQ dengan berbagai cara. Untuk pengembangan dan pengujian lokal, hanya satu instance yang akan dibuat untuk setiap komponen.

Jalankan RocketMQ secara lokal

RocketMQ berjalan di semua sistem operasi utama dan hanya memerlukan Java JDK versi 8 atau lebih tinggi untuk diinstal. Untuk memeriksanya, jalankan java -version :

$ java -version
java version " 1.8.0_121 "

Untuk pengguna Windows, klik di sini untuk mengunduh rilis biner RocketMQ 5.2.0, ekstrak ke disk lokal Anda, seperti D:rocketmq . Untuk pengguna macOS dan Linux, jalankan perintah berikut:

 # 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

Siapkan terminal dan ubah ke direktori bin yang diekstrak:

$ cd rocketmq-all-5.2.0-bin-release/bin

1) Mulai Server Nama

NameServer akan mendengarkan pada 0.0.0.0:9876 , pastikan port tersebut tidak digunakan oleh orang lain di mesin lokal, lalu lakukan hal berikut.

Untuk pengguna macOS dan 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...

Untuk pengguna Windows, Anda perlu mengatur variabel lingkungan terlebih dahulu:

• Dari desktop, klik kanan ikon Komputer.
• Pilih Properti dari menu konteks.
• Klik tautan Pengaturan sistem lanjutan.
• Klik Variabel Lingkungan.
• Tambahkan Lingkungan ROCKETMQ_HOME="D:rocketmq" .

Kemudian ubah direktori menjadi rocketmq, ketik dan jalankan:

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

2) Mulai Pialang

Untuk pengguna macOS dan 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...

Untuk pengguna Windows:

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

Jalankan RocketMQ di Docker

Anda dapat menjalankan RocketMQ di mesin Anda sendiri di dalam container Docker, jaringan host akan digunakan untuk mengekspos port mendengarkan di container.

1) Mulai Server Nama

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

2) Mulai Pialang

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

Jalankan RocketMQ di Kubernetes

Anda juga dapat menjalankan klaster RocketMQ dalam klaster Kubernetes menggunakan Operator RocketMQ. Sebelum melakukan operasi, pastikan kubectl dan file kubeconfig terkait terinstal di mesin Anda.

1) Instal 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) Buat Instans Klaster

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

---

Komunitas Apache RocketMQ

• Aliran RocketMQ: Mesin komputasi aliran ringan berdasarkan Apache RocketMQ.
• RocketMQ Flink: Konektor Apache RocketMQ dari Apache Flink yang mendukung konektor sumber dan sink dalam aliran data dan Tabel.
• API RocketMQ: Protokol protobuf RocketMQ.
• Klien RocketMQ: klien RocketMQ berbasis gRPC/protobuf.
• Klien berbasis Remote RocketMQ
  • CPP Klien RocketMQ
  • Klien RocketMQ Pergi
  • Python Klien RocketMQ
  • Nodej Klien RocketMQ
• RocketMQ Spring: Sebuah proyek yang membantu pengembang dengan cepat mengintegrasikan Apache RocketMQ dengan Spring Boot.
• Eksportir RocketMQ: Eksportir Apache RocketMQ untuk Prometheus.
• Operator RocketMQ: Menyediakan cara untuk menjalankan cluster Apache RocketMQ di Kubernetes.
• RocketMQ Docker: Repo Git dari Docker Image untuk Apache RocketMQ.
• Dasbor RocketMQ: Konsol pengoperasian dan pemeliharaan Apache RocketMQ.
• RocketMQ Connect: Alat untuk streaming data secara terukur dan andal antara Apache RocketMQ dan sistem lain.
• RocketMQ MQTT: Model arsitektur protokol MQTT baru, yang menjadi dasar Apache RocketMQ dapat mendukung pesan dari terminal seperti perangkat IoT dan Aplikasi Seluler dengan lebih baik.
• RocketMQ EventBridge: EventBridge memudahkan pembuatan aplikasi berbasis peristiwa.
• Proyek Komunitas Inkubasi RocketMQ: Proyek komunitas inkubator Apache RocketMQ, termasuk logappender, rocketmq-ansible, rocketmq-beats-integration, rocketmq-cloudevents-binding, dll.
• Situs RocketMQ: Repositori untuk situs web Apache RocketMQ.
• RocketMQ E2E: Sebuah proyek untuk menguji Apache RocketMQ, termasuk pengujian ujung ke ujung, kinerja, dan kompatibilitas.

---

Pelajari & Hubungi kami

• Milis: https://rocketmq.apache.org/about/contact/
• Beranda: https://rocketmq.apache.org
• Dokumen: https://rocketmq.apache.org/docs/quick-start/
• Masalah: https://github.com/apache/rocketmq/issues
• Robekan: https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal
• Tanyakan: https://stackoverflow.com/questions/tagged/rocketmq
• Kendur: https://rocketmq-invite-automation.herokuapp.com/

---

Berkontribusi

Kami selalu menyambut kontribusi baru, baik untuk pembersihan sepele, fitur baru yang besar, atau imbalan materi lainnya, detail lebih lanjut lihat di sini.

---

Lisensi

Lisensi Apache, Versi 2.0 Hak Cipta (C) Apache Software Foundation

---

Pemberitahuan Kontrol Ekspor

Distribusi ini mencakup perangkat lunak kriptografi. Negara tempat Anda tinggal saat ini mungkin memiliki pembatasan terhadap impor, kepemilikan, penggunaan, dan/atau ekspor ulang perangkat lunak enkripsi ke negara lain. SEBELUM menggunakan perangkat lunak enkripsi apa pun, harap periksa undang-undang, peraturan, dan kebijakan negara Anda mengenai impor, kepemilikan, atau penggunaan, dan ekspor ulang perangkat lunak enkripsi, untuk mengetahui apakah hal ini diizinkan. Lihat http://www.wassenaar.org/ untuk informasi lebih lanjut.

Departemen Perdagangan Pemerintah AS, Biro Industri dan Keamanan (BIS), telah mengklasifikasikan perangkat lunak ini sebagai Nomor Kontrol Komoditas Ekspor (ECCN) 5D002.C.1, yang mencakup perangkat lunak keamanan informasi yang menggunakan atau menjalankan fungsi kriptografi dengan algoritma asimetris. Bentuk dan cara distribusi Apache Software Foundation ini membuatnya memenuhi syarat untuk diekspor berdasarkan pengecualian Lisensi Pengecualian ENC Technology Software Unrestricted (TSU) (lihat Peraturan Administrasi Ekspor BIS, Bagian 740.13) untuk kode objek dan kode sumber.

Berikut ini rincian lebih lanjut tentang perangkat lunak kriptografi yang disertakan:

Perangkat lunak ini menggunakan Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) untuk mendukung otentikasi, serta enkripsi dan dekripsi data yang dikirim melalui jaringan antar layanan.