Repository files navigation

English |简体中文

RMQTT broker is a fully open source, highly scalable, highly available distributed MQTT messaging broker for IoT, M2Mand mobile applications that can handle millions of concurrent clients on a single service node.

• 100% Rust safe code;

• Based ontokio,ntex,ntex-mqtt;

• MQTT v3.1, v3.1.1 and v5.0 protocols support;

  • QoS0, QoS1, QoS2 message support;
  • Offline message support;
  • Retained message support;
  • Last Will message support;

• Distributed cluster;

• Built-in AUTH/ACL;

• HTTP AUTH/ACL;

• JWT AUTH/ACL;

• WebHook;

• HTTP APIs;

• $SYS System Topics;

• Store session information;

• Store unexpired messages;

• MQTT Bridging - Ingress Mode

• MQTT Bridging - Egress Mode

• Apache Kafka Bridging - Ingress Mode

• Apache Kafka Bridging - Egress Mode

• Apache Pulsar Bridging - Ingress Mode

• Apache Pulsar Bridging - Egress Mode

• NATS Bridging - Egress Mode

• Reductstore Bridging - Egress Mode

• Topic Rewrite

• Auto Subscription

• Shared subscription($share/{Group}/{TopicFilter});

• Exclusive subscription($exclusive/{TopicFilter});

• Limit subscription($limit/{LimitQuantity}/{TopicFilter});

• Delayed publish($delayed/{DelayInterval}/{TopicName});

• Hooks;

• TLS support;

• WebSocket support;

• WebSocket-TLS support;

• Built-in extensible components;

• Extensible plug-in support;

• Metrics & Stats;

• Rate limit;

• Inflight and Queue;

• Message resending;

• For full list of new features, please readRMQTT Release Notes.

TheRMQTT broker is cross-platform, which supports Linux, Unix, macOS and Windows. It meansRMQTT can be deployed onx86_64 architecture servers and ARM devices like Raspberry Pi.

• Single node

mkdir -p /app/log/rmqttdocker run -d --name rmqtt -p 1883:1883 -p 8883:8883 -p 11883:11883 -p 6060:6060 -v /app/log/rmqtt:/var/log/rmqtt  rmqtt/rmqtt:latest

• Multi node

  docker run -d --name rmqtt1 -p 1884:1883 -p 8884:8883 -p 11884:11883 -p 6064:6060 -v /app/log/rmqtt/1:/var/log/rmqtt  rmqtt/rmqtt:latest --id 1 --plugins-default-startups"rmqtt-cluster-raft" --node-grpc-addrs"1@172.17.0.3:5363""2@172.17.0.4:5363""3@172.17.0.5:5363" --raft-peer-addrs"1@172.17.0.3:6003""2@172.17.0.4:6003""3@172.17.0.5:6003"     docker run -d --name rmqtt2 -p 1885:1883 -p 8885:8883 -p 11885:11883 -p 6065:6060 -v /app/log/rmqtt/2:/var/log/rmqtt  rmqtt/rmqtt:latest --id 2 --plugins-default-startups"rmqtt-cluster-raft" --node-grpc-addrs"1@172.17.0.3:5363""2@172.17.0.4:5363""3@172.17.0.5:5363" --raft-peer-addrs"1@172.17.0.3:6003""2@172.17.0.4:6003""3@172.17.0.5:6003"     docker run -d --name rmqtt3 -p 1886:1883 -p 8886:8883 -p 11886:11883 -p 6066:6060 -v /app/log/rmqtt/3:/var/log/rmqtt  rmqtt/rmqtt:latest --id 3 --plugins-default-startups"rmqtt-cluster-raft" --node-grpc-addrs"1@172.17.0.3:5363""2@172.17.0.4:5363""3@172.17.0.5:5363" --raft-peer-addrs"1@172.17.0.3:6003""2@172.17.0.4:6003""3@172.17.0.5:6003"

Node IDs: 1, 2, 3; Node IP Addrs: 172.17.0.3, 172.17.0.4, 172.17.0.5

1. Download docker-compose configuration template

2. Start docker-compose cluster

docker-compose up -d

3. View cluster

curl"http://127.0.0.1:6066/api/v1/health/check"

Get the binary package of the corresponding OS fromRMQTT Download page.

• Single Node Install

• Multi Node Install

• client_test.py Test.test_retained_messages [OK]
  • Need to enable the "rmqtt-retainer" plugin.
• client_test.py Test.test_zero_length_clientid [OK]
• client_test.py Test.will_message_test [OK]
• client_test.py Test.test_zero_length_clientid [OK]
• client_test.py Test.test_offline_message_queueing [OK]
• client_test.py Test.test_overlapping_subscriptions [OK]
• client_test.py Test.test_keepalive [OK]
• client_test.py Test.test_redelivery_on_reconnect [OK]
• client_test.py Test.test_dollar_topics [OK]
• client_test.py Test.test_unsubscribe [OK]
• client_test.py Test.test_subscribe_failure [OK]
  You need to modify thermqtt-acl.toml configuration and add the following line at the first line: ["deny", "all", "subscribe", ["test/nosubscribe"]],

• client_test5.py Test.test_retained_message [OK]
  • Need to enable the "rmqtt-retainer" plugin.
• client_test5.py Test.test_will_message [OK]
• client_test5.py Test.test_offline_message_queueing [OK]
• client_test5.py Test.test_dollar_topics [OK]
• client_test5.py Test.test_unsubscribe [OK]
• client_test5.py Test.test_session_expiry [OK]
• client_test5.py Test.test_shared_subscriptions [OK]
• client_test5.py Test.test_basic [OK]
• client_test5.py Test.test_overlapping_subscriptions [OK]
• client_test5.py Test.test_redelivery_on_reconnect [OK]
• client_test5.py Test.test_payload_format [OK]
• client_test5.py Test.test_publication_expiry [OK]
• client_test5.py Test.test_subscribe_options [OK]
• client_test5.py Test.test_assigned_clientid [OK]
• client_test5.py Test.test_subscribe_identifiers [OK]
• client_test5.py Test.test_request_response [OK]
• client_test5.py Test.test_server_topic_alias [OK]
• client_test5.py Test.test_client_topic_alias [OK]
• client_test5.py Test.test_maximum_packet_size [OK]
• client_test5.py Test.test_keepalive [OK]
• client_test5.py Test.test_zero_length_clientid [OK]
• client_test5.py Test.test_user_properties [OK]
• client_test5.py Test.test_flow_control2 [OK]
• client_test5.py Test.test_flow_control1 [OK]
• client_test5.py Test.test_will_delay [OK]
• client_test5.py Test.test_server_keep_alive [OK]
  • You need to modify thermqtt.toml configuration and changemax_keepalive to 60.
• client_test5.py Test.test_subscribe_failure [OK]
  • You need to modify thermqtt-acl.toml configuration and add the following line at the first line: ["deny", "all", "subscribe", ["test/nosubscribe"]],Modify thetest_subscribe_failure() method inclient_test5.py by changing0x80 to0x87.Becausermqtt returns the error code 0x87, whiletest_subscribe_failure expects it to return 0x80.UnspecifiedError = 0x80, NotAuthorized = 0x87。

Note: Before running test cases, please disable thermqtt-message-storage plugin.

For detailed benchmark test results and information, see documentation.