MGin MQTT注册插件

安装

go get -u github.com/maczh/mqtt

使用

在MGin微服务模块的main.go中,在app := mgin.NewApp()之后，加入一行

	//加载MQTT消息队列
    app.MGin.UsePlugin("mqtt", mqtt.MQTT)

yml配置

在MGin微服务模块本地配置文件中

go:
  config:
    used: mqtt
    prefix:
      mqtt: mqtt

配置中心的mqtt-test.yml配置

go:
  data:
    mqtt:
      broker: tcp://172.30.226.52:1883
      clientId: go-mqtt-client
      username:
      password:
      subscribe:
        - topic: /test/topic
          qos: 0
          handlerFuncName: testHandler
        - topic: /test/topic2
          qos: 0
          handlerFuncName: testHandler2

发送消息

    mqtt.MQTT.Publish("mytopic", 0, false, msg)

侦听主题消息并处理

• 定义消息处理函数

import (
    paho "github.com/eclipse/paho.mqtt.golang"
    "github.com/maczh/mgin"
    "github.com/maczh/mqtt"
)

var testHandler paho.MessageHandler = func(client paho.Client, msg paho.Message) {
    fmt.Printf("Received topic: %s\n%s\n", msg.Topic(), string(msg.Payload()))
}

• 在main.go中添加侦听代码

	//侦听MQTT消息，说明，主题名后缀的#为通配符，代表可以侦听同一前缀的所有主题消息
    mqtt.MQTT.Subscribe("test/topic/#", 0, testHandler)