暗黑破坏神不朽点亮九盏灯过关攻略

2026-07-20 22:28:49 热点 783℃

1、言语甚么是完成MQTT

MQTT（Message Queuing Telemetry Transport，消息行列远测传输和谈），和谈是言语一种基于宣布/订阅（publish/subscribe）编制的“轻量级”通信和谈，该和谈构建于TCP/IP和谈上，完成由IBM在1999年宣布。和谈

MQTT最除夜益处在于，言语可以以极少的完成代码和无穷的带宽，为邻接长途设备供给及时刚毅的和谈消息处事。作为一种低开消、言语低带宽占用的完成即时通信和谈，使其在物联网、和谈小型设备、言语挪动独霸等方面有较普及的完成独霸

MQTT是一个基于客户端-处事器的消息宣布/订阅传输和谈。MQTT和谈是和谈轻量、复杂、开放和易于完成的，这些特点使它合用局限特别很是普及。在良多气候下，包含受限的气候中，如：机械与机械（M2M）通信和物联网（IoT）。其在，经由过程卫星链路通信传感器、有时拨号的医疗设备、智能家居、及一些小型化设备中已普及独霸

MQTT另有一个特点就是客户端之间不必彼此通信, MQTT通信更像是邮箱处事，宣布者宣布消息遍地事器，领受者只需订阅了其处事在线后便可收到

完成MQTT和谈需求客户端和处事器端通信完成，在通信过程中，MQTT和谈中有三种身份：宣布者（Publish）、代办代办代办代理（Broker）（处事器）、订阅者（Subscribe）。个中，消息的宣布者和订阅者都是客户端，消息代办代办代办代理是处事器，消息宣布者可以同时是订阅者。

MQTT传输的消息分为：主题（Topic）和负载（payload）两部分：

（1）Topic ，可以邃晓为消息的圭表类型，订阅者订阅（Subscribe）后，就会收到该主题的消息内容（payload）；

（2）payload ，可以邃晓为消息的内容，是指订阅者具体要独霸的内容。

Topic就是新有名，payload就是消息体

MQTT会构建底层群集传输：它将创建客户端遍地事器的邻接，供给二者之间的一个有序的、无损的、基于字撙节的双向传输。

当独霸数据经由过程MQTT群集发送时，MQTT会把与之相干的**处事质量（QoS）和主落款（Topic）**相干络。

2 、Go言语MQTT处事器Broker的搭建

处事端用erlang编写的一个开源项目：emqqtd

# 下载拆卸包wget https://github.com/emqx/emqx/releases/download/v4.0.4/emqx-ubuntu18.04-v4.0.4.zipcd mqttd/emqx.├── bin├── data├── erts-10.5.2├── etc├── lib├── log└── releases# 开启处事./bin/emqx start# 搜检外形./bin/emqx_ctl status# 停止处事./bin/emqx stop

找到本身的IP，访谒http://[你的IP]:18083/#/clients

用户名：admin
暗码：public

便可进进处事器的独霸台

RYTlik

3、Go客户端访谒复杂API

客户端用golang客户端的库：“github.com/eclipse/paho.mqtt.golang”

# 下载依托包go get -u github.com/eclipse/paho.mqtt.golang

实例以下：

编写了两个函数一个宣布一个订阅，传进参数便可处事

改削EMQServerAddress为你处事器的IP

package main// 与后端mqtt处事交互import (	"fmt"	mqtt "github.com/eclipse/paho.mqtt.golang"	"log"	"os"	"strconv"	"time")const EMQServerAddress = "你的IP"// 成立全局mqtt publish消息措置 handlervar messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) { 	fmt.Println("Push Message:")	fmt.Printf("TOPIC: %s\n", msg.Topic())	fmt.Printf("MSG: %s\n", msg.Payload())}// 成立全局mqtt sub消息措置 handlervar messageSubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) { 	fmt.Println("收到订阅消息:")	fmt.Printf("Sub Client Topic : %s \n", msg.Topic())	fmt.Printf("Sub Client msg : %s \n", msg.Payload())}// 邻接的回损掉落踪落函数var connectHandler mqtt.OnConnectHandler =func(client mqtt.Client) { 	fmt.Println("新的邻接!" + " Connected")}// 丢损掉落踪落邻接的回损掉落踪落函数var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) { 	fmt.Printf("Connect loss: %v\n", err)}func init() { 	// 设置设备放置偏向提示	mqtt.DEBUG = log.New(os.Stdout, "		[mqttDEBUG]", 0)	mqtt.ERROR = log.New(os.Stdout, " 	[mqttERROR]", 0)}/** * @Description: 宣布订阅 * @param clientID * @param addr * @param topic * @param payload */func Push(topic string, qos byte, retain bool, payload string) { 	// opts ClientOptions 用于设置 broker，端口	，客户端 id ，用户名暗码等选项	opts := mqtt.NewClientOptions().AddBroker("tcp://" + EMQServerAddress + ":1883").SetClientID("test_push")	opts.SetKeepAlive(60 * time.Second)	// Message callback handler，在没有任何订阅时，宣布端调用此函数	opts.SetDefaultPublishHandler(messagePubHandler)	opts.SetPingTimeout(1 * time.Second)	opts.OnConnect = connectHandler	opts.OnConnectionLost = connectLostHandler	client := mqtt.NewClient(opts)	if token := client.Connect(); token.Wait() && token.Error() != nil { 		panic(token.Error())	}	//宣布消息	// qos是处事质量: ==1: 一次, >=1: 起码一次, <=1:最多一次	// retained: 展示mqtt处事器要保管此次推送的信息，假如有新的订阅者展示
，就会把这消息推送给它（经久化推送）	token := client.Publish(topic, qos, retain, payload)	token.Wait()	fmt.Println("Push Data : "+topic, "Data Size is "+strconv.Itoa(len(payload)))	fmt.Println("Disconnect with broker")	client.Disconnect(250)}/** * @Description: 订阅与消弭订阅 * @param clientID * @param addr * @param topic * @param isSub */func Subscription(topic string, qos byte, isSub bool, handleFun func([]byte)) { 	opts := mqtt.NewClientOptions().AddBroker("tcp://" + EMQServerAddress + ":1883").SetClientID("sub_test")	opts.SetKeepAlive(60 * time.Second)	opts.SetPingTimeout(1 * time.Second)	opts.OnConnect = func(client mqtt.Client) { 		fmt.Println("New Subscription! Connected" + " => " + topic)	}	opts.OnConnectionLost = connectLostHandler	client := mqtt.NewClient(opts)	if token := client.Connect(); token.Wait() && token.Error() != nil { 		panic(token.Error())	}	if isSub { 		// 订阅消息		if token := client.Subscribe(topic, qos, func(client mqtt.Client, msg mqtt.Message) { 			fmt.Printf("Receive Subscribe Message :")			fmt.Printf("Sub Client Topic : %s, Data size is  %d \n", msg.Topic(), len(msg.Payload()))			if len(msg.Payload()) > 0 { 				handleFun(msg.Payload())			}		}); token.Wait() && token.Error() != nil { 			fmt.Println(token.Error())			os.Exit(1)		}	} else { 		// 消弭订阅		if token := client.Unsubscribe(topic); token.Wait() && token.Error() != nil { 			fmt.Println(token.Error())			os.Exit(1)		}	}}