MQTT的报文标识符, 如何理解 5C

很多控制报文的可变报头部分包含一个两字节的报文标识符字段。这些报文是 PUBLISH(QoS > 0时), PUBACK,PUBREC,PUBREL,PUBCOMP,SUBSCRIBE, SUBACK,UNSUBSCIBE,UNSUBACK。

SUBSCRIBE,UNSUBSCRIBE和PUBLISH(QoS大于0)控制报文必须包含一个非零的16 位报文标识符(Packet Identifier)[MQTT-2.3.1-1]。客户端每次发送一个新的这些类型的报文 时都必须分配一个当前未使用的报文标识符 [MQTT-2.3.1-2]。如果一个客户端要重发这个特 殊的控制报文,在随后重发那个报文时,它必须使用相同的标识符。当客户端处理完这个报 文对应的确认后,这个报文标识符就释放可重用。QoS 1的PUBLISH对应的是PUBACK, QoS 2的PUBLISH对应的是PUBCOMP,与SUBSCRIBE或UNSUBSCRIBE对应的分别是 SUBACK或UNSUBACK [MQTT-2.3.1-3]。发送一个QoS 0的PUBLISH报文时,相同的条件也 适用于服务端 [MQTT-2.3.1-4]。

QoS等于0的PUBLISH报文不能包含报文标识符 [MQTT-2.3.1-5]。
PUBACK, PUBREC, PUBREL报文必须包含与最初发送的PUBLISH报文相同的报文标识符 [MQTT-2.3.1-6]。类似地,SUBACK和UNSUBACK必须包含在对应的SUBSCRIBE和 UNSUBSCRIBE报文中使用的报文标识符 [MQTT-2.3.1-7]。

**1.所谓的报文标识符号,我暂且将其理解成ID, 上面各种报文,我可以理解成是信件
假设古代人行军打仗有各种信都是通过不同颜色的鸡毛来确定的。这个鸡毛的颜色就是标识符,这样理解对吗?是每一种的报文有自己单独的ID 还是每一种报文的每一次都要有不同的ID呢?
2. 为什么Qos0的时候不能有标识符号?
3. 我在规范中还看到一句话,“客户端发送标识符为0x1234的PUBLISH报文,它有可能会在收到那个报文的PUBACK之前, 先收到服务端发送的另一个不同的但是报文标识符也为0x1234的PUBLISH报文。” ID居然可以相同?实在是没有办法理解
**

1个回答

报文标识符用来区分报文,特别是在重发的报文中用来标识是否是同一个报文,并在需要应答的场景中用于确定是对哪个发送报文的应答。可变报头的报文标识符(Packet Identifier)字段存在于在多个类型的报文里。

很多控制报文的可变报头部分包含一个两字节的报文标识符字段。这些报文是PUBLISH(QoS>0时), PUBACK,PUBREC,PUBREL,PUBCOMP,SUBSCRIBE,SUBACK,UNSUBSCIBE,UNSUBACK。
SUBSCRIBE,UNSUBSCRIBE和PUBLISH(QoS大于0)控制报文必须包含一个非零的16位报文标识符(Packet Identifier)。客户端每次发送一个新的这些类型的报文时都必须分配一个当前未使用的报文标识符。如果一个客户端要重发这个特殊的控制报文,在随后重发那个报文时,它必须使用相同的标识符。当客户端处理完这个报文对应的确认后,这个报文标识符就释放可重用。QoS 1的PUBLISH对应的是PUBACK,QoS 2的PUBLISH对应的是PUBCOMP,而SUBSCRIBE或UNSUBSCRIBE对应的分别是SUBACK或UNSUBACK。发送一个QoS0的PUBLISH报文时,相同的条件也适用于服务端?
QoS设置为0的PUBLISH报文不能包含报文标识符。

PUBACK, PUBREC, PUBREL报文必须包含与最初发送的PUBLISH报文相同的报文标识符。类似地,SUBACK和UNSUBACK必须包含在对应的SUBSCRIBE和UNSUBSCRIBE报文中使用的报文标识符。

客户端和服务端彼此独立地分配报文标识符。因此,客户端服务端组合使用相同的报文标识符可以实现并发的消息交换。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
客户端想要调用mqtt服务器上的传来的数据流里的某一项数据应该怎么操作呢

客户端想要调用mqtt服务器上的传来的数据流里的某一项数据应该怎么操作呢 ![图片说明](https://img-ask.csdn.net/upload/201904/11/1554991067_614675.png) 从mqtt.fx 上面收到的数据包是上图这样的,我想调用里面的RSSI值到java算法里面该用什么代码呢,之前听人说可以用mqtt的subscribe,可行吗?

如何使用paho.mqtt.golang库订阅多个MQTT主题?

<div class="post-text" itemprop="text"> <p>I try to connect to a MQTT broker running on an external server where I need to handle multiple different topics. The problem is, that <strong>only the last subscribed handler is called</strong>, even if the topic does not match the one passed as parameter to the <code>Subscribe()</code> method.</p> <p><strong>Example:</strong> sending any content to <code>p1/test</code> triggers the registrationHandler which only should listen for "<em>P1/controller/registration</em>". The other handlers or the DefaultPublishHandler are never called.</p> <p>A simplified version of my program:</p> <pre><code>func main(){ var opts = MQTT.NewClientOptions() opts.AddBroker(address) opts.SetClientID("go-controller") opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) { log.Printf("topic: %s ", msg.Topic()) }) client = MQTT.NewClient(opts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { log.Panicln(token.Error()) } client.Subscribe("P1/#", 0, logHandler) client.Subscribe("P1/controller/registration", 0, registrationHandler) } var logHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { ... log.Printf("Topic %s logged... ", msg.Topic()) } var registrationHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { ... log.Printf("Topic %s registered... ", message.Value) } </code></pre> <p><strong>EDIT #1</strong></p> <p>I found out that the oder of subscribing to topics matters. When I swap both subscription calls the correct handlers get called.</p> </div>

