亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

MQTT 實(shí)戰(zhàn)

tyheist / 3480人閱讀

摘要：協(xié)議版本版本介紹是一個用編寫的客戶端庫用于開發(fā)在或其他兼容平臺如上運(yùn)行的應(yīng)用程序提供了兩個提供完全異步的通過注冊的回調(diào)完成是的同步包裝器例子這個就是官網(wǎng)提供的例子可以直接連上代理做測試的相關(guān)類介紹此類主要用于連接代理發(fā)布消息訂閱消息斷開連接

mqtt 協(xié)議版本: 3.1.1
eclipse paho client 版本: 1.2.0
eclipse paho client 介紹

Paho Java Client 是一個用Java編寫的MQTT客戶端庫, 用于開發(fā)在JVM或其他Java兼容平臺（如Android）上運(yùn)行的應(yīng)用程序.

Paho Java Client提供了兩個API: MqttAsyncClient 提供完全異步的API, 通過注冊的回調(diào)完成. MqttClient 是 MqttAsyncClient 的同步包裝器.

例子 
        String topic        = "MQTT Examples";
        String content      = "Message from MqttPublishSample";
        int qos             = 2;
        String broker       = "tcp://iot.eclipse.org:1883";
        String clientId     = "JavaSample";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: "+broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");
            System.out.println("Publishing message: "+content);
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            sampleClient.publish(topic, message);
            System.out.println("Message published");
            sampleClient.disconnect();
            System.out.println("Disconnected");
            System.exit(0);
        } catch(MqttException me) {
            System.out.println("reason "+me.getReasonCode());
            System.out.println("msg "+me.getMessage());
            System.out.println("loc "+me.getLocalizedMessage());
            System.out.println("cause "+me.getCause());
            System.out.println("excep "+me);
            me.printStackTrace();
        }

這個就是官網(wǎng)提供的例子, 可以直接連上代理做測試的.

相關(guān)類介紹 MqttClient

此類主要用于連接代理、發(fā)布消息、訂閱消息、斷開連接.

public void publish(String topic, byte[] payload,int qos, boolean retained) throws MqttException, MqttPersistenceException {}
public void publish(String topic, MqttMessage message) throws MqttException, MqttPersistenceException {}

public void subscribe(String topicFilter) throws MqttException {}
public void subscribe(String[] topicFilters) throws MqttException {}
public void subscribe(String topicFilter, int qos) throws MqttException {}
public void subscribe(String[] topicFilters, int[] qos) throws MqttException {}
public void subscribe(String topicFilter, IMqttMessageListener messageListener) throws MqttException {}
public void subscribe(String[] topicFilters, IMqttMessageListener[] messageListeners) throws MqttException {}
public void subscribe(String topicFilter, int qos, IMqttMessageListener messageListener) throws MqttException {}
public void subscribe(String[] topicFilters, int[] qos, IMqttMessageListener[] messageListeners) throws MqttException {}

public void connect() throws MqttSecurityException, MqttException {}
public void connect(MqttConnectOptions options) throws MqttSecurityException, MqttException {}

public void disconnect() throws MqttException {}
public void disconnect(long quiesceTimeout) throws MqttException {}
MqttConnectOptions

此類保存了客戶端連接到代理時的一些參數(shù).

public void setUserName(String userName) {}

public void setPassword(char[] password) {}

public void setConnectionTimeout(int connectionTimeout) {}
MqttMessage

要發(fā)送的消息正文, 指定消息內(nèi)容、Qos、Retained.

public void setQos(int qos) {}
public void setPayload(byte[] payload) {}
public void setRetained(boolean retained) {}

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/72329.html

相關(guān)文章

  • 【如何構(gòu)建商業(yè)級別聊天系統(tǒng)】 MQTT 篇（四）MQTT 特性之 持久會話、保留消息、遺囑

    摘要：如何構(gòu)建商業(yè)級別聊天系統(tǒng)篇四特性之持久會話保留消息遺囑本篇將介紹的一些我們應(yīng)該關(guān)注的特性關(guān)注不迷路我是擱淺神秘地址持久會話為什么需要持久會話為了接收的消息，客戶端在連接時會創(chuàng)建其感興趣主題的訂閱。代理僅存儲每個主題的一條保留消息。 ...

    LancerComet 評論0 收藏0

  • 譯書《物聯(lián)網(wǎng)實(shí)戰(zhàn)指南》出版 | 新成就：翻譯自己的英文簡介

    摘要：英文書名，中文書名物聯(lián)網(wǎng)實(shí)戰(zhàn)指南。物聯(lián)網(wǎng)實(shí)戰(zhàn)指南與自己動手設(shè)計物聯(lián)網(wǎng)這里面又有好多的故事，不過正是因?yàn)橐粫屛矣辛藢憰南敕ú贿^，最開始的時候是電子書。我們將在未來的兩周末，贈送出幾本的物聯(lián)網(wǎng)實(shí)戰(zhàn)指南和自己動手設(shè)計物聯(lián)網(wǎng)，詳情見 這本書有一個很長的故事，到今天算是走到了一個意想中的結(jié)局。從審閱這本書開始、英文版出版、翻譯成中文就這樣走了兩年的時間，這是一本值得紀(jì)念的書籍。 英文書名《L...

    Shimmer 評論0 收藏0

  • ESP32學(xué)習(xí)筆記（46）——MQTT客戶端

    摘要：一簡介實(shí)現(xiàn)方式實(shí)現(xiàn)協(xié)議需要客戶端和服務(wù)器端通訊完成，在通訊過程中，協(xié)議中有三種身份發(fā)布者代理服務(wù)器訂閱者。其中，消息的發(fā)布者和訂閱者都是客戶端，消息代理是服務(wù)器，消息發(fā)布者可以同時是訂閱者。 ...

    Jenny_Tong 評論0 收藏0

  • MQTT如何快速助你產(chǎn)品化

    摘要：時間就是金錢，效率就是生命本教程助力開發(fā)者使用協(xié)議快速產(chǎn)品化。摘要借助具備及聯(lián)網(wǎng)功能的，快速部署到客戶產(chǎn)品上，助力開發(fā)，縮短開發(fā)周期，快速實(shí)現(xiàn)產(chǎn)品商業(yè)化。 時間就是金錢，效率就是生命 本教程助力開發(fā)者使用MQTT協(xié)議快速產(chǎn)品化。 摘要 借助具備MQTT及聯(lián)網(wǎng)功能的DTU，快速部署到客戶產(chǎn)品...

    sutaking 評論0 收藏0

發(fā)表評論

0條評論

tyheist

男|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<