mqtt編譯安裝
⑴ 如何在windows上用C語言實現MQTT協議
C語言是一門通用計算機編程語言，廣泛應用於底層開發。C語言的設計目標是提供一種能以簡易的方式編譯、處理低級存儲器、產生少量的機器碼以及不需要任何運行環境支持便能運行的編程語言。
盡管C語言提供了許多低級處理的功能，但仍然保持著良好跨平台的特性，以一個標准規格寫出的C語言程序可在許多電腦平台上進行編譯，甚至包含一些嵌入式處理器(單片機或稱MCU)以及超級電腦等作業平台。
二十世紀八十年代，為了避免各開發廠商用的C語言語法產生差異，由美國國家標准局為C語言制定了一套完整的美國國家標准語法，稱為ANSI C，作為C語言最初的標准。 目前2011年12月8日，國際標准化組織(ISO)和國際電工委員會(IEC)發布的C11標準是C語言的第三個官方標准，也是C語言的最新標准，該標准更好的支持了漢字函數名和漢字標識符，一定程度上實現了漢字編程。
C語言是一門面向過程的計算機編程語言，與C++，java等面向對象的編程語言有所不同。
其編譯器主要有Clang、GCC、WIN-TC、SUBLIME、MSVC、Turbo C等。
⑵ 在linux中安裝mqtt後怎樣使用
MQTT是IBM開發的一個即時通訊協議。MQTT是面向M2M和物聯網的連接協議
⑶ 在雲伺服器上搭建了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的報文。
⑷ 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 ScheledExecutorService scheler;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
resultTv = (TextView) findViewById(R.id.result);
init();
handler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
if(msg.what == 1) {
Toast.makeText(MainActivity.this, (String) msg.obj,
Toast.LENGTH_SHORT).show();
System.out.println("-----------------------------");
} else if(msg.what == 2) {
Toast.makeText(MainActivity.this, "連接成功", Toast.LENGTH_SHORT).show();
try {
client.subscribe(myTopic, 1);
} catch (Exception e) {
e.printStackTrace();
}
} else if(msg.what == 3) {
Toast.makeText(MainActivity.this, "連接失敗，系統正在重連", Toast.LENGTH_SHORT).show();
}
}
};
startReconnect();
}
private void startReconnect() {
scheler = Executors.();
scheler.scheleAtFixedRate(new Runnable() {
@Override
public void run() {
if(!client.isConnected()) {
connect();
}
}
}, 0 * 1000, 10 * 1000, TimeUnit.MILLISECONDS);
}
private void init() {
try {
//host為主機名，test為clientid即連接MQTT的客戶端ID，一般以客戶端唯一標識符表示，MemoryPersistence設置clientid的保存形式，默認為以內存保存
client = new MqttClient(host, "test",
new MemoryPersistence());
//MQTT的連接設置
options = new MqttConnectOptions();
//設置是否清空session,這里如果設置為false表示伺服器會保留客戶端的連接記錄，這里設置為true表示每次連接到伺服器都以新的身份連接
options.setCleanSession(true);
//設置連接的用戶名
options.setUserName(userName);
//設置連接的密碼
options.setPassword(passWord.toCharArray());
// 設置超時時間 單位為秒
options.setConnectionTimeout(10);
// 設置會話心跳時間 單位為秒 伺服器會每隔1.5*20秒的時間向客戶端發送個消息判斷客戶端是否在線，但這個方法並沒有重連的機制
options.setKeepAliveInterval(20);
//設置回調
client.setCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable cause) {
//連接丟失後，一般在這裡面進行重連
System.out.println("connectionLost----------");
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
//publish後會執行到這里
System.out.println("deliveryComplete---------"
+ token.isComplete());
}
@Override
public void messageArrived(String topicName, MqttMessage message)
throws Exception {
//subscribe後得到的消息會執行到這裡面
System.out.println("messageArrived----------");
Message msg = new Message();
msg.what = 1;
msg.obj = topicName+"---"+message.toString();
handler.sendMessage(msg);
}
});
// connect();
} catch (Exception e) {
e.printStackTrace();
}
}
private void connect() {
new Thread(new Runnable() {
@Override
public void run() {
try {
client.connect(options);
Message msg = new Message();
msg.what = 2;
handler.sendMessage(msg);
} catch (Exception e) {
e.printStackTrace();
Message msg = new Message();
msg.what = 3;
handler.sendMessage(msg);
}
}
}).start();
}
@Override
public boolean onKeyDown(int keyCode, KeyEvent event) {
if(client != null && keyCode == KeyEvent.KEYCODE_BACK) {
try {
client.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
return super.onKeyDown(keyCode, event);
}
@Override
protected void onDestroy() {
super.onDestroy();
try {
scheler.shutdown();
client.disconnect();
} catch (MqttException e) {
e.printStackTrace();
}
}
}
由於項目需要，我用到了心跳重連。根據 這里 的解釋設置apollo.xml，主要有設置主機連接的地址。另外，options還有個setWill方法，如果項目中需要知道客戶端是否掉線可以調用該方法。
⑸ mqtt怎麼在windows上搭建
windows的平台 由於有32位的 也有64位的 所以 去下一個和自己的電腦 相區配的。
下載後直接雙擊安裝就行 之後 進入安裝目錄 最好用命令行的方式 啟動mosquitto.exe 然後就是 編寫 android 客戶端代碼 mqtt 是訂閱/發布的方式 eoeandroid 安卓開發社區上有詳細的教程，你自己可以找一下。。
⑹ 如何導入paho mqtt java編譯通過
Eclipse Paho MQTT工具是一個基於Java的Eclipse桌面客戶端程序，其底層的和MQTT伺服器進行的交互的java類庫就是Eclipse Paho java庫。假設我們在本機（127.0.0.1）已經啟動了一個mosquitto MQTT伺服器，其埠為1883
⑺ Ubun安裝好MQTT之後如何配置
mqtt.fx的安裝和使用
MQTT.fx 是目前主流的mqtt客戶端，可以快速驗證是否可以與IoT Hub 服務交流發布或訂閱消息。設備將當前所處的狀態作為MQTT主題發送給IoT Hub，每個MQTT主題topic具有不同等級的名稱，如「建築/樓層/溫度。」 MQTT代理伺服器將接收到的主題topic發送給給所有訂閱的客戶端。
目前最新版下載地址（支持windows，linux，
⑻ paho.mqtt.python模塊怎麼安裝
【1】MQTT協議中可指定用戶名和密碼，在yeelink協議中，用戶名變為U-ApiKey，密碼為U-ApiKey的具體值。
【2】訂閱主題為設備URI，需要把API版本號修改為v1.1
【3】主機名稱為mqtt.yeelink.net，而不是api.yeelink.net
在mqtt.js的示例代碼中：client = mqtt.connect('mqtt://user:pass@localhost');
在yeelink的示例代碼中：client = mqtt.connect("mqtt://U-ApiKey:<your_key>@mqtt.yeelink.net");
以上的兩個示例代碼更可以說明各參數的對應關系。
⑼ 如何在iphone上安裝mqtt
itunes/cn/app/id389481236?mt=8點左邊的view in itunes系統自動打開itunes然後在itunes上購買了（是免費的）同步到手機上就可以了。