client

package
v0.0.1-beta.3 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

README

1. EMQX 安装

docker pull emqx/emqx:5.3.2
docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083  emqx:5.3.2

2. Docker部署注意事项

  1. 如果您想持久化 EMQX Docker 容器中生成的数据,则需要保留以下目录,这样即使容器不再存在,数据也能持久保存。
/opt/emqx/data
/opt/emqx/log
  1. 启动容器并挂载目录:
docker run -d --name emqx \
  -p 1883:1883 -p 8083:8083 \
  -p 8084:8084 -p 8883:8883 \
  -p 18083:18083 \
  -v $PWD/data:/opt/emqx/data \
  -v $PWD/log:/opt/emqx/log \
  emqx/emqx:5.3.2
  1. 在 Docker 环境中,localhost或127.0.0.1指的是容器自己的内部网络接口,而不是主机的内部网络接口。要访问主机上运行的服务,请使用主机的 IP 地址或使用主机网络设置。如果您使用的是 Docker for Mac 或 Docker for Windows,则可以用作host.docker.internal主机地址。
  2. EMQX 使用data/mnesia/<node_name>目录来存储数据。选择一个稳定的标识符(例如主机名或完全限定域名 (FQDN) )作为节点名称至关重要。这种做法可以避免因节点名称更改而导致的数据丢失

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultRequestTimeout = time.Second * 20

Functions

This section is empty.

Types

type MQTTConfig

type MQTTConfig struct {
	Network  string
	Addr     string
	ClientID string
	Username string
	Password string

	AutoReconnect        bool
	MaxReconnectInterval time.Duration
}

type Mqtt

type Mqtt struct {
	Client mqtt.Client
	// contains filtered or unexported fields
}

func NewMqttClient

func NewMqttClient(server *MQTTConfig, logger log.Logger) *Mqtt

func (*Mqtt) DefaultCloseCallBack

func (m *Mqtt) DefaultCloseCallBack(client mqtt.Client, err error)

func (*Mqtt) DefaultConnectCallBack

func (m *Mqtt) DefaultConnectCallBack(client mqtt.Client)

func (*Mqtt) DefaultReConnectsCallBack

func (m *Mqtt) DefaultReConnectsCallBack(client mqtt.Client, err error)

func (*Mqtt) DefaultReceiveCallBack

func (m *Mqtt) DefaultReceiveCallBack(client mqtt.Client, msg mqtt.Message)

func (*Mqtt) Start

func (m *Mqtt) Start(ctx context.Context) error

func (*Mqtt) Stop

func (m *Mqtt) Stop(ctx context.Context) error

func (*Mqtt) Subscribe

func (m *Mqtt) Subscribe(topic string, qos int, callback mqtt.MessageHandler) error

func (*Mqtt) Unsubscribe

func (m *Mqtt) Unsubscribe(topic string) error

type PayloadFunc

type PayloadFunc struct {
	Qos int
	// contains filtered or unexported fields
}

Jump to

Keyboard shortcuts

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