test

Documentation

Index

• Variables
• func Check(sn string) *mqtt.Client
• func InBound(sn string, topic string) bool
• func Init(sn string, server string) *mqtt.Client
• func Pub(sn string, topic string, data string) bool
• func Start(sn string, server string)
• func Stop(sn string) bool
• func Sub(sn string, topic string, callback mqtt.MessageHandler) bool
• func UnSub(sn string, topic string) bool

Variables

var CallBack mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
	fmt.Printf("2 topic: %s\n", msg.Topic())
	fmt.Printf("2 msg  : %s\n", msg.Payload())
}

Functions

func Check

func Check(sn string) *mqtt.Client

func InBound

func InBound(sn string, topic string) bool

InBound 数据入站 订阅消息 qos:0

func Init

func Init(sn string, server string) *mqtt.Client

Init 初始化客户端

func Pub

func Pub(sn string, topic string, data string) bool

Pub 数据出站 发布消息 qos:0 retained:false

func Start

func Start(sn string, server string)

Start 启动引擎 启动客户端连接

func Stop

func Stop(sn string) bool

Stop 关闭引擎 断开客户端连接

func Sub

func Sub(sn string, topic string, callback mqtt.MessageHandler) bool

func UnSub

func UnSub(sn string, topic string) bool

UnSub 取消订阅，指定主题