說實話這個折騰了我好久好久，我才知道，原來學習不是最痛苦的，學習卻學不會才是最痛苦的事。生產者將消息發布到一個主題，消費者從該協議里讀取數據，MQTT是為IoT物聯網通信設計的協議，MQTT使物聯網低延遲、更省電，支持3種消息發布服務質量～

知乎視頻?www.zhihu.com

• 最多一次
• 最少一次
• 只有一次

比較出名的MQTT有ActiveMQ（apollo）、IBM Websphere MQ、RabbitMQ、Mosquitto，我實驗中用的是apollo和Mosquitto，本篇文章是一個吐槽大會，因為我有太多苦水要倒掉，昨晚搞到12點半，早上7點醒了又繼續搞到8點，才依依不舍的去上班~

晚上下班，我想說放棄了，放棄了，這個實驗放棄了，我欠兄弟們一個實驗成功截圖，又折騰了好一會，瞅了一眼，什么？客戶端竟然有打印數據？成功了。兄弟們，只要努力，它就一定能成功啊~

• 首先是apollo的cmd中的啟動信息

• 登錄web頁面
• 默認用戶名：admin
• 默認密碼：password

看上去一切很美好的樣子，但是發現代碼跑不起來，報錯信息如下，百度找不到答案，只有自己不停的去嘗試新的方法~

• 之后，我又嘗試了Mosquitto

• 好不容易讓他能連接服務器了
• 結果又斷開了連接（32101錯誤碼）

• 人生苦短，python當歌～
• 人生苦短，python當歌～
• 人生苦短，python當歌～

古話說的好，無心插柳柳成蔭，客戶端成功打印出來過一次，我真的不知道是咋回事，因為服務端老是報錯，所以客戶端就別想消費了，真的是上天眷顧苦心人啊~

代碼計算的是每天共享單車的行程的年度分布情況，先看一下數據長啥樣子：

.map(rec => rec.split(",")).map(rec => (rec(1).split(" ")(0), 1)).updateStateByKey(statefulCount).map(pair => (pair._2, pair._1)).transform(rec => rec.sortByKey(ascending = false))

為什么出現這樣的結果，代碼分析如下：

• [map(rec => (rec(1).split(" ")(0), 1))]
• 第二列是開始時間，獲得：(年月日,1)
• [updateStateByKey(statefulCount)]
• 對相同的年月日，累加后面的1
• [map(pair => (pair._2, pair._1))]
• 調換一個key和value，得到上圖，撒花~

---

我的踩坑服務端代碼：（Java代碼）

import

我的踩坑客戶端代碼：（scala代碼）

import

本篇完，謝謝大家～

總結

以上是生活随笔為你收集整理的java mqtt客户端_MQTT消息队列遥测传输的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。