Gmqtt 简介——基于Go语言的 MQTT borker 实现

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

功能特性

• 内置了许多实用的钩子方法，使用者可以方便的定制需要的MQTT服务器（鉴权,ACL等功能）
• 支持tls/ssl以及ws/wss
• 提供扩展编程接口，可以通过函数调用直接往broker发消息，添加删除订阅等。详见server.go的Server接口定义，以及 admin插件。
• 丰富的钩子方法和扩展编程接口赋予了Gmqtt强大的插件定制化能力。详见server/plugin.go 和 /plugin。
• 提供监控指标，支持prometheus。 (plugin: prometheus)
• GRPC和REST API 支持. (plugin:admin)
• 支持session持久化，broker重启消息不丢失，目前支持redis持久化。
• 支持集群, 示例和详情请参考federation plugin。

开始

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

下列命令会使用默认配置启动Gmqtt服务，该服务使用1883端口[tcp]和8883端口[websocket]端口提供MQTT broker服务，并加载admin和prometheus插件。

$ git clone https://github.com/DrmagicE/gmqtt
$ cd gmqtt/cmd/gmqttd
$ go run . start -c default_config.yml

配置

Gmqtt通过-c来指定配置文件路径，如果没有指定，Gmqtt默认读取$HOME/gmqtt.yml为配置文件。

使用持久化存储

Gmqtt默认使用内存存储，这也是Gmqtt推荐的存储方式，内存存储具备绝佳的性能优势，但缺点是session信息会在broker重启后丢失。 如果你希望重启后session不丢失，可以配置redis持久化存储：

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 插件提供)。 Gmqtt默认配置没有开启鉴权，可以通过修改配置文件来加载鉴权插件：

# plugin loading orders
plugin_order:
  - auth
  - prometheus
  - admin

加载后，需要添加账户才可以连接，可以通过HTTP接口来添加账户：

# 创建： 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"}}

Docker

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

文档说明

钩子方法

Gmqtt实现了下列钩子方法。