mqtt

Documentation

Index

• func StartBroker(port, WsPort string) error
• type Client
  • func NewClient(host, clientId string) *Client
  • func (p *Client) Close()
  • func (p *Client) Publish(topic string, qos byte, payload interface{}, retain bool)
  • func (p *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler)
  • func (p *Client) Unsubscribe(topic string)

Functions

func StartBroker

func StartBroker(port, WsPort string) error

StartBroker 启动Broker服务

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(host, clientId string) *Client

NewClient host例如："tcp://iot.eclipse.org:1883"

func (*Client) Close

func (p *Client) Close()

Close 关闭客户端

func (*Client) Publish

func (p *Client) Publish(topic string, qos byte, payload interface{}, retain bool)

Publish 发布消息

func (*Client) Subscribe

func (p *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler)

func (*Client) Unsubscribe

func (p *Client) Unsubscribe(topic string)