# Gmqtt

**Repository Path**: mirrors/Gmqtt

## Basic Information

- **Project Name**: Gmqtt
- **Description**: Gmqtt是用Go语言实现的一个具备灵活扩展能力、高性能的MQTT broker，其完整实现了MQTT V3.1.1和V5协议
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: https://www.oschina.net/p/gmqtt
- **GVP Project**: No

## Statistics

- **Stars**: 36
- **Forks**: 12
- **Created**: 2021-02-26
- **Last Updated**: 2025-05-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Gmqtt [![Mentioned in Awesome Go](https://awesome.re/mentioned-badge.svg)](https://github.com/avelino/awesome-go) [![Gitter](https://badges.gitter.im/gmqtt/community.svg)](https://gitter.im/gmqtt/community?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge) ![Build Status](https://github.com/DrmagicE/gmqtt/actions/workflows/test.yml/badge.svg) [![codecov](https://codecov.io/gh/DrmagicE/gmqtt/branch/master/graph/badge.svg)](https://codecov.io/gh/DrmagicE/gmqtt) [![Go Report Card](https://goreportcard.com/badge/github.com/DrmagicE/gmqtt)](https://goreportcard.com/report/github.com/DrmagicE/gmqtt)

Gmqtt是用Go语言实现的一个具备灵活灵活扩展能力，高性能的MQTT broker，其完整实现了MQTT V3.x和V5协议。

# 项目现状
由于个人原因，该项目较少维护。以下是一些提供给想使用此项目的人的信息。  
Gmqtt已用于生产，效果良好。生产环境服务于大约数百个客户（现在可能是数千个或10000个），并且每个客户端以15s一次的频率发布QoS 1消息来报告其状态。
云上的订阅者会将这些状态存储到持久后端。  
所有客户端都是非持久会话，使用v3.1.1协议。

# 更多资料
[Gmqtt插件机制详解](https://juejin.cn/post/6908305981923409934)  
[Gmqtt——Go语言实现的MQTT broker](https://juejin.cn/post/6905898448743038990)

# 功能特性
* 内置了许多实用的钩子方法，使用者可以方便的定制需要的MQTT服务器（鉴权,ACL等功能）
* 支持tls/ssl以及ws/wss
* 提供扩展编程接口，可以通过函数调用直接往broker发消息，添加删除订阅等。详见`server.go`的`Server`接口定义，以及 [admin](https://github.com/DrmagicE/Gmqtt/blob/master/plugin/admin/READEME.md)插件。
* 丰富的钩子方法和扩展编程接口赋予了Gmqtt强大的插件定制化能力。详见`server/plugin.go` 和 `/plugin`。
* 提供监控指标，支持prometheus。 (plugin: [prometheus](https://github.com/DrmagicE/Gmqtt/blob/master/plugin/prometheus/READEME.md))
* GRPC和REST API 支持. (plugin:[admin](https://github.com/DrmagicE/Gmqtt/blob/master/plugin/admin/READEME.md))
* 支持session持久化，broker重启消息不丢失，目前支持redis持久化。
* 支持集群, 示例和详情请参考[federation plugin](./plugin/federation/README.md)。(注意: 这项特性并没有在生产环境中验证过)

# 开始
我们需要通过源码编译的方式启动，请确保您所在的机器上已经具备Go环境。

下列命令会使用默认配置启动Gmqtt服务，该服务使用1883端口[tcp]和8883端口[websocket]端口提供MQTT broker服务，并加载admin和prometheus插件。
```bash
$ git clone https://github.com/DrmagicE/gmqtt
$ cd gmqtt/cmd/gmqttd
$ go run . start -c default_config.yml
```

## 配置
Gmqtt通过`-c`来指定配置文件路径，如果没有指定，Gmqtt默认读取`$HOME/gmqtt.yml`为配置文件。
[配置示例](https://github.com/DrmagicE/Gmqtt/blob/master/cmd/Gmqttd/default_config.yml)。

## 使用持久化存储
Gmqtt默认使用内存存储，这也是Gmqtt推荐的存储方式，内存存储具备绝佳的性能优势，但缺点是session信息会在broker重启后丢失。
如果你希望重启后session不丢失，可以配置redis持久化存储：
```yaml
persistence:
  type: redis  
  redis:
    # redis server address
    addr: "127.0.0.1:6379"
    # the maximum number of idle connections in the redis connection pool
    max_idle: 1000
    # the maximum number of connections allocated by the redis connection pool at a given time.
    # If zero, there is no limit on the number of connections in the pool.
    max_active: 0
    # the connection idle timeout, connection will be closed after remaining idle for this duration. If the value is zero, then idle connections are not closed
    idle_timeout: 240s
    password: ""
    # the number of the redis database
    database: 0
```

## 配置鉴权
Gmqtt内置了基于username/password的简单鉴权机制。(由 [auth](https://github.com/DrmagicE/gmqtt/blob/master/plugin/auth) 插件提供)。
Gmqtt默认配置没有开启鉴权，可以通过修改配置文件来加载鉴权插件：
```yaml
# plugin loading orders
plugin_order:
  - auth
  - prometheus
  - admin
```
加载后，需要添加账户才可以连接，可以通过HTTP接口来添加账户：
```bash
# 创建： username = user1, password = user1pass
$ curl -X POST -d '{"password":"user1pass"}' 127.0.0.1:8083/v1/accounts/user1
{}
# 查询：
$ curl 127.0.0.1:8083/v1/accounts/user1
{"account":{"username":"user1","password":"20a0db53bc1881a7f739cd956b740039"}}
```
API文档：[swagger](https://github.com/DrmagicE/gmqtt/blob/master/plugin/auth/swagger)


## Docker
```
$ docker build -t gmqtt .
$ docker run -p 1883:1883 -p 8883:8883 -p 8082:8082 -p 8083:8083  -p 8084:8084  gmqtt
```

# 文档说明
[godoc](https://www.godoc.org/github.com/DrmagicE/gmqtt)
## 钩子方法
Gmqtt实现了下列钩子方法。

| hook | 说明 | 用途示例 |
|------|------------|------------|
| OnAccept  | TCP连接建立时调用|  TCP连接限速，黑白名单等.      |
| OnStop  | 当gmqtt退出时调用 |    |
| OnSubscribe  | 收到订阅请求时调用| 校验订阅是否合法    |
| OnSubscribed  | 订阅成功后调用   |   统计订阅报文数量   |
| OnUnsubscribe  | 取消订阅时调用       | 校验是否允许取消订阅       |
| OnUnsubscribed  | 取消订阅成功后调用   |   统计订阅报文数     |
| OnMsgArrived  | 收到消息发布报文时调用       |  校验发布权限，改写发布消息       |
| OnBasicAuth  | 收到连接请求报文时调用       | 客户端连接鉴权       |
| OnEnhancedAuth  | 收到带有AuthMetho的连接请求报文时调用（V5特性）| 客户端连接鉴权      |
| OnReAuth  | 收到Auth报文时调用（V5特性）        | 客户端连接鉴权      |
| OnConnected  | 客户端连接成功后调用|    统计在线客户端数量    | 
| OnSessionCreated  | 客户端创建新session后调用       |  统计session数量       |
| OnSessionResumed  | 客户端从旧session恢复后调用       | 统计session数量       |
| OnSessionTerminated  | session删除后调用       | 统计session数量       |
| OnDelivered  | 消息从broker投递到客户端后调用       |        |
| OnClosed  | 客户端断开连接后调用       |   统计在线客户端数量      |
| OnMsgDropped  | 消息被丢弃时调用 |        |
| OnWillPublish | 发布遗嘱消息前 | 修改或丢弃遗嘱消息|
| OnWillPublished| 发布遗嘱消息后| |


## 怎么写插件
[How to write plugins](https://github.com/DrmagicE/gmqtt/blob/master/plugin/README.md)

# 测试
## 单元测试
```
$ go test -race ./...  
```

## 集成测试
[paho.mqtt.testing](https://github.com/eclipse/paho.mqtt.testing).