成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

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

tyheist / 3434人閱讀

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

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

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

Paho Java Client提供了兩個(gè)API: MqttAsyncClient 提供完全異步的API, 通過(guò)注冊(cè)的回調(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();
        }

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

相關(guān)類介紹 MqttClient

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

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í)的一些參數(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)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/72329.html

相關(guān)文章

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

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

    LancerComet 評(píng)論0 收藏0

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

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

    Shimmer 評(píng)論0 收藏0

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

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

    Jenny_Tong 評(píng)論0 收藏0

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

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

    sutaking 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

tyheist

男|高級(jí)講師

TA的文章

閱讀更多
最新活動(dòng)
閱讀需要支付1元查看
<