保持MQTT Go客户端运行

<div class="post-text" itemprop="text"> <p>I think it is a silly question, I need a MQTT Client to keep running after connection and subscription. I never encountered the problem because my MQTT clients are always coupled with an HTTP server, and when launching a HTTP server, the code don't stop running. </p> <p>But in the present use case I only need a MQTT Client to subscribe to some topic and stay alive.</p> <p>Here is what I do (the function just connect to a broker and subcribe to one topic.)</p> <pre class="lang-golang prettyprint-override"><code>func main() { godotenv.Load("./.env") _initMqttConnection() } </code></pre> <p>I need the client to stay connected and not stop just after the subscription is done. </p> <p>How to perform that simple thing ?</p> <p>Edit 1 : Complete Code </p> <p></p><div class="snippet" data-lang="js" data-hide="false" data-console="true" data-babel="false"> <div class="snippet-code"> <pre class="snippet-code-js lang-js prettyprint-override"><code>package main import ( "encoding/json" "fmt" "log" "net/http" "os" "path/filepath" "strings" "github.com/yosssi/gmq/mqtt" "github.com/yosssi/gmq/mqtt/client" "github.com/joho/godotenv" "github.com/skratchdot/open-golang/open" ) var cli *client.Client func _initMqttConnection() { cli = client.New(&amp;client.Options{ ErrorHandler: func(err error) { fmt.Println(err) }, }) defer cli.Terminate() log.Println("Connecting to " + os.Getenv("mqtt_host")) err := cli.Connect(&amp;client.ConnectOptions{ Network: "tcp", Address: os.Getenv("mqtt_host"), UserName: []byte(os.Getenv("mqtt_user")), Password: []byte(os.Getenv("mqtt_password")), ClientID: []byte("mqtt_video_launcher"), }) if err != nil { log.Println("Error 1") panic(err) } log.Println("Connected to MQTT") topic_to_sub := []byte("/" + os.Getenv("video_topic")) err = cli.Subscribe(&amp;client.SubscribeOptions{ SubReqs: []*client.SubReq{ &amp;client.SubReq{ TopicFilter: topic_to_sub, QoS: mqtt.QoS0, Handler: func(topicName, message []byte) { //do struff with message fmt.Println(string(topicName), string(message)) }, }, }, }) if err != nil { panic(err) } log.Println("Subscription OK : " + string(topic_to_sub[:len(topic_to_sub)])) } func main() { godotenv.Load("./.env") _initMqttConnection() }</code></pre> </div> </div> <p>The temporary solution I use is adding : </p> <pre><code>http.ListenAndServe(":", nil) </code></pre> <p>at the end. </p> </div>

golang mqtt发布并订阅

