|Project Name||Stars||Downloads||Repos Using This||Packages Using This||Most Recent Commit||Total Releases||Latest Release||Open Issues||License||Language|
|Rocketmq||19,836||374||77||2 days ago||25||June 24, 2023||547||apache-2.0||Java|
|Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.|
|Pulsar||13,171||15||18 hours ago||40||July 19, 2023||1,192||apache-2.0||Java|
|Apache Pulsar - distributed pub-sub messaging system|
|Rabbitmq Server||11,036||111||14||13 hours ago||190||July 17, 2023||292||other||Starlark|
|Open source RabbitMQ: core server and tier 1 (built-in) plugins|
|Centrifugo||7,383||2 days ago||73||June 30, 2022||12||apache-2.0||Go|
|Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably. Set up once and forever.|
|Jocko||4,516||2 years ago||61||mit||Go|
|Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)|
|Incubator Heron||3,643||12||2||7 months ago||25||March 31, 2018||410||apache-2.0||Java|
|Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter|
|Liftbridge||2,413||2||7 months ago||67||September 09, 2022||44||apache-2.0||Go|
|Lightweight, fault-tolerant message streams.|
|Libsourcey||1,256||9 months ago||71||lgpl-2.1||C++|
|C++14 evented IO libraries for high performance networking and media based applications|
|Mqcloud||1,091||a month ago||22||apache-2.0||Java|
|Openmessaging Java||693||59||6||2 years ago||13||March 16, 2021||10||apache-2.0||Java|
|OpenMessaging Runtime Interface for Java|
Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.
It offers a variety of features:
This paragraph guides you through steps of installing RocketMQ in different ways. For local development and testing, only one instance will be created for each component.
RocketMQ runs on all major operating systems and requires only a Java JDK version 8 or higher to be installed.
To check, run
$ java -version java version "1.8.0_121"
For Windows users, click here to download the 5.1.1 RocketMQ binary release,
unpack it to your local disk, such as
For macOS and Linux users, execute following commands:
# Download release from the Apache mirror $ wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.1/rocketmq-all-5.1.1-bin-release.zip # Unpack the release $ unzip rocketmq-all-5.1.1-bin-release.zip
Prepare a terminal and change to the extracted
$ cd rocketmq-all-5.1.1/bin
1) Start NameServer
NameServer will be listening at
0.0.0.0:9876, make sure that the port is not used by others on the local machine, and then do as follows.
For macOS and Linux users:
### start Name Server $ nohup sh mqnamesrv & ### check whether Name Server is successfully started $ tail -f ~/logs/rocketmqlogs/namesrv.log The Name Server boot success...
For Windows users, you need set environment variables first:
Then change directory to rocketmq, type and run:
$ mqnamesrv.cmd The Name Server boot success...
2) Start Broker
For macOS and Linux users:
### 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, 184.108.40.206:10911] boot success...
For Windows users:
$ mqbroker.cmd -n localhost:9876 The broker[broker-a, 220.127.116.11:10911] boot success...
You can run RocketMQ on your own machine within Docker containers,
host network will be used to expose listening port in the container.
1) Start NameServer
$ docker run -it --net=host apache/rocketmq ./mqnamesrv
2) Start Broker
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876
You can also run a RocketMQ cluster within a Kubernetes cluster using RocketMQ Operator.
Before your operations, make sure that
kubectl and related kubeconfig file installed on your machine.
1) Install 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 Cluster Instance
### 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 License, Version 2.0 Copyright (C) Apache Software Foundation
This distribution includes cryptographic software. The country in which you currently reside may have restrictions on the import, possession, use, and/or re-export to another country, of encryption software. BEFORE using any encryption software, please check your country's laws, regulations and policies concerning the import, possession, or use, and re-export of encryption software, to see if this is permitted. See http://www.wassenaar.org/ for more information.
The U.S. Government Department of Commerce, Bureau of Industry and Security (BIS), has classified this software as Export Commodity Control Number (ECCN) 5D002.C.1, which includes information security software using or performing cryptographic functions with asymmetric algorithms. The form and manner of this Apache Software Foundation distribution makes it eligible for export under the License Exception ENC Technology Software Unrestricted (TSU) exception (see the BIS Export Administration Regulations, Section 740.13) for both object code and source code.
The following provides more details on the included cryptographic software:
This software uses Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) to support authentication, and encryption and decryption of data sent across the network between services.