mqtt_utils

package
v1.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MQTTClient 

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

func NewMQTTClient 

func NewMQTTClient(config MQTTConfiguration) (*MQTTClient, error)

func (*MQTTClient) ConnectionLostHandler 

func (c *MQTTClient) ConnectionLostHandler(client mqtt.Client, err error)

func (*MQTTClient) Disconnect added in v1.1.0 

func (c *MQTTClient) Disconnect()

Disconnect 断开连接

func (*MQTTClient) GetSubscription added in v1.1.0 

func (c *MQTTClient) GetSubscription(topic string) (qos byte, callback mqtt.MessageHandler, exists bool)

GetSubscription 获取主题的订阅详情

func (*MQTTClient) IsConnected added in v1.1.0 

func (c *MQTTClient) IsConnected() bool

IsConnected 检查连接状态

func (*MQTTClient) OnConnectHandler 

func (c *MQTTClient) OnConnectHandler(client mqtt.Client)

func (*MQTTClient) Publish 

func (c *MQTTClient) Publish(r *MQTTPublishRequest) error

Publish 发布消息（自动重连）

func (*MQTTClient) ResubscribeAll added in v1.1.0 

func (c *MQTTClient) ResubscribeAll()

ResubscribeAll 重新订阅所有已注册的主题

func (*MQTTClient) SetLogger added in v1.1.0 

func (c *MQTTClient) SetLogger(logger *log.Logger)

SetLogger 设置自定义日志器

func (*MQTTClient) Subscribe 

func (c *MQTTClient) Subscribe(topic string, qos byte, callback mqtt.MessageHandler)

Subscribe 订阅单个主题

func (*MQTTClient) SubscribeMultiple added in v1.1.0 

func (c *MQTTClient) SubscribeMultiple(subscriptions map[string]byte, callback mqtt.MessageHandler)

SubscribeMultiple 批量订阅主题

func (*MQTTClient) Unsubscribe 

func (c *MQTTClient) Unsubscribe(topics ...string)

Unsubscribe 批量取消订阅

type MQTTConfiguration 

type MQTTConfiguration struct {
	ID       string `yaml:"id"`
	URL      string `yaml:"url"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type MQTTPublishRequest 

type MQTTPublishRequest struct {
	Topic    string
	Qos      byte
	Retained bool
	Payload  any
}

func NewMQTTPublishRequest 

func NewMQTTPublishRequest(topic string, qos byte, retained bool, payload any) *MQTTPublishRequest

type Subscription added in v1.1.0 

type Subscription struct {
	Topic    string
	Qos      byte
	Callback mqtt.MessageHandler
}

Subscription 表示一个主题订阅的详细信息

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.