<div class="post-text" itemprop="text"> <p>Does anybody know where I can get some example MQTT client Go (golang) code that does both publish and subscribe in an infinite loop ?</p> <p>I am messaging with a Mosquitto broker running on MacOs.</p> <p>In more detail... </p> <ol> <li>Get a message from the network (a topic)</li> <li>Compute something based on that message</li> <li>Send the result of the computation back to the network (topic)</li> </ol> <p>Here is the code I am using:</p> <pre><code>package main import ( "fmt" MQTT "github.com/eclipse/paho.mqtt.golang" "os" "time" ) var knt int var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { fmt.Printf("MSG: %s ", msg.Payload()) text:= fmt.Sprintf("this is result msg #%d!", knt) knt++ token := client.Publish("nn/result", 0, false, text) token.Wait() } func main() { knt = 0 opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883") opts.SetClientID("mac-go") opts.SetDefaultPublishHandler(f) c := MQTT.NewClient(opts) if token := c.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } if token := c.Subscribe("nn/sensors", 0, nil); token.Wait() &amp;&amp; token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } time.Sleep(3 * time.Second) } //end of main </code></pre> <p>I looked through the GoDocs for some hint as to how to keep the connections open but nothing seems pertinent. I can certainly do an infinite loop over the 'subscribe' but that seems inefficient. </p> </div>

使用Goroutine订阅MQTT消息

<div class="post-text" itemprop="text"> <p>I currently have a Go code that can subscribe and print sensor data that is published to a certain topic. Here is my code: </p> <pre><code>package main import ( "crypto/tls" "flag" "fmt" //"log" "os" "os/signal" "strconv" "syscall" "time" MQTT "github.com/eclipse/paho.mqtt.golang" ) func onMessageReceived(client MQTT.Client, message MQTT.Message) { //fmt.Printf("Received message on topic: %s Message: %s ", message.Topic(), message.Payload()) fmt.Printf("%s ", message.Payload()) } func main() { //MQTT.DEBUG = log.New(os.Stdout, "", 0) //MQTT.ERROR = log.New(os.Stdout, "", 0) c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, syscall.SIGTERM) hostname, _ := os.Hostname() server := flag.String("server", "tcp://test.mosquitto.org:1883", "The full url of the MQTT server to connect to ex: tcp://127.0.0.1:1883") topic := flag.String("topic", "topic/sensorTemperature", "Topic to subscribe to") qos := flag.Int("qos", 0, "The QoS to subscribe to messages at") clientid := flag.String("clientid", hostname+strconv.Itoa(time.Now().Second()), "A clientid for the connection") username := flag.String("username", "", "A username to authenticate to the MQTT server") password := flag.String("password", "", "Password to match username") flag.Parse() connOpts := MQTT.NewClientOptions().AddBroker(*server).SetClientID(*clientid).SetCleanSession(true) if *username != "" { connOpts.SetUsername(*username) if *password != "" { connOpts.SetPassword(*password) } } tlsConfig := &amp;tls.Config{InsecureSkipVerify: true, ClientAuth: tls.NoClientCert} connOpts.SetTLSConfig(tlsConfig) connOpts.OnConnect = func(c MQTT.Client) { if token := c.Subscribe(*topic, byte(*qos), onMessageReceived); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } } client := MQTT.NewClient(connOpts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } else { fmt.Printf("Connected to %s ", *server) } &lt;-c } </code></pre> <p>Instead of subscribing to messages like this, I want to put the part of the code that subscribes in a <strong>Goroutine</strong>. I want to be able to call <code>go func onMessageReceived</code>. How can I do that if this function is called in <code>c.Subscribe</code>? And how can I add a <code>sync.WaitGroup</code> parameter in? Thank you.</p> </div>

非阻塞MQTT用户[PHP]

<div class="post-text" itemprop="text"> <p>I am using a raspberry Pi to act as an MQTT broker for a group of sensors. The idea is to have a form with an input field on a website, and based on the value of the input field when submitted, the client should publish a message to the MQTT broker and then start a subscription to the same topic. </p> <p>The website should then wait for a response from the MQTT server (i.e. message sent = "temp" and the RBP publishes a new message "Temp is 35 degrees Celsius". </p> <p>However, when I invoke the subscriber function PHP receives the fatal error <code>Fatal error: Maximum execution time of 30 seconds exceeded</code></p> <p>It seems the PHP is blocking the script for too long, therefore quitting before receiving the a message. I need the PHP script to listen for a maximum of 1-2 minutes, and then it can close the MQTT connection. </p> <pre><code>&lt;?php require("phpMQTT.php"); $server = "xx.xx.xx.xx"; $port = 1883; $username = "username"; $password = "password"; $client_id = uniqid(); $mqtt = new phpMQTT($server, $port, $client_id); //Read message from form, which type of sensor to read $msg = $_POST['sensor']; if (!empty($msg)) { if ($mqtt-&gt;connect(true, null, $username, $password)) { //Publish type of sensor to read $mqtt-&gt;publish("dev/sensors", $msg , 0); $mqtt-&gt;close(); } //Start listen for response subscribeToTopic($mqtt); } function subscribeToTopic($mqtt) { //Set topic to listen to $topics['dev/sensors'] = array("qos" =&gt; 0, "function" =&gt; "procmsg"); $mqtt-&gt;subscribe($topics, 0); //Listen for the response in the subscribed topic while ($mqtt-&gt;proc()) { } $mqtt-&gt;close(); } function procmsg($topic, $msg) { global $mqtt; echo $msg; //Close mqtt-connection after message is received $mqtt-&gt;close(); } ?&gt; </code></pre> <p>If using MQTT is not possible for website / MQTT server connections, what would be a more suitable alternative to achieve this logic? </p> </div>

在程序MQTT期间更改订阅主题

<div class="post-text" itemprop="text"> <p>I have a MQTT Go program that is subscribed to the topic <code>"info"</code>, in which I receive a JSON message. I validate that JSON message, and if the validation is successful, I want to start subscribing to a new topic <code>"info_updates"</code>. Here is my <strong>subscribing</strong> code: </p> <pre><code>func Info(){ c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, syscall.SIGTERM) opts := MQTT.NewClientOptions().AddBroker("tcp://test.mosquitto.org:1883") opts.SetDefaultPublishHandler(f) topic := "info" //I want to be able to change this later to "info_updates" opts.OnConnect = func(c MQTT.Client) { if token := c.Subscribe(topic, 0, f); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } } // Creating new client client := MQTT.NewClient(opts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } else { fmt.Printf("Connected to server ") } &lt;-c } </code></pre> <p>Here is the code where I validate the JSON (parts of it):</p> <pre><code>var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { var integrationResult string if JSONValidate(msg.Payload())[0] == ""{ //sanity check = successful integrationResult = "successful" }else{ //sanity check = unsuccessful integrationResult = "unsuccessful" } //do something here to tell the first function to change subscribing topic if integrationResult = "successful" } </code></pre> <p><strong>Note:</strong> <code>func Info()</code> and <code>MQTT.MessageHandler</code> are in two seperate files. I am stumped on how I can communicate with <code>func Info()</code> to change the topic subscription. Thank you. </p> </div>

esp8266+mqtt主动发布消息问题

我看好多人都是在mqttDataCb()这个函数里,接收到云端数据后给云端回复数据。而我想esp8266主动发送数据给云端,利用这个函数void mqttPublishedCb(uint32_t *args) { MQTT_Client* client = (MQTT_Client*)args; if(suart_flag) { MQTT_Publish(client, "/mqtt/topic/0", "hello0", 6, 0, 0); } INFO("MQTT: Published\r\n"); } 但不知道为什么加了判定就不能主动发布了,请问有人知道为什么吗,应该在哪个函数主动发布消息啊?

RabbitMQ 插件MQTT使用 mqtt需要大量连接设备 for Java

RabbitMQ 插件MQTT使用 mqtt需要大量连接设备 for Java 使用RabbitMQ作为mqtt的服务器,如何管理mqtt创建大量连接进行发布与订阅消息。(云端服务器)设备与云端服务器建立长连接

Golang中的mqtt客户端偶尔断开连接

<div class="post-text" itemprop="text"> <p>I am using paho mqtt client in GO to connect to a broker. Everything works fine for a while, in which I can publish to topics and listen to any subscription. After a while the client loses connection to the broker, for no apparent reason with this log:</p> <pre><code>[MQTT] ERROR: 2018/09/04 17:31:30 [net] outgoing stopped with error write tcp IP1 -&gt; IP2: write: broken pipe [MQTT] ERROR: 2018/09/04 17:31:30 [net] logic received from error channel, other components have errored, stopping </code></pre> <p>I am connecting to the broker like this:</p> <pre><code>opts := mqtt.NewClientOptions(). AddBroker(broker). SetClientID(fmt.Sprintf("%s-%v", ProgramName, time.Now().Unix())). SetUsername(username). SetPassword(password). SetOrderMatters(true) if tlsConfig != nil { opts.SetTLSConfig(tlsConfig) } pahoClient := mqtt.NewClient(opts) client = &amp;DefaultMQTTClient{ c: pahoClient, subscribeQoS: subscribeQoS, publishQoS: publishQoS, name: name, log: Log.WithPrefix("mqtt").WithFields(logrus.Fields{ "name": name, "broker": broker, }), } client.Log().Debug("connecting to mqtt broker") if err = client.Connect(); err != nil { err = client.Log().Trace(err, "failed to connect to mqtt broker") return } client.Log().Info("established connection with mqtt broker") </code></pre> <p>And the version of paho that I am using is 1.0.0. Any hint is welcome!</p> </div>

RabbitMQ 插件MQTT使用

如何开MQTT的SSL连接,Java如何使用 RabbitMQ如何开启SSL连接,并进行使用

如何检查我与mqtt代理的连接是否断开?

<div class="post-text" itemprop="text"> <p>我正在尝试使用<a href="https://github.com/eclipse/paho.mqtt.golang" rel="nofollow noreferrer">paho</a> pkg来通过golang构建MQTT子客户端,当代理断开连接时,我的客户端就会出现问题,我一开始以为会出现丢失的消息,但这种情况并没有发生,启动代理后,MQTT子客户端却无法获得由MQTT PUB客户端发送的消息。</p> <p>为什么会发生这种事,我怎么才能解决呢?</p> <p>代码:</p> <pre><code>package main import ( "fmt" "os" mqtt "github.com/eclipse/paho.mqtt.golang" ) var ( broker = "tcp://localhost:1883" f mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) { fmt.Printf("TOPIC: %s ", msg.Topic()) fmt.Printf("MSG: %s ", msg.Payload()) } ) func main() { //create a ClientOptions opts := mqtt.NewClientOptions().AddBroker(broker) opts.SetClientID("group-one") opts.SetDefaultPublishHandler(f) //create and start a client using the above ClientOptions c := mqtt.NewClient(opts) if token := c.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } if token := c.Subscribe("test", 0, nil); token.Wait() &amp;&amp; token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } for { } } </code></pre> </div>

使用Goroutine订阅MQTT不打印消息

<div class="post-text" itemprop="text"> <p>I currently have Go code that subscribes to a topic and prints out sensor data. The part that prints out the sensor data is in a <strong>Goroutine</strong>, however, nothing is printing out currently. This is my code: </p> <pre><code>package main import ( "fmt" MQTT "github.com/eclipse/paho.mqtt.golang" "os" "os/signal" "syscall" "sync" ) var wg sync.WaitGroup func subscriber(client MQTT.Client, message MQTT.Message) { wg.Add(1) go func() { defer wg.Done() fmt.Printf("%s ", message.Payload()) }() } func main() { c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, syscall.SIGTERM) opts := MQTT.NewClientOptions().AddBroker("tcp://test.mosquitto.org:1883") //opts.SetDefaultPublishHandler(f) // Topic to subscribe to for sensor data topic := "sensor/data" client := MQTT.NewClient(opts) if token := client.Connect(); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } else { fmt.Printf("Connected to server ") } opts.OnConnect = func(c MQTT.Client) { //if token := c.Subscribe(topic, 0, f); token.Wait() &amp;&amp; token.Error() != nil { if token := c.Subscribe(topic, 0, subscriber); token.Wait() &amp;&amp; token.Error() != nil { panic(token.Error()) } } wg.Wait() &lt;-c } </code></pre> <p>I'm wondering if it has to do with the way I coded the sync.WaitGroup? Any ideas are appreciated. </p> </div>

在订阅完成之前,AWS MQTT连接丢失

<div class="post-text" itemprop="text"> <p>I'm having an intermittent issue with go trying to connect to AWS MQTT. Sometimes it works fine, other times not so much. When I connect I get this error: Connection lost before Subscribe completed</p> <p>I'm really not sure why it does this, at first everything seemed to work fine but now it throws this error more often than not. Here's the code that I'm using to connect:</p> <pre><code>type ServerConnection struct { Cert tls.Certificate Host string Port int Path string Topic string Qos int Messages chan MQTT.Message Control chan os.Signal } func (server *ServerConnection) Start() error { cid := uuid.New().String() connOpts := &amp;MQTT.ClientOptions{ ClientID: cid, CleanSession: true, AutoReconnect: true, MaxReconnectInterval: 1 * time.Second, KeepAlive: 30000, TLSConfig: tls.Config{Certificates: []tls.Certificate{server.Cert}}, } connOpts.SetConnectTimeout(30 * time.Second) connOpts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) { server.Messages &lt;- msg }) brokerURL := fmt.Sprintf("tcps://%s:%d%s", server.Host, server.Port, server.Path) connOpts.AddBroker(brokerURL) mqttClient := MQTT.NewClient(connOpts) if token := mqttClient.Connect(); token.Wait() &amp;&amp; token.Error() != nil { return token.Error() } // Subscribe go func() { log.Printf("subscribing") if token := mqttClient.Subscribe(server.Topic, byte(server.Qos), nil); token.Wait() &amp;&amp; token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } log.Printf("subscribed") }() server.ProcessMessages() log.Println("[MQTT] Connected") quit := make(chan struct{}) signal.Notify(server.Control, os.Interrupt) go func() { &lt;-server.Control mqttClient.Disconnect(250) fmt.Println("[MQTT] Disconnect") quit &lt;- struct{}{} }() &lt;-quit return nil } </code></pre> </div>

保持MQTT客户端连接始终处于活动状态

<div class="post-text" itemprop="text"> <p>I am using <code>CloudMQTT</code> as a <code>MQTT broker</code> in my Pub-Sub based application. I am using my <code>publisher</code> to publish data to the <code>CloudMQTT server</code> over a <code>topic</code>, and I plan to <code>subscribe</code> to the broker on my webpage to recieve the transmitted information.</p> <p>I am using this procedure to create a <code>Client</code>(subscriber): <a href="https://www.cloudmqtt.com/docs-php.html" rel="nofollow">https://www.cloudmqtt.com/docs-php.html</a></p> <p>Code goes as follows:</p> <pre><code>// subscribe.php require("phpMQTT.php"); $host = "hostname"; $port = port; $username = "username"; $password = "password"; $mqtt = new phpMQTT($host, $port, "ClientID".rand()); if(!$mqtt-&gt;connect(true,NULL,$username,$password)){ exit(1); } //currently subscribed topics $topics['topic'] = array("qos"=&gt;0, "function"=&gt;"procmsg"); $mqtt-&gt;subscribe($topics,0); while($mqtt-&gt;proc()){ } $mqtt-&gt;close(); function procmsg($topic,$msg){ echo "Msg Recieved: $msg"; } </code></pre> <p>Here is the <code>phpMQTT.php</code> file: <a href="https://github.com/bluerhinos/phpMQTT/blob/master/phpMQTT.php" rel="nofollow">https://github.com/bluerhinos/phpMQTT/blob/master/phpMQTT.php</a></p> <p>However, the issue in this case is that it recieves data only when the webpage is open.. I want to keep the connection alive even if the webpage is not open to always recieve published messages, how can I do it?</p> <p><strong>EDIT :</strong> I might be open to using some other technology on the server to handle this subscription process, if anyone can recommend some alternatives</p> </div>

MQTT 请求/响应模式的使用。

在使用MQTT协议的过程中需用到请求/响应模式,在MQTT5.0新特性中新增了Request/Response模式,但未找到测试程序,不知哪位大神用过这个模式阿,能否给一份测试代码,感激不尽! 目的是实现A向B发一条指令,B根据这个条指令回复一条信息,有类似的程序都可以啊。还要求只能是C语言的程序。 编程能力较弱,可能问题提问比较菜,希望各位大神帮帮忙啊。 各位大神,帮帮孩子吧

LinkIT One使用paho mqtt连接服务器失败

背景描述: 使用LinkIT One基于paho的mqtt客户端,当代码执行到rc=client.connect(data);,超时然后返回rc=-1。 测试连接的服务端包括IBM Watson、中移OneNet还有自己搭建的mosquitto,都是一样的错误。查了一下paho的实现代码,把MQTTClient.h中的connect实现改了一下就connect成功了,但subscribe又超时并返回错误了(如下所示)。 在网上查到了和我类似的错误,貌似LinkIT One并不能使用paho的mqtt。但将mqtt客户端换成pubsub后却能够正常工作。 下面是我的测试代码(mqtt服务器是本地局域网的mosquitto) ``` #include <LWiFi.h> #include <LWiFiClient.h> #include <IPStack.h> #include <Countdown.h> #include <MQTTClient.h> #define WIFI_AP "SSID" #define WIFI_PASSWORD "PASSWD" #define WIFI_AUTH LWIFI_WPA int port = 1883; char servername[]="10.214.149.119"; char clientName[] = "myaccount"; char topicName[] = "@tp"; char userName[] = "myaccount"; char password[] = "12345"; LWiFiClient tcpClient; IPStack ipstack(tcpClient); MQTT::Client<IPStack, Countdown, 200> client = MQTT::Client<IPStack, Countdown, 200>(ipstack); void messageArrived(MQTT::MessageData& md){ MQTT::Message &message = md.message; char res[100]; int len = message.payloadlen; strncpy(res, (char*)message.payload, len); res[len] = '\0'; Serial.println(res); } void setup(){ Serial.begin(9600); while(!Serial.available()); InitWiFi(); if (!client.isConnected()) reconnect(); int rc = client.subscribe(topicName, MQTT::QOS0, messageArrived); if (rc != 0) Serial.println(String("rc from MQTT subscribe is ")+rc); else Serial.println(String("rc from MQTT subscribe is ")+rc); } void loop(){ Serial.println("loop"); client.yield(100); delay(2000); } void InitWiFi(){ LWiFi.begin(); // Keep retrying until connected to AP Serial.println("Connecting to AP"); while (0 == LWiFi.connect(WIFI_AP, LWiFiLoginInfo(WIFI_AUTH, WIFI_PASSWORD))) { Serial.println("Retry connect AP ... "); delay(1000); } Serial.println("Connected to AP"); } void reconnect() { // Loop until we're reconnected if(!client.isConnected()) { int rc = ipstack.connect(servername, port); if (rc == 1){ Serial.println("IPStack Success"); }else{ Serial.println("IPStack Failed"); } Serial.print("Connecting to IOT platform ..."); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 4; data.clientID.cstring = clientName; data.username.cstring = userName; data.password.cstring = password; rc = client.connect(data); if (rc == 0) { Serial.println( "[DONE]" ); } else { Serial.println( "[FAILED]"); delay(5000); } } } ``` 我的问题是: 有没有大神使用LinkIT One基于paho的mqtt实现了客户端,可以正常pub/sub话题,测试的mqtt代理可以是mosquitto或IBM Watson或中移OneNet?允许修改paho或LWiFiClient的源码?(我只要基于paho的实现) 提示: 1.通过之前在Arduino UNO、BeagleBone Black、树莓派2的实验感觉各种mqtt的代理基本都一样的,能在mosquitto上测试通过的基本都能在IBM Watson或OneNet上测试通过; 2.LinkIt One用pubsub测试没有问题,这说明LWiFiClient很大概率是没问题的,估计要修改paho的实现代码

关于java通过ssl连接mqtt

我这边java在没有通过ssl连接mqtt的时候是可以连接的(可以订阅与发布), 但是通过ssl就不行了,发现是读取证书的时候出错了,错误是这样的: java.security.cert.CertificateException: Unable to initialize, java.io.IOException: extra data given to DerValue constructor at sun.security.x509.X509CertImpl.<init>(Unknown Source) at sun.security.provider.X509Factory.engineGenerateCertificate(Unknown Source) at java.security.cert.CertificateFactory.generateCertificate(Unknown Source) at com.test.mqtt.AppTest.main(AppTest.java:51) Caused by: java.io.IOException: extra data given to DerValue constructor at sun.security.util.DerValue.init(Unknown Source) at sun.security.util.DerValue.<init>(Unknown Source) at sun.security.util.DerValue.<init>(Unknown Source) ... 4 more 具体代码是: CertificateFactory cf; try { cf = CertificateFactory.getInstance("X.509"); FileInputStream crtIn = new FileInputStream("D:\\test\\client.crt"); X509Certificate caCert = (X509Certificate) cf.generateCertificate(crtIn); //Certificate caCert = cf.generateCertificate(crtIn); crtIn.close(); } catch (CertificateException e) { // TODO Auto-generated catch block e.printStackTrace(); }

MQTT客户端Paho MQTT和mosquitto有什么区别?

最近要使用C语言在路由器上开发MQTT客户端,是直接使用共享库或静态库的库函数来连接Broker,不是直接使用sample里面的可执行程序。 在网上搜了下,Paho MQTT和mosquitto都可以作为MQTT客户端,不知道两者有什么区别?可以的话麻烦从库的大小、编译时是否依赖其他第三方库、功能的完整性等几方面比较一下

定量遥感中文版 梁顺林著 范闻捷译

这是梁顺林的定量遥感的中文版,由范闻捷等翻译的,是电子版PDF,解决了大家看英文费时费事的问题,希望大家下载看看,一定会有帮助的

Java 最常见的 200+ 面试题:面试必备

这份面试清单是从我 2015 年做了 TeamLeader 之后开始收集的,一方面是给公司招聘用,另一方面是想用它来挖掘在 Java 技术栈中,还有那些知识点是我不知道的,我想找到这些技术盲点,然后修复它,以此来提高自己的技术水平。虽然我是从 2009 年就开始参加编程工作了,但我依旧觉得自己现在要学的东西很多,并且学习这些知识,让我很有成就感和满足感,那所以何乐而不为呢? 说回面试的事,这份面试...

机器学习初学者必会的案例精讲

通过六个实际的编码项目,带领同学入门人工智能。这些项目涉及机器学习(回归,分类,聚类),深度学习(神经网络),底层数学算法,Weka数据挖掘,利用Git开源项目实战等。

远程工具,免费

远程工具,免费

java jdk 8 帮助文档 中文 文档 chm 谷歌翻译

JDK1.8 API 中文谷歌翻译版 java帮助文档 JDK API java 帮助文档 谷歌翻译 JDK1.8 API 中文 谷歌翻译版 java帮助文档 Java最新帮助文档 本帮助文档是使用谷

csma/ca和csma/cd的matlab仿真源代码带有详细的注释

csma/ca和csma/cd的matlab仿真源代码带有详细的注释,载波侦听,随意设置节点数,带有炫酷的图形展示效果。

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

软件测试入门、SQL、性能测试、测试管理工具

软件测试2小时入门,让您快速了解软件测试基本知识,有系统的了解; SQL一小时,让您快速理解和掌握SQL基本语法 jmeter性能测试 ,让您快速了解主流来源性能测试工具jmeter 测试管理工具-禅道,让您快速学会禅道的使用,学会测试项目、用例、缺陷的管理、

pokemmo的资源

pokemmo必须的4个rom 分别为绿宝石 火红 心金 黑白 还有汉化补丁 资源不错哦 记得下载

三个项目玩转深度学习(附1G源码)

从事大数据与人工智能开发与实践约十年,钱老师亲自见证了大数据行业的发展与人工智能的从冷到热。事实证明,计算机技术的发展,算力突破,海量数据,机器人技术等,开启了第四次工业革命的序章。深度学习图像分类一直是人工智能的经典任务,是智慧零售、安防、无人驾驶等机器视觉应用领域的核心技术之一,掌握图像分类技术是机器视觉学习的重中之重。针对现有线上学习的特点与实际需求,我们开发了人工智能案例实战系列课程。打造:以项目案例实践为驱动的课程学习方式,覆盖了智能零售,智慧交通等常见领域,通过基础学习、项目案例实践、社群答疑,三维立体的方式,打造最好的学习效果。

无线通信中的智能天线:IS-95和第3代CDMA应用_.pdf

无线通信中的智能天线:IS-95和第3代CDMA应用_.pdf

设计模式(JAVA语言实现)--20种设计模式附带源码

课程亮点: 课程培训详细的笔记以及实例代码,让学员开始掌握设计模式知识点 课程内容: 工厂模式、桥接模式、组合模式、装饰器模式、外观模式、享元模式、原型模型、代理模式、单例模式、适配器模式 策略模式、模板方法模式、观察者模式、迭代器模式、责任链模式、命令模式、备忘录模式、状态模式、访问者模式 课程特色: 笔记设计模式,用笔记串连所有知识点,让学员从一点一滴积累,学习过程无压力 笔记标题采用关键字标识法,帮助学员更加容易记住知识点 笔记以超链接形式让知识点关联起来,形式知识体系 采用先概念后实例再应用方式,知识点深入浅出 提供授课内容笔记作为课后复习以及工作备查工具 部分图表(电脑PC端查看):

Java8零基础入门视频教程

这门课程基于主流的java8平台,由浅入深的详细讲解了java SE的开发技术,可以使java方向的入门学员,快速扎实的掌握java开发技术!

玩转Linux:常用命令实例指南

人工智能、物联网、大数据时代,Linux正有着一统天下的趋势,几乎每个程序员岗位,都要求掌握Linux。本课程零基础也能轻松入门。 本课程以简洁易懂的语言手把手教你系统掌握日常所需的Linux知识,每个知识点都会配合案例实战让你融汇贯通。课程通俗易懂,简洁流畅,适合0基础以及对Linux掌握不熟练的人学习; 【限时福利】 1)购课后按提示添加小助手,进答疑群,还可获得价值300元的编程大礼包! 2)本月购买此套餐加入老师答疑交流群,可参加老师的免费分享活动,学习最新技术项目经验。 --------------------------------------------------------------- 29元=掌握Linux必修知识+社群答疑+讲师社群分享会+700元编程礼包。 &nbsp;

极简JAVA学习营第四期(报名以后加助教微信:eduxy-1)

想学好JAVA必须要报两万的培训班吗? Java大神勿入 如果你: 零基础想学JAVA却不知道从何入手 看了一堆书和视频却还是连JAVA的环境都搭建不起来 囊中羞涩面对两万起的JAVA培训班不忍直视 在职没有每天大块的时间专门学习JAVA 那么恭喜你找到组织了,在这里有: 1. 一群志同道合立志学好JAVA的同学一起学习讨论JAVA 2. 灵活机动的学习时间完成特定学习任务+每日编程实战练习 3. 热心助人的助教和讲师及时帮你解决问题,不按时完成作业小心助教老师的家访哦 上一张图看看前辈的感悟: &nbsp; &nbsp; 大家一定迫不及待想知道什么是极简JAVA学习营了吧,下面就来给大家说道说道: 什么是极简JAVA学习营? 1. 针对Java小白或者初级Java学习者; 2. 利用9天时间,每天1个小时时间; 3.通过 每日作业 / 组队PK / 助教答疑 / 实战编程 / 项目答辩 / 社群讨论 / 趣味知识抢答等方式让学员爱上学习编程 , 最终实现能独立开发一个基于控制台的‘库存管理系统’ 的学习模式 极简JAVA学习营是怎么学习的? &nbsp; 如何报名? 只要购买了极简JAVA一:JAVA入门就算报名成功! &nbsp;本期为第四期极简JAVA学习营,我们来看看往期学员的学习状态: 作业看这里~ &nbsp; 助教的作业报告是不是很专业 不交作业打屁屁 助教答疑是不是很用心 &nbsp; 有奖抢答大家玩的很嗨啊 &nbsp; &nbsp; 项目答辩终于开始啦 &nbsp; 优秀者的获奖感言 &nbsp; 这是答辩项目的效果 &nbsp; &nbsp; 这么细致的服务,这么好的氛围,这样的学习效果,需要多少钱呢? 不要1999,不要199,不要99,只要9.9 是的你没听错,只要9.9以上所有就都属于你了 如果你: 1、&nbsp;想学JAVA没有基础 2、&nbsp;想学JAVA没有整块的时间 3、&nbsp;想学JAVA没有足够的预算 还等什么?赶紧报名吧,抓紧抢位,本期只招300人,错过只有等时间待定的下一期了 &nbsp; 报名请加小助手微信:eduxy-1 &nbsp; &nbsp;

Python数据清洗实战入门

本次课程主要以真实的电商数据为基础,通过Python详细的介绍了数据分析中的数据清洗阶段各种技巧和方法。

董付国老师Python全栈学习优惠套餐

购买套餐的朋友可以关注微信公众号“Python小屋”,上传付款截图,然后领取董老师任意图书1本。

linux下利用/proc进行进程树的打印

在linux下利用c语言实现的进程树的打印,主要通过/proc下的目录中的进程文件,获取status中的进程信息内容,然后利用递归实现进程树的打印

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

HoloLens2开发入门教程

本课程为HoloLens2开发入门教程,讲解部署开发环境,安装VS2019,Unity版本,Windows SDK,创建Unity项目,讲解如何使用MRTK,编辑器模拟手势交互,打包VS工程并编译部署应用到HoloLens上等。

150讲轻松搞定Python网络爬虫

【为什么学爬虫?】 &nbsp; &nbsp; &nbsp; &nbsp;1、爬虫入手容易,但是深入较难,如何写出高效率的爬虫,如何写出灵活性高可扩展的爬虫都是一项技术活。另外在爬虫过程中,经常容易遇到被反爬虫,比如字体反爬、IP识别、验证码等,如何层层攻克难点拿到想要的数据,这门课程,你都能学到! &nbsp; &nbsp; &nbsp; &nbsp;2、如果是作为一个其他行业的开发者,比如app开发,web开发,学习爬虫能让你加强对技术的认知,能够开发出更加安全的软件和网站 【课程设计】 一个完整的爬虫程序,无论大小,总体来说可以分成三个步骤,分别是: 网络请求:模拟浏览器的行为从网上抓取数据。 数据解析:将请求下来的数据进行过滤,提取我们想要的数据。 数据存储:将提取到的数据存储到硬盘或者内存中。比如用mysql数据库或者redis等。 那么本课程也是按照这几个步骤循序渐进的进行讲解,带领学生完整的掌握每个步骤的技术。另外,因为爬虫的多样性,在爬取的过程中可能会发生被反爬、效率低下等。因此我们又增加了两个章节用来提高爬虫程序的灵活性,分别是: 爬虫进阶:包括IP代理,多线程爬虫,图形验证码识别、JS加密解密、动态网页爬虫、字体反爬识别等。 Scrapy和分布式爬虫:Scrapy框架、Scrapy-redis组件、分布式爬虫等。 通过爬虫进阶的知识点我们能应付大量的反爬网站,而Scrapy框架作为一个专业的爬虫框架,使用他可以快速提高我们编写爬虫程序的效率和速度。另外如果一台机器不能满足你的需求,我们可以用分布式爬虫让多台机器帮助你快速爬取数据。 &nbsp; 从基础爬虫到商业化应用爬虫,本套课程满足您的所有需求! 【课程服务】 专属付费社群+每周三讨论会+1v1答疑

MySQL 8.0.19安装教程(windows 64位)

话不多说直接开干 目录 1-先去官网下载点击的MySQL的下载​ 2-配置初始化的my.ini文件的文件 3-初始化MySQL 4-安装MySQL服务 + 启动MySQL 服务 5-连接MySQL + 修改密码 先去官网下载点击的MySQL的下载 下载完成后解压 解压完是这个样子 配置初始化的my.ini文件的文件 ...

Python数据挖掘简易入门

&nbsp; &nbsp; &nbsp; &nbsp; 本课程为Python数据挖掘方向的入门课程,课程主要以真实数据为基础,详细介绍数据挖掘入门的流程和使用Python实现pandas与numpy在数据挖掘方向的运用,并深入学习如何运用scikit-learn调用常用的数据挖掘算法解决数据挖掘问题,为进一步深入学习数据挖掘打下扎实的基础。

深度学习原理+项目实战+算法详解+主流框架(套餐)

深度学习系列课程从深度学习基础知识点开始讲解一步步进入神经网络的世界再到卷积和递归神经网络,详解各大经典网络架构。实战部分选择当下最火爆深度学习框架PyTorch与Tensorflow/Keras,全程实战演示框架核心使用与建模方法。项目实战部分选择计算机视觉与自然语言处理领域经典项目,从零开始详解算法原理,debug模式逐行代码解读。适合准备就业和转行的同学们加入学习! 建议按照下列课程顺序来进行学习 (1)掌握深度学习必备经典网络架构 (2)深度框架实战方法 (3)计算机视觉与自然语言处理项目实战。(按照课程排列顺序即可)

网络工程师小白入门--【思科CCNA、华为HCNA等网络工程师认证】

本课程适合CCNA或HCNA网络小白同志,高手请绕道,可以直接学习进价课程。通过本预科课程的学习,为学习网络工程师、思科CCNA、华为HCNA这些认证打下坚实的基础! 重要!思科认证2020年2月24日起,已启用新版认证和考试,包括题库都会更新,由于疫情原因,请关注官网和本地考点信息。题库网络上很容易下载到。

Ubuntu18.04安装教程

Ubuntu18.04.1安装一、准备工作1.下载Ubuntu18.04.1 LTS2.制作U盘启动盘3.准备 Ubuntu18.04.1 的硬盘空间二、安装Ubuntu18.04.1三、安装后的一些工作1.安装输入法2.更换软件源四、双系统如何卸载Ubuntu18.04.1新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列...

sql语句 异常 Err] 1064 - You have an error in your SQL syntax; check the manual that corresponds to your

