mqtt編譯失敗

Ⅰ 在雲伺服器上搭建了mqtt，為什麼手機連接不上mqtt，要怎麼做才能連接上求求大神幫忙

MQTT協議是廣泛應用的物聯網協議，使用測試MQTT協議需要MQTT的代理。有兩種方法使用MQTT服務，一是租用現成的MQTT伺服器，如阿里雲，網路雲，華為雲等公用的雲平台提供的MQTT服務，使用公用的MQTT伺服器的好處是省事，但如果僅僅用於測試學習還需要注冊帳號，靈活性差些，有的平台還需要付費。另一方法是自己使用開源的MQTT組件來搭建。
MQTT伺服器非常多，如apache的ActiveMQ，emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。
這里介紹的是用輕量級的mosquitto開源項目來搭建一個屬於自己的MQTT伺服器。
第一步：需要安裝一台linux主機，這不多介紹，可以使用真機安裝也可以使用虛擬機安裝。如果僅僅是自己測試使用都可以。
第二步：下載mosquitto需要的依賴
sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake

第三步：下載mosquitto並解壓，現在mosquitto官網最新的版本是1.5.1
tar xzvf mosquitto-1.5.1.tar.gz
第四步：編譯
cd mosquitto-1.5.1/
make
make install
第五步：啟動mosquitto
./mosquitto -v
1535473957: mosquitto version 1.5.1 starting
1535473957: Using default config.
1535473957: Opening ipv4 listen socket on port 1883.
1535473957: Opening ipv6 listen socket on port 1883.
這時候mosquitto就會以默認的參數啟動。如果需要帶配置文件可以修改配置文件mosquitto.conf，
啟動時候加上參數 -c，
./mosquitto -c mosquitto.conf
可以看到，mosquitto監聽的埠為1883.
這時候我們的MQTT伺服器就搭建好了。可找一個mqtt客戶端來測試一下。
先發布一個主題「home/garden/fountain/2」
內容是「hello world」
這時候在mosquitto會列印出下面的log
535474247: New connection from 192.168.1.105 on port 1883.
1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).
1535474247: No will message specified.
1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)
1535474307: Received PINGREQ from MQTT_FX_Client
1535474307: Sending PINGRESP to MQTT_FX_Client
1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))
1535474367: Received PINGREQ from MQTT_FX_Client
1535474367: Sending PINGRESP to MQTT_FX_Client

訂閱主題「home/garden/fountain/2」

可以看到收到了自己發布的消息。
用wireshark抓包
可以看到抓到了一個MQTT的publish的報文。

Ⅱ Paho Mqtt SSL連接時常見異常問題以及解決方案

在使用Mqtt的SSL方式連接時遇到了如下問題：

說明使用SSL連接配置中的TrustManager里的server驗證失敗，即服務端證書簽名時用的host和現在簽名的host不是同一個。如果是HTTPS，可以通過重寫hostNameVerifyer的方法來解決問題，網上有很多攻略
對於Mqtt連接時遇到這個問題，應該檢查是否pom.xml中依賴的版本有沖突。經實際驗證，paho的版本使用 較新 版本時會遇到這個問題（無論證書是正確/錯誤，均優先報no name mathing錯誤，推測是較低版本的校驗機制較弱）因此可以參考下面的搭配，使用較低版本跳過這個錯誤。因為暫未找到mqtt ssl連接時忽略host驗證的方法

對於Mqtt連接時遇到這個問題，應該檢查是否現在所使用的證書，和伺服器端的證書不是同一個。這一次就栽在這個問題上了

pom.xml文件中的依賴：

Ⅲ Android MQTT 通信

  MQTT 協議 是基於發布/訂閱模式的物聯網通信協議，憑借簡單易實現、支持 QoS、報文小等特點，占據了物聯網協議的半壁江山。
  常用於 IOT 物聯網和一些需要服務端主動通知客戶端的場景。

1. 導入依賴

2. 創建 MqttHelper 輔助類，設置回調監聽

3. 連接 MQTT

  連接成功或失敗，以及中途的連接掉線，會觸發 OnMqttStatusChangeListener 回調

4. MQTT 連接狀態監聽

5. MQTT 收發消息監聽

  onSubMessage 訂閱的消息回調，因為存在訂閱多個 topic 的情況，所以回調能知道是來自哪個 Topic 的消息；
  onPubMessage 發布的消息回調，用於確認發布的消息是否發送成功。

6. MQTT 訂閱 Topic

  需要在 MQTT 連接成功後才能訂閱 topic，否則訂閱 Topic 不成功，收不到對應消息

7. MQTT 取消訂閱 Topic

8. MQTT 發布消息

9. MQTT 斷開連接

10. 通知設置
  由於 MQTT 啟動了一個 Service，而 Android 8.0 以上對於後台 Service 限制時長 5 秒；所以將 MqttService 綁定到 Notification 上成為了一個前台通知；通知的標題和內容顯示可以在 strings.xml 中設置，對應屬性如下：

  Android 8.0 及以上開啟前台服務綁定到通知，8.0 以下默認不啟用，可將 mqtt_foreground_notification_low_26 設為 true，將 8.0 以下設備也開啟前台通知服務

  創建 MQTT 實例時需要傳送參數 MqttOptions,下面將介紹下部分參數;

1. Topic
  MQTT 是一種發布/訂閱的消息協議, 通過設定的主題 Topic,
發布者向 Topic 發送的 payload 負載消息會經過伺服器, 轉發到所有訂閱襪橋
該 Topic 的訂閱者
   通配符 : 假想移動端消息推送場景,有的系統消息是全體用戶接收,有的消息是 Android 或 iOS 設備接收, 又或者是某些消息具體推送到用戶,當然, 對應的多種類型消息可以通過多訂閱幾個對應的 Topic 解決,也可以使用通配符;
  通配符有兩個, " + " 和 " # ", 與正斜杠 " / " 組合使用;加號只能表示一級Topic, 井號可以表示任意層級 Topic; 例如: 訂閱 Topic為 " System/+ ", 發布者發布的 Topic 可以是 System、System/Android、System/iOS; 但是不能是 System/iOS/123, 而訂閱的 Topic 如果是" System/# " 則可以收到;
   注意,只有訂閱的 Topic 才可以使用 通配符, 發布和遺囑的 Topic 不能包含通配符.

2. ClientID
  發布者和訂閱者都是屬於客戶端, 客戶端與服務端建立連接之後,發送的第一個報文消息必須是 Connect 消息隱好缺,而 Connect 的消息載荷中必須包含 clientID 客戶端唯一標識;
  如果兩個客戶端的 clientID 一樣, 則服務端記錄第一個客戶端連接之後再收到第二個客戶端連接請求,則會向一個客戶端發送 Disconnect 報文斷開連接, 並連接第二個客戶端, 而如果此時設置了自動重連, 第一個客戶端再次連接,服務端又斷開與第二個的連接, 連上第一個客戶端, 如此將導灶辯致兩個客戶端不斷的被擠掉重連.
  注意: clientID 使用的字元最好是 大小寫字母和數字, 長度最好限制在[1, 23] 之間;

3. 遺囑消息
  可選參數, 客戶端沒有主動向服務端發起 disconnect 斷開連接消息,然而服務端檢測到和客戶端之間的連接已斷開, 此時服務端將該客戶端設置的遺囑消息發送出去
  應用場景: 客戶端因網路等情況掉線之後, 可以及時通知到所有訂閱該遺囑 Topic 的客戶端;
  遺囑 Topic 中不能存在通配符.

4. Session
  客戶端和服務端之間建立的會話狀態, 一般用於消息保存, 如果設置清除 Session,則每次客戶端和服務端建立連接會創建一個新的會話,之前連接中的消息不能恢復,
  而設置不清除會話, 對應發布者發送的 qos 為 1和2 的消息,還未被訂閱者接收確認,則需要保存在會話中, 以便訂閱者下次連接可以恢復這些消息;
  注意: Session 存儲的消息是保存在內容中的, 所以如果不是重要的消息,最好是設置清除 Session, 或者設置 qos = 0;

5. 心跳包
  標識客戶端傳輸一次控制報文到下一次傳輸之間允許的空閑時間；在這段時間內，如果客戶端沒有其他任何報文發送，必須發送一個 PINGREQ 報文到伺服器，而如果服務端在 1.5 倍心跳時間內沒有收到客戶端消息，則會主動斷開客戶端的連接，發送其遺囑消息給所有訂閱者。而服務端收到 PINGREQ 報文之後，立即返回 PINGRESP 報文給客戶端
  心跳時間單位為秒，佔用2個位元組，最大 2^16 - 1 = 65535秒（18小時12分鍾15秒）,設置為 0 表示不使用心跳機制； 心跳時間一般設置為幾分鍾或幾十秒即可，時間短點可以更快的發出遺囑消息通知掉線，但是時間短會增加消息頻率，影響服務端並發； 微信長連接為 300 秒，而三大運營商貌似也有個連接時間最小的為 5 分鍾。

6. qos
  服務質量等級 qos 對應兩部分,一是客戶端到服務端發送的消息, 一是服務端到客戶端訂閱的消息; 從發布者到訂閱者實際 qos 為兩段路中 qos 最小的。
  qos 可選值 0(最多交付一次)、1(最少交付一次)、2(正好交付一次);
   qos = 0 ：接收方不發送響應，發送方不進行重試；發送方只管發一次，不管是否發成功，也不管接收方是否成功接收，適用於不重要的數據傳輸；
   qos = 1 ：確保消息至少有一次到達接收方，發送方向接收方發送消息，需要等待接收方返回應答消息，如果發送方在一定時間之內沒有收到應答，發送方繼續下一次消息發送，直到收到應答消息，刪除本地消息緩存，不再發送；所以接收方可能收到1-n次消息；適用於需要收到所有消息，客戶端可以處理重復消息。
   qos = 2 ：確保消息只一次到達接收方，發送方和接收方之間消息處理流程最復雜；
   Mqtt Qos 深度解讀 和 MQTT協議QoS2 准確一次送達的實現

7. payload 負載消息
  位元組流類型, 是 MQTT 通信傳輸的真實數據

8. 保留消息
  發布消息時設置, 對應參數 retain, 服務端將保留對應 Topic 最新的一條消息記錄; 保留消息的作用是每次客戶端連接上線都會收到其 Topic 的最後一條保留消息, 所以可能存在網路不穩定,頻繁掉線重連,每次重連重復收到保留消息;
   可以向對應的 Topic 發送一條 空消息,用於清除保留消息。

MQTT 服務搭建 Apache Apollo 伺服器 搭建 MQTT 服務
Github 倉庫
mqtt 協議

Ⅳ android studio怎麼安裝mqtt

你好，
1、 下載Apollo伺服器，下載後解壓，然後運行apache-apollo-1.6\bin\apollo.cmd，輸入create mybroker（名字任意取，這里是根據 官網 介紹的來取的）創建伺服器實例，伺服器實例包含了所有的配置，運行時數據等，並且和一個伺服器喊哪進程關聯。
2、create mybroker之後會在bin目錄下生成mybroker文件夾，裡麵包含有很多信息，其中etc\apollo.xml文件下是配置伺服器信息的文件，etc\users.properties文件包含連接MQTT伺服器時用到的用戶名和密碼，後面會介紹，可以修改原始的admin=password，可以接著換行添加新的用戶名密碼。
3、打開cmd，運行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 開啟伺服器，可以在瀏覽器中輸入 http://127.0.0.1:61680/ 查看是否安裝成功，該界面展示了topic，連接數等很多信息。
經過上面的簡單步驟，伺服器基本上就已經完成，下一篇將介紹Android客戶端的編寫和注意事項。
客戶端使用的API，開始我使用昌滲攔的是mqtt-client，使用過後發現問耐胡題百出，不能很好的滿足要求，後來使用了官方推薦的 Eclipse Paho ，下面開始客戶端代碼的編寫，為了方便測試這里有android和j2se兩個工程：
1、新建android工程MQTTClient
2、MainActivity代碼如下：
[java] view plainprint?

package ldw.mqttclient;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheledExecutorService;

import java.util.concurrent.TimeUnit;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;

import org.eclipse.paho.client.mqttv3.MqttCallback;

import org.eclipse.paho.client.mqttv3.MqttClient;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

import org.eclipse.paho.client.mqttv3.MqttException;

import org.eclipse.paho.client.mqttv3.MqttMessage;

import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.view.KeyEvent;

import android.widget.TextView;

import android.widget.Toast;

public class MainActivity extends Activity {

private TextView resultTv;

private String host = "tcp://127.0.0.1:1883";

private String userName = "admin";

private String passWord = "password";

private Handler handler;

private MqttClient client;

private String myTopic = "test/topic";

private MqttConnectOptions options;

private ScheledExecutor