mqtt

package

v0.0.0-...-b639fcc Latest Latest Go to latest Published: Jan 9, 2021 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/robertzml/Glaucus

Documentation ¶

Index ¶

Variables
func InitMQTT()
func StartReceive()
type MLogger
- func (m MLogger) Printf(format string, v ...interface{})
- func (m MLogger) Println(v ...interface{})
type MQTT

Constants ¶

This section is empty.

Variables ¶

View Source

var WaterHeaterStatusHandler paho.MessageHandler = func(client paho.Client, msg paho.Message) {
	glog.WriteVerbose(packageName, "getWHStatus",
		fmt.Sprintf("TOPIC: %s, Id: %d, QoS: %d\tMSG: %s.\t MQTT status producer", msg.Topic(), msg.MessageID(), msg.Qos(), msg.Payload()))

	pak := new(base.ReceivePacket)
	pak.ProductType = 1
	pak.Topic = msg.Topic()
	pak.Payload = string(msg.Payload()[:])

	base.MqttStatusCh <- pak
}

热水器状态消息订阅处理方法

Functions ¶

func InitMQTT ¶

func InitMQTT()

初始化全局MQTT 变量

func StartReceive ¶

func StartReceive()

启动MQTT接收服务

Types ¶

type MLogger ¶

type MLogger struct {
	Level int
}

paho 日志

func (MLogger) Printf ¶

func (m MLogger) Printf(format string, v ...interface{})

func (MLogger) Println ¶

func (m MLogger) Println(v ...interface{})

type MQTT ¶

type MQTT struct {
	ClientId string
	Address  string
	// contains filtered or unexported fields
}

MQTT 结构体

var (
	// 全局MQTT 接收连接
	ReceiveMqtt *MQTT
)

func (*MQTT) Connect ¶

func (m *MQTT) Connect(clientId string, username string, password string, address string, onConn paho.OnConnectHandler)

connect to mqtt server by clientId

func (*MQTT) Disconnect ¶

func (m *MQTT) Disconnect()

关闭连接

func (*MQTT) IsConnect ¶

func (m *MQTT) IsConnect() bool

检查连接是否正常

func (*MQTT) Publish ¶

func (m *MQTT) Publish(topic string, qos byte, payload string)

发布订阅

func (m *MQTT) Subscribe(topic string, qos byte, callback paho.MessageHandler) (err error)

订阅相关主题，设置QoS

func (*MQTT) Unsubscribe ¶

func (m *MQTT) Unsubscribe(topic string) (err error)

取消订阅

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL