An Open-Source, Distributed MQTT Message Broker for IoT.

Related tags

Messaging mmq
Overview

MMQ broker

MMQ broker 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。

MMQ broker 完整支持MQTT V3.1 和 V3.1.1。

安装

MMQ broker 是跨平台的，支持 Linux、Unix、macOS 以及 Windows。这意味着 MMQ broker 可以部署在 x86_64 架构的服务器上。由于使用raft一致性算法，集群部署建议奇数个。

直接安装

Docker安装

Kubernetes安装

快速入门

单机版启动

cd .\bin
#windows start
startup.cmd -m standalone
cd ./bin
#linux start
sh startup.sh -m standalone
#linux shutdown
sh shutdown.sh

集群版启动

cd ./config
#配置集群文件
cp cluster.conf.example cluster.conf
cd .\bin
#windows start
startup.cmd
cd ./bin
#linux start
sh startup.sh
#linux shutdown
sh shutdown.sh

MQTT 规范

你可以通过以下链接了解与查阅 MQTT 协议:

MQTT Version 3.1.1

开源许可

Apache License 2.0, 详见 LICENSE。

开发计划

##规则引擎 ###桥接kafka ###桥接MQTT ###桥接Tdengine ###桥接influxdb ##模块 ###Coap协议网关 ###TCP协议网关 ###JT/T808网关

You might also like...

Carbyne Stack secret sharing distributed object store

Carbyne Stack Amphora Secret Share Store Amphora is an open source object store for secret shared data and part of Carbyne Stack. DISCLAIMER: Carbyne

Dec 1, 2022

SeaTunnel is a distributed, high-performance data integration platform for the synchronization and transformation of massive data (offline & real-time).

SeaTunnel is a distributed, high-performance data integration platform for the synchronization and transformation of massive data (offline & real-time).

SeaTunnel SeaTunnel was formerly named Waterdrop , and renamed SeaTunnel since October 12, 2021. SeaTunnel is a very easy-to-use ultra-high-performanc

Jan 2, 2023

Open data platform based on flink. Now scaleph is supporting data integration with seatunnel on flink

scaleph The Scaleph project features data integration, develop, job schedule and orchestration and trys to provide one-stop data platform for develope

Jan 3, 2023

Demo project for Kafka Ignite streamer, Kafka as source and Ignite cache as sink

ignite-kafka-streamer **Description : Demo project for Kafka Ignite streamer, Kafka as source and Ignite cache as sink Step-1) Run both Zookeeper and

Feb 1, 2022

An Open-Source, Distributed MQTT Broker for IoT.

简体中文 | English MMQ broker MMQ broker 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。 MMQ broker 完整支持MQTT V3.1 和 V3.1.1。 特征 分布式MQTT服务 万级连接数并发（3台

Dec 15, 2022

IoT Platform, Device management, data collection, processing and visualization, multi protocol, rule engine, netty mqtt client

IoT Platform, Device management, data collection, processing and visualization, multi protocol, rule engine, netty mqtt client

GIoT GIoT: GIoT是一个开源的IoT平台，支持设备管理、物模型，产品、设备管理、规则引擎、多种存储、多sink、多协议（http、mqtt、tcp，自定义协议）、多租户管理等等，提供插件化开发 Documentation Quick Start Module - giot-starte

Sep 13, 2022

MQTT broker(java实现高性能的、可扩展、支持集群）

MQTT broker(java实现高性能的、可扩展、支持集群）

SMQTT是一款开源的MQTT消息代理Broker， SMQTT基于Netty开发，底层采用Reactor3反应堆模型,支持单机部署，支持容器化部署，具备低延迟，高吞吐量，支持百万TCP连接，同时支持多种协议交互，是一款非常优秀的消息中间件！ smqtt目前拥有的功能如下： 消息质量等级实现(支持q

Jan 6, 2023

Hi, Spring fans! In this installment we look Spring Integration's support for MQTT and the HiveMQ broker

Spring Integration MQTT & HiveMQ Hi, Spring fans! In this installment we look Spring Integration's support for MQTT and the HiveMQ broker. I'm joined

Nov 21, 2022

Fast and reliable message broker built on top of Kafka.

Hermes Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and a

Jan 3, 2023

Rqueue aka Redis Queue [Task Queue, Message Broker] for Spring framework

Rqueue aka Redis Queue [Task Queue, Message Broker] for Spring framework

Rqueue: Redis Queue, Task Queue, Scheduled Queue for Spring and Spring Boot Rqueue is an asynchronous task executor(worker) built for spring and sprin

Jan 5, 2023

📬Zola (Extremely) Simple Message Queue for spring, It is the simplest Message Queue you've ever experienced.

📬Zola (Extremely) Simple Message Queue for spring, It is the simplest Message Queue you've ever experienced.

It is the simplest Message Queue you've ever experienced. home (engish version) korean version docs 📗 Getting Started || Overview || Docs ZSMQ ZSMQ (

Nov 23, 2022

ScaleCube Services is a high throughput, low latency reactive microservices library built to scale. it features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)

ScaleCube Services is a high throughput, low latency reactive microservices library built to scale. it features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)

scalecube-services MICROSERVICES 2.0 An open-source project that is focused on streamlining reactive-programming of Microservices Reactive-systems tha

Dec 22, 2022

Build highly concurrent, distributed, and resilient message-driven applications on the JVM

Akka We believe that writing correct concurrent & distributed, resilient and elastic applications is too hard. Most of the time it's because we are us

Jan 3, 2023

Model import deployment framework for retraining models (pytorch, tensorflow,keras) deploying in JVM Micro service environments, mobile devices, iot, and Apache Spark

Model import deployment framework for retraining models (pytorch, tensorflow,keras) deploying in JVM Micro service environments, mobile devices, iot, and Apache Spark

The Eclipse Deeplearning4J (DL4J) ecosystem is a set of projects intended to support all the needs of a JVM based deep learning application. This mean

Dec 30, 2022

Care aims to create an IoT solution to hospitals interconnecting smart monitors to decrease the time a doctor takes to respond to an emergency.

Care aims to create an IoT solution to hospitals interconnecting smart monitors to decrease the time a doctor takes to respond to an emergency.

Care Description This project called Care, developed for the INFO1127 course - Software Engineering - aims to create an IoT solution to hospitals inte

Oct 4, 2022

Zeus IOT 是全球首家基于 Zabbix 的开源物联网分布式采集平台，具备 百万+ IOT设备的数据采集、分析、存储能力。

Zeus IOT 宙斯物联网分布式采集平台 快速安装 Zeus-IOT 支持 Centos 7、Ubuntu 20.04、Debain 10 、Kylin、UOS 等基于x86_64平台的 Linux 操作系统。 Centos7、RedHat 7 curl -L https://github.com

Dec 30, 2022

ZapIt - An advanced MQTT client made for the modern age

ZapIt - An advanced MQTT client made for the modern age

ZapIt An advanced MQTT client made for the modern age. Documentation Please refer to the Wiki Section. Installing Go to the Releases section and downl

Oct 8, 2022

Android app for Ribbit, Broker API Reference App

Android app for Ribbit, Broker API Reference App

Ribbit Reference Implementation (Android) The reference implementation for designing the Android user interface of a broker-dealer trading application

Nov 24, 2022

:fire: Seata is an easy-to-use, high-performance, open source distributed transaction solution.

:fire: Seata is an easy-to-use, high-performance, open source distributed transaction solution.

Seata: Simple Extensible Autonomous Transaction Architecture What is Seata? A distributed transaction solution with high performance and ease of use f

Jan 2, 2023
Comments
  • 同学，您这个项目引入了64个开源组件，存在21个漏洞，辛苦升级一下

    同学，您这个项目引入了64个开源组件，存在21个漏洞，辛苦升级一下

    检测到 MrHKing/mmqtt 一共引入了64个开源组件，存在21个漏洞

    漏洞标题：Vmware VMware Spring Security 权限许可和访问控制问题漏洞
缺陷组件：org.springframework.security:[email protected]
漏洞编号：CVE-2021-22112
漏洞描述：Vmware VMware Spring Security是美国威睿（Vmware）公司的一套为基于Spring的应用程序提供说明性安全保护的安全框架。
VMware Spring Security 中存在权限许可和访问控制问题漏洞。该漏洞源于攻击者可以通过Spring Security的多个SecurityContext更改绕过限制，以提升其权限。以下产品及版本受到影响：Spring Security 5.4.0 至 5.4.3 版本, Spring Security 5.3.0.RELEASE 至 5.3.7.RELEASE 版本, Spring Security 5.2.0.RELEASE 至 5.2.8.RELEASE 版本。
影响范围：(∞, 5.2.9.RELEASE)
最小修复版本：5.2.9.RELEASE
缺陷组件引入路径：org.monkey.mmq:[email protected]>org.springframework.boot:[email protected]>org.springframework.security:[email protected]>org.springframework.security:[email protected]

    另外还有21个漏洞，详细报告：https://mofeisec.com/jr?p=i7f469

    opened by ghost 1
Releases(v1.1.4)
Owner
Solley
IoT DevOps
Solley
GitHub
Efficient reliable UDP unicast, UDP multicast, and IPC message transport

Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie

Real Logic 6.3k Jan 9, 2023
An example Twitch.tv bot that allows you to manage channel rewards (without requiring a message), and chat messages.

Twitch Bot Example shit code that can be used as a template for a twitch bot that takes advantage of channel rewards (that dont require text input) an

Evan 3 Nov 3, 2022
Microservice-based online payment system for customers and merchants using RESTful APIs and message queues

Microservice-based online payment system for customers and merchants using RESTful APIs and message queues

Daniel Larsen 1 Mar 23, 2022
A modular and portable open source XMPP client library written in Java for Android and Java (SE) VMs

Smack About Smack is an open source, highly modular, easy to use, XMPP client library written in Java for Java SE compatible JVMs and Android. A pure

Ignite Realtime 2.3k Dec 28, 2022
Apache Camel is an open source integration framework that empowers you to quickly and easily integrate various systems consuming or producing data.

Apache Camel Apache Camel is a powerful, open-source integration framework based on prevalent Enterprise Integration Patterns with powerful bean integ

The Apache Software Foundation 4.7k Dec 31, 2022
HornetQ is an open source project to build a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system.

HornetQ If you need information about the HornetQ project please go to http://community.jboss.org/wiki/HornetQ http://www.jboss.org/hornetq/ This file

HornetQ 245 Dec 3, 2022
An XMPP server licensed under the Open Source Apache License.

Openfire About Openfire is a real time collaboration (RTC) server licensed under the Open Source Apache License. It uses the only widely adopted open

Ignite Realtime 2.6k Jan 3, 2023
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

Nakadi Event Broker Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues, which can be used

Zalando SE 866 Dec 21, 2022
Apache Pulsar - distributed pub-sub messaging system

Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API. Learn more about Pulsar at https:

The Apache Software Foundation 12.1k Jan 4, 2023
A high available,high performance distributed messaging system.

#新闻 MetaQ 1.4.6.2发布。更新日志 MetaQ 1.4.6.1发布。更新日志 MetaQ 1.4.5.1发布。更新日志 MetaQ 1.4.5发布。更新日志 Meta-ruby 0.1 released: a ruby client for metaq. SOURCE #介绍 Meta

dennis zhuang 1.3k Dec 12, 2022