gomqtt

Documentation

Index

• func GetClient(opts *mqtt.ClientOptions) (client mqtt.Client, err error)
• func GetClientOptions(conf *Config) *mqtt.ClientOptions
• func Init(opts *mqtt.ClientOptions) (err error)
• func Publish(topic string, payload interface{}, qos byte, retained bool) (err error)
• func Subscribe(item SubscribeType)
• type Config
• type SubscribeType

Functions

func GetClient

func GetClient(opts *mqtt.ClientOptions) (client mqtt.Client, err error)

GetClient 获取MQTT连接

func GetClientOptions

func GetClientOptions(conf *Config) *mqtt.ClientOptions

GetClientOptions 获取MQTT连接配置项

func Init

func Init(opts *mqtt.ClientOptions) (err error)

Init 初始化监听器

func Publish

func Publish(topic string, payload interface{}, qos byte, retained bool) (err error)

Publish 通用发布消息接口

func Subscribe

func Subscribe(item SubscribeType)

Subscribe 注册订阅消息

Types

type Config

type Config struct {
	Broker     string // Broker地址，例如tcp://127.0.0.1:1883或ssl://127.0.0.1:8883. 如果配置ssl，则必须配置CACert
	Username   string // 用户名，可选
	Password   string // 密码，可选
	CACert     string // CA证书，单向认证只需要配置此文件即可，无需ClientCert和ClientKey，可选
	ClientCert string // ClientCert，可选
	ClientKey  string // ClientKey，可选
	ClientID   string // ClientID，可选
}

Config MQTT的配置信息格式

type SubscribeType

type SubscribeType struct {
	Topic      string
	Qos        byte
	Callback   mqtt.MessageHandler
	RetryTimes int // 为0表示无限重试
}