在我们开发的工程中,有时候会报 [Err] 1064 - You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ------ 这种异常 不用多想,肯定是我们的sql语句出现问题,下面...

西南交通大学新秀杯数学建模试题

题目比较难,如果符合大家的口味欢迎大家下载哈,提高你的思维想象能力

Windows版YOLOv4目标检测实战:训练自己的数据集

课程演示环境:Windows10; cuda 10.2; cudnn7.6.5; Python3.7; VisualStudio2019; OpenCV3.4 需要学习ubuntu系统上YOLOv4的同学请前往:《YOLOv4目标检测实战:训练自己的数据集》 课程链接:https://edu.csdn.net/course/detail/28745 YOLOv4来了!速度和精度双提升! 与 YOLOv3 相比,新版本的 AP (精度)和 FPS (每秒帧率)分别提高了 10% 和 12%。 YOLO系列是基于深度学习的端到端实时目标检测方法。本课程将手把手地教大家使用labelImg标注和使用YOLOv4训练自己的数据集。课程实战分为两个项目:单目标检测(足球目标检测)和多目标检测(足球和梅西同时检测)。 本课程的YOLOv4使用AlexyAB/darknet,在Windows系统上做项目演示。包括:安装软件环境、安装YOLOv4、标注自己的数据集、整理自己的数据集、修改配置文件、训练自己的数据集、测试训练出的网络模型、性能统计(mAP计算)和先验框聚类分析。还将介绍改善YOLOv4目标检测性能的技巧。 除本课程《Windows版YOLOv4目标检测实战:训练自己的数据集》外,本人将推出有关YOLOv4目标检测的系列课程。请持续关注该系列的其它视频课程,包括: 《Windows版YOLOv4目标检测实战:人脸口罩佩戴检测》 《Windows版YOLOv4目标检测实战:中国交通标志识别》 《Windows版YOLOv4目标检测:原理与源码解析》

Spring Boot -01- 快速入门篇(图文教程)

Spring Boot -01- 快速入门篇 今天开始不断整理 Spring Boot 2.0 版本学习笔记,大家可以在博客看到我的笔记,然后大家想看视频课程也可以到【慕课网】手机 app,去找【Spring Boot 2.0 深度实践】的课程,令人开心的是,课程完全免费! 什么是 Spring Boot? Spring Boot 是由 Pivotal 团队提供的全新框架。Spring Boot...

相关热词 c# dbml文件 修改 c#遍历tree c# 能够控制单片机 c#对象写入数据库 c# 添加activex c#2005 json c# 数据库在云端 c# 字符串移位加密 c#禁用滚轮 c#实体类list去重复
立即提问