如何獲取mqtt伺服器的在線客戶端

A. 如果在程序中查看ActiveMQ中消費者是否在線

如果是C/S的結構，你的服務端和客戶端應該是Socket連接，可以利用心跳來保持服務端和客戶端的連接，已確定客戶端是否存在

B. 在雲伺服器上搭建了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的報文。

C. 如何採用mqtt協議實現android消息推送

D. 如何用wireshark分析mqtt協議

MQTT是一項消息傳遞技術，由IBM再2001年發布。

總結一下，機制就是使用一個代理伺服器messagebroker，
客戶端client連接上這個伺服器，然後告訴伺服器說，我可以接收哪些類型的消息，
同時，client也可以發布自己的消息，這些消息根據協議的內容，可以被其他client獲取。
只要手機客戶端，連上伺服器，然後就可以接收和發布消息了，不用自己寫socket什麼了，

低帶寬，低耗電量，代碼量也少，很簡單吧。

package com.pig.test.mqtt;

import com.ibm.mqtt.MqttClient;

import
com.ibm.mqtt.MqttException;
import com.ibm.mqtt.MqttSimpleCallback;

public class SubscribeClient {
private final static String
CONNECTION_STRING = "tcp://192.168.1.60:1883";
private final static boolean
CLEAN_START = true;
private final static short KEEP_ALIVE =
30;//低耗網路，但是又需要及時獲取數據，心跳30s
private final static String CLIENT_ID =
"client1";
private final static String[] TOPICS =
{
"Test/TestTopics/Topic1",
"Test/TestTopics/Topic2",
"Test/TestTopics/Topic3",
"toku/client1"
};
private
final static int[] QOS_VALUES = {0, 0, 2,
0};

//////////////////
private MqttClient mqttClient =
null;

public SubscribeClient(String i){
try {
mqttClient =
new MqttClient(CONNECTION_STRING);
SimpleCallbackHandler
simpleCallbackHandler = new
SimpleCallbackHandler();
mqttClient.registerSimpleHandler(simpleCallbackHandler);//注冊接收消息方法
mqttClient.connect(CLIENT_ID+i,
CLEAN_START, KEEP_ALIVE);
mqttClient.subscribe(TOPICS,
QOS_VALUES);//訂閱接主題

/**
*
完成訂閱後，可以增加心跳，保持網路通暢，也可以發布自己的消息
*/
mqttClient.publish(PUBLISH_TOPICS, "keepalive".getBytes(), QOS_VALUES[0],

true);

} catch (MqttException e) {
// TODO Auto-generated
catch block
e.printStackTrace();
}
}

/**
* 簡單回調函數，處理client接收到的主題消息
* @author pig
*

*/
class SimpleCallbackHandler implements MqttSimpleCallback{

/**
* 當客戶機和broker意外斷開時觸發
* 可以再此處理重新訂閱

*/
@Override
public void connectionLost() throws Exception {
//
TODO Auto-generated method
stub
System.out.println("客戶機和broker已經斷開");
}

/**
* 客戶端訂閱消息後，該方法負責回調接收處理消息
*/
@Override
public void
publishArrived(String topicName, byte[] payload, int Qos, boolean retained)
throws Exception {
// TODO Auto-generated method
stub
System.out.println("訂閱主題: " +
topicName);
System.out.println("消息數據: " + new
String(payload));
System.out.println("消息級別(0,1,2): " +
Qos);
System.out.println("是否是實時發送的消息(false=實時，true=伺服器上保留的最後消息): " +
retained);
}

}

/**
* 高級回調
* @author pig

*
*/
class AdvancedCallbackHandler implements MqttSimpleCallback{

@Override
public void connectionLost() throws Exception {
//
TODO Auto-generated method stub

}

@Override
public void publishArrived(String arg0, byte[] arg1, int
arg2,
boolean arg3) throws Exception {
// TODO Auto-generated
method stub

}

}

/**
* @param args

*/
public static void main(String[] args) {
// TODO Auto-generated
method stub
new SubscribeClient("" + i);

}

}

broker伺服器，MQTT的jar包，記得下載啊，沒有就消息我咯~

到這里，如果完成IBM的MQTT協議實現push消息的實例的，
都會有個問題，好像沒考慮到安全問題，如果客戶端連上來作亂怎麼辦呢？

上面用的broker時rsmb的，mqtt的簡單伺服器。
IBM已經推出了MQTT V3.1版本，已經加入了安全驗證機制，不要怕啦。

轉載僅供參考，版權屬於原作者。祝你愉快，滿意請採納哦

E. android mqtt怎麼獲取用戶的狀態

1 從Service繼承一個類。
2 創建startService()方法。
3 創建endService()方法 重載onCreate方法和onDestroy方法，並在這兩個方法裡面來調用startService以及endService。
4 在startService中，通過getSystemService方法獲取Context.LOCATION_SERVICE。
5 基於LocationListener實現一個新類。默認將重載四個方法onLocationChanged、onProviderDisabled、onProviderEnabled、onStatusChanged。對於onLocationChanged方法是我們更新最新的GPS數據的方法。一般我們的操作都只需要在這里進行處理。
6 調用LocationManager的requestLocationUpdates方法，來定期觸發獲取GPS數據即可。在onLocationChanged函數裡面可以實現我們對得到的經緯度的最終操作。
7 最後在我們的Activity裡面通過按鈕來啟動Service，停止Service。

F. 怎樣從MQTT 伺服器 應答中獲取時間戳

定義3個虛擬用戶組，分別進行連接，發布，訂閱操作。
* 連接者：虛擬用戶數=10， 發起10個到伺服器的背景連接，每2秒鍾發一次心跳請求，15秒後斷連。
* 發布者：虛擬用戶數=5，每隔一秒發送一條32位元組的隨機串，帶時間戳，循環10次結束。
* 訂閱者：虛擬用戶數=2，接收相應話題上的消息，每隔一秒輸出采樣間隔里接收到的消息統計，循環10次結束。
在JMeter中運行該場景，15秒鍾左右運行結束。可以在測試結果樹中看到每個操作的詳細信息。表格視圖的"Sample Time"列出了操作花費的時間(毫秒)。由於這次測試在本地，並發用戶數很少，所以連接、消息發送、接收時延都很短。您可以指向實際的MQTT伺服器，模擬更大的並發用戶數。

G. 如何寫一個MQTT連接的android客戶端

MQTT是一個輕量級的消息發布/訂閱協議，它是實現基於手機客戶端的消息推送伺服器的理想解決方案。 我們可以從這里下載該項目的實例代碼，並且可以找到一個採用php書寫的伺服器端實現。 架構如下所示： wmqtt.jar 是IBM提供的MQTT協議的實現。你可以從如下站點下載它。你可以將該jar包加入你自己的Android應用程序中。 Really Small Message Broker (RSMB) ，他是一個簡單的MQTT代理，同樣由IBM提供。預設打開1883埠，應用程序當中，它負責接收來自伺服器的消息並將其轉發給指定的移動設備。 SAM是一個針對MQTT寫的PHP庫。你可以從這個下載它. send_mqtt.php是一個通過POST接收消息並且通過SAM將消息發送給RSMB的PHP腳本。 實例代碼： Ø 採用XMPP協議實現Android推送 這是我在項目中採用的方案。事實上Google官方的C2DM伺服器底層也是採用XMPP協議進行的封裝。 XMPP(可擴展通訊和表示協議)是基於可擴展標記語言（XML）的協議，它用於即時消息（IM）以及在線探測。這個協議可能最終允許網際網路用戶向網際網路上的其他任何人發送即時消息。 androidpn是一個基於XMPP協議的java開源Android push notification實現。它包含了完整的客戶端和伺服器端。經過源代碼研究我發現，該伺服器端基本是在另外一個開源工程openfire基礎上修改實現的，不過比較郁悶的是androidpn的文檔是由韓語寫的，所以整個研究過程基本都是讀源碼。它的實現示意圖如下： androidpn客戶端需要用到一個基於java的開源XMPP協議包asmack，這個包同樣也是基於openfire下的另外一個開源項目smack，不過我們不需要自己編譯，可以直接把androidpn客戶端裡面的asmack.jar拿來使用。客戶端利用asmack中提供的XMPPConnection類與伺服器建立持久連接，並通過該連接進行用戶注冊和登錄認證，同樣也是通過這條連接，接收伺服器發送的通知。 androidpn伺服器端也是java語言實現的，基於openfire開源工程，不過它的Web部分採用的是spring框架，這一點與openfire是不同的。Androidpn伺服器包含兩個部分，一個是偵聽在5222埠上的XMPP服務，負責與客戶端的XMPPConnection類進行通信，作用是用戶注冊和身份認證，並發送推送通知消息。另外一部分是Web伺服器，採用一個輕量級的HTTP伺服器，負責接收用戶的Web請求。伺服器架構如下： 最上層包含四個組成部分，分別是SessionManager，Auth Manager，PresenceManager以及Notification Manager。SessionManager負責管理客戶端與伺服器之間的會話，Auth Manager負責客戶端用戶認證管理，Presence Manager負責管理客戶端用戶的登錄狀態，NotificationManager負責實現伺服器向客戶端推送消息功能。 伺服器端界面如下，分別對應了上述的幾個功能模塊： 發送以後，我們可以在手機端看到接收的